From 934e5e957c3a63af6a0509b55c18a95768e519e2 Mon Sep 17 00:00:00 2001 From: _Kerman Date: Thu, 30 Jul 2026 18:27:36 +0800 Subject: [PATCH] test(cli): accept durable inbox receipt before turn --- packages/examples/cli-demo/tests/built-bin.e2e.ts | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/packages/examples/cli-demo/tests/built-bin.e2e.ts b/packages/examples/cli-demo/tests/built-bin.e2e.ts index 8dc3fd7362..c58d2657fb 100644 --- a/packages/examples/cli-demo/tests/built-bin.e2e.ts +++ b/packages/examples/cli-demo/tests/built-bin.e2e.ts @@ -167,7 +167,19 @@ describe.skipIf(!existsSync(cliBin))('dsh-cli-demo BUILT bin', () => { const stream = await runBuiltBin(consumer, ['--config', './cordis.yml', '--output-format', 'stream-json', 'stream task']) const lines = stream.stdout.trimEnd().split('\n').map(line => JSON.parse(line) as Record) - expect(lines[0]).toMatchObject({ type: 'session_event', event: { type: 'turn/start' } }) + expect(lines[0]).toMatchObject({ + type: 'session_event', + event: { + type: 'agent/inbox/spliced', + data: { + target: 'next-turn', + start: 0, + inserted: [{ content: [{ type: 'text', text: 'stream task' }], source: { kind: 'user' } }], + }, + }, + }) + expect(lines.findIndex(line => + (line['event'] as { type?: string } | undefined)?.type === 'turn/start')).toBeGreaterThan(0) expect(lines.at(-1)).toMatchObject({ type: 'result', output: 'BUILT: stream task' }) const sessionsRoot = join(consumer, '.sessions') const files = await readdir(sessionsRoot, { recursive: true })