feat: resolve presentation live target

2026-07-09 06:11:33 +07:00
parent 5a3070df11
commit c332e58697
2 changed files with 100 additions and 0 deletions
@@ -0,0 +1,54 @@
+import { describe, expect, it } from "vitest";
+import {
+  DEFAULT_PRESENTATION_TARGET,
+  resolvePresentationTarget,
+} from "./live-target.js";
+
+const fakeStorage = (value: string | null): Storage => ({
+  length: value === null ? 0 : 1,
+  clear() {},
+  getItem: (key: string) => key === "lda.workflowConsole.target" ? value : null,
+  key: () => null,
+  removeItem() {},
+  setItem() {},
+});
+
+describe("resolvePresentationTarget", () => {
+  it("uses the console target from session storage", () => {
+    expect(resolvePresentationTarget(fakeStorage("http://127.0.0.1:8765/rpc"))).toEqual({
+      mode: "live",
+      target: "http://127.0.0.1:8765/rpc",
+      source: "session-storage",
+    });
+  });
+
+  it("falls back to the default loopback target when storage is empty", () => {
+    expect(resolvePresentationTarget(fakeStorage(null))).toEqual({
+      mode: "live",
+      target: DEFAULT_PRESENTATION_TARGET,
+      source: "default",
+    });
+  });
+
+  it("uses replay mode when storage access throws", () => {
+    const broken = {
+      getItem() {
+        throw new Error("blocked");
+      },
+    } as unknown as Storage;
+
+    expect(resolvePresentationTarget(broken)).toEqual({
+      mode: "replay",
+      target: null,
+      reason: "session storage is unavailable",
+    });
+  });
+
+  it("uses replay mode for non-http targets", () => {
+    expect(resolvePresentationTarget(fakeStorage("file:///tmp/rpc"))).toEqual({
+      mode: "replay",
+      target: null,
+      reason: "presentation target is not an HTTP URL",
+    });
+  });
+});
@@ -0,0 +1,46 @@
+import { STORAGE_KEY } from "../app/state.js";
+
+export type PresentationTargetState =
+  | { readonly mode: "live"; readonly target: string; readonly source: "session-storage" | "default" }
+  | { readonly mode: "replay"; readonly target: null; readonly reason: string };
+
+export const DEFAULT_PRESENTATION_TARGET = "http://127.0.0.1:8765/rpc";
+
+const isHttpUrl = (value: string): boolean => {
+  try {
+    const url = new URL(value);
+    return url.protocol === "http:" || url.protocol === "https:";
+  } catch {
+    return false;
+  }
+};
+
+export const resolvePresentationTarget = (
+  storage: Storage | null = typeof sessionStorage === "undefined" ? null : sessionStorage,
+): PresentationTargetState => {
+  let stored: string | null;
+  try {
+    stored = storage?.getItem(STORAGE_KEY) ?? null;
+  } catch {
+    return {
+      mode: "replay",
+      target: null,
+      reason: "session storage is unavailable",
+    };
+  }
+
+  const target = stored ?? DEFAULT_PRESENTATION_TARGET;
+  if (!isHttpUrl(target)) {
+    return {
+      mode: "replay",
+      target: null,
+      reason: "presentation target is not an HTTP URL",
+    };
+  }
+
+  return {
+    mode: "live",
+    target,
+    source: stored ? "session-storage" : "default",
+  };
+};