Export template source from d71f7227deb1d634401d259963dfd641fb535606:quixos-instance/packages/web-studio-display-runtime

src/portable.ts

@@ -0,0 +1,47 @@
+import { QxReject } from "@quixos/camino-replica-core";
+import { createRegistry } from "./gen/qx.js";
+export const registry = createRegistry({
+  enroll: async ({ input, ports }) => {
+    if (!/^[a-f0-9-]{36}$/.test(input.nonce) || input.label.length > 100)
+      throw new QxReject("INVALID_DISPLAY_ENROLLMENT");
+    const enrolled = await ports.enrolled.resolve();
+    for (const previous of enrolled) {
+      if ((await ports.existing["nonce.get"]({ receiver: previous.target, input: null })) === input.nonce)
+        return previous.target;
+    }
+    if (enrolled.length >= 128) throw new QxReject("DISPLAY_ENROLLMENT_LIMIT");
+    const target = await ports.target.create(
+      { nonce: input.nonce, initial: { label: input.label, generation: 0, presentation: null, observed: null } },
+      { key: "display" },
+    );
+    const ref = {
+      ...target,
+      expectation: { kind: "interface" as const, id: "interface:org.quixos.web-studio.display-target@1" as const },
+    };
+    await ports.enrolled.connect(ref, { key: "display" });
+    return ref;
+  },
+  assign: async ({ input, ports }) => {
+    if (input && !(await ports.subject["canPresent.call"]({ receiver: input.subject, input: input.presentation })))
+      throw new QxReject("INVALID_PRESENTATION");
+    const state = await ports.data.get();
+    if (state.generation === 4294967295) throw new QxReject("DISPLAY_GENERATION_EXHAUSTED");
+    const generation = state.generation + 1;
+    for (const previous of await ports.selected.resolve()) await ports.selected.disconnect(previous.entry);
+    if (input) await ports.selected.connect(input.subject, { key: "subject" });
+    for (const previous of await ports.mount.resolve()) await ports.mount.disconnect(previous.entry);
+    if (input?.presentationMount) await ports.mount.connect(input.presentationMount, { key: "presentationMount" });
+    await ports.data.set({ ...state, generation, presentation: input?.presentation ?? null, observed: null });
+    return generation;
+  },
+  acknowledge: async ({ input, ports }) => {
+    if (!["mounted", "failed", "empty"].includes(input.status) || input.error.length > 2000)
+      throw new QxReject("INVALID_DISPLAY_REPORT");
+    const state = await ports.data.get();
+    if (input.generation !== state.generation || (state.observed && input.sequence <= state.observed.sequence))
+      return false;
+    if ((state.presentation === null) !== (input.status === "empty")) throw new QxReject("INVALID_DISPLAY_REPORT");
+    await ports.data.set({ ...state, observed: input });
+    return true;
+  },
+});