vrr/eigent
2
0
Fork 0
mirror of https://github.com/eigent-ai/eigent.git synced 2026-08-21 06:33:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix: keep remote projections monotonic

Browse source
This commit is contained in:
4pmtong 2026-08-05 23:47:13 +08:00
parent a3adf6120e
commit 71bc4d1efa
2 changed files with 30 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/lib/projector/effects.ts
View file

@ -27,7 +27,12 @@ export function deriveLiveEffects(
});
}
}
if (next.needsResync && !previous.needsResync) {
if (
next.needsResync &&
(!previous.needsResync ||
next.resyncReason !== previous.resyncReason ||
next.resyncTargetCursor !== previous.resyncTargetCursor)
) {
effects.push({
type: 'request_resync',
reason: next.resyncReason || 'unknown_gap',

24
test/unit/lib/projector.test.ts
View file

@ -147,6 +147,30 @@ describe('projector pipeline', () => {
});
});
it('requests another resync when a later gap extends the missing range', () => {
const initial = reduceProjectView(
createProjectViewState('project-1', 'live'),
normalizeEvent(event())
);
const firstGapEvent = normalizeEvent(
event({ event_id: 'event-3', cloud_cursor: 3, run_sequence: 3 })
);
const firstGap = reduceProjectView(initial, firstGapEvent);
const laterGapEvent = normalizeEvent(
event({ event_id: 'event-4', cloud_cursor: 4, run_sequence: 4 })
);
const laterGap = reduceProjectView(firstGap, laterGapEvent);
expect(
deriveLiveEffects(firstGap, laterGap, laterGapEvent, 'live')
).toEqual([
{
type: 'request_resync',
reason: 'run_sequence_gap:run-1:2:4',
},
]);
});
it('derives effects only in live mode', () => {
const normalized = normalizeEvent(
event({ event_type: 'run.completed', legacy_step: 'end' })