refactor(dashboard): remove unfed dashboard surfaces

Author: ScriptedAlchemy

dashboard/src/data/sse/connect.test.ts

@@ -92,6 +92,16 @@ describe("dashboard SSE wire bridge", () => {
     connection.close();
   });
 
+  it("subscribes only to server-emitted code-index activity", () => {
+    vi.stubGlobal("EventSource", FakeEventSource);
+    const connection = connectEvents("/api/events");
+    const source = FakeEventSource.instances[0]!;
+
+    expect(source.listeners.has("code_index")).toBe(false);
+    expect(source.listeners.has("code_index_activity")).toBe(true);
+    connection.close();
+  });
+
   it("projects accepted events to live pulses carrying their own scope identity", () => {
     vi.stubGlobal("EventSource", FakeEventSource);
     const connection = connectEvents("/api/events");

dashboard/src/data/sse/connect.ts

@@ -5,7 +5,6 @@ const DASHBOARD_EVENT_NAMES = [
   'heartbeat',
   'project_registry',
   'storage_telemetry',
-  'code_index',
   // Live agent activity, coalesced server-side to at most 2/s per family per
   // project. Named events are opt-in, so a new family must be listed here.
   'hook_activity',

dashboard/src/data/sse/reseed.dom.test.tsx

@@ -154,8 +154,8 @@ async function tick(emit: () => void): Promise<void> {
 /** Open a canonical refresh with a revision gap and leave it in flight. */
 async function openRefreshWithGap(source: FakeEventSource): Promise<void> {
   await tick(() => {
-    source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, 1));
-    source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, 5));
+    source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, 1));
+    source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, 5));
   });
 }
 
@@ -211,7 +211,7 @@ describe('SSE canonical refresh — signals during the window', () => {
     // flag, so this signal only survives if the reducer remembers it as an
     // epoch the in-flight refresh cannot claim to have covered.
     await tick(() => {
-      source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, 20));
+      source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, 20));
     });
     expect(refresh.spy).toHaveBeenCalledTimes(1);
 
@@ -226,15 +226,15 @@ describe('SSE canonical refresh — signals during the window', () => {
     // its commit ends the chain because no newer signal arrived.
     for (let revision = 21; revision <= 25; revision += 1) {
       await tick(() => {
-        source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, revision));
+        source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, revision));
       });
     }
     expect(refresh.spy).toHaveBeenCalledTimes(2);
 
     await settleRefreshes(() => refresh.resolveAll());
     for (let revision = 26; revision <= 30; revision += 1) {
       await tick(() => {
-        source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, revision));
+        source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, revision));
       });
     }
     expect(refresh.spy).toHaveBeenCalledTimes(2);
@@ -254,7 +254,7 @@ describe('SSE canonical refresh — signals during the window', () => {
     // The queue overflows while that refresh is still in flight.
     await tick(() => {
       for (let revision = 6; revision <= 6 + MAX_QUEUED_EVENTS; revision += 1) {
-        source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, revision));
+        source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, revision));
       }
     });
     expect(reducerStats().stale).toBe(true);
@@ -281,7 +281,7 @@ describe('SSE canonical refresh — failure is not success', () => {
 
     await tick(() => {
       for (let revision = 1; revision <= MAX_QUEUED_EVENTS + 1; revision += 1) {
-        source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, revision));
+        source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, revision));
       }
     });
     expect(refresh.spy).toHaveBeenCalledTimes(1);
@@ -302,13 +302,13 @@ describe('SSE canonical refresh — failure is not success', () => {
     // Nor is a failure a retry trigger: re-issuing the identical refresh every
     // tick is the storm the coalescing clock exists to prevent.
     await tick(() => {
-      source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, MAX_QUEUED_EVENTS + 2));
+      source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, MAX_QUEUED_EVENTS + 2));
     });
     expect(refresh.spy).toHaveBeenCalledTimes(1);
 
     // A genuinely newer signal is a new attempt, though — here a reconnect.
     await tick(() => {
-      source.emit('code_index', frame('code_index', NEUTRAL_FAMILY, 1, RECONNECTED_RUN_ID));
+      source.emit('code_index_activity', frame('code_index_activity', NEUTRAL_FAMILY, 1, RECONNECTED_RUN_ID));
     });
     expect(refresh.spy).toHaveBeenCalledTimes(2);
     expect(refresh.spy).toHaveBeenLastCalledWith();

dashboard/src/data/sse/throughput.test.ts

@@ -40,8 +40,8 @@ interface Body {
  */
 function envelope(revision: number, filler = ""): SseEventEnvelope<Body> {
   return {
-    stream: { stream_id: "code_index", generation: 1 },
-    event_id: `run-1-1700000000000000:code_index:${revision}`,
+    stream: { stream_id: "code_index_activity", generation: 1 },
+    event_id: `run-1-1700000000000000:code_index_activity:${revision}`,
     revision: { event_revision: revision, entity_revision: revision },
     scope: '{"project_id":"project.alpha","storage_mode":"profile_sharded"}',
     observation_time: String(1_700_000_000_000_000 + revision),

dashboard/src/workspaces/loom/LoomPage.dom.test.tsx

@@ -230,29 +230,6 @@ const TEMPORAL = {
             'provider-qualified session_git_spans rows for the displayed session page',
         },
       },
-      {
-        id: 'delivery_outcomes',
-        label: 'Pull request, review, CI & release outcomes',
-        state: 'unsupported',
-        authority: null,
-        granularity: 'Delivery projection row',
-        providers: [],
-        item_count: null,
-        reason:
-          'the shared Delivery overview is mounted, but its outcome projections are unavailable or unsupported and do not expose session-linked rows; Loom does not duplicate them',
-        required_authority:
-          'GET /api/delivery/overview with session-linked pull_requests, review_comments, ci_checks, failure_localization, and releases rows',
-        coverage: {
-          completeness: 'unsupported',
-          eligible: null,
-          examined: null,
-          matched: null,
-          omitted: null,
-          unit: null,
-          reason:
-            'coverage belongs to the shared Delivery projection once it serves session-linked rows',
-        },
-      },
     ],
     commits: [
       {
@@ -334,6 +311,15 @@ afterEach(() => {
 });
 
 describe('LoomPage', () => {
+  it('does not present unfed Delivery outcomes as a Loom relation', async () => {
+    renderLoom();
+
+    const row = await screen.findByText('Deliver Git primitive runtime');
+    await userEvent.click(row);
+
+    expect(screen.queryByText('→ delivery outcomes')).toBeNull();
+  });
+
   it('draws the weave from the typed Loom temporal read', async () => {
     const fetchMock = serve(HAPPY);
     vi.stubGlobal('fetch', fetchMock);
@@ -389,11 +375,6 @@ describe('LoomPage', () => {
     expect(
       screen.queryByText(/no session→file or session→commit route/),
     ).toBeNull();
-    expect(
-      screen.getAllByText(
-        /GET \/api\/delivery\/overview with session-linked pull_requests/,
-      ).length,
-    ).toBeGreaterThanOrEqual(1);
   });
 
   it('states which threads have no recorded extent, with the real count', async () => {
@@ -430,7 +411,6 @@ describe('LoomPage', () => {
     expect(screen.getByText('Session ↔ commit')).toBeTruthy();
     expect(screen.getByText('Session → edited file')).toBeTruthy();
     expect(screen.getByText('Branch & worktree spans')).toBeTruthy();
-    expect(screen.getByText('Pull request, review, CI & release outcomes')).toBeTruthy();
     expect(screen.getByText(/commit_sessions/)).toBeTruthy();
   });
 

dashboard/src/workspaces/loom/LoomPage.tsx

@@ -142,8 +142,6 @@ export function LoomPage() {
                   span.provider === selected.host && span.session_id === selected.sessionId,
               )
             : [];
-          const deliveryStatus =
-            data.source_statuses.find((source) => source.id === 'delivery_outcomes') ?? null;
           const commitStatus =
             data.source_statuses.find((source) => source.id === 'session_commit') ?? null;
           const branchStatus =
@@ -276,7 +274,6 @@ export function LoomPage() {
                       branchSpans: selectedSpans,
                       commitStatus,
                       branchStatus,
-                      deliveryStatus,
                     }}
                   />
                 </aside>

dashboard/src/workspaces/loom/ThreadChain.tsx

@@ -20,7 +20,6 @@ import {
  * This is the "selecting a thread isolates its chain" half of the Loom:
  * prompt → tools comes from session detail, then provider-qualified edits,
  * commits and branch/worktree spans continue from the Loom temporal read.
- * Delivery outcomes terminate in the shared route's typed dependency state.
  *
  * One further honesty point drives the whole layout: the LCM session endpoint
  * may omit `timestamp`, so the chain is always ordered by the store's
@@ -33,7 +32,6 @@ export interface ThreadRelations {
   branchSpans: readonly LoomBranchSpan[];
   commitStatus: LoomSourceStatus | null;
   branchStatus: LoomSourceStatus | null;
-  deliveryStatus: LoomSourceStatus | null;
 }
 
 export function ThreadChain({
@@ -267,7 +265,6 @@ function ChainTerminus({
     branchSpans,
     commitStatus,
     branchStatus,
-    deliveryStatus,
   } = relations;
   return (
     <div className="flex flex-col gap-3">
@@ -356,16 +353,6 @@ function ChainTerminus({
         )}
       </CausalGroup>
 
-      <CausalGroup label="→ delivery outcomes">
-        <StateChip
-          kind={deliveryStatus?.state ?? 'unknown'}
-          detail={
-            deliveryStatus?.required_authority ??
-            deliveryStatus?.reason ??
-            'Loom temporal response omitted the Delivery dependency status'
-          }
-        />
-      </CausalGroup>
     </div>
   );
 }