Distillation

Date: Sep 17, 2026

• 🟡 (09:07) Inspection of the supplied recovery implementation showed it imports SessionExecution, uses SessionInputTable, SessionRecoveryTable, and SessionExecutionTable, orders execution claims by asc(SessionExecutionTable.time_created), asc(SessionExecutionTable.id), and renews ownership with { owner_id: ownerID, expires_at: now + SESSION_EXECUTION_LEASE_MS }.
• 🟡 (09:07) Recovery processing orders durable recovery rows by asc(SessionRecoveryTable.time_created), asc(SessionRecoveryTable.execution_id), validates continuation inputs through SessionInput.validateRecovery(db, row.continuationMessageID), and filters pending work using SessionRecoveryTable.wake_pending = true; ordinary wake selection distinguishes retries with gt(SessionTable.wake_attempts, 0) and lte(SessionTable.wake_attempts, MAX_WAKE_ATTEMPTS).
• 🟡 (09:07) The recovery implementation includes claim-phase handling for "cancelled", clears claims through SessionExecutionClaim.clear(db, recoveryClaim), inspects whether the latest message is an incomplete assistant message, handles tool calls via callID: tool.id, and logs failures with Effect.logError("Failed to recover Session", cause).
• 🟡 (09:07) An initial file search returned No files found; a subsequent search located /tmp/opencode/session-recovery-v21-review/packages/core/src/event.ts and /tmp/opencode/session-recovery-v21-review/packages/core/src/session/event.ts.
• 🟡 (09:07) Search of /tmp/opencode/session-recovery-v21-review/packages/core/src/event.ts found 34 commit/publish-related matches. At lines 122–123, durable events support an optional local operational projection commit?: (seq: number) => Effect.Effect<void> that is committed atomically with the event and is neither replayed nor serialized.
• 🟡 (09:07) In packages/core/src/event.ts, commitDurableEvent(...) accepts the local commit hook; after projectors run, it invokes commit(seq) when present. publishEvent(...) rejects a commit hook on a non-durable definition with "Local commit hooks require a durable event".
• 🟡 (09:07) packages/core/src/event.ts exposes durable-event options including publish?: boolean, ownerID?: string, and strictOwner?: boolean; after a successful durable commit, optional publication emits the committed aggregateID and seq, while durable wake subscribers are notified through PubSub.publish(wake, undefined).