diff options
| author | Adam Malczewski <[email protected]> | 2026-06-07 18:52:13 +0900 |
|---|---|---|
| committer | Adam Malczewski <[email protected]> | 2026-06-07 18:52:13 +0900 |
| commit | 80f8a219c89a963c485da0f40dc428bf688fedb7 (patch) | |
| tree | 737822344118e5c1c840b8399a554a1898f07093 /src/features/chat/store.test.ts | |
| parent | 48c6d85c3cc5a57a729f14068e2346b17ed62088 (diff) | |
| download | dispatch-web-80f8a219c89a963c485da0f40dc428bf688fedb7.tar.gz dispatch-web-80f8a219c89a963c485da0f40dc428bf688fedb7.zip | |
Revert "feat(chat): live turn metrics — telemetry reducer + rendering"
This reverts commit 48c6d85c3cc5a57a729f14068e2346b17ed62088.
Diffstat (limited to 'src/features/chat/store.test.ts')
| -rw-r--r-- | src/features/chat/store.test.ts | 46 |
1 files changed, 0 insertions, 46 deletions
diff --git a/src/features/chat/store.test.ts b/src/features/chat/store.test.ts index 347cdd7..71781ac 100644 --- a/src/features/chat/store.test.ts +++ b/src/features/chat/store.test.ts @@ -393,52 +393,6 @@ describe("createChatStore", () => { store.dispose(); }); - it("folding step-complete and usage events populates telemetry", () => { - const transport = createFakeTransport(); - const historySync = createFakeHistorySync(); - const cache = createFakeCache(); - const store = createChatStore({ - conversationId: CONV_ID, - transport: transport.impl, - historySync: historySync.impl, - cache: cache.impl, - }); - - store.handleDelta(deltaEvent({ type: "turn-start", conversationId: CONV_ID, turnId: "t1" })); - store.handleDelta( - deltaEvent({ - type: "step-complete", - conversationId: CONV_ID, - turnId: "t1", - stepId: "t1#0" as StepId, - ttftMs: 300, - decodeMs: 700, - genTotalMs: 1000, - }), - ); - store.handleDelta( - deltaEvent({ - type: "usage", - conversationId: CONV_ID, - turnId: "t1", - stepId: "t1#0" as StepId, - usage: { inputTokens: 50, outputTokens: 20 }, - }), - ); - - const turn = store.telemetry.turns.get("t1"); - expect(turn).toBeDefined(); - expect(turn?.steps).toHaveLength(1); - const step = turn?.steps.find((s) => s.stepId === ("t1#0" as StepId)); - expect(step).toBeDefined(); - expect(step?.ttftMs).toBe(300); - expect(step?.decodeMs).toBe(700); - expect(step?.usage?.inputTokens).toBe(50); - expect(step?.usage?.outputTokens).toBe(20); - - store.dispose(); - }); - it("handleDelta ignores a chat.delta for a different conversationId", () => { const transport = createFakeTransport(); const historySync = createFakeHistorySync(); |
