block · loganj · Aug 18, 2026 · Aug 18, 2026 · Aug 18, 2026 · Aug 18, 2026
@@ -0,0 +1,34 @@
+import { defineConfig, devices } from "@playwright/test";
+
+export default defineConfig({
+  testDir: "./tests/e2e",
+  outputDir: "test-results-b3-pr-demo",
+  timeout: 120_000,
+  retries: 0,
+  workers: 1,
+  reporter: [["list"]],
+  use: {
+    baseURL: "http://127.0.0.1:4173",
+    ...devices["Desktop Chrome"],
+    viewport: { width: 1440, height: 900 },
+    video: { mode: "on", size: { width: 1440, height: 900 } },
+    screenshot: "on",
+    trace: "off",
+  },
+  projects: [
+    {
+      name: "relay-b3-pr-capture",
+      testMatch: "**/workstream-board-b3-pr.capture.spec.ts",
+    },
+    {
+      name: "canvas-bridge-regression",
+      testMatch: "**/get-canvas-bridge.spec.ts",
+    },
+  ],
+  webServer: {
+    command: "python3 -m http.server 4173 -d dist",
+    cwd: ".",
+    reuseExistingServer: false,
+    url: "http://127.0.0.1:4173",
+  },
+});
@@ -0,0 +1,271 @@
+import assert from "node:assert/strict";
+import { after, before, test } from "node:test";
+import { JSDOM } from "jsdom";
+
+const dom = new JSDOM("<!doctype html><html><body></body></html>", {
+  url: "http://localhost",
+});
+
+before(() => {
+  Object.assign(globalThis, {
+    document: dom.window.document,
+    HTMLElement: dom.window.HTMLElement,
+    IS_REACT_ACT_ENVIRONMENT: true,
+    window: dom.window,
+  });
+});
+
+after(() => dom.window.close());
+
+import {
+  createWorkstreamPollingRegistry,
+  fetchBuzzPullRequestStatus,
+  fetchGithubPullRequestStatus,
+  parseWorkstreamPullRequestReference,
+  parseWorkstreamPullRequestReferences,
+} from "./workstreamPullRequestStatus.ts";
+
+const OWNER = "a".repeat(64);
+const EVENT = "b".repeat(64);
+const buzz = `buzz://pr?id=${EVENT}&owner=${OWNER}&d=buzz`;
+
+function response(body, status = 200) {
+  return new Response(JSON.stringify(body), {
+    status,
+    headers: { "content-type": "application/json" },
+  });
+}
+
+test("parses canonical Buzz, GitHub, malformed, and unsupported references", () => {
+  const refs = parseWorkstreamPullRequestReferences([
+    buzz,
+    { url: "https://github.com/Block/Buzz/pull/42", label: "labeled PR" },
+    "https://github.com/Block/Buzz/pull/42",
+    "https://github.com/block/buzz/issues/42",
+    "https://example.com/pr/1",
+    "not a url",
+    null,
+  ]);
+  assert.equal(refs[0].kind, "buzz");
+  assert.equal(refs[0].identity, `buzz:${OWNER}:buzz:${EVENT}`);
+  assert.equal(refs[1].kind, "github");
+  assert.equal(refs[1].href, "https://github.com/block/buzz/pull/42");
+  assert.equal(refs[2].kind, "github");
+  assert.equal(refs[3].kind, "unsupported");
+  assert.equal(refs[3].reason, "malformed");
+  assert.equal(refs[4].reason, "unsupported-provider");
+  assert.equal(refs[5].reason, "malformed");
+  assert.equal(refs[6].reason, "invalid-field");
+});
+
+test("GitHub status reports lifecycle and latest review state", async () => {
+  const ref = parseWorkstreamPullRequestReference(
+    "https://github.com/block/buzz/pull/42",
+  );
+  assert.equal(ref.kind, "github");
+  const result = await fetchGithubPullRequestStatus(ref, {
+    fetcher: async (url) =>
+      String(url).endsWith("/reviews?per_page=100")
+        ? response([
+            {
+              user: { login: "reviewer" },
+              state: "APPROVED",
+              submitted_at: "2026-08-18T00:00:00Z",
+            },
+          ])
+        : response({
+            number: 42,
+            title: "Board PR",
+            state: "closed",
+            draft: false,
+            merged_at: "2026-08-18T01:00:00Z",
+            requested_reviewers: [],
+          }),
+  });
+  assert.deepEqual(result, {
+    status: "live",
+    provider: "github",
+    href: "https://github.com/block/buzz/pull/42",
+    repository: "block/buzz",
+    number: 42,
+    title: "Board PR",
+    lifecycle: "merged",
+    reviewState: "approved",
+  });
+});
+
+test("Buzz status consumes root and existing NIP-34 status events", async () => {
+  const ref = parseWorkstreamPullRequestReference(buzz);
+  assert.equal(ref.kind, "buzz");
+  const root = {
+    id: EVENT,
+    pubkey: OWNER,
+    kind: 1618,
+    created_at: 10,
+    content: "Wire board",
+    tags: [
+      ["a", `30617:${OWNER}:buzz`],
+      ["d", "pr-1"],
+      ["subject", "Wire board"],
+      ["p", "c".repeat(64)],
+    ],
+  };
+  const status = {
+    id: "c".repeat(64),
+    pubkey: OWNER,
+    kind: 1631,
+    created_at: 20,
+    content: "",
+    tags: [
+      ["e", EVENT],
+      ["a", `30617:${OWNER}:buzz`],
+    ],
+  };
+  const result = await fetchBuzzPullRequestStatus(ref, async (filter) =>
+    filter.kinds[0] === 1618 ? [root] : [status],
+  );
+  assert.equal(result.status, "live");
+  assert.equal(result.lifecycle, "merged");
+  assert.equal(result.title, "Wire board");
+  assert.equal(result.reviewState, "review-requested");
+});
+
+test("polling deduplicates canonical identities and tears down", async () => {
+  let requests = 0;
+  let aborted = false;
+  let resolveRequest;
+  const pending = new Promise((resolve) => {
+    resolveRequest = resolve;
+  });
+  const reference = parseWorkstreamPullRequestReference(
+    "https://github.com/block/buzz/pull/42",
+  );
+  assert.equal(reference.kind, "github");
+  const registry = createWorkstreamPollingRegistry({
+    fetcher: async (_url, init) => {
+      requests += 1;
+      init.signal.addEventListener("abort", () => {
+        aborted = true;
+      });
+      await pending;
+      return response({
+        number: 42,
+        title: "Board",
+        state: "open",
+        draft: false,
+      });
+    },
+    intervalMs: 1000,
+  });
+  const listener = () => {};
+  const unsubscribeOne = registry.subscribe(reference, listener);
+  const unsubscribeTwo = registry.subscribe(reference, () => {});
+  assert.equal(registry.entryCount(), 1);
+  await Promise.resolve();
+  await Promise.resolve();
+  assert.equal(requests, 2);
+  unsubscribeOne();
+  assert.equal(registry.entryCount(), 1);
+  unsubscribeTwo();
+  assert.equal(registry.entryCount(), 0);
+  assert.equal(aborted, true);
+  resolveRequest();
+});
+
+test("workstream status hook exposes loading before a supported PR resolves", async () => {
+  const { cleanup, renderHook } = await import("@testing-library/react");
+  const { useWorkstreamPullRequestStatuses } = await import(
+    "./workstreamPullRequestStatus.ts"
+  );
+  const reference = parseWorkstreamPullRequestReference(
+    "https://github.com/block/buzz/pull/42",
+  );
+  const registry = createWorkstreamPollingRegistry({
+    fetcher: () => new Promise(() => {}),
+  });
+  const references = [reference];
+  const { result, unmount } = renderHook(() =>
+    useWorkstreamPullRequestStatuses(references, registry),
+  );
+  assert.deepEqual(result.current.get(reference.identity), {
+    status: "loading",
+  });
+  unmount();
+  cleanup();
+});
+
+test("workstream status hook preserves a synchronous live callback", async () => {
+  const { act, cleanup, renderHook } = await import("@testing-library/react");
+  const { useWorkstreamPullRequestStatuses } = await import(
+    "./workstreamPullRequestStatus.ts"
+  );
+  const reference = parseWorkstreamPullRequestReference(
+    "https://github.com/block/buzz/pull/42",
+  );
+  const registry = createWorkstreamPollingRegistry({
+    fetcher: async (url) =>
+      String(url).endsWith("/reviews?per_page=100")
+        ? response([])
+        : response({ number: 42, title: "Board", state: "open", draft: false }),
+    maxPolls: 1,
+  });
+  const prime = registry.subscribe(reference, () => {});
+  await act(async () => {
+    await Promise.resolve();
+    await Promise.resolve();
+  });
+  const references = [reference];
+  const { result, unmount } = renderHook(() =>
+    useWorkstreamPullRequestStatuses(references, registry),
+  );
+  await act(async () => {
+    await Promise.resolve();
+  });
+  assert.deepEqual(result.current.get(reference.identity), {
+    status: "live",
+    provider: "github",
+    href: "https://github.com/block/buzz/pull/42",
+    repository: "block/buzz",
+    number: 42,
+    title: "Board",
+    lifecycle: "open",
+    reviewState: "no-reviews",
+  });
+  unmount();
+  prime();
+  cleanup();
+});
+
+test("workstream status hook removes stale references and preserves unsupported state", async () => {
+  const { act, cleanup, renderHook } = await import("@testing-library/react");
+  const { useWorkstreamPullRequestStatuses } = await import(
+    "./workstreamPullRequestStatus.ts"
+  );
+  const supported = parseWorkstreamPullRequestReference(
+    "https://github.com/block/buzz/pull/42",
+  );
+  const unsupported = parseWorkstreamPullRequestReference(
+    "https://example.com/pr/1",
+  );
+  const registry = createWorkstreamPollingRegistry({
+    fetcher: () => new Promise(() => {}),
+  });
+  const { result, rerender, unmount } = renderHook(
+    ({ refs }) => useWorkstreamPullRequestStatuses(refs, registry),
+    { initialProps: { refs: [supported, unsupported] } },
+  );
+  assert.deepEqual(
+    result.current.get(unsupported.identity)?.status,
+    "unsupported",
+  );
+  await act(async () => {
+    rerender({ refs: [unsupported] });
+  });
+  assert.equal(result.current.has(supported.identity), false);
+  assert.deepEqual(
+    result.current.get(unsupported.identity)?.status,
+    "unsupported",
+  );
+  unmount();
+  cleanup();
+});