jb/paseo
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

test(app): stabilize consecutive turn e2e

Browse Source
This commit is contained in:
Mohamed Boudra
2026-08-21 13:58:21 +02:00
parent 602860625c
commit c527b203c4
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/app/e2e/browser/agent-consecutive-turns.spec.ts
+9 -4
View File
@@ -726,7 +726,7 @@ async function recordDelayedRunningTransition(
gate.holdNextAgentStreamEvent("turn_started"); gate.holdNextAgentStreamEvent("turn_started");
gate.holdNextAgentUpdate(agent.agentId, "running"); gate.holdNextAgentUpdate(agent.agentId, "running");
gate.holdNextServerMessage("send_agent_message_response"); gate.holdNextServerMessage("send_agent_message_response");
gate.setAgentStreamItemSuppressed("assistant_message", true); gate.setAgentStreamSuppressed(true);
await recordTurnFrames(page, prompt); await recordTurnFrames(page, prompt);
await installActivityContinuityOracle(page, prompt); await installActivityContinuityOracle(page, prompt);
await submitMessage(page, prompt); await submitMessage(page, prompt);
@@ -779,13 +779,13 @@ async function recordDelayedRunningTransition(
const checkpoints = await readActivityContinuityOracle(page); const checkpoints = await readActivityContinuityOracle(page);
expectActivityContinuity(checkpoints); expectActivityContinuity(checkpoints);
expect(elapsedBeforeAuthoritative).toBe(0); expect(elapsedBeforeAuthoritative).toBe(0);
gate.setAgentStreamItemSuppressed("assistant_message", false); gate.setAgentStreamSuppressed(false);
return { frames, checkpoints }; return { frames, checkpoints };
} finally { } finally {
if (!turnReleased) gate.releaseHeldAgentStreamEvent("turn_started"); if (!turnReleased) gate.releaseHeldAgentStreamEvent("turn_started");
if (!snapshotReleased) gate.releaseHeldAgentUpdate(agent.agentId, "running"); if (!snapshotReleased) gate.releaseHeldAgentUpdate(agent.agentId, "running");
if (!responseReleased) gate.releaseHeldServerMessage("send_agent_message_response"); if (!responseReleased) gate.releaseHeldServerMessage("send_agent_message_response");
gate.setAgentStreamItemSuppressed("assistant_message", false); gate.setAgentStreamSuppressed(false);
} }
} }
@@ -814,6 +814,8 @@ test("keeps the first prompt of a new agent in place through authoritative hydra
await expectComposerVisible(page); await expectComposerVisible(page);
const prompt = "Delay synthetic user message by 300ms."; const prompt = "Delay synthetic user message by 300ms.";
gate.holdNextServerMessage("fetch_agent_timeline_response");
gate.setAgentStreamEventSuppressed("timeline", true);
await attachImageFromMenu(page, FIRST_PROMPT_IMAGE); await attachImageFromMenu(page, FIRST_PROMPT_IMAGE);
await expectAttachmentPill(page, "composer-image-attachment-pill"); await expectAttachmentPill(page, "composer-image-attachment-pill");
await recordTurnFrames(page, prompt); await recordTurnFrames(page, prompt);
@@ -821,7 +823,10 @@ test("keeps the first prompt of a new agent in place through authoritative hydra
const submittedRow = page.getByTestId("user-message").filter({ hasText: prompt }).first(); const submittedRow = page.getByTestId("user-message").filter({ hasText: prompt }).first();
await expect(submittedRow).toBeVisible(); await expect(submittedRow).toBeVisible();
await gate.waitForServerMessage("fetch_agent_timeline_response"); await gate.waitForHeldServerMessage("fetch_agent_timeline_response");
gate.truncateHeldTimelineAfterLast("user_message");
gate.releaseHeldServerMessage("fetch_agent_timeline_response");
await expect(submittedRow.getByTestId("rewind-menu-trigger")).toBeVisible();
await recordPaintsFor(page, 80); await recordPaintsFor(page, 80);
expectAtomicFirstPromptTransition(await stopTurnFrameRecording(page)); expectAtomicFirstPromptTransition(await stopTurnFrameRecording(page));
} finally { } finally {