return tick().then(tick).then(tick);

}

function waitForEventLoopTurn(): Promise<void> {

return new Promise<void>((resolve) => {

setImmediate(resolve);

});

}

function getPromptErrorCode(result: AgentHarnessAttemptResult): string | undefined {

return (result.promptError as { code?: string } | undefined)?.code;

}

createToolBridge,

pool: makeFakePool(sdk),

});

await new Promise<void>((resolve) => setImmediate(resolve));

await waitForEventLoopTurn();

expect(beforePromptBuild).toHaveBeenCalledWith(

expect.objectContaining({ prompt: "hello" }),

expect(sdk.sessions[0]?.rpc.history.cancelBackgroundCompaction).toHaveBeenCalledTimes(1);

expect(sdk.sessions[0]?.disconnect).toHaveBeenCalledTimes(1);

expect(sdk.client.deleteSession).toHaveBeenCalledWith("sess-1");

expect(pool.release).toHaveBeenCalledTimes(1);

expect(pool.release.mock.calls).toHaveLength(1);

});

it("cancels retained compaction when the caller aborts after a turn result", async () => {

await runCopilotAttempt(makeParams({ hooksConfig: { onUserPromptSubmitted } } as never), {

pool: makeFakePool(sdk),

});

await new Promise<void>((resolve) => setImmediate(resolve));

await waitForEventLoopTurn();

expect(onUserPromptSubmitted).toHaveBeenCalledWith(

expect.objectContaining({ prompt: "hello" }),

pool: makeFakePool(sdk),

},

);

await new Promise<void>((resolve) => setImmediate(resolve));

await waitForEventLoopTurn();

expect(result.aborted).toBe(true);

expect(sdk.sessions[0]?.sendAndWait).not.toHaveBeenCalled();

settled = true;

return result;

});

await new Promise<void>((resolve) => setImmediate(resolve));

await waitForEventLoopTurn();

expect(agentEnd).toHaveBeenCalledTimes(1);

expect(settled).toBe(false);

expect(sdk.sessions[0]?.rpc.history.cancelBackgroundCompaction).toHaveBeenCalledTimes(1);

expect(sdk.sessions[0]?.disconnect).toHaveBeenCalledTimes(1);

expect(sdk.client.deleteSession).toHaveBeenCalledWith("sess-1");

expect(pool.release).toHaveBeenCalledTimes(1);

expect(pool.release.mock.calls).toHaveLength(1);

});

it("cancels deferred cleanup when the timed-out caller aborts", async () => {