From 3dd3fa5d05799cb359817508f6fd3dfff01af8a5 Mon Sep 17 00:00:00 2001 From: Evandro Fonseca Junior Date: Sat, 10 Oct 2026 04:23:16 -0300 Subject: [PATCH] test: read SSE chunks until session.updated arrives session.status and session.updated are two separate res.write calls, so the test failed whenever TCP delivered them in different chunks. --- extensions/piagentui-server.test.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/extensions/piagentui-server.test.ts b/extensions/piagentui-server.test.ts index f0a6660..0a6ef1c 100644 --- a/extensions/piagentui-server.test.ts +++ b/extensions/piagentui-server.test.ts @@ -1025,8 +1025,13 @@ describe('PiAgentUi Extension Server', () => { // Trigger agent_start - should broadcast session.status and session.updated! await listeners['agent_start']() - const chunk3 = await reader?.read() - const text3 = new TextDecoder().decode(chunk3?.value) + // The two events are separate writes, so TCP may deliver them in different chunks. + let text3 = '' + while (!text3.includes('session.updated')) { + const chunk = await reader?.read() + if (!chunk || chunk.done) break + text3 += new TextDecoder().decode(chunk.value) + } expect(text3).toContain('session.status') expect(text3).toContain('working') expect(text3).toContain('session.updated')