Distillation

Date: Sep 17, 2026

• 🔴 (10:03) User stated the session-recovery invariant: “never resume an older assistant projection”; a newer turn supersedes stale incomplete rows.
• 🟡 (10:02) User supplied the createLLMEventPublisher implementation for review. It lazily creates an assistant message, tracks text and tool state by event/call ID, publishes text/tool lifecycle events, settles tool outputs, and exposes assistant failure and interruption handling.
• 🟡 (10:02) createLLMEventPublisher treats invalid event ordering as fatal programmer-state errors, including Tool input end before start: ${callID} and Tool input delta before start: ${event.id}.
• 🟡 (10:03) Investigation found no additional files from one search, then located durable event publication and replay logic in /tmp/opencode/session-recovery-v23-review/packages/core/src/event.ts.
• 🟡 (10:03) In packages/core/src/event.ts, publishEvent() rejects commit hooks for non-durable definitions with InvalidDurableEventError and message "Local commit hooks require a durable event".
• 🟡 (10:03) Durable event commits run registered projectors first, then the optional local commit(seq) hook, upsert EventSequenceTable, insert into EventTable, wake subscribers for the committed aggregate, attach { aggregateID, seq, version } to the payload, and notify listeners.
• 🟡 (10:03) Durable replay is idempotent only when an already-used sequence contains the same event ID, versioned type, and deeply equal encoded data; otherwise it dies with InvalidDurableEventError stating Replay diverged at aggregate ${aggregateID} sequence ${input.seq}.
• 🟡 (10:03) Durable ownership behavior in packages/core/src/event.ts: replay can claim an unowned EventSequenceTable row using input.ownerID; when a row already has a different ownerID, the commit returns without appending; newly inserted sequence rows store owner_id: input?.ownerID.
• 🟡 (10:03) Durable event sequencing rejects noncontiguous replay with Sequence mismatch for aggregate ${aggregateID}: expected ${latest + 1}, got ${seq} and rejects reuse of an event ID at another aggregate/sequence with Event ${event.id} already exists at aggregate ${stored.aggregateID} sequence ${stored.seq}.
• 🟡 (10:03) Event notification isolates durable listeners through observe(): non-interruption listener failures are logged as "Event listener failed" with eventID, eventType, and cause; typed and global PubSub channels are then notified.
• 🟡 (10:03) User supplied session projection code containing SessionAlreadyProjected, SessionMessageTable, recovery continuation projection based on executionID, usage accounting through applyUsage, and projectors for events including SessionV1.Event.Updated, SessionEvent.ModelSwitched, SessionEvent.Prompted, and SessionEvent.Tool.Called.