test(companion): cover waitForIdle abort cancellation

This commit is contained in:
William Valentin
2026-02-16 20:56:59 -08:00
parent a000235826
commit 1a46b122e0
2 changed files with 28 additions and 0 deletions
+11
View File
@@ -927,6 +927,17 @@
], ],
"test_status": "pnpm test:run src/companion/platformClients.integration.test.ts src/companion/platformClients.test.ts src/companion/runtimeClient.test.ts src/companion/heartbeatLoop.test.ts + pnpm typecheck passing" "test_status": "pnpm test:run src/companion/platformClients.integration.test.ts src/companion/platformClients.test.ts src/companion/runtimeClient.test.ts src/companion/heartbeatLoop.test.ts + pnpm typecheck passing"
}, },
"companion-runtime-wait-for-idle-abort-coverage": {
"status": "completed",
"date": "2026-02-17",
"updated": "2026-02-17",
"summary": "Added abort-signal regression coverage for runtime `waitForIdle()` so pending idle waits cancel deterministically with explicit abort errors.",
"files_modified": [
"src/companion/runtimeClient.test.ts",
"docs/plans/state.json"
],
"test_status": "pnpm test:run src/companion/runtimeClient.test.ts src/companion/platformClients.test.ts src/companion/heartbeatLoop.test.ts src/companion/platformClients.integration.test.ts + pnpm typecheck passing"
},
"browser-tools-activation-clarity": { "browser-tools-activation-clarity": {
"status": "completed", "status": "completed",
"date": "2026-02-17", "date": "2026-02-17",
+17
View File
@@ -693,6 +693,23 @@ describe('CompanionRuntimeClient', () => {
await pendingWait; await pendingWait;
}); });
it('waitForIdle supports AbortSignal cancellation', async () => {
const client = new CompanionRuntimeClient({
url: 'ws://127.0.0.1:1',
});
const pendingWait = client.waitForEvent('agent.stream', { timeoutMs: 10_000 }).catch(() => undefined);
const controller = new AbortController();
const awaited = expect(
client.waitForIdle({ timeoutMs: 10_000, signal: controller.signal }),
).rejects.toThrow('Aborted while waiting for runtime idle state');
controller.abort();
await awaited;
client.clearEventSubscriptions();
await pendingWait;
});
it('connects and performs node registration + capability discovery', async () => { it('connects and performs node registration + capability discovery', async () => {
if (!LISTEN_ALLOWED) { if (!LISTEN_ALLOWED) {
return; return;