From 28883bb03dcde28770b6783e8ef02c5805449557 Mon Sep 17 00:00:00 2001 From: luochen211 Date: Tue, 20 Oct 2026 10:32:40 +0800 Subject: [PATCH] fix(zcode): abort unknown boundary flush after request arrival --- .../zcode/plugins/powercontext/tests/boundary.test.mjs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/integrations/zcode/plugins/powercontext/tests/boundary.test.mjs b/integrations/zcode/plugins/powercontext/tests/boundary.test.mjs index 50c2341416..9ea73bc63f 100644 --- a/integrations/zcode/plugins/powercontext/tests/boundary.test.mjs +++ b/integrations/zcode/plugins/powercontext/tests/boundary.test.mjs @@ -280,8 +280,14 @@ test('pending preserves concurrent receipts and pauses unknown writes', { timeou const unknownData = join(root, 'unknown') const unknown = await beginCaptureTracking(input, settings, keys, 'scope-boundary', unknownData) await unknown.accepted(3) - delay = 1200 - const result = await flushBoundary(input, settings, keys, resolveCurrent, AbortSignal.timeout(800), unknownData) + // Abort only after the fixture receives the request so pre-dispatch work cannot turn this into `failed`. + const cancel = new AbortController() + responseGate = new Promise(resolve => { releaseResponse = resolve }) + received = () => cancel.abort() + const result = await flushBoundary(input, settings, keys, resolveCurrent, cancel.signal, unknownData) + received = undefined + releaseResponse() + responseGate = undefined assert.equal(result.state, 'unknown') const afterUnknown = flushes t.mock.timers.tick(5100)