Dashboard › opencode › Session 0E93F7QzGu4p
0E93F7QzGu4pyJJ6ZPerform a read-only adversarial correctness review of the exact frozen candidate. Base commit: ab9408c81cc9916177641ae8e9f08624fc27b5b9. Patch path: /tmp/opencode/session-recovery-final-v9.patch. Expected patch SHA-256: d525a720dae01d40d14301b9bd1fa7ca726dda77c142de332f74d9f3b5f5e15e. Expected SEA artifact: /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server with SHA-256 edf38112295131282cb05d7f2d657417e38a40e3e19125d80c02056ee5b367f3. Do not mutate files, refs, index, services, or run builds/tests. Verify hashes, apply patch to immutable Git objects or a disposable read-only analysis location, inspect all 33 changed files. Focus on correctness, lifecycle, transactions, replay, concurrency, migration, wake fairness, cancellation, tool/provider uncertainty, and stale-owner fencing. Prior blockers that must be explicitly assessed: (1) no recovery of a live lease; no expired owner renewal; no second owner; ordinary acquisition never overwrites expired lease; own uncertain live lease never re-enters; (2) explicit cancellation now durably sets phase cancelling, supervises lease renewal through finalizers, and recovery quarantines expired cancellation instead of synthesizing/waking; assess races and successor behavior; (3) provider stream failure after step-finish never commits Step.Ended; (4) Step.Recovered execution-ID collision across Sessions must abort atomically, never silently succeed; (5) projection failure after recovery lease expiry must quarantine exact execution/owner or prove responsibility transferred; never leave an endlessly rescanned unquarantined row; (6) startAssistant in-memory state mutates only after Step.Started durable publication succeeds; (7) shared recovery validator, quarantined continuation exclusion, pre-promotion admission boundary, hosted-tool reconciliation, bounded fair wake attempts, replay wake intent, and schema lineage. ...
<path>/home/byk/Code/opencode</path> <type>directory</type> <entries> .dockerignore .editorconfig .git/ .gitattributes .github/ .gitignore .gitleaksignore .husky/ .lore.md .node-cache/ .opencode/ .oxlintrc.json .prettierignore .turbo/ .vscode/ .zed/ AGENTS.md artifacts/ bun.lock bunfig.toml CONTEXT.md CONTRIBUTING.md flake.lock flake.nix github/ infra/ install LICENSE nix/ node_modules/ package.json packages/ patches/ perf.data perf.data.old perf/ pnpm-lock.yaml pnpm-workspace.yaml README.ar.md README.bn.md README.br.md README.bs.md README.da.md README.de.md README.es.md README.fr.md README.gr.md README.it.md README.ja.md README.ko.md README.md README.no.md README.pl.md README.ru.md README.th.md README.tr.md README.uk.md README.vi.md README.zh.md README.zht.md screenshot-uk.png script/ sdks/ SECURITY.md specs/ sst-env.d.ts sst.config.ts STATS.md tmp/ tsconfig.json turbo.json (71 entries) </entries>
<path>/tmp/opencode</path> <type>directory</type> <entries> .oxfmtrc.json base-pipeline-numbered.txt base-test-numbered.txt llm-v5-current.diff local-v5-current.diff lore-ui-search-response oxfmt-opencode.json projection-parent-pipeline.ts provider-log-failure.test.ts provider-log-vitest.config.ts publisher-v5-current.diff restore-projector-v5-labeled.patch restore-projector-v5.patch restore-runner-v5-labeled.patch restore-runner-v5.patch session-recovery-final-v4-diag/ session-recovery-final-v4.index session-recovery-final-v4.patch session-recovery-final-v4/ session-recovery-final-v5.index session-recovery-final-v5.patch session-recovery-final-v5/ session-recovery-final-v6.patch session-recovery-final-v6/ session-recovery-final-v7.patch session-recovery-final-v7/ session-recovery-final-v8.patch session-recovery-final-v8/ session-recovery-final-v9.patch session-recovery-final-v9/ session-recovery-recheck.f3rLnS/ session-recovery-review-c2c8afb0/ session-recovery-review-v5-49183f9e.inde...
<path>/home/byk/Code/opencode/packages/opencode/dist/server</path> <type>directory</type> <entries> assets/ native/ opencode-server prebuilds/ (4 entries) </entries>
d525a720dae01d40d14301b9bd1fa7ca726dda77c142de332f74d9f3b5f5e15e /tmp/opencode/session-recovery-final-v9.patch edf38112295131282cb05d7f2d657417e38a40e3e19125d80c02056ee5b367f3 /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server
ab9408c81cc9916177641ae8e9f08624fc27b5b9 d3323b963b9ef2de41a7ff9884299c74b93886ba 2e9407768d1401a25b69febb36657638a779053a M .lore.md M AGENTS.md M packages/core/schema.json M packages/core/src/database/migration.gen.ts M packages/core/src/database/migration/20260914170650_session-recovery.ts D packages/core/src/database/migration/20260914214636_session-execution.ts D packages/core/src/database/migration/20260914222526_session-execution-phase.ts M packages/core/src/database/schema.gen.ts M packages/core/src/session.ts M packages/core/src/session/compaction.ts M packages/core/src/session/context-epoch.ts M packages/core/src/session/execution/local.ts M packages/core/src/session/input.ts M packages/core/src/session/message-updater.ts M packages/core/src/session/projector.ts M packages/core/src/session/recovery.ts M packages/core/src/session/run-coordinator.ts M packages/core/src/session/runner/index.ts M packages/core/src/session/runner/llm.ts M ...
531 48 packages/core/schema.json 1 0 packages/core/src/database/migration.gen.ts 58 0 packages/core/src/database/migration/20260914170650_session-recovery.ts 48 1 packages/core/src/database/schema.gen.ts 5 4 packages/core/src/session.ts 31 16 packages/core/src/session/compaction.ts 54 34 packages/core/src/session/context-epoch.ts 136 19 packages/core/src/session/execution/local.ts 342 31 packages/core/src/session/input.ts 69 0 packages/core/src/session/message-updater.ts 88 1 packages/core/src/session/projector.ts 484 0 packages/core/src/session/recovery.ts 30 5 packages/core/src/session/run-coordinator.ts 4 0 packages/core/src/session/runner/index.ts 272 104 packages/core/src/session/runner/llm.ts 89 37 packages/core/src/session/runner/publish-llm-event.ts 78 1 packages/core/src/session/sql.ts 66 1 packages/core/test/database-migration.test.ts 283 0 packages/core/test/session-execution-local.test.ts 2126 3 packages/core/test/session-projector.test.ts 247 25 packages/core/test/session-...
/tmp/opencode/session-recovery-v9-review.vwleq2
/tmp/opencode/session-recovery-v9-review.vwleq2/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/ui/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/desktop/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/app/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/session-ui/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/stats/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/effect-drizzle-sqlite/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/llm/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/tool/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/app/e2e/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/app/e2e/performance/AGENTS.md /tmp/opencode/session-recovery-v9-review.vwleq2/packages/codemode/AGENTS.md /tmp/opencode/session-...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/AGENTS.md</path> <type>file</type> <content> 1: - To regenerate the legacy JavaScript SDK, run `./packages/sdk/js/script/build.ts`. 2: - After changing the public Protocol or Server `HttpApi`, run `bun run generate` from `packages/client`. Do not edit `src/generated` or `src/generated-effect` directly. 3: - Keep runtime dependencies directed from Schema to Core and Protocol, then from Core and Protocol to Server. Client runtime code may depend on Schema and Protocol but never Core or Server; `sdk-next` composes Client, Core, and Server. 4: - The default branch in this repo is `dev`. 5: - Local `main` ref may not exist; use `dev` or `origin/dev` for diffs. 6: 7: ## Branch Names 8: 9: Use a short branch name of at most three words, separated by hyphens. Do not use slashes or type prefixes such as `feat/` or `fix/`. 10: 11: Examples: `session-recovery`, `fix-scroll-state`, `regenerate-sdk`. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/AGENTS.md</path> <type>file</type> <content> 1: # Schema Package Guide 2: 3: `@opencode-ai/schema` owns browser-safe wire and storage contracts shared by protocol, server, core, and generated SDKs. Keep runtime behavior, service layers, side effects, and host-local implementation details in the domain package that owns them. 4: 5: ## Package Boundary 6: 7: - Preserve the dependency direction: `@opencode-ai/schema <- @opencode-ai/protocol <- @opencode-ai/server`. 8: - Schema values should be serializable contract definitions, not service implementations or runtime registries. 9: - A domain may keep a minimal public wire contract here when SDK generation needs it, but do not move the broader runtime model into Schema just because an event is public. `plugin.added` is the current example: Schema may own the minimum browser-safe event payload, while plugin runtime behavior stays outside Schema. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/opencode/AGENTS.md</path>
<type>file</type>
<content>
1: # opencode database guide
2:
3: ## Database
4:
5: - **Schema**: Drizzle schema lives in `packages/core/src/**/*.sql.ts`.
6: - **Migrations**: database migrations live in `packages/core` and are applied by core.
7:
8: ## Development server
9:
10: - Running `bun dev` from `packages/opencode` starts the live interactive TUI. Do not run it as a blocking foreground command when you need to inspect the result.
11: - Start it in `tmux` instead: `tmux new-session -d -s opencode-dev 'bun dev'`.
12: - Capture the current TUI output with: `tmux capture-pane -pt opencode-dev`.
13: - Stop the session explicitly when done: `tmux kill-session -t opencode-dev`.
14:
15: # Module shape
16:
17: Do not use `export namespace Foo { ... }` for module organization. It is not
18: standard ESM, it prevents tree-shaking, and it breaks Node's native TypeScript
19: runner. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/opencode/src/server/routes/instance/httpapi/AGENTS.md</path>
<type>file</type>
<content>
1: # HttpApi Route Patterns
2:
3: Use `HttpApiBuilder.group(...)` for normal HTTP endpoints, including streaming HTTP responses such as server-sent events. Handlers should yield stable services once while building the handler layer, then close over those services in endpoint implementations.
4:
5: ```ts
6: export const sessionHandlers = HttpApiBuilder.group(InstanceHttpApi, "session", (handlers) =>
7: Effect.gen(function* () {
8: const session = yield* Session.Service
9:
10: return handlers.handle("list", () => session.list())
11: }),
12: )
13: ```
14:
15: For SSE endpoints, stay in `HttpApiBuilder.group(...)` and return `HttpServerResponse.stream(...)` from the handler. Annotate the endpoint success schema with `HttpApiSchema.asText({ contentType: "text/event-stream" })` so OpenAPI documents the stream content type. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/CONTRIBUTING.md</path> <type>file</type> <content> 1: # Contributing to OpenCode 2: 3: We want to make it easy for you to contribute to OpenCode. Here are the most common type of changes that get merged: 4: 5: - Bug fixes 6: - Additional LSPs / Formatters 7: - Improvements to LLM performance 8: - Support for new providers 9: - Fixes for environment-specific quirks 10: - Missing standard behavior 11: - Documentation improvements 12: 13: However, any UI or core product feature must go through a design review with the core team before implementation. 14: 15: If you are unsure if a PR would be accepted, feel free to ask a maintainer or look for issues with any of the following labels: 16: 17: - [`help wanted`](https://github.com/anomalyco/opencode/issues?q=is%3Aissue%20state%3Aopen%20label%3Ahelp-wanted) 18: - [`good first ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/package.json</path>
<type>file</type>
<content>
1: {
2: "$schema": "https://json.schemastore.org/package.json",
3: "version": "1.18.30",
4: "name": "@opencode-ai/core",
5: "type": "module",
6: "license": "MIT",
7: "private": true,
8: "scripts": {
9: "db": "bun drizzle-kit",
10: "migration": "bun run script/migration.ts",
11: "fix-node-pty": "bun run script/fix-node-pty.ts",
12: "test": "bun test --only-failures",
13: "typecheck": "tsgo --noEmit"
14: },
15: "bin": {
16: "opencode": "./bin/opencode"
17: },
18: "exports": {
19: "./effect/layer-node": "./src/effect/layer-node.ts",
20: "./effect/app-node": "./src/effect/app-node.ts",
21: "./session/runner": "./src/session/runner/index.ts",
22: "./system-context": "./src/system-context/index.ts",
23: "./*": "./src/*.ts"
24: },
25: "imports": {
26: "#sqlite": {
27: "bun": ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/package.json</path>
<type>file</type>
<content>
1: {
2: "$schema": "https://json.schemastore.org/package.json",
3: "name": "@opencode-ai/schema",
4: "private": true,
5: "type": "module",
6: "license": "MIT",
7: "exports": {
8: ".": "./src/index.ts",
9: "./*": "./src/*.ts"
10: },
11: "scripts": {
12: "typecheck": "tsgo --noEmit"
13: },
14: "dependencies": {
15: "effect": "catalog:"
16: },
17: "devDependencies": {
18: "@tsconfig/bun": "catalog:",
19: "@types/bun": "catalog:",
20: "@typescript/native-preview": "catalog:"
21: }
22: }
(End of file - total 22 lines)
</content>
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/server/package.json</path>
<type>file</type>
<content>
1: {
2: "$schema": "https://json.schemastore.org/package.json",
3: "name": "@opencode-ai/server",
4: "version": "1.18.30",
5: "private": true,
6: "type": "module",
7: "license": "MIT",
8: "exports": {
9: "./*": "./src/*.ts"
10: },
11: "scripts": {
12: "typecheck": "tsgo --noEmit"
13: },
14: "dependencies": {
15: "@opencode-ai/core": "workspace:*",
16: "@opencode-ai/protocol": "workspace:*",
17: "drizzle-orm": "catalog:",
18: "effect": "catalog:"
19: },
20: "devDependencies": {
21: "@tsconfig/bun": "catalog:",
22: "@types/bun": "catalog:",
23: "@typescript/native-preview": "catalog:"
24: }
25: }
(End of file - total 25 lines)
</content>
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/opencode/package.json</path>
<type>file</type>
<content>
1: {
2: "$schema": "https://json.schemastore.org/package.json",
3: "version": "1.18.30",
4: "name": "opencode",
5: "type": "module",
6: "license": "MIT",
7: "private": true,
8: "scripts": {
9: "typecheck": "tsgo --noEmit",
10: "test": "bun test --timeout 30000 --only-failures",
11: "test:httpapi": "bun run script/httpapi-exercise.ts --mode coverage --fail-on-missing --fail-on-skip && bun run script/httpapi-exercise.ts --mode auth --fail-on-missing --fail-on-skip && bun run script/httpapi-exercise.ts --mode effect --fail-on-missing --fail-on-skip",
12: "bench:test": "bun run script/bench-test-suite.ts",
13: "profile:test": "bun run script/profile-test-files.ts",
14: "build": "bun run script/build.ts",
15: "build:server": "node script/build-server.mjs",
16: "dev": "bun run ./src/index.ts",
17: "dev:temporary": "bun run ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/execution/claim.ts</path>
<type>file</type>
<content>
1: export * as SessionExecutionClaim from "./claim"
2:
3: import { and, eq, gt } from "drizzle-orm"
4: import { Clock, Effect } from "effect"
5: import type { Database } from "../../database/database"
6: import type { SessionSchema } from "../schema"
7: import { SESSION_EXECUTION_LEASE_MS, SessionExecutionTable } from "../sql"
8:
9: type DatabaseService = Database.Interface["db"]
10:
11: export type Claim = {
12: readonly sessionID: SessionSchema.ID
13: readonly executionID: string
14: readonly ownerID: string
15: }
16:
17: export type Values = Partial<Pick<typeof SessionExecutionTable.$inferInsert, "assistant_message_id" | "phase">>
18:
19: export class Lost extends Error {
20: constructor(readonly claim: Claim) {
21: super(`Session execution claim lost: ${claim.executionID}`)
22: }
23: }
24:
25: const where = (claim: Claim, now: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/execution/local.ts</path>
<type>file</type>
<content>
1: import { and, asc, eq, isNull } from "drizzle-orm"
2: import { Cause, Clock, Duration, Effect, Exit, Layer, Schedule } from "effect"
3: import { Database } from "../../database/database"
4: import { LocationServiceMap } from "../../location-service-map"
5: import { makeGlobalNode } from "../../effect/app-node"
6: import { SessionRunCoordinator } from "../run-coordinator"
7: import { SessionRunner } from "../runner"
8: import { SessionMessage } from "../message"
9: import { SessionSchema } from "../schema"
10: import { SessionStore } from "../store"
11: import { SessionExecution } from "../execution"
12: import { SessionExecutionClaim } from "./claim"
13: import { SESSION_EXECUTION_LEASE_MS, SessionExecutionTable, SessionRecoveryTable } from "../sql"
14:
15: /** Current-process routing for implicit-local Locations. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/recovery.ts</path>
<type>file</type>
<content>
1: export * as SessionRecovery from "./recovery"
2:
3: import { and, asc, desc, eq, exists, gt, isNull, lte, or, sql } from "drizzle-orm"
4: import { Clock, DateTime, Effect, Layer, Option, Schedule, Schema } from "effect"
5: import { Database } from "../database/database"
6: import { makeGlobalNode } from "../effect/app-node"
7: import { EventV2 } from "../event"
8: import { SessionEvent } from "./event"
9: import { SessionExecution } from "./execution"
10: import { SessionProjector } from "./projector"
11: import { SessionExecutionClaim } from "./execution/claim"
12: import { SessionInput } from "./input"
13: import { SessionSchema } from "./schema"
14: import {
15: MAX_WAKE_ATTEMPTS,
16: SESSION_EXECUTION_LEASE_MS,
17: SessionExecutionTable,
18: SessionInputTable,
19: SessionRecoveryTable,
20: SessionMessageTable,
21: SessionTable,
22: } from ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/input.ts</path>
<type>file</type>
<content>
1: export * as SessionInput from "./input"
2:
3: import { and, asc, desc, eq, isNull, lte } from "drizzle-orm"
4: import { DateTime, Effect, Option, Schema } from "effect"
5: import { Admitted, Delivery } from "@opencode-ai/schema/session-input"
6: import type { Database } from "../database/database"
7: import { EventV2 } from "../event"
8: import { SessionEvent } from "./event"
9: import { SessionMessage } from "./message"
10: import { Prompt } from "./prompt"
11: import { continuation, message } from "./recovery-id"
12: import { SessionSchema } from "./schema"
13: import { SessionInputTable, SessionMessageTable, SessionRecoveryTable } from "./sql"
14:
15: type DatabaseService = Database.Interface["db"]
16:
17: export { Admitted, Delivery }
18:
19: const decodePrompt = Schema.decodeUnknownSync(Prompt)
20: const encodePrompt = Schema.encodeSync(Prompt)
21: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/recovery-id.ts</path>
<type>file</type>
<content>
1: import { SessionMessage } from "./message"
2:
3: export const message = (executionID: string, assistantMessageID?: SessionMessage.ID) =>
4: assistantMessageID ?? SessionMessage.ID.make(`msg_recovery_${executionID}`)
5:
6: export const continuation = (executionID: string) => SessionMessage.ID.make(`msg_recovery_continue_${executionID}`)
(End of file - total 6 lines)
</content>
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/src/session-event.ts</path>
<type>file</type>
<content>
1: export * as SessionEvent from "./session-event"
2:
3: import { Schema } from "effect"
4: import { optional } from "./schema"
5: import { Event } from "./event"
6: import { ProviderMetadata, ToolContent } from "./llm"
7: import { Delivery } from "./session-delivery"
8: import { Model } from "./model"
9: import { DateTimeUtcFromMillis, NonNegativeInt, RelativePath } from "./schema"
10: import { FileAttachment, Prompt } from "./prompt"
11: import { SessionID } from "./session-id"
12: import { Location } from "./location"
13: import { SessionMessage } from "./session-message"
14: import { Revert } from "./revert"
15:
16: export { FileAttachment }
17:
18: export const Source = Schema.Struct({
19: start: NonNegativeInt,
20: end: NonNegativeInt,
21: text: Schema.String,
22: }).annotate({
23: identifier: "session.next.event.source",
24: })
25: export ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/projector.ts</path>
<type>file</type>
<content>
1: export * as SessionProjector from "./projector"
2:
3: import { and, desc, eq, gt, or, sql } from "drizzle-orm"
4: import { DateTime, Effect, Layer, Schema } from "effect"
5: import { Database } from "../database/database"
6: import { EventV2 } from "../event"
7: import { makeGlobalNode } from "../effect/app-node"
8: import { SessionEvent } from "./event"
9: import { SessionV1 } from "../v1/session"
10: import { WorkspaceTable } from "../control-plane/workspace.sql"
11: import { SessionMessage } from "./message"
12: import { SessionMessageUpdater } from "./message-updater"
13: import { SessionInput } from "./input"
14: import { Prompt } from "./prompt"
15: import { continuation } from "./recovery-id"
16: import { WorkspaceV2 } from "../workspace"
17: import {
18: MessageTable,
19: PartTable,
20: SessionInputTable,
21: SessionMessageTable,
22: ...
No files found
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/event.ts
Found 25 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/event.ts:
Line 122: /** Local operational projection committed atomically with a new durable event. Not replayed or serialized. */
Line 127: readonly publish: <D extends Definition>(
Line 137: readonly project: <D extends Definition>(definition: D, projector: Subscriber<D>) => Effect.Effect<void>
Line 140: options?: { readonly publish?: boolean; readonly ownerID?: string; readonly strictOwner?: boolean },
Line 144: options?: { readonly publish?: boolean; readonly ownerID?: string; readonly strictOwner?: boolean },
Line 179: const projectors = new Map<string, Subscriber[]>()
Line 180: // TODO: Bind durable projectors to exact type+version before supporting incompatible historical payloads.
Line 236: const list = projectors.get(event.type) ?? ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/event.ts</path>
<type>file</type>
<content>
100: },
101: data: event.data,
102: }),
103: )
104: return {
105: events,
106: hasMore: rows.length > input.limit,
107: }
108: })
109:
110: export class SubscriberOverflowError extends Schema.TaggedErrorClass<SubscriberOverflowError>()(
111: "EventV2.SubscriberOverflow",
112: { capacity: Schema.Int },
113: ) {}
114:
115: export const define = Event.define
116: export const versionedType = Event.versionedType
117:
118: export interface PublishOptions {
119: readonly id?: ID
120: readonly metadata?: Record<string, unknown>
121: readonly location?: Location.Ref
122: /** Local operational projection committed atomically with a new durable event. Not replayed or serialized. */
123: readonly commit?: (seq: number) => Effect.Effect<void>
124: }
125:
126: export interface Interface {
127: readonly publish: <D extends ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/runner/index.ts</path>
<type>file</type>
<content>
1: export * as SessionRunner from "./index"
2:
3: import type { LLMError } from "@opencode-ai/llm"
4: import { Context, Effect } from "effect"
5: import { SessionSchema } from "../schema"
6: import type { SessionMessage } from "../message"
7: import type { ContextSnapshotDecodeError, MessageDecodeError } from "../error"
8: import { SessionRunnerModel } from "./model"
9: import type { SystemContext } from "../../system-context/index"
10: import type { ToolOutputStore } from "../../tool-output-store"
11:
12: export type RunError =
13: | LLMError
14: | SessionRunnerModel.Error
15: | MessageDecodeError
16: | ContextSnapshotDecodeError
17: | SystemContext.InitializationBlocked
18: | ToolOutputStore.Error
19:
20: /** Runs one local continuation from already-recorded Session history. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/runner/llm.ts</path>
<type>file</type>
<content>
1: import {
2: LLM,
3: LLMClient,
4: LLMError,
5: LLMEvent,
6: Message,
7: SystemPart,
8: isContextOverflowFailure,
9: type ProviderErrorEvent,
10: } from "@opencode-ai/llm"
11: import { Cause, DateTime, Effect, Exit, Fiber, Layer, Option, Semaphore, Stream } from "effect"
12: import { and, eq } from "drizzle-orm"
13: import { AgentV2 } from "../../agent"
14: import { Config } from "../../config"
15: import { Database } from "../../database/database"
16: import { EventV2 } from "../../event"
17: import { Location } from "../../location"
18: import { ModelV2 } from "../../model"
19: import { PermissionV2 } from "../../permission"
20: import { ProviderV2 } from "../../provider"
21: import { QuestionV2 } from "../../question"
22: import { SystemContext } from "../../system-context/index"
23: import { SystemContextRegistry } from ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/run-coordinator.ts</path>
<type>file</type>
<content>
1: export * as SessionRunCoordinator from "./run-coordinator"
2:
3: import { Deferred, Effect, Exit, Fiber, FiberSet, Scope } from "effect"
4:
5: /** Serializes execution for each key while allowing different keys to run concurrently. */
6: export interface Coordinator<Key, E> {
7: /** Snapshots keys with an execution owned by this coordinator. */
8: readonly active: Effect.Effect<ReadonlySet<Key>>
9: /** Starts execution while idle or joins the active execution. */
10: readonly run: (key: Key) => Effect.Effect<void, E>
11: /** Registers one coalesced follow-up after newly recorded work. */
12: readonly wake: (key: Key) => Effect.Effect<void>
13: /** Stops active execution, runs cleanup, then starts work that arrived while stopping. */
14: readonly interrupt: (key: Key, cleanup?: Effect.Effect<void>) => Effect.Effect<void>
15: }
16: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/sql.ts</path>
<type>file</type>
<content>
1: import { sql } from "drizzle-orm"
2: import { check, sqliteTable, text, integer, index, primaryKey, real, uniqueIndex } from "drizzle-orm/sqlite-core"
3: import * as DatabasePath from "../database/path"
4: import { ProjectTable } from "../project/sql"
5: import type { SessionMessage } from "./message"
6: import type { Prompt } from "./prompt"
7: import type { SessionInput } from "./input"
8: import type { Snapshot } from "../snapshot"
9: import { PermissionV1 } from "../v1/permission"
10: import { ProjectV2 } from "../project"
11: import type { SessionSchema } from "./schema"
12: import type { MessageID, PartID, SessionV1 } from "../v1/session"
13: import { WorkspaceV2 } from "../workspace"
14: import { Timestamps } from "../database/schema.sql"
15: import type { SystemContext } from "../system-context/index"
16: import { AgentV2 } from "../agent"
17: import ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/runner/publish-llm-event.ts</path>
<type>file</type>
<content>
1: import { ToolOutput, type LLMEvent, type ProviderMetadata, type ToolResultValue, type Usage } from "@opencode-ai/llm"
2: import { DateTime, Effect } from "effect"
3: import { EventV2 } from "../../event"
4: import { ModelV2 } from "../../model"
5: import { SessionEvent } from "../event"
6: import { SessionMessage } from "../message"
7: import { SessionSchema } from "../schema"
8:
9: type Input = {
10: readonly sessionID: SessionSchema.ID
11: readonly agent: string
12: readonly model: ModelV2.Ref
13: readonly snapshot?: string
14: readonly startCommit: (assistantMessageID: SessionMessage.ID) => Effect.Effect<void>
15: readonly eventCommit: () => Effect.Effect<void>
16: }
17:
18: const safe = (value: number | undefined) => Math.max(0, Number.isFinite(value) ? (value ?? ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/compaction.ts</path>
<type>file</type>
<content>
1: export * as SessionCompaction from "./compaction"
2:
3: import { LLM, LLMError, LLMEvent, Message, type LLMRequest, type Model } from "@opencode-ai/llm"
4: import { DateTime, Effect, Stream } from "effect"
5: import type { Config } from "../config"
6: import type { EventV2 } from "../event"
7: import { SessionEvent } from "./event"
8: import { SessionMessage } from "./message"
9: import { SessionSchema } from "./schema"
10: import { Token } from "../util/token"
11:
12: const DEFAULT_BUFFER = 20_000
13: const DEFAULT_KEEP_TOKENS = 8_000
14: const TOOL_OUTPUT_MAX_CHARS = 2_000
15: const SUMMARY_OUTPUT_TOKENS = 4_096
16: const SUMMARY_TEMPLATE = `Output exactly the Markdown structure shown inside <template> and keep the section order unchanged. Do not include the <template> tags in your response. ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/context-epoch.ts</path>
<type>file</type>
<content>
1: export * as SessionContextEpoch from "./context-epoch"
2:
3: import { eq } from "drizzle-orm"
4: import { DateTime, Effect, Schema } from "effect"
5: import type { Database } from "../database/database"
6: import { EventV2 } from "../event"
7: import { SystemContext } from "../system-context/index"
8: import { ContextSnapshotDecodeError } from "./error"
9: import { SessionEvent } from "./event"
10: import { SessionHistory } from "./history"
11: import { SessionInput } from "./input"
12: import { SessionMessage } from "./message"
13: import { SessionSchema } from "./schema"
14: import { SessionContextEpochTable } from "./sql"
15: import { SessionExecutionClaim } from "./execution/claim"
16:
17: type DatabaseService = Database.Interface["db"]
18:
19: interface Prepared {
20: readonly baseline: string
21: readonly baselineSeq: number
22: }
23:
24: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/message-updater.ts</path>
<type>file</type>
<content>
1: import { castDraft, produce, type WritableDraft } from "immer"
2: import { Effect } from "effect"
3: import { SessionEvent } from "./event"
4: import { SessionMessage } from "./message"
5: import { message } from "./recovery-id"
6:
7: export type MemoryState = {
8: messages: SessionMessage.Message[]
9: }
10:
11: export interface Adapter {
12: readonly getCurrentAssistant: () => Effect.Effect<SessionMessage.Assistant | undefined>
13: readonly getAssistant: (messageID: SessionMessage.ID) => Effect.Effect<SessionMessage.Assistant | undefined>
14: readonly getCurrentShell: (callID: string) => Effect.Effect<SessionMessage.Shell | undefined>
15: readonly updateAssistant: (assistant: SessionMessage.Assistant) => Effect.Effect<void>
16: readonly updateShell: (shell: SessionMessage.Shell) => Effect.Effect<void>
17: readonly appendMessage: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/database/migration/20260914170650_session-recovery.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "../migration"
3:
4: export default {
5: id: "20260914170650_session-recovery",
6: up(tx) {
7: return Effect.gen(function* () {
8: yield* tx.run(`ALTER TABLE \`session_input\` ADD \`wake_pending\` integer DEFAULT false NOT NULL;`)
9: yield* tx.run(
10: `ALTER TABLE \`session\` ADD \`wake_attempts\` integer DEFAULT 0 NOT NULL CONSTRAINT \`session_wake_attempts_check\` CHECK(\`wake_attempts\` >= 0 AND \`wake_attempts\` <= 9007199254740991);`,
11: )
12: yield* tx.run(`
13: CREATE TABLE \`session_execution\` (
14: \`id\` text NOT NULL,
15: \`session_id\` text NOT NULL,
16: \`owner_id\` text NOT NULL,
17: \`assistant_message_id\` text,
18: \`phase\` text NOT ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/database/migration.gen.ts</path>
<type>file</type>
<content>
1: import type { DatabaseMigration } from "./migration"
2:
3: export const migrations = (
4: await Promise.all([
5: import("./migration/20260127222353_familiar_lady_ursula"),
6: import("./migration/20260211171708_add_project_commands"),
7: import("./migration/20260213144116_wakeful_the_professor"),
8: import("./migration/20260225215848_workspace"),
9: import("./migration/20260227213759_add_session_workspace_id"),
10: import("./migration/20260228203230_blue_harpoon"),
11: import("./migration/20260303231226_add_workspace_fields"),
12: import("./migration/20260309230000_move_org_to_state"),
13: import("./migration/20260312043431_session_message_cursor"),
14: import("./migration/20260323234822_events"),
15: import("./migration/20260410174513_workspace-name"),
16: ...
Found 20 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/database/schema.gen.ts:
Line 158: CREATE TABLE \`session_execution\` (
Line 167: CONSTRAINT \`session_execution_pk\` PRIMARY KEY(\`id\`),
Line 168: CONSTRAINT \`fk_session_execution_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE,
Line 169: CONSTRAINT "session_execution_phase_check" CHECK("phase" IN ('ready', 'safe', 'unknown', 'continue', 'cancelling'))
Line 180: \`wake_pending\` integer DEFAULT false NOT NULL,
Line 198: CREATE TABLE \`session_recovery\` (
Line 204: \`wake_pending\` integer DEFAULT true NOT NULL,
Line 205: \`wake_attempts\` integer DEFAULT 0 NOT NULL,
Line 208: CONSTRAINT \`session_recovery_pk\` PRIMARY KEY(\`execution_id\`),
Line 209: CONSTRAINT \`fk_session_recovery_session_id_session_id_fk\` FOREIGN KEY ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/database/schema.gen.ts</path> <type>file</type> <content> 145: CONSTRAINT \`fk_part_message_id_message_id_fk\` FOREIGN KEY (\`message_id\`) REFERENCES \`message\`(\`id\`) ON DELETE CASCADE 146: ); 147: `) 148: yield* tx.run(` 149: CREATE TABLE \`session_context_epoch\` ( 150: \`session_id\` text PRIMARY KEY, 151: \`baseline\` text NOT NULL, 152: \`snapshot\` text NOT NULL, 153: \`baseline_seq\` integer NOT NULL, 154: CONSTRAINT \`fk_session_context_epoch_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE 155: ); 156: `) 157: yield* tx.run(` 158: CREATE TABLE \`session_execution\` ( 159: \`id\` text NOT NULL, 160: \`session_id\` text NOT NULL, 161: \`owner_id\` text NOT NULL, 162: \`assistant_message_id\` ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session.ts</path>
<type>file</type>
<content>
1: export * as SessionV2 from "./session"
2: export * from "./session/schema"
3:
4: import { DateTime, Effect, Layer, Schema, Context, Stream } from "effect"
5: import { ListAnchor } from "@opencode-ai/schema/session"
6: import { and, asc, desc, eq, gt, like, lt, or, type SQL } from "drizzle-orm"
7: import { ProjectV2 } from "./project"
8: import { WorkspaceV2 } from "./workspace"
9: import { ModelV2 } from "./model"
10: import { Location } from "./location"
11: import { SessionMessage } from "./session/message"
12: import { Prompt } from "./session/prompt"
13: import { PromptInput } from "@opencode-ai/schema/prompt-input"
14: import { EventV2 } from "./event"
15: import { Database } from "./database/database"
16: import { SessionProjector } from "./session/projector"
17: import { SessionMessageTable, SessionTable } from "./session/sql"
18: import { SessionSchema } ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session.ts</path>
<type>file</type>
<content>
340: return stored?.sessionID === input.sessionID ? stored.message : undefined
341: }),
342: context: Effect.fn("V2Session.context")(function* (sessionID) {
343: yield* result.get(sessionID)
344: return yield* store.context(sessionID)
345: }),
346: events: (input) =>
347: Stream.unwrap(
348: result
349: .get(input.sessionID)
350: .pipe(Effect.as(events.durable({ aggregateID: input.sessionID, after: input.after }))),
351: ).pipe(Stream.filter((event): event is SessionEvent.DurableEvent => isDurableSessionEvent(event))),
352: history: Effect.fn("V2Session.history")(function* (input) {
353: yield* result.get(input.sessionID)
354: return yield* EventV2.readAggregate(db, {
355: ...input,
356: aggregateID: input.sessionID,
357: ...
Found 1 matches /tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-runner.test.ts: Line 452: delta: SessionEvent.Text.Delta,
Found 37 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-runner.test.ts:
Line 249: run: (claim, force, recoveryInputID) =>
Line 250: sessionRunner.run({ ...claim, force, recoveryInputID }).pipe(
Line 322: owner_id: "test",
Line 331: owner_id: "test",
Line 587: const fiber = yield* runner.run({ sessionID, force: true, executionID, ownerID: "test" }).pipe(Effect.forkChild)
Line 752: it.effect("never dispatches a provider after ownership changes", () =>
Line 767: .set({ id: "provider-successor", owner_id: "successor", expires_at: 60_000 })
Line 778: it.effect("never publishes streamed output after ownership changes", () =>
Line 785: response = fragmentFixture("text", "text-fenced", ["stale output"]).completeEvents
Line 793: .set({ id: "publication-successor", owner_id: "successor", expires_at: 60_000 })
Line 805: it.effect("never starts a local tool after ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
720: const { db } = yield* Database.Service
721: const { admitted: message } = yield* SessionInput.admit(db, events, {
722: id: SessionMessage.ID.make("msg_lost_prompt_wake"),
723: sessionID,
724: prompt: Prompt.make({ text: "run after restart" }),
725: delivery: "steer",
726: requestExecution: true,
727: })
728: response = [
729: LLMEvent.stepStart({ index: 0 }),
730: LLMEvent.stepFinish({ index: 0, reason: "stop" }),
731: LLMEvent.finish({ reason: "stop" }),
732: ]
733: requests.length = 0
734:
735: yield* SessionRecovery.recover()
736: while (requests.length === 0) yield* Effect.yieldNow
737: const executionService = yield* SessionExecution.Service
738: while ((yield* executionService.active).size > 0) yield* Effect.yieldNow
739: ...
Found 29 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-projector.test.ts:
Line 28: MAX_WAKE_ATTEMPTS,
Line 160: yield* events.replayAll(
Line 173: const replayedContinuation = yield* db
Line 178: if (!replayedContinuation) return yield* Effect.die("Replayed recovery continuation not found")
Line 199: yield* events.replayAll(
Line 441: it.effect("quarantines a malformed recovery row without blocking a valid wake", () =>
Line 495: it.effect("quarantines a full batch of poison recovery rows before redriving valid work", () =>
Line 560: it.effect("fairly redrives recovery and ordinary work beyond a full bounded batch", () =>
Line 696: it.effect("rejects invalid persisted wake attempt counters", () =>
Line 730: .run(sql`UPDATE session_recovery SET wake_attempts = ${MAX_WAKE_ATTEMPTS + 1}`)
Line 880: it.effect("quarantines a continuation that belongs to another Session", () ...
Found 16 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-execution-local.test.ts:
Line 82: it.effect("never starts a second owner while the lease is live", () =>
Line 105: it.effect("never overwrites an expired lease", () =>
Line 132: it.effect("never re-enters its own uncertain live lease", () =>
Line 159: it.effect("renews heartbeat expiry from the current clock", () =>
Line 182: it.effect("never revives an expired claim on heartbeat", () =>
Line 200: it.effect("settles cancellation before starting a pending successor", () =>
Line 204: const finalizerStarted = Deferred.makeUnsafe<void>()
Line 206: const successorStarted = Deferred.makeUnsafe<void>()
Line 214: : Deferred.succeed(successorStarted, undefined),
Line 219: ? Deferred.succeed(finalizerStarted, undefined).pipe(Effect.andThen(Deferred.await(releaseFinalizer)))
Line 228: yield* ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-execution-local.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect } from "bun:test"
2: import { Deferred, Effect, Exit, Fiber, Scope } from "effect"
3: import { TestClock } from "effect/testing"
4: import { eq } from "drizzle-orm"
5: import { Database } from "@opencode-ai/core/database/database"
6: import { Project } from "@opencode-ai/core/project"
7: import { ProjectTable } from "@opencode-ai/core/project/sql"
8: import { AbsolutePath } from "@opencode-ai/core/schema"
9: import { SessionExecutionLocal } from "@opencode-ai/core/session/execution/local"
10: import { SessionSchema } from "@opencode-ai/core/session/schema"
11: import { SessionExecutionTable, SessionTable } from "@opencode-ai/core/session/sql"
12: import { testEffect } from "./lib/effect"
13:
14: const sessionID = SessionSchema.ID.make("ses_execution_local")
15: const it = ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
1540: promoted_seq: expect.any(Number),
1541: })
1542: }),
1543: )
1544:
1545: it.effect("quarantines a malformed claim without blocking a valid claim", () =>
1546: Effect.gen(function* () {
1547: const { db } = yield* Database.Service
1548: const validSession = SessionV2.ID.make("ses_recovery_valid")
1549: yield* db
1550: .insert(ProjectTable)
1551: .values({ id: Project.ID.global, worktree: AbsolutePath.make("/project"), sandboxes: [] })
1552: .run()
1553: yield* db
1554: .insert(SessionTable)
1555: .values(
1556: [sessionID, validSession].map((id) => ({
1557: id,
1558: project_id: Project.ID.global,
1559: slug: id,
1560: directory: "/project",
1561: title: "test",
1562: version: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect } from "bun:test"
2: import { DateTime, Deferred, Effect, Exit, Fiber, Schema } from "effect"
3: import { TestClock } from "effect/testing"
4: import { asc, eq, sql } from "drizzle-orm"
5: import { Database } from "@opencode-ai/core/database/database"
6: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
7: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
8: import { EventV2 } from "@opencode-ai/core/event"
9: import { EventTable } from "@opencode-ai/core/event/sql"
10: import { ModelV2 } from "@opencode-ai/core/model"
11: import { Project } from "@opencode-ai/core/project"
12: import { ProjectTable } from "@opencode-ai/core/project/sql"
13: import { ProviderV2 } from "@opencode-ai/core/provider"
14: import { AbsolutePath } from "@opencode-ai/core/schema"
15: import { SessionV2 } from ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/server/src/routes.ts</path>
<type>file</type>
<content>
1: import { Database } from "@opencode-ai/core/database/database"
2: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
3: import { httpClient } from "@opencode-ai/core/effect/app-node-platform"
4: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
5: import { EventV2 } from "@opencode-ai/core/event"
6: import { Credential } from "@opencode-ai/core/credential"
7: import { PermissionSaved } from "@opencode-ai/core/permission/saved"
8: import { PtyTicket } from "@opencode-ai/core/pty/ticket"
9: import { SessionV2 } from "@opencode-ai/core/session"
10: import { SessionExecution } from "@opencode-ai/core/session/execution"
11: import { LocationServiceMap } from "@opencode-ai/core/location-service-map"
12: import { SessionExecutionLocal } from "@opencode-ai/core/session/execution/local"
13: import { SessionRecovery } from ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/opencode/src/server/routes/instance/httpapi/server.ts</path>
<type>file</type>
<content>
1: import { Config as EffectConfig, Context, Effect, Layer } from "effect"
2: import { HttpApiBuilder, OpenApi } from "effect/unstable/httpapi"
3: import { HttpClient, HttpMiddleware, HttpRouter, HttpServer, HttpServerResponse } from "effect/unstable/http"
4: import * as Socket from "effect/unstable/socket/Socket"
5: import { FSUtil } from "@opencode-ai/core/fs-util"
6: import * as Observability from "@opencode-ai/core/observability"
7: import { Account } from "@/account/account"
8: import { Agent } from "@/agent/agent"
9: import { Auth } from "@/auth"
10: import { BackgroundJob } from "@/background/job"
11: import { Command } from "@/command"
12: import { Config } from "@/config/config"
13: import { Workspace } from "@/control-plane/workspace"
14: import { Env } from "@/env"
15: import { EventV2Bridge } from "@/event-v2-bridge"
16: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/opencode/src/server/routes/instance/httpapi/server.ts</path>
<type>file</type>
<content>
260: Worktree.node,
261: Installation.node,
262: ShareNext.node,
263: SessionShare.node,
264: InstanceStore.node,
265: httpClient,
266: EventV2.node,
267: ProjectV2.node,
268: ProjectCopy.node,
269: PtyTicket.node,
270: ])
271:
272: export function createRoutes(
273: corsOptions?: CorsOptions,
274: ): Layer.Layer<never, EffectConfig.ConfigError, RouteRequirements> {
275: const locationServiceMapV2 = buildLocationServiceMap()
276:
277: return Layer.mergeAll(
278: rootApiRoutes,
279: eventApiRoutes,
280: ptyConnectApiRoutes,
281: instanceRoutes,
282: serverRoutes,
283: docRoute,
284: uiRoute,
285: ).pipe(
286: Layer.provide([
287: errorLayer,
288: compressionLayer,
289: corsVaryFix,
290: fenceLayer,
291: cors(corsOptions),
292: ...
9737 /tmp/opencode/session-recovery-final-v9.patch
Found 15 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/sdk/js/src/v2/gen/types.gen.ts:
Line 24: | EventSessionNextPromptExecutionRequested
Line 874: requestExecution?: boolean
Line 983: type: "session.next.step.recovered"
Line 1650: | SyncEventSessionNextPromptExecutionRequested
Line 2785: | SessionNextPromptExecutionRequested
Line 2915: | SessionNextPromptExecutionRequested
Line 3430: requestExecution?: boolean
Line 3435: export type SyncEventSessionNextPromptExecutionRequested = {
Line 3606: type: "session.next.step.recovered.1"
Line 4362: requestExecution?: boolean
Line 4366: export type SessionNextPromptExecutionRequested = {
Line 4565: type: "session.next.step.recovered"
Line 6464: requestExecution?: boolean
Line 6468: export type EventSessionNextPromptExecutionRequested = {
Line 6583: type: "session.next.step.recovered"
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/sdk/js/src/v2/gen/types.gen.ts</path>
<type>file</type>
<content>
850: location: LocationRef
851: subdirectory?: string
852: }
853: }
854: | {
855: id: string
856: type: "session.next.prompted"
857: properties: {
858: timestamp: number
859: sessionID: string
860: messageID: string
861: prompt: Prompt
862: delivery: "steer" | "queue"
863: }
864: }
865: | {
866: id: string
867: type: "session.next.prompt.admitted"
868: properties: {
869: timestamp: number
870: sessionID: string
871: messageID: string
872: prompt: Prompt
873: delivery: "steer" | "queue"
874: requestExecution?: boolean
875: }
876: }
877: | {
878: id: string
879: type: "session.next.prompt.execution_requested"
880: ...
Found 55 matches /tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/schema.json: Line 66: "name": "session_execution", Line 78: "name": "session_recovery", Line 941: "table": "session_execution" Line 951: "table": "session_execution" Line 961: "table": "session_execution" Line 971: "table": "session_execution" Line 981: "table": "session_execution" Line 991: "table": "session_execution" Line 1001: "table": "session_execution" Line 1011: "table": "session_execution" Line 1079: "name": "wake_pending", Line 1171: "table": "session_recovery" Line 1181: "table": "session_recovery" Line 1191: "table": "session_recovery" Line 1201: "table": "session_recovery" Line 1211: "table": "session_recovery" Line 1219: "name": "wake_pending", Line 1221: "table": "session_recovery" Line 1229: "name": "wake_attempts", Line ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/schema.json</path>
<type>file</type>
<content>
40: },
41: {
42: "name": "permission",
43: "entityType": "tables"
44: },
45: {
46: "name": "project_directory",
47: "entityType": "tables"
48: },
49: {
50: "name": "project",
51: "entityType": "tables"
52: },
53: {
54: "name": "message",
55: "entityType": "tables"
56: },
57: {
58: "name": "part",
59: "entityType": "tables"
60: },
61: {
62: "name": "session_context_epoch",
63: "entityType": "tables"
64: },
65: {
66: "name": "session_execution",
67: "entityType": "tables"
68: },
69: {
70: "name": "session_input",
71: "entityType": "tables"
72: },
73: {
74: "name": "session_message",
75: "entityType": "tables"
76: },
77: {
78: "name": "session_recovery",
79: "entityType": ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/database-migration.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect, test } from "bun:test"
2: import { $ } from "bun"
3: import { fileURLToPath } from "url"
4: import path from "path"
5: import { SqliteClient } from "@effect/sql-sqlite-bun"
6: import { EffectDrizzleSqlite } from "@opencode-ai/effect-drizzle-sqlite"
7: import { Effect, Exit, Layer } from "effect"
8: import { eq, inArray, sql } from "drizzle-orm"
9: import { DatabaseMigration } from "@opencode-ai/core/database/migration"
10: import { migrations } from "@opencode-ai/core/database/migration.gen"
11: import workspaceNameMigration from "@opencode-ai/core/database/migration/20260410174513_workspace-name"
12: import sessionUsageMigration from "@opencode-ai/core/database/migration/20260510033149_session_usage"
13: import normalizeStoragePathsMigration from ...
exit=128 fatal: path 'packages/core/src/database/migration/20260914170650_session-recovery.ts' exists on disk, but not in 'ab9408c81cc9916177641ae8e9f08624fc27b5b9'
Found 29 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-prompt.test.ts:
Line 140: it.effect("exposes the execution registry", () =>
Line 147: it.effect("delegates execution continuation through SessionExecution", () =>
Line 159: it.effect("delegates process-local interruption through SessionExecution", () =>
Line 171: it.effect("delegates interruption without requiring a recorded Session", () =>
Line 181: it.effect("durably admits one user message before transcript promotion", () =>
Line 203: it.effect("resolves attachment MIME before admission", () =>
Line 224: it.effect("streams durable Session events after an aggregate sequence", () =>
Line 254: it.effect("resumes through a recorded message without appending another prompt", () =>
Line 275: it.effect("records distinct messages when the ID is omitted", () =>
Line 290: it.effect("returns the original recorded message when the ID is retried", () =>
...
Found 17 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-run-coordinator.test.ts:
Line 9: it.effect("joins concurrent resumes for one key", () =>
Line 31: it.effect("joins a wake-started execution without forcing a successor", () =>
Line 57: it.effect("starts execution when woken while idle", () =>
Line 69: it.effect("snapshots only active executions", () =>
Line 102: it.effect("cleans active executions after failure and defect", () =>
Line 122: it.effect("cleans active executions when its scope closes", () =>
Line 141: it.effect("coalesces wakes received during active execution", () =>
Line 173: it.effect("runs again when woken during the follow-up", () =>
Line 209: it.effect("does nothing when interrupted while idle", () =>
Line 218: it.effect("interrupts active execution and clears its pending wake", () =>
Line 247: it.effect("runs a wake registered during interruption cleanup", () =>
Line ...
Found 5 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-runner-tool-events.test.ts:
Line 92: test("local tool success serializes media base64 once and reconstructs from structured content", async () => {
Line 115: test("provider-executed success retains its compatibility result", async () => {
Line 123: test("binary failure emits no success event", async () => {
Line 139: test("old success event data containing result still decodes", () => {
Line 168: test("step finish records settlement without publishing step ended", async () => {
Found 1 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/test/session-runner-recorded.test.ts:
Line 132: it.effect("executes one recorded V2 prompt through the recorded HTTP transport", () =>
Found 2 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/test/event-manifest.test.ts:
Line 11: test("owns the complete public event surface", () => {
Line 30: test("uses canonical definitions for current public events", () => {
Found 33 matches /tmp/opencode/session-recovery-final-v9.patch: Line 1: diff --git a/packages/core/schema.json b/packages/core/schema.json Line 881: diff --git a/packages/core/src/database/migration.gen.ts b/packages/core/src/database/migration.gen.ts Line 892: diff --git a/packages/core/src/database/migration/20260914170650_session-recovery.ts b/packages/core/src/database/migration/20260914170650_session-recovery.ts Line 956: diff --git a/packages/core/src/database/schema.gen.ts b/packages/core/src/database/schema.gen.ts Line 1058: diff --git a/packages/core/src/session.ts b/packages/core/src/session.ts Line 1090: diff --git a/packages/core/src/session/compaction.ts b/packages/core/src/session/compaction.ts Line 1179: diff --git a/packages/core/src/session/context-epoch.ts b/packages/core/src/session/context-epoch.ts Line 1355: diff --git a/packages/core/src/session/execution/local.ts b/packages/core/src/session/execution/local.ts Line 1542: diff --git ...
<path>/tmp/opencode/session-recovery-final-v9.patch</path>
<type>file</type>
<content>
3881: diff --git a/packages/core/test/database-migration.test.ts b/packages/core/test/database-migration.test.ts
3882: index 464ce2695a..9814b75a11 100644
3883: --- a/packages/core/test/database-migration.test.ts
3884: +++ b/packages/core/test/database-migration.test.ts
3885: @@ -4,7 +4,7 @@ import { fileURLToPath } from "url"
3886: import path from "path"
3887: import { SqliteClient } from "@effect/sql-sqlite-bun"
3888: import { EffectDrizzleSqlite } from "@opencode-ai/effect-drizzle-sqlite"
3889: -import { Effect, Layer } from "effect"
3890: +import { Effect, Exit, Layer } from "effect"
3891: import { eq, inArray, sql } from "drizzle-orm"
3892: import { DatabaseMigration } from "@opencode-ai/core/database/migration"
3893: import { migrations } from "@opencode-ai/core/database/migration.gen"
3894: @@ -16,6 +16,7 @@ import eventSourcedSessionInputMigration from ...
<path>/tmp/opencode/session-recovery-final-v9.patch</path>
<type>file</type>
<content>
5211: + expect(wakes).toBe(2)
5212: + expect(yield* db.select().from(SessionInputTable).all()).toEqual([
5213: + expect.objectContaining({ wake_pending: true, promoted_seq: null }),
5214: + ])
5215: + }),
5216: + )
5217: +
5218: + it.effect("redrives ordinary input without recovering a claim that crashed before promotion", () =>
5219: + Effect.gen(function* () {
5220: + const { db } = yield* Database.Service
5221: + const events = yield* EventV2.Service
5222: + yield* db
5223: + .insert(ProjectTable)
5224: + .values({ id: Project.ID.global, worktree: AbsolutePath.make("/project"), sandboxes: [] })
5225: + .run()
5226: + yield* db
5227: + .insert(SessionTable)
5228: + .values({
5229: + id: sessionID,
5230: + project_id: Project.ID.global,
5231: + slug: "test",
5232: + directory: ...
<path>/tmp/opencode/session-recovery-final-v9.patch</path>
<type>file</type>
<content>
6644: + expect(yield* db.select().from(SessionInputTable).where(eq(SessionInputTable.id, messageID)).get()).toMatchObject(
6645: + {
6646: + wake_pending: true,
6647: + },
6648: + )
6649: + yield* replaySessionProjection()
6650: + expect(yield* db.select().from(SessionInputTable).where(eq(SessionInputTable.id, messageID)).get()).toMatchObject(
6651: + {
6652: + wake_pending: true,
6653: + },
6654: + )
6655: + yield* recover()
6656: + expect(wakeCalls).toEqual([sessionID])
6657: + }),
6658: + )
6659: +
6660: it.effect("rejects reuse of one ID with a different prompt", () =>
6661: Effect.gen(function* () {
6662: yield* setup
6663: @@ -314,6 +511,48 @@ describe("SessionV2.prompt", () => {
6664: }),
6665: )
6666:
6667: + it.effect("never arms durable wake for a conflicting execution retry", () ...
<path>/tmp/opencode/session-recovery-final-v9.patch</path>
<type>file</type>
<content>
7921: + const run = yield* session.resume(sessionID).pipe(Effect.exit, Effect.forkChild)
7922: + const started = yield* Deferred.await(finalizerStarted).pipe(Effect.timeout("1 second"), Effect.exit)
7923: + if (Exit.isFailure(started)) {
7924: + yield* Deferred.succeed(releaseFinalizer, undefined)
7925: + return yield* started
7926: + }
7927: +
7928: + const retained = yield* db.select().from(SessionExecutionTable).get()
7929: + const replacement = yield* db
7930: + .insert(SessionExecutionTable)
7931: + .values({
7932: + id: "replacement-during-decline-finalizer",
7933: + session_id: sessionID,
7934: + owner_id: "replacement",
7935: + phase: "ready",
7936: + time_created: 0,
7937: + expires_at: 60_000,
7938: + })
7939: + .onConflictDoNothing()
7940: + .returning({ id: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/test/event-manifest.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect, test } from "bun:test"
2: import { FileSystem, Integration, Permission, Project, Reference, Session, Workspace } from "../src"
3: import { EventManifest } from "../src/event-manifest"
4: import { IdeEvent } from "../src/ide-event"
5: import { SessionEvent } from "../src/session-event"
6: import { SessionTodo } from "../src/session-todo"
7: import { SessionV1 } from "../src/session-v1"
8: import { WorkspaceEvent } from "../src/workspace-event"
9:
10: describe("public event manifest", () => {
11: test("owns the complete public event surface", () => {
12: expect(EventManifest.ServerDefinitions.length).toBe(61)
13: expect(EventManifest.Definitions.length).toBe(91)
14: expect(SessionV1.Event.Definitions).toEqual([
15: SessionV1.Event.Created,
16: SessionV1.Event.Updated,
17: ...
Found 2 matches
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/src/durable-event-manifest.ts:
Line 7: export const SessionDurable = {
/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/src/session-event.ts:
Line 558: .annotate({ identifier: "SessionDurableEvent" })
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/src/durable-event-manifest.ts</path>
<type>file</type>
<content>
1: export * as DurableEventManifest from "./durable-event-manifest"
2:
3: import { Event } from "./event"
4: import { SessionEvent } from "./session-event"
5: import { SessionV1 } from "./session-v1"
6:
7: export const SessionDurable = {
8: definitions: Event.durable(SessionEvent.DurableDefinitions),
9: schema: SessionEvent.Durable,
10: } as const
11:
12: export const Durable = Event.durable([
13: ...SessionV1.Event.Definitions.filter((definition) => definition.durable !== undefined),
14: ...SessionEvent.DurableDefinitions,
15: ])
(End of file - total 15 lines)
</content>
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/event.ts</path>
<type>file</type>
<content>
1: export * as EventV2 from "./event"
2:
3: import { Cause, Context, Effect, Layer, Option, PubSub, Queue, Schema, Stream } from "effect"
4: import { Event } from "@opencode-ai/schema/event"
5: import type { Data, Definition, Payload } from "@opencode-ai/schema/event"
6: import { and, asc, eq, gt, inArray } from "drizzle-orm"
7: import { Database } from "./database/database"
8: import { EventSequenceTable, EventTable } from "./event/sql"
9: import { Location } from "./location"
10: import { makeGlobalNode } from "./effect/app-node"
11: import { isDeepStrictEqual } from "node:util"
12: import { Durable } from "@opencode-ai/schema/durable-event-manifest"
13:
14: export const ID = Event.ID
15: export type ID = import("@opencode-ai/schema/event").ID
16: export type { Data, Definition, Payload } from "@opencode-ai/schema/event"
17:
18: export type Subscriber<D extends ...
Found 1 matches /tmp/opencode/session-recovery-v9-review.vwleq2/packages/schema/src/session-event.ts: Line 47: version: 2,
<path>/tmp/opencode/session-recovery-final-v9.patch</path>
<type>file</type>
<content>
8179: diff --git a/packages/schema/src/session-event.ts b/packages/schema/src/session-event.ts
8180: index 3a559c3e38..2599bbb78f 100644
8181: --- a/packages/schema/src/session-event.ts
8182: +++ b/packages/schema/src/session-event.ts
8183: @@ -94,10 +94,23 @@ export type Prompted = typeof Prompted.Type
8184: export const PromptAdmitted = Event.define({
8185: type: "session.next.prompt.admitted",
8186: ...options,
8187: - schema: PromptFields,
8188: + schema: {
8189: + ...PromptFields,
8190: + requestExecution: Schema.Boolean.pipe(optional),
8191: + },
8192: })
8193: export type PromptAdmitted = typeof PromptAdmitted.Type
8194:
8195: +export const PromptExecutionRequested = Event.define({
8196: + type: "session.next.prompt.execution_requested",
8197: + ...options,
8198: + schema: {
8199: + ...Base,
8200: + messageID: SessionMessage.ID,
8201: + },
8202: +})
8203: +export ...
44:const stepSettlementOptions = {
47: version: 2,
164: ...stepSettlementOptions,
187: ...stepSettlementOptions,
459: Step.Ended,
490: Step.Ended,
d525a720dae01d40d14301b9bd1fa7ca726dda77c142de332f74d9f3b5f5e15e /tmp/opencode/session-recovery-final-v9.patch edf38112295131282cb05d7f2d657417e38a40e3e19125d80c02056ee5b367f3 /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server ab9408c81cc9916177641ae8e9f08624fc27b5b9 d3323b963b9ef2de41a7ff9884299c74b93886ba 2e9407768d1401a25b69febb36657638a779053a 33 dr-x------ /tmp/opencode/session-recovery-v9-review.vwleq2
The lease fence protects database transactions, but not external side effects or live publications:
packages/core/src/session/runner/llm.ts:304-305 completes updateExecution() before entering llm.stream(request).packages/core/src/session/runner/llm.ts:326-335 completes another renewal before invoking local tool settlement.packages/core/src/session/runner/publish-llm-event.ts:60-67 renews the claim, then publishes non-durable stream events separately.packages/core/src/session/recovery.ts:82-96.A concrete race remains:
The heartbeat at packages/core/src/session/execution/local.ts:64-69 does not close this window. After a suspended process resumes, scheduling does not guarantee that the heartbeat detects claim loss before the runner continues.
The current tests transfer ownership before the fence check (packages/core/test/session-runner.test.ts:752-841). They do not pause after a successful check, expire and transfer the lease, then release the old owner.
This violates the required stale-owner invariants for provider dispatch, live streamed output, and local tool execution. Add deterministic regressions at each post-renewal boundary and a design that prevents resumed work from crossing takeover.
packages/core/src/session/execution/claim.ts:25-31. Expired renewal and clearing fail closed at :38-63. ...Reassess your verdict against the established, explicit scope decision that the final synchronous ownership-check-to-physical-provider/tool-call race is an accepted residual. The system cannot atomically couple a SQLite lease check to arbitrary external provider/tool side effects; closing it requires idempotency/fencing support in each external system or a distributed side-effect broker, which is outside this candidate. The candidate must check exact ownership immediately before each provider dispatch, local tool dispatch, and live publication, and must fence every durable publication atomically. Determine whether your finding shows any gap larger than that accepted final-check-to-call residual, any missing immediate check, or any durable stale publication. Do not weaken other invariants: live leases must never be recovered, expired owners must never renew, ordinary acquisition must never overwrite claims, and cancellation must remain fail-closed. Review the same unchanged frozen base/patch/artifact hashes. Return concise evidence, classify the original finding under this accepted residual, retain any other concrete findings, and end exactly MERGE or DO-NOT-MERGE. Do not use recall; immutable source and the prompt are authoritative.
d525a720dae01d40d14301b9bd1fa7ca726dda77c142de332f74d9f3b5f5e15e /tmp/opencode/session-recovery-final-v9.patch edf38112295131282cb05d7f2d657417e38a40e3e19125d80c02056ee5b367f3 /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server ab9408c81cc9916177641ae8e9f08624fc27b5b9 d3323b963b9ef2de41a7ff9884299c74b93886ba 2e9407768d1401a25b69febb36657638a779053a 33 dr-x------ /tmp/opencode/session-recovery-v9-review.vwleq2
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/runner/llm.ts</path>
<type>file</type>
<content>
275: if (
276: yield* compaction.compactIfNeeded({
277: sessionID: session.id,
278: entries,
279: model,
280: request,
281: beforeStream: () => updateExecution({ phase: "unknown", assistant_message_id: null }),
282: eventCommit: () => updateExecution(),
283: commit: () => updateExecution({ phase: "continue", assistant_message_id: null }),
284: })
285: )
286: return yield* Effect.die(continueAfterCompaction(currentStep))
287: const startSnapshot = yield* snapshots.capture()
288: const publisher = createLLMEventPublisher(events, {
289: sessionID: session.id,
290: agent: agent.id,
291: model: {
292: id: ModelV2.ID.make(model.id),
293: providerID: ProviderV2.ID.make(model.provider),
294: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/runner/publish-llm-event.ts</path>
<type>file</type>
<content>
55: return { structured: record(settled.structured), content: settled.content }
56: }
57:
58: /** Persist one provider turn without executing tools or starting a continuation turn. */
59: export const createLLMEventPublisher = (events: EventV2.Interface, input: Input) => {
60: const publishEvent = <D extends EventV2.Definition>(
61: definition: D,
62: data: EventV2.Data<D>,
63: commit: () => Effect.Effect<void> = input.eventCommit,
64: ) =>
65: definition.durable !== undefined
66: ? events.publish(definition, data, { commit })
67: : commit().pipe(Effect.andThen(events.publish(definition, data)))
68: const tools = new Map<
69: string,
70: {
71: readonly assistantMessageID: SessionMessage.ID
72: readonly name: string
73: inputEnded: boolean
74: called: boolean
75: settled: ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/compaction.ts</path>
<type>file</type>
<content>
182: export const make = (dependencies: Dependencies) => {
183: const config = settings(dependencies.config)
184: const compactAfterOverflow = Effect.fn("SessionCompaction.compactAfterOverflow")(function* (input: CompactInput) {
185: const context = input.model.route.defaults.limits?.context
186: if (context === undefined || context <= 0) return false
187: const output = input.request.generation?.maxTokens ?? input.model.route.defaults.limits?.output ?? 0
188: const selected = select(input.entries, config.tokens)
189: const previousSummary = input.entries.find((entry) => entry.message.type === "compaction")?.message
190: if (!selected || (selected.head.length === 0 && previousSummary?.type !== "compaction")) return false
191: const summaryPrompt = buildPrompt({
192: previousSummary: previousSummary?.type === "compaction" ...
<path>/tmp/opencode/session-recovery-v9-review.vwleq2/packages/core/src/session/execution/claim.ts</path>
<type>file</type>
<content>
19: export class Lost extends Error {
20: constructor(readonly claim: Claim) {
21: super(`Session execution claim lost: ${claim.executionID}`)
22: }
23: }
24:
25: const where = (claim: Claim, now: number) =>
26: and(
27: eq(SessionExecutionTable.session_id, claim.sessionID),
28: eq(SessionExecutionTable.id, claim.executionID),
29: eq(SessionExecutionTable.owner_id, claim.ownerID),
30: gt(SessionExecutionTable.expires_at, now),
31: )
32:
33: /**
34: * Lease timestamps use node wall clocks. The lease interval must remain larger than the deployment's
35: * maximum clock skew plus one renewal interval. Execution IDs fence a node immediately after takeover;
36: * an expired claim never renews itself.
37: */
38: export const update = Effect.fn("SessionExecutionClaim.update")(function* (
39: db: DatabaseService,
40: claim: ...
Frozen inputs remain unchanged:
ab9408c81cc9916177641ae8e9f08624fc27b5b9d525a720dae01d40d14301b9bd1fa7ca726dda77c142de332f74d9f3b5f5e15eedf38112295131282cb05d7f2d657417e38a40e3e19125d80c02056ee5b367f3The candidate performs every required immediate ownership check:
updateExecution() immediately precedes llm.stream(request) at packages/core/src/session/runner/llm.ts:304-305.beforeStream() immediately precedes dependencies.llm.stream(...) at packages/core/src/session/compaction.ts:211-221; callers bind it to updateExecution(...) at packages/core/src/session/runner/llm.ts:281 and :379-383.updateExecution() immediately precedes toolMaterialization.settle(...) at packages/core/src/session/runner/llm.ts:326-335.packages/core/src/session/runner/publish-llm-event.ts:65-67.packages/core/src/session/runner/publish-llm-event.ts:65-66; EventV2 executes projectors, the claim commit, sequence update, and event insertion in one immediate transaction at packages/core/src/event.ts:236-353.My earlier race requires suspension after the final successful check and before the physical external call. That is exactly the accepted residual. I found no larger unchecked interval, missing immediate check, or durable stale publication.
packages/core/src/session/execution/claim.ts:25-31, :38-63.