Distillation

Date: Sep 17, 2026

• 🟡 (09:13) In packages/core/src/event.ts, commitDurableEvent(...) wraps durable publication in Effect.uninterruptible and a database transaction with { behavior: "immediate" }; inside the transaction it runs registered projectors, invokes the optional commit(seq) hook, upserts EventSequenceTable, and inserts into EventTable, in that exact order.
• 🟡 (09:13) In packages/core/src/event.ts, durable subscriber wake-up occurs only after the transaction completes successfully: pubsub.durable.get(committed.aggregateID) entries receive PubSub.publish(wake, undefined).
• 🟡 (09:13) commitDurableEvent(...) validates that the configured durable aggregate field is a string and rejects an input.aggregateID mismatch with InvalidDurableEventError.
• 🟡 (09:13) commitDurableEvent(...) replay handling compares the stored event’s ID, versioned type, and deeply equal encoded data. An exact replay returns without rerunning projectors or the local commit hook; a mismatch fails with "Replay diverged at aggregate ${aggregateID} sequence ${input.seq}".
• 🟡 (09:13) commitDurableEvent(...) owner handling rejects a conflicting owner when input.strictOwner is true, silently returns for a non-strict conflicting owner, and can populate a previously null EventSequenceTable.owner_id during an exact replay.
• 🟡 (09:13) commitDurableEvent(...) enforces contiguous sequence numbers and globally unique event IDs; errors include "Sequence mismatch for aggregate ${aggregateID}: expected ${latest + 1}, got ${seq}" and "Event ${event.id} already exists at aggregate ${stored.aggregateID} sequence ${stored.seq}".
• 🟡 (09:13) packages/core/test/session-runner.test.ts:4200 contains LLMEvent.toolCall({ id: "call-terminal", name: "echo", input: { text: "done" } }); this was the sole search match for call-terminal.