vrr/eigent
2
0
Fork 0
mirror of https://github.com/eigent-ai/eigent.git synced 2026-10-19 08:53:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

test: replay seeded events before live ones in run state reconciliation tests (#2054)
Some checks are pending
CodeQL Advanced / Analyze (actions) (push) Waiting to run
Details
CodeQL Advanced / Analyze (javascript-typescript) (push) Waiting to run
Details
CodeQL Advanced / Analyze (python) (push) Waiting to run
Details
Pre-commit / pre-commit (push) Waiting to run
Details
Test / Run Web + Local Brain Smoke (push) Waiting to run
Details
Test / Run Frontend Guardrails (push) Waiting to run
Details
Test / Run Browser Preview Electron Test (push) Waiting to run
Details
Test / Run Python Tests (push) Waiting to run
Details

Browse source
This commit is contained in:
Tong Chen 2026-10-14 16:04:52 +08:00 • committed by GitHub
parent 299a123610
commit 98ce9fb14a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 29 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

37
test/unit/service/runStateReconciliation.test.ts
View file

@ -70,6 +70,32 @@ function summary(status: string, version = 3) {
};
}
function seededEvents() {
return [
event(1, 'run.attempt_started'),
event(2, 'interaction.requested', {
interaction_id: 'question-fixture',
interaction_type: 'question',
prompt: 'Continue?',
}),
];
}
/**
* A companion stream resumes from the older of the timeline and the Run
* projection. The seeded Run projection comes from a summary without event
* sequences, so the stream starts at 0 and the server replays 1 and 2 first.
*/
async function replaySeededEvents(stream: SSETransportOptions) {
expect(stream.url).toContain('after_sequence=0');
for (const seeded of seededEvents())
await stream.onmessage?.({
id: '',
event: 'run_event',
data: JSON.stringify(seeded),
});
}
function seed() {
const store = getProjectEventStore(projectId);
store.replaceSnapshot({
@ -86,14 +112,7 @@ function seed() {
resume_blocked_reason: null,
},
],
recent_events: [
event(1, 'run.attempt_started'),
event(2, 'interaction.requested', {
interaction_id: 'question-fixture',
interaction_type: 'question',
prompt: 'Continue?',
}),
],
recent_events: seededEvents(),
});
runProjectionStore.upsertRunSummaries(projectId, [
summary('waiting_for_user', 2),
@ -348,6 +367,7 @@ describe('stream to canonical state reconciliation', () => {
});
owners.push(owner);
owner.updateSnapshot(store.getSnapshot());
await replaySeededEvents(streams[0]);
await streams[0].onmessage({
id: '',
event: 'run_event',
@ -684,6 +704,7 @@ describe('stream to canonical state reconciliation', () => {
});
owners.push(owner);
owner.updateSnapshot(store.getSnapshot());
await replaySeededEvents(streams[0]);
await streams[0].onmessage({
id: '',
event: 'run_event',