File size: 1,777 Bytes
fc93158 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 | import { afterEach, describe, expect, it, vi } from "vitest";
import { emitSessionTranscriptUpdate, onSessionTranscriptUpdate } from "./transcript-events.js";
const cleanup: Array<() => void> = [];
afterEach(() => {
while (cleanup.length > 0) {
cleanup.pop()?.();
}
});
describe("transcript events", () => {
it("emits trimmed session file updates", () => {
const listener = vi.fn();
cleanup.push(onSessionTranscriptUpdate(listener));
emitSessionTranscriptUpdate(" /tmp/session.jsonl ");
expect(listener).toHaveBeenCalledTimes(1);
expect(listener).toHaveBeenCalledWith({ sessionFile: "/tmp/session.jsonl" });
});
it("continues notifying other listeners when one throws", () => {
const first = vi.fn(() => {
throw new Error("boom");
});
const second = vi.fn();
cleanup.push(onSessionTranscriptUpdate(first));
cleanup.push(onSessionTranscriptUpdate(second));
expect(() => emitSessionTranscriptUpdate("/tmp/session.jsonl")).not.toThrow();
expect(first).toHaveBeenCalledTimes(1);
expect(second).toHaveBeenCalledTimes(1);
});
it("emits normalized rich transcript updates", () => {
const listener = vi.fn();
cleanup.push(onSessionTranscriptUpdate(listener));
emitSessionTranscriptUpdate({
sessionFile: " /tmp/session.jsonl ",
sessionKey: " agent:main:main ",
message: { role: "assistant", content: [{ type: "text", text: "hi" }] },
messageId: " msg-1 ",
});
expect(listener).toHaveBeenCalledTimes(1);
expect(listener).toHaveBeenCalledWith({
sessionFile: "/tmp/session.jsonl",
sessionKey: "agent:main:main",
message: { role: "assistant", content: [{ type: "text", text: "hi" }] },
messageId: "msg-1",
});
});
});
|