test: aligned merged regression tests with current main contracts

- handoff veto mock returns a promise and threshold expectation includes onSwitchCancelled
- codex websocket stale-anchor stats assertion tolerates lastTurn debug payload
This commit is contained in:
can1357
2026-07-08 15:43:56 +02:00
parent 53df3c82b7
commit 68da3dca8a
2 changed files with 5 additions and 8 deletions
+1 -1
View File
@@ -2808,7 +2808,7 @@ describe("openai-codex streaming", () => {
sessionId: "ws-proxy-stale-anchor-session",
providerSessionState,
});
expect(stats).toEqual({
expect(stats).toMatchObject({
fullContextRequests: 2,
deltaRequests: 1,
lastInputItems: (retryInput as unknown[]).length,
@@ -1420,6 +1420,7 @@ describe("AgentSession handoff", () => {
expect(handoffSpy).toHaveBeenCalledWith(expect.stringContaining("Threshold-triggered maintenance"), {
autoTriggered: true,
signal: expect.anything(),
onSwitchCancelled: expect.any(Function),
});
expect(events.filter(event => event.type === "auto_compaction_start")).toHaveLength(1);
const endEvents = events.filter(event => event.type === "auto_compaction_end");
@@ -1701,13 +1702,9 @@ describe("AgentSession handoff", () => {
modelRegistry,
);
vi.spyOn(extensionRunner, "hasHandlers").mockImplementation(eventName => eventName === "session_before_switch");
const emit = extensionRunner.emit.bind(extensionRunner);
const emitSpy = vi.spyOn(extensionRunner, "emit").mockImplementation(event => {
if (event.type === "session_before_switch") {
return { cancel: true };
}
return emit(event);
});
const emitSpy = vi.spyOn(extensionRunner, "emit").mockImplementation((async () => ({
cancel: true,
})) as ExtensionRunner["emit"]);
await session.dispose();
session = new AgentSession({