chatDeltaSentAt: new Map([["run-stop-1", Date.now()]]),

removeChatRun: vi.fn().mockReturnValue({ sessionKey: "main", clientRunId: "client-stop-1" }),

agentRunSeq: new Map<string, number>([["run-stop-1", 1]]),

dedupe: {

get: vi.fn(),

},

});

await chatHandlers["chat.send"]({

sessionKey: "main",

clientRunId: "run-stop-canonical",

}),

dedupe: {

get: vi.fn(),

},

});

await chatHandlers["chat.send"]({

sessionKey: "alias-main",

clientRunId: "run-stop-raw-alias",

}),

dedupe: {

get: vi.fn(),

},

});

await chatHandlers["chat.send"]({

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"]({

chatDeltaSentAt: Map<string, number>;

chatDeltaLastBroadcastLen: Map<string, number>;

chatDeltaLastBroadcastText: Map<string, string>;

dedupe: Map<string, unknown>;

agentDeltaSentAt: Map<string, number>;

bufferedAgentEvents: Map<string, unknown>;

chatAbortedRuns: Map<string, number>;

chatDeltaSentAt: new Map(),

chatDeltaLastBroadcastLen: new Map(),

chatDeltaLastBroadcastText: new Map(),

dedupe: new Map(),

agentDeltaSentAt: new Map(),

bufferedAgentEvents: new Map(),

chatAbortedRuns: new Map<string, number>(),