From fd293bd2a7e0dfb22ac91bd2dcf4e8bc3ca20cbe Mon Sep 17 00:00:00 2001 From: Kaspre Date: Wed, 20 May 2026 09:09:42 -0400 Subject: [PATCH] test(gateway): use real dedupe map in abort helpers --- .../server-methods/chat.abort-persistence.test.ts | 12 ------------ .../server-methods/chat.abort.test-helpers.ts | 2 ++ 2 files changed, 2 insertions(+), 12 deletions(-) diff --git a/src/gateway/server-methods/chat.abort-persistence.test.ts b/src/gateway/server-methods/chat.abort-persistence.test.ts index 715f629c7347..896e0f472b11 100644 --- a/src/gateway/server-methods/chat.abort-persistence.test.ts +++ b/src/gateway/server-methods/chat.abort-persistence.test.ts @@ -279,9 +279,6 @@ describe("chat abort transcript persistence", () => { chatDeltaSentAt: new Map([["run-stop-1", Date.now()]]), removeChatRun: vi.fn().mockReturnValue({ sessionKey: "main", clientRunId: "client-stop-1" }), agentRunSeq: new Map([["run-stop-1", 1]]), - dedupe: { - get: vi.fn(), - }, }); await chatHandlers["chat.send"]({ @@ -321,9 +318,6 @@ describe("chat abort transcript persistence", () => { sessionKey: "main", clientRunId: "run-stop-canonical", }), - dedupe: { - get: vi.fn(), - }, }); await chatHandlers["chat.send"]({ @@ -356,9 +350,6 @@ describe("chat abort transcript persistence", () => { sessionKey: "alias-main", clientRunId: "run-stop-raw-alias", }), - dedupe: { - get: vi.fn(), - }, }); await chatHandlers["chat.send"]({ @@ -387,9 +378,6 @@ describe("chat abort transcript persistence", () => { const active = createActiveRun("third-session", { sessionId }); const context = createChatAbortContext({ chatAbortControllers: new Map([["run-stop-client-session", active]]), - dedupe: { - get: vi.fn(), - }, }); await chatHandlers["chat.send"]({ diff --git a/src/gateway/server-methods/chat.abort.test-helpers.ts b/src/gateway/server-methods/chat.abort.test-helpers.ts index c2c5a1860cb6..af8ddec9e737 100644 --- a/src/gateway/server-methods/chat.abort.test-helpers.ts +++ b/src/gateway/server-methods/chat.abort.test-helpers.ts @@ -27,6 +27,7 @@ type ChatAbortTestContext = Record & { chatDeltaSentAt: Map; chatDeltaLastBroadcastLen: Map; chatDeltaLastBroadcastText: Map; + dedupe: Map; agentDeltaSentAt: Map; bufferedAgentEvents: Map; chatAbortedRuns: Map; @@ -48,6 +49,7 @@ export function createChatAbortContext( chatDeltaSentAt: new Map(), chatDeltaLastBroadcastLen: new Map(), chatDeltaLastBroadcastText: new Map(), + dedupe: new Map(), agentDeltaSentAt: new Map(), bufferedAgentEvents: new Map(), chatAbortedRuns: new Map(),