From f067ab45e4cd4fd6396ad5e43677b29c8183dedc Mon Sep 17 00:00:00 2001 From: Jinwoo-H Date: Fri, 4 Sep 2026 03:00:28 -0400 Subject: [PATCH] fix(agent-hooks): carry evidenceObservedAt into the status snapshot The fleet liveness projection reads getStatusSnapshot(), whose sole builder dropped the observation clock, so every worker fell back to the delivery clock and an hour-stale replayed agent read live. --- .../server-replay-evidence-clock.test.ts | 16 ++++++++++++++++ .../agent-hooks/server/server-status-identity.ts | 3 +++ 2 files changed, 19 insertions(+) diff --git a/src/main/agent-hooks/server-replay-evidence-clock.test.ts b/src/main/agent-hooks/server-replay-evidence-clock.test.ts index 12475a35d64..7dda18b930c 100644 --- a/src/main/agent-hooks/server-replay-evidence-clock.test.ts +++ b/src/main/agent-hooks/server-replay-evidence-clock.test.ts @@ -72,6 +72,22 @@ describe('the observation clock a relay replay must not restamp', () => { expect(replayed.evidenceObservedAt).toBe(T0) }) + it('carries the observation time out of getStatusSnapshot, not just the listener', () => { + ingest(server, { hook_event_name: 'UserPromptSubmit', prompt: 'do the thing' }) + vi.setSystemTime(T0 + 25 * 60 * 1000) + server.clearStatusEntriesForConnection(CONNECTION) + ingest( + server, + { hook_event_name: 'UserPromptSubmit', prompt: 'do the thing' }, + { isReplay: true } + ) + + // The fleet projection reads this snapshot, not the listener payload. + const row = server.getStatusSnapshot().find((entry) => entry.paneKey === PANE)! + expect(row.receivedAt).toBeGreaterThan(T0 + 25 * 60 * 1000 - 1) + expect(row.evidenceObservedAt).toBe(T0) + }) + it('lets a live event restamp the observation time after a replay', () => { ingest(server, { hook_event_name: 'UserPromptSubmit', prompt: 'do the thing' }) vi.setSystemTime(T0 + 25 * 60 * 1000) diff --git a/src/main/agent-hooks/server/server-status-identity.ts b/src/main/agent-hooks/server/server-status-identity.ts index 41a87b4d7de..a4ee28f1bb8 100644 --- a/src/main/agent-hooks/server/server-status-identity.ts +++ b/src/main/agent-hooks/server/server-status-identity.ts @@ -59,6 +59,9 @@ export function toAgentStatusIpcPayload( worktreeId: entry.worktreeId, connectionId: entry.connectionId, receivedAt: entry.receivedAt, + ...(entry.evidenceObservedAt !== undefined + ? { evidenceObservedAt: entry.evidenceObservedAt } + : {}), stateStartedAt: entry.stateStartedAt, ...(entry.providerSession ? { providerSession: entry.providerSession } : {}), ...(entry.providerSessionOnly ? { providerSessionOnly: true } : {}),