Distillation

Date: Sep 17, 2026

• 🟡 (01:47) packages/core/test/session-projector.test.ts:68-220 defines test "atomically reconciles one abandoned execution into one continuation" using assistant ID msg_recovery_assistant, execution ID "execution", continuation ID continuation("execution"), and an expired SessionExecutionTable row with owner_id: "dead", phase: "unknown", time_created: 0, and expires_at: 0.
• 🟡 (01:47) In the atomic recovery test, SessionEvent.Step.Started creates the assistant projection, then SessionEvent.Step.Recovered at timestamp DateTime.makeUnsafe(1) supplies executionID: "execution", the same assistant ID, and phase: "unknown"; its commit callback deletes the corresponding SessionExecutionTable row.
• 🟡 (01:47) The recovered assistant is expected to have finish: "error", error { type: "unknown", message: "Provider Step outcome unknown after server restart" }, and exactly the recovery text part { type: "text", id: "recovery:execution", text: "Provider Step outcome unknown after server restart" }.
• 🟡 (01:47) Recovery creates one queued continuation in SessionInputTable with session_id: sessionID, prompt: { text: "continue" }, and delivery: "queue"; it also creates exactly one SessionRecoveryTable row with execution_id: "execution", assistant_message_id: assistantID, and phase: "unknown", while leaving SessionExecutionTable empty.
• 🟡 (01:47) The test records session events from EventTable in ascending sequence order, removes the aggregate, deletes recovery/input/message projections, and calls events.replayAll(...); replay reconstructs exactly 1 recovery row, 1 input row, and 1 message row.
• 🟡 (01:47) Publishing SessionEvent.Prompted for the replayed continuation with prompt text "continue" and delivery "queue" changes the recovery row to wake_pending: false; replaying the resulting settled event history preserves wake_pending: false.
• 🟡 (01:47) Republishing the same SessionEvent.Step.Recovered at DateTime.makeUnsafe(2) remains idempotent: SessionInputTable still contains exactly 1 row and SessionRecoveryTable still contains exactly 1 row.
• 🟡 (01:47) packages/core/test/session-projector.test.ts:222 begins a separate test named "records a recovery continuation without forging an assistant identity".