Skip to content

Commit e858eef

Browse files
fix(cli): preserve state after interrupted runs
1 parent 3b5e2f9 commit e858eef

1 file changed

Lines changed: 26 additions & 0 deletions

File tree

cli/src/hooks/helpers/__tests__/send-message.test.ts

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -289,6 +289,32 @@ describe('setupStreamingContext', () => {
289289
expect(abortController).toBe(ownedAbortController)
290290
})
291291

292+
test('invokes the owner checkpoint callback before abort cleanup', () => {
293+
let messages = createBaseMessages()
294+
const streamRefs = createStreamController()
295+
const timerController = createMockTimerController()
296+
const onAbort = mock(() => {})
297+
298+
const { abortController } = setupStreamingContext({
299+
aiMessageId: 'ai-1',
300+
timerController,
301+
setMessages: (fn: any) => {
302+
messages = fn(messages)
303+
},
304+
streamRefs,
305+
onAbort,
306+
setStreamStatus: () => {},
307+
setCanProcessQueue: () => {},
308+
updateChainInProgress: () => {},
309+
setIsRetrying: () => {},
310+
setStreamingAgents: () => {},
311+
})
312+
313+
abortController.abort()
314+
315+
expect(onAbort).toHaveBeenCalledTimes(1)
316+
})
317+
292318
test('setupStreamingContext resets streamRefs and starts timer', () => {
293319
let messages = createBaseMessages()
294320
const streamRefs = createStreamController()

0 commit comments

Comments
 (0)