diff options
| author | Adam Malczewski <[email protected]> | 2026-10-21 02:56:48 +0900 |
|---|---|---|
| committer | Adam Malczewski <[email protected]> | 2026-10-21 02:56:48 +0900 |
| commit | 0c0f366b3820136c9877f80005939011c30b2de4 (patch) | |
| tree | d6cd470b038ea968e677436131d34f3d1fd66b6a /src/core/chunks | |
| parent | 2686cf6bcd247d17528922e36aa380a521c964e0 (diff) | |
| download | dispatch-web-0c0f366b3820136c9877f80005939011c30b2de4.tar.gz dispatch-web-0c0f366b3820136c9877f80005939011c30b2de4.zip | |
fix(review-4.4): tolerate additive terminal turn events
Diffstat (limited to 'src/core/chunks')
| -rw-r--r-- | src/core/chunks/reducer.test.ts | 10 | ||||
| -rw-r--r-- | src/core/chunks/reducer.ts | 3 |
2 files changed, 13 insertions, 0 deletions
diff --git a/src/core/chunks/reducer.test.ts b/src/core/chunks/reducer.test.ts index cba6fad..ae0aa73 100644 --- a/src/core/chunks/reducer.test.ts +++ b/src/core/chunks/reducer.test.ts @@ -1051,3 +1051,13 @@ describe("turnId provenance on live chunks", () => { expect(selectChunks(s).map((c) => c.turnId)).toEqual(["t9", undefined]); }); }); + +describe("foldEvent — additive wire compatibility", () => { + it.each(["turn-ended", "future-event"])("preserves transcript identity for %s", (type) => { + const state = foldEvent(foldEvent(initialState(), turnStart("t1")), textDelta("t1", "partial")); + const before = structuredClone(state); + const event = { type, conversationId: "c1", turnId: "t1", reason: "sealed" }; + expect(foldEvent(state, event as Parameters<typeof foldEvent>[1])).toBe(state); + expect(state).toEqual(before); + }); +}); diff --git a/src/core/chunks/reducer.ts b/src/core/chunks/reducer.ts index 4eb08c1..0af2ddd 100644 --- a/src/core/chunks/reducer.ts +++ b/src/core/chunks/reducer.ts @@ -408,6 +408,9 @@ function reduceEvent(state: TranscriptState, event: AgentEvent): TranscriptState // (already true from `turn-start`) is left untouched. return { ...state, providerRetry: event }; } + + default: + return state; // Forward-compatible with additive wire events. } } |
