Compare commits

...

2 Commits

Author SHA1 Message Date
Kit Langton 7d277f931e fix(tui): keep global event routing unchanged 2026-07-10 12:17:59 -04:00
Kit Langton 1d11bf84c9 fix(tui): filter duplicate event work 2026-07-10 12:13:41 -04:00
2 changed files with 3 additions and 14 deletions
-6
View File
@@ -92,12 +92,6 @@ export const { use: useSDK, provider: SDKProvider } = createSimpleContext({
const event = await iterator.next()
if (abort.signal.aborted || controller.signal.aborted) return
if (event.done) return new Error("Event stream disconnected")
if ("durable" in event.value)
log.info("event", {
type: event.value.type,
aggregateID: event.value.durable.aggregateID,
seq: event.value.durable.seq,
})
events.emit(event.value.type, event.value)
}
})()
+3 -8
View File
@@ -112,7 +112,7 @@ function Probe(props: {
}
describe("useEvent", () => {
test("logs only durable events", async () => {
test("does not log individual events", async () => {
const logs: Array<{ message: string; tags: Readonly<Record<string, unknown>> }> = []
const { app, emit, seen } = await mount(undefined, (_level, message, tags) => {
if (message === "event") logs.push({ message, tags })
@@ -131,14 +131,9 @@ describe("useEvent", () => {
try {
emit(vcs("main"))
emit(durable)
await wait(() => seen.length === 2 && logs.length === 1)
await wait(() => seen.length === 2)
expect(logs).toEqual([
{
message: "event",
tags: { component: "sdk", type: "session.renamed", aggregateID: "ses_test", seq: 1 },
},
])
expect(logs).toEqual([])
} finally {
app.renderer.destroy()
}