Dashboard › opencode › Session 13VSJEUCn4Rj
13VSJEUCn4RjSl5bzPerform a strict READ-ONLY correctness/adversarial review of frozen v20 in /tmp/opencode/session-recovery-v20-review. Do not edit, run tests/builds/services, mutate VCS/index/refs, or use recall. Read applicable guidance and inspect all changed files plus necessary context. Immutable inputs: base ab9408c81cc9916177641ae8e9f08624fc27b5b9; patch /tmp/opencode/session-recovery-final-v20.patch SHA-256 24352107c74d8245fcba7f8571ba0be4b7fc514e6c73cfbf0498f0c25f29f9ba; SEA /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server SHA-256 d0c78e881892d4f894fab7f6be00643c133ca21f9d2c88ae0d5ff31215393021; 34 paths. Verify provenance/hashes/applicability first. Inspect lifecycle, transactions, replay, concurrency, fencing, recovery identity, migrations, generated contracts, and tests. Focus on prior v19 blockers: no Step.Interrupted or cancelling->cancelled before owner and outer finalizers join; coordinator cleanup then reconciles unresolved tools/Step exactly once and clears before successor starts; publication failure retains cancelling; expired cancelled clears safely while expired cancelling quarantines; direct SessionRunner interruption without coordinator remains unknown; immediate ownership checks precede both snapshot writes. Also verify explicit resume durable intent and scan index/current client generation. Treat disclosed final check-to-external-call, process-local interruption, and bounded clock skew as residuals. Findings first with MUST-FIX/CONCERN and exact file:line evidence; if none, explicitly say so. End exactly MERGE or DO-NOT-MERGE.
<path>/tmp/opencode/session-recovery-v20-review</path> <type>directory</type> <entries> .dockerignore .editorconfig .git .gitattributes .github/ .gitignore .gitleaksignore .husky/ .lore.md .opencode/ .oxlintrc.json .prettierignore .vscode/ .zed/ AGENTS.md artifacts/ bun.lock bunfig.toml CONTEXT.md CONTRIBUTING.md flake.lock flake.nix github/ infra/ install LICENSE nix/ package.json packages/ patches/ 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 tsconfig.json turbo.json (65 entries) </entries>
/tmp/opencode/session-recovery-v20-review/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/app/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/ui/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/app/e2e/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/desktop/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/app/e2e/performance/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/codemode/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/opencode/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/session-ui/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/effect-drizzle-sqlite/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/llm/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/opencode/test/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/opencode/src/session/llm/AGENTS.md /tmp/opencode/session-recovery-v20-review/packages/schema/AGENTS.md /tmp/openco...
24352107c74d8245fcba7f8571ba0be4b7fc514e6c73cfbf0498f0c25f29f9ba /tmp/opencode/session-recovery-final-v20.patch d0c78e881892d4f894fab7f6be00643c133ca21f9d2c88ae0d5ff31215393021 /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server ab9408c81cc9916177641ae8e9f08624fc27b5b9 # branch.oid ab9408c81cc9916177641ae8e9f08624fc27b5b9 # branch.head (detached) 1 .M N... 100644 100644 100644 3b3188c8742a4ba6b5a173d296a4ac28bac710fc 3b3188c8742a4ba6b5a173d296a4ac28bac710fc packages/client/src/generated/types.ts 1 .M N... 100644 100644 100644 d0eeeebd5c419b02287413e8e521fefcbc3c4f27 d0eeeebd5c419b02287413e8e521fefcbc3c4f27 packages/core/schema.json 1 .M N... 100644 100644 100644 e6ea4eaa1477e80397c8cc5c6808f2ac1214891a e6ea4eaa1477e80397c8cc5c6808f2ac1214891a packages/core/src/database/migration.gen.ts 1 .M N... 100644 100644 100644 ed60fde6c55fe4df217bba241ed9e8fa1ba323d5 ed60fde6c55fe4df217bba241ed9e8fa1ba323d5 packages/core/src/database/schema.gen.ts 1 .M N... ...
<path>/tmp/opencode/session-recovery-final-v20.patch</path>
<type>file</type>
<content>
1: diff --git a/packages/client/src/generated/types.ts b/packages/client/src/generated/types.ts
2: index 3b3188c874..5130fa9496 100644
3: --- a/packages/client/src/generated/types.ts
4: +++ b/packages/client/src/generated/types.ts
5: @@ -775,8 +775,17 @@ export type SessionsHistoryOutput = {
6: }>
7: }
8: readonly delivery: "steer" | "queue"
9: + readonly requestExecution?: boolean
10: }
11: }
12: + | {
13: + readonly id: string
14: + readonly metadata?: { readonly [x: string]: JsonValue }
15: + readonly type: "session.next.prompt.execution_requested"
16: + readonly durable?: { readonly aggregateID: string; readonly seq: number; readonly version: number }
17: + readonly location?: { readonly directory: string; readonly workspaceID?: string }
18: + readonly data: { readonly timestamp: number; ...
<path>/tmp/opencode/session-recovery-v20-review/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`. ...
File not found: /tmp/opencode/session-recovery-v20-review/packages/core/AGENTS.md
<path>/tmp/opencode/session-recovery-v20-review/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-v20-review/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-v20-review/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-v20-review/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-v20-review/package.json</path>
<type>file</type>
<content>
1: {
2: "$schema": "https://json.schemastore.org/package.json",
3: "name": "opencode",
4: "description": "AI-powered development tool",
5: "private": true,
6: "type": "module",
7: "packageManager": "bun@1.3.14",
8: "scripts": {
9: "dev": "bun run --cwd packages/opencode src/index.ts",
10: "dev:desktop": "bun --cwd packages/desktop dev",
11: "dev:web": "bun --cwd packages/app dev",
12: "dev:console": "ulimit -n 10240 2>/dev/null; bun run --cwd packages/console/app dev",
13: "dev:stats": "bun sst shell --stage=production -- bun run --cwd packages/stats/app dev",
14: "dev:storybook": "bun --cwd packages/storybook storybook",
15: "lint": "oxlint",
16: "typecheck": "bun turbo typecheck",
17: "upgrade-opentui": "bun run script/upgrade-opentui.ts",
18: "postinstall": "bun run --cwd packages/core fix-node-pty",
19: "prepare": "husky",
20: ...
<path>/tmp/opencode/session-recovery-v20-review/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": ...
72 0 packages/client/src/generated/types.ts 567 48 packages/core/schema.json 1 0 packages/core/src/database/migration.gen.ts 62 0 packages/core/src/database/migration/20260914170650_session-recovery.ts 52 1 packages/core/src/database/schema.gen.ts 6 4 packages/core/src/session.ts 31 16 packages/core/src/session/compaction.ts 54 34 packages/core/src/session/context-epoch.ts 200 19 packages/core/src/session/execution/local.ts 391 31 packages/core/src/session/input.ts 69 0 packages/core/src/session/message-updater.ts 88 1 packages/core/src/session/projector.ts 508 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 289 104 packages/core/src/session/runner/llm.ts 108 48 packages/core/src/session/runner/publish-llm-event.ts 88 1 packages/core/src/session/sql.ts 66 1 packages/core/test/database-migration.test.ts 352 0 packages/core/test/session-execution-local.test.ts 2819 3 packages/core/test/session-project...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/src/session/execution/claim.ts</path>
<type>file</type>
<content>
1: export * as SessionExecutionClaim from "./claim"
2:
3: import { and, eq, gt, notInArray } 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<
18: Pick<typeof SessionExecutionTable.$inferInsert, "assistant_message_id" | "assistant_seq" | "phase">
19: >
20:
21: export class Lost extends Error {
22: constructor(readonly claim: Claim) {
23: super(`Session execution claim lost: ${claim.executionID}`)
24: }
25: }
26:
27: ...
<path>/tmp/opencode/session-recovery-v20-review/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-v20-review/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-v20-review/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 type { ...
<path>/tmp/opencode/session-recovery-v20-review/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 interface ...
<path>/tmp/opencode/session-recovery-v20-review/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, SessionTable } from "./sql"
14:
15: type DatabaseService = Database.Interface["db"]
16:
17: export { Admitted, Delivery }
18:
19: const decodePrompt = Schema.decodeUnknownSync(Prompt)
20: const encodePrompt = ...
<path>/tmp/opencode/session-recovery-v20-review/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 { continuation } from "./recovery-id"
14: import { SessionSchema } from "./schema"
15: import {
16: MAX_WAKE_ATTEMPTS,
17: SESSION_EXECUTION_LEASE_MS,
18: SessionExecutionTable,
19: SessionInputTable,
20: SessionRecoveryTable,
21: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/src/session/execution/local.ts</path>
<type>file</type>
<content>
1: import { and, asc, desc, eq, isNull } from "drizzle-orm"
2: import { Cause, Clock, DateTime, Duration, Effect, Exit, Layer, Option, 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 { EventV2 } from "../../event"
13: import { SessionEvent } from "../event"
14: import { SessionExecutionClaim } from "./claim"
15: import {
16: SESSION_EXECUTION_LEASE_MS,
17: SessionExecutionTable,
18: ...
<path>/tmp/opencode/session-recovery-v20-review/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:
17: ...
<path>/tmp/opencode/session-recovery-v20-review/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-v20-review/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-v20-review/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, seq: number) => 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-v20-review/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: ...
<path>/tmp/opencode/session-recovery-v20-review/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: (message: ...
<path>/tmp/opencode/session-recovery-v20-review/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-v20-review/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-v20-review/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 } from ...
<path>/tmp/opencode/session-recovery-v20-review/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-v20-review/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: import { ...
<path>/tmp/opencode/session-recovery-v20-review/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: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/src/database/schema.gen.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "./migration"
3:
4: export default {
5: up(tx) {
6: return Effect.gen(function* () {
7: yield* tx.run(`
8: CREATE TABLE \`workspace\` (
9: \`id\` text PRIMARY KEY,
10: \`type\` text NOT NULL,
11: \`name\` text DEFAULT '' NOT NULL,
12: \`branch\` text,
13: \`directory\` text,
14: \`extra\` text,
15: \`project_id\` text NOT NULL,
16: \`time_used\` integer NOT NULL,
17: CONSTRAINT \`fk_workspace_project_id_project_id_fk\` FOREIGN KEY (\`project_id\`) REFERENCES \`project\`(\`id\`) ON DELETE CASCADE
18: );
19: `)
20: yield* tx.run(`
21: CREATE TABLE \`data_migration\` (
22: \`name\` text PRIMARY KEY,
23: \`time_completed\` integer NOT ...
Found 8 matches /tmp/opencode/session-recovery-v20-review/packages/client/src/generated/types.ts: Line 778: readonly requestExecution?: boolean Line 784: readonly type: "session.next.prompt.execution_requested" Line 895: readonly type: "session.next.step.interrupted" Line 908: readonly type: "session.next.step.recovered" Line 1272: readonly requestExecution?: boolean Line 1278: readonly type: "session.next.prompt.execution_requested" Line 1389: readonly type: "session.next.step.interrupted" Line 1402: readonly type: "session.next.step.recovered"
/tmp/opencode/session-recovery-v20-review/packages/client/src/generated-effect/client-error.ts /tmp/opencode/session-recovery-v20-review/packages/client/src/generated-effect/index.ts /tmp/opencode/session-recovery-v20-review/packages/client/src/generated-effect/client.ts
No files found
<path>/tmp/opencode/session-recovery-v20-review/packages/client/src/generated-effect/client.ts</path>
<type>file</type>
<content>
1: // Generated by @opencode-ai/httpapi-codegen. Do not edit.
2: import { Effect, Stream, Schema } from "effect"
3: import { Sse } from "effect/unstable/encoding"
4: import { HttpClientError } from "effect/unstable/http"
5: import { HttpApiClient } from "effect/unstable/httpapi"
6: import { ClientApi } from "../contract"
7: import { ClientError } from "./client-error"
8:
9: type RawClient = HttpApiClient.ForApi<typeof ClientApi>
10:
11: const mapClientError = <E>(error: E) =>
12: HttpClientError.isHttpClientError(error) || Schema.isSchemaError(error) || Sse.Retry.is(error)
13: ? new ClientError({ cause: error })
14: : error
15:
16: const Endpoint0_0 = (raw: RawClient["server.health"]) => () =>
17: raw["health.get"]({}).pipe(Effect.mapError(mapClientError))
18:
19: const adaptGroup0 = (raw: RawClient["server.health"]) => ({ get: ...
Found 57 matches /tmp/opencode/session-recovery-v20-review/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 1021: "table": "session_execution" Line 1089: "name": "wake_pending", Line 1181: "table": "session_recovery" Line 1191: "table": "session_recovery" Line 1201: "table": "session_recovery" Line 1211: "table": "session_recovery" Line 1221: "table": "session_recovery" Line 1229: "name": "wake_pending", Line 1231: "table": "session_recovery" Line ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/schema.json</path>
<type>file</type>
<content>
2250: "where": null,
2251: "origin": "manual",
2252: "name": "part_session_idx",
2253: "entityType": "indexes",
2254: "table": "part"
2255: },
2256: {
2257: "columns": [
2258: {
2259: "value": "session_id",
2260: "isExpression": false
2261: }
2262: ],
2263: "isUnique": true,
2264: "where": null,
2265: "origin": "manual",
2266: "name": "session_execution_session_idx",
2267: "entityType": "indexes",
2268: "table": "session_execution"
2269: },
2270: {
2271: "columns": [
2272: {
2273: "value": "owner_id",
2274: "isExpression": false
2275: }
2276: ],
2277: "isUnique": false,
2278: "where": null,
2279: "origin": "manual",
2280: "name": "session_execution_owner_idx",
2281: ...
Found 34 matches /tmp/opencode/session-recovery-final-v20.patch: Line 1: diff --git a/packages/client/src/generated/types.ts b/packages/client/src/generated/types.ts Line 109: diff --git a/packages/core/schema.json b/packages/core/schema.json Line 1025: diff --git a/packages/core/src/database/migration.gen.ts b/packages/core/src/database/migration.gen.ts Line 1036: diff --git a/packages/core/src/database/migration/20260914170650_session-recovery.ts b/packages/core/src/database/migration/20260914170650_session-recovery.ts Line 1104: diff --git a/packages/core/src/database/schema.gen.ts b/packages/core/src/database/schema.gen.ts Line 1210: diff --git a/packages/core/src/session.ts b/packages/core/src/session.ts Line 1250: diff --git a/packages/core/src/session/compaction.ts b/packages/core/src/session/compaction.ts Line 1339: diff --git a/packages/core/src/session/context-epoch.ts b/packages/core/src/session/context-epoch.ts Line 1515: diff --git ...
<path>/tmp/opencode/session-recovery-v20-review/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 "@opencode-ai/core/database/migration/20260601010001_normalize_storage_paths"
14: ...
<path>/tmp/opencode/session-recovery-v20-review/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, sql } 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 { SessionExecutionClaim } from "@opencode-ai/core/session/execution/claim"
11: import { SessionMessage } from "@opencode-ai/core/session/message"
12: import { SessionSchema } from "@opencode-ai/core/session/schema"
13: import { SessionExecutionTable, SessionTable } from "@opencode-ai/core/session/sql"
14: import { testEffect ...
Found 53 matches
/tmp/opencode/session-recovery-v20-review/packages/core/test/session-projector.test.ts:
Line 68: it.effect("atomically reconciles one abandoned execution into one continuation", () =>
Line 222: it.effect("records a recovery continuation without forging an assistant identity", () =>
Line 258: it.effect("recovers each abandoned execution once across repeated startup scans", () =>
Line 304: it.effect("never recovers a live execution lease", () =>
Line 342: it.effect("never recovers an execution superseded by a newer assistant", () =>
Line 390: it.effect(`never recovers an assistant-less ${phase} execution superseded by a newer assistant`, () =>
Line 435: it.effect(`never commits assistant-less ${phase} recovery after concurrent assistant supersession`, () =>
Line 504: it.effect("recovers assistant-less continuation at its current assistant boundary", () =>
Line 555: it.effect("redrives a durable recovery wake after ...
<path>/tmp/opencode/session-recovery-v20-review/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-v20-review/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
1201: title: "test",
1202: version: "test",
1203: })
1204: .run()
1205: yield* SessionInput.admit(db, events, {
1206: id: SessionMessage.ID.make("msg_ready_before_promotion"),
1207: sessionID,
1208: prompt: Prompt.make({ text: "pending" }),
1209: delivery: "steer",
1210: requestExecution: true,
1211: })
1212: yield* db
1213: .insert(SessionExecutionTable)
1214: .values({
1215: id: "ready-before-promotion",
1216: session_id: sessionID,
1217: owner_id: "dead",
1218: phase: "ready",
1219: time_created: 0,
1220: expires_at: 0,
1221: })
1222: .run()
1223: const wakes: string[] = []
1224:
1225: yield* SessionRecovery.recover().pipe(
1226: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
2401: `)
2402: yield* SessionRecovery.recover().pipe(
2403: Effect.provideService(SessionExecution.Service, recoveryExecution),
2404: )
2405: expect(
2406: yield* db
2407: .select()
2408: .from(SessionExecutionTable)
2409: .where(eq(SessionExecutionTable.recovery_error, "Recovery projection failed"))
2410: .all(),
2411: ).toHaveLength(SessionRecovery.BATCH_SIZE)
2412:
2413: yield* SessionRecovery.recover().pipe(
2414: Effect.provideService(SessionExecution.Service, recoveryExecution),
2415: Effect.ensuring(db.run(sql`DROP TRIGGER fail_recovery_projection`).pipe(Effect.orDie)),
2416: )
2417: expect(yield* db.select().from(SessionRecoveryTable).all()).toEqual([
2418: expect.objectContaining({ execution_id: "conversion-100" }),
2419: ...
Found 29 matches
/tmp/opencode/session-recovery-v20-review/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", () =>
Line ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-prompt.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect } from "bun:test"
2: import { DateTime, Effect, Fiber, Layer, Stream } from "effect"
3: import { asc, eq } from "drizzle-orm"
4: import { Database } from "@opencode-ai/core/database/database"
5: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
6: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
7: import { EventV2 } from "@opencode-ai/core/event"
8: import { EventTable } from "@opencode-ai/core/event/sql"
9: import { SessionEvent } from "@opencode-ai/core/session/event"
10: import { Project } from "@opencode-ai/core/project"
11: import { ProjectTable } from "@opencode-ai/core/project/sql"
12: import { AbsolutePath } from "@opencode-ai/core/schema"
13: import { SessionV2 } from "@opencode-ai/core/session"
14: import { Prompt } from "@opencode-ai/core/session/prompt"
15: import { SessionMessage ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-run-coordinator.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect } from "bun:test"
2: import { Cause, Deferred, Effect, Exit, Fiber, Layer } from "effect"
3: import { SessionRunCoordinator } from "@opencode-ai/core/session/run-coordinator"
4: import { testEffect } from "./lib/effect"
5:
6: const it = testEffect(Layer.empty)
7:
8: describe("SessionRunCoordinator", () => {
9: it.effect("joins concurrent resumes for one key", () =>
10: Effect.scoped(
11: Effect.gen(function* () {
12: const gate = yield* Deferred.make<void>()
13: let runs = 0
14: const coordinator = yield* SessionRunCoordinator.make({
15: drain: () => Effect.sync(() => runs++).pipe(Effect.andThen(Deferred.await(gate))),
16: })
17:
18: const first = yield* coordinator.run("session").pipe(Effect.forkChild)
19: yield* Effect.yieldNow
20: const ...
Found 100 matches (more matches available)
/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts:
Line 619: it.effect("redrives only the synthetic recovery continuation", () =>
Line 688: it.effect("clears durable execution intent when ordinary input is promoted", () =>
Line 715: it.effect("redrives an ordinary prompt after its advisory wake is lost", () =>
Line 752: it.effect("never dispatches a provider after ownership changes", () =>
Line 778: it.effect("never publishes streamed output after ownership changes", () =>
Line 805: it.effect("never starts a local tool after ownership changes", () =>
Line 845: it.effect("never fails interrupted tools after ownership changes", () =>
Line 902: it.effect("advertises and executes a globally attached application tool", () =>
Line 958: it.effect("starts a real runner turn after default prompt recording", () =>
Line 977: it.effect("streams one request with registry ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
580: responseStream = Stream.concat(
581: Stream.fromIterable(fixture.partialEvents),
582: Stream.fromEffect(Deferred.succeed(streamed, undefined)).pipe(Stream.flatMap(() => Stream.never)),
583: )
584:
585: const runner = yield* SessionRunner.Service
586: yield* insertExecution(sessionID)
587: const fiber = yield* runner.run({ sessionID, force: true, executionID, ownerID: "test" }).pipe(Effect.forkChild)
588: yield* Deferred.await(streamed)
589: yield* Fiber.interrupt(fiber)
590: const { db } = yield* Database.Service
591: expect(
592: yield* db
593: .select({ id: SessionExecutionTable.id, phase: SessionExecutionTable.phase })
594: .from(SessionExecutionTable)
595: .where(eq(SessionExecutionTable.session_id, sessionID))
596: .get(),
597: ).toEqual({ id: executionID, phase: ...
Found 35 matches
/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts:
Line 26: import { Snapshot } from "@opencode-ai/core/snapshot"
Line 600: event.type.startsWith(SessionEvent.Step.Interrupted.type),
Line 752: it.effect("never dispatches a provider after ownership changes", () =>
Line 778: it.effect("never publishes streamed output after ownership changes", () =>
Line 805: it.effect("never starts a local tool after ownership changes", () =>
Line 845: it.effect("never fails interrupted tools after ownership changes", () =>
Line 1060: it.effect("fails gracefully when a stored context snapshot cannot be decoded", () =>
Line 1070: .set({ snapshot: { invalid: { value: "bad" } } })
Line 1511: fragmentFixture("text", "text-uncommitted-summary", ["## Objective\n- Interrupted"]).completeEvents,
Line 1762: fragmentFixture("text", "text-summary", ["## Objective\n- ...
No files found
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect } from "bun:test"
2: import {
3: LLMClient,
4: LLMError,
5: LLMEvent,
6: Model,
7: TransportReason,
8: InvalidRequestReason,
9: type LLMClientShape,
10: type LLMRequest,
11: } from "@opencode-ai/llm"
12: import * as OpenAIChat from "@opencode-ai/llm/protocols/openai-chat"
13: import { Database } from "@opencode-ai/core/database/database"
14: import { makeLocationNode } from "@opencode-ai/core/effect/app-node"
15: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
16: import { LayerNodePlatform } from "@opencode-ai/core/effect/app-node-platform"
17: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
18: import { EventV2 } from "@opencode-ai/core/event"
19: import { PermissionV2 } from "@opencode-ai/core/permission"
20: import { EventTable } from "@opencode-ai/core/event/sql"
21: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
1450: "x-session-affinity": sessionID,
1451: "X-Session-Id": sessionID,
1452: },
1453: {
1454: "x-session-affinity": sessionID,
1455: "X-Session-Id": sessionID,
1456: },
1457: ])
1458: expect(userTexts(requests[0])[0]).toContain("## Objective")
1459: expect(userTexts(requests[1])).toHaveLength(1)
1460: expect(userTexts(requests[1])[0]).toContain("<summary>\n## Objective\n- Preserve the task\n</summary>")
1461: expect(userTexts(requests[1])[0]).toContain(`[User]: ${"Recent exact request ".repeat(180)}`)
1462:
1463: const context = yield* (yield* SessionStore.Service).context(sessionID)
1464: expect(context.map((message) => message.type)).toEqual(["compaction", "assistant"])
1465: expect(context[0]).toMatchObject({
1466: type: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
3500: }),
3501: })
3502: yield* session.prompt({ sessionID, prompt: Prompt.make({ text: "Call blocked" }), resume: false })
3503:
3504: requests.length = 0
3505: responses = [
3506: [
3507: LLMEvent.stepStart({ index: 0 }),
3508: LLMEvent.toolCall({ id: "call-blocked", name: "blocked", input: {} }),
3509: LLMEvent.stepFinish({ index: 0, reason: "tool-calls" }),
3510: LLMEvent.finish({ reason: "tool-calls" }),
3511: ],
3512: [
3513: LLMEvent.stepStart({ index: 0 }),
3514: LLMEvent.stepFinish({ index: 0, reason: "stop" }),
3515: LLMEvent.finish({ reason: "stop" }),
3516: ],
3517: ]
3518:
3519: yield* session.resume(sessionID)
3520:
3521: expect(requests).toHaveLength(2)
3522: expect(yield* ...
Found 6 matches /tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts: Line 600: event.type.startsWith(SessionEvent.Step.Interrupted.type), Line 3580: event.type.startsWith(SessionEvent.Step.Interrupted.type), Line 3994: .where(eq(EventTable.type, "session.next.step.interrupted.1")) Line 4048: .where(eq(EventTable.type, "session.next.step.interrupted.1")) Line 4082: .where(eq(EventTable.type, "session.next.step.interrupted.1")) Line 4113: .where(eq(EventTable.type, "session.next.step.interrupted.1"))
<path>/tmp/opencode/session-recovery-v20-review/packages/client/src/generated/types.ts</path>
<type>file</type>
<content>
750: readonly delivery: "steer" | "queue"
751: }
752: }
753: | {
754: readonly id: string
755: readonly metadata?: { readonly [x: string]: JsonValue }
756: readonly type: "session.next.prompt.admitted"
757: readonly durable?: { readonly aggregateID: string; readonly seq: number; readonly version: number }
758: readonly location?: { readonly directory: string; readonly workspaceID?: string }
759: readonly data: {
760: readonly timestamp: number
761: readonly sessionID: string
762: readonly messageID: string
763: readonly prompt: {
764: readonly text: string
765: readonly files?: ReadonlyArray<{
766: readonly uri: string
767: readonly mime: string
768: readonly name?: string
769: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/sdk/js/src/v2/gen/types.gen.ts</path>
<type>file</type>
<content>
700: * Display text (1-5 words, concise)
701: */
702: label: string
703: /**
704: * Explanation of choice
705: */
706: description: string
707: }
708:
709: export type QuestionInfo = {
710: /**
711: * Complete question
712: */
713: question: string
714: /**
715: * Very short label (max 30 chars)
716: */
717: header: string
718: /**
719: * Available choices
720: */
721: options: Array<QuestionOption>
722: multiple?: boolean
723: custom?: boolean
724: }
725:
726: export type QuestionTool = {
727: messageID: string
728: callID: string
729: }
730:
731: export type QuestionAnswer = Array<string>
732:
733: export type GlobalEvent = {
734: directory: string
735: project?: string
736: workspace?: string
737: payload:
738: | {
739: id: string
740: type: "models-dev.refreshed"
741: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/sdk/js/src/v2/gen/types.gen.ts</path>
<type>file</type>
<content>
928: id: string
929: type: "session.next.step.started"
930: properties: {
931: timestamp: number
932: sessionID: string
933: assistantMessageID: string
934: agent: string
935: model: ModelRef
936: snapshot?: string
937: }
938: }
939: | {
940: id: string
941: type: "session.next.step.ended"
942: properties: {
943: timestamp: number
944: sessionID: string
945: assistantMessageID: string
946: finish: string
947: cost: number
948: tokens: {
949: input: number
950: output: number
951: reasoning: number
952: cache: {
953: read: number
954: write: number
955: }
956: }
957: ...
<path>/tmp/opencode/session-recovery-v20-review/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: SessionV1.Event.Deleted,
18: ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner-recorded.test.ts</path>
<type>file</type>
<content>
1: import { HttpRecorder } from "@opencode-ai/http-recorder"
2: import { HttpRecorderInternal } from "@opencode-ai/http-recorder/internal"
3: import * as OpenAIChat from "@opencode-ai/llm/protocols/openai-chat"
4: import { Auth, LLMClient, RequestExecutor } from "@opencode-ai/llm/route"
5: import { Database } from "@opencode-ai/core/database/database"
6: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
7: import { LayerNodePlatform } from "@opencode-ai/core/effect/app-node-platform"
8: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
9: import { EventV2 } from "@opencode-ai/core/event"
10: import { EventTable } from "@opencode-ai/core/event/sql"
11: import { PermissionV2 } from "@opencode-ai/core/permission"
12: import { AgentV2 } from "@opencode-ai/core/agent"
13: import { Config } from ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner-tool-events.test.ts</path>
<type>file</type>
<content>
1: import { expect, test } from "bun:test"
2: import { Effect, Schema, Stream } from "effect"
3: import { LLMEvent } from "@opencode-ai/llm"
4: import { EventV2 } from "@opencode-ai/core/event"
5: import { SessionEvent } from "@opencode-ai/core/session/event"
6: import { SessionMessage } from "@opencode-ai/core/session/message"
7: import { SessionV2 } from "@opencode-ai/core/session"
8: import { ModelV2 } from "@opencode-ai/core/model"
9: import { ProviderV2 } from "@opencode-ai/core/provider"
10: import { createLLMEventPublisher } from "@opencode-ai/core/session/runner/publish-llm-event"
11:
12: const sessionID = SessionV2.ID.make("ses_tool_event_test")
13: const base64 = "iVBORw0KGgoAAAANSUhEUgAAAAEAAAAB"
14:
15: const capture = () => {
16: const published: Array<{ readonly type: string; readonly data: unknown }> = []
17: const events = ...
Found 16 matches
/tmp/opencode/session-recovery-v20-review/packages/sdk/openapi.json:
Line 17899: "requestExecution": {
Line 17919: "enum": ["session.next.prompt.execution_requested"]
Line 18253: "enum": ["session.next.step.interrupted"]
Line 18289: "enum": ["session.next.step.recovered"]
Line 25709: "requestExecution": {
Line 25740: "enum": ["session.next.prompt.execution_requested.1"]
Line 26242: "enum": ["session.next.step.interrupted.1"]
Line 26299: "enum": ["session.next.step.recovered.1"]
Line 28599: "requestExecution": {
Line 28622: "enum": ["session.next.prompt.execution_requested"]
Line 29132: "enum": ["session.next.step.interrupted"]
Line 29190: "enum": ["session.next.step.recovered"]
Line 34811: "requestExecution": {
Line ...
No files found
<path>/tmp/opencode/session-recovery-v20-review/packages/core/src/session/event.ts</path> <type>file</type> <content> 1: export * from "@opencode-ai/schema/session-event" 2: export * as SessionEvent from "@opencode-ai/schema/session-event" (End of file - total 2 lines) </content>
File not found: /tmp/opencode/session-recovery-v20-review/packages/core/src/event/index.ts
/tmp/opencode/session-recovery-v20-review/packages/core/src/event.ts
<path>/tmp/opencode/session-recovery-v20-review/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 Definition ...
Traceback (most recent call last):
File "<string>", line 13, in <module>
File "/usr/lib/python3.12/subprocess.py", line 466, in check_output
return run(*popenargs, stdout=PIPE, timeout=timeout, check=True,
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/lib/python3.12/subprocess.py", line 571, in run
raise CalledProcessError(retcode, process.args,
subprocess.CalledProcessError: Command '['git', 'rev-parse', 'ab9408c81cc9916177641ae8e9f08624fc27b5b9:packages/core/src/database/migration/20260914170650_session-recovery.ts']' returned non-zero exit status 128.
sections=34 mismatches=0
ab9408c81cc9916177641ae8e9f08624fc27b5b9 forward_apply_exit=1 error: patch failed: packages/core/schema.json:1 error: packages/core/schema.json: patch does not apply error: patch failed: packages/core/src/database/migration.gen.ts:40 error: packages/core/src/database/migration.gen.ts: patch does not apply error: packages/core/src/database/migration/20260914170650_session-recovery.ts: already exists in working directory error: patch failed: packages/core/src/database/schema.gen.ts:154 error: packages/core/src/database/schema.gen.ts: patch does not apply error: patch failed: packages/core/src/session.ts:365 error: packages/core/src/session.ts: patch does not apply error: patch failed: packages/core/src/session/compaction.ts:73 error: packages/core/src/session/compaction.ts: patch does not apply error: patch failed: packages/core/src/session/context-epoch.ts:12 error: packages/core/src/session/context-epoch.ts: patch does not apply error: patch failed: ...
...output truncated...
Full output saved to: /home/byk/.local/share/opencode/tool-output/tool_0ae92bf14001v5GA551jMegu2U
import { ApplicationTools } from "@opencode-ai/core/tool/application-tools"
@@ -41,12 +42,14 @@ import { AgentV2 } from "@opencode-ai/core/agent"
import { Config } from "@opencode-ai/core/config"
import { ConfigCompaction } from "@opencode-ai/core/config/compaction"
import { Tool } from "@opencode-ai/core/tool/tool"
import {
SessionContextEpochTable,
+ SessionExecutionTable,
SessionInputTable,
SessionMessageTable,
+ SessionRecoveryTable,
SessionTable,
} from "@opencode-ai/core/session/sql"
import { SessionStore } from "@opencode-ai/core/session/store"
import { SystemContext } from "@opencode-ai/core/system-context"
import { SystemContextRegistry } from "@opencode-ai/core/system-context/registry"
@@ -54,22 +57,24 @@ import { SkillGuidance } from "@opencode-ai/core/skill/guidance"
import { ReferenceGuidance } from ...
<path>/tmp/opencode/session-recovery-v20-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
4200: LLMEvent.toolCall({ id: "call-terminal", name: "echo", input: { text: "done" } }),
4201: LLMEvent.stepFinish({ index: 0, reason: "tool-calls" }),
4202: LLMEvent.finish({ reason: "tool-calls" }),
4203: ],
4204: [
4205: LLMEvent.stepStart({ index: 0 }),
4206: LLMEvent.toolCall({ id: "call-forbidden", name: "echo", input: { text: "forbidden" } }),
4207: LLMEvent.stepFinish({ index: 0, reason: "tool-calls" }),
4208: LLMEvent.finish({ reason: "tool-calls" }),
4209: ],
4210: ]
4211:
4212: yield* session.resume(sessionID)
4213:
4214: expect(requests).toHaveLength(2)
4215: expect(requests[0]?.toolChoice).toBeUndefined()
4216: expect(requests[1]?.toolChoice).toMatchObject({ type: "none" })
4217: ...
Found 8 matches
/tmp/opencode/session-recovery-v20-review/packages/core/src/tool/tool.ts:
Line 66: readonly settle: (call: ToolCall, context: Context) => Effect.Effect<ToolOutput, ToolFailure>
Line 91: settle: (call, context) =>
Line 150: export const settle = (tool: AnyTool, call: ToolCall, context: Context) => runtimeOf(tool).settle(call, context)
/tmp/opencode/session-recovery-v20-review/packages/core/src/tool/registry.ts:
Line 24: readonly materialize: (permissions?: PermissionV2.Ruleset) => Effect.Effect<Materialization>
Line 31: readonly settle: (input: ExecuteInput) => Effect.Effect<Settlement, ToolOutputStore.Error>
Line 62: const pending = yield* settle(registration.tool, input.call, {
Line 106: materialize: Effect.fn("ToolRegistry.materialize")(function* (permissions = []) {
Line 116: settle: (input) => {
<path>/tmp/opencode/session-recovery-v20-review/packages/core/src/tool/registry.ts</path>
<type>file</type>
<content>
1: export * as ToolRegistry from "./registry"
2:
3: import { ToolOutput, type ToolCall, type ToolDefinition, type ToolResultValue } from "@opencode-ai/llm"
4: import { Context, Effect, Layer, Scope } from "effect"
5: import { AgentV2 } from "../agent"
6: import { PermissionV2 } from "../permission"
7: import { SessionMessage } from "../session/message"
8: import { SessionSchema } from "../session/schema"
9: import { ToolOutputStore } from "../tool-output-store"
10: import { Wildcard } from "../util/wildcard"
11: import { ApplicationTools } from "./application-tools"
12: import { definition, permission, settle, validateName, type AnyTool, type RegistrationError } from "./tool"
13: import { Tools } from "./tools"
14: import { makeLocationNode } from "../effect/app-node"
15:
16: export type ExecuteInput = {
17: readonly sessionID: SessionSchema.ID
18: readonly ...
...output truncated...
Full output saved to: /home/byk/.local/share/opencode/tool-output/tool_0ae9a902c001p0lQM3aaw2L4gk
+ executionID: string,
+ promotion: Promotion | undefined,
step: number,
+ ownerID: string,
recoverOverflow?: typeof compaction.compactAfterOverflow,
) {
const session = yield* getSession(sessionID)
if (session.location.directory !== location.directory || session.location.workspaceID !== location.workspaceID)
return yield* Effect.interrupt
+ const claim = { sessionID, executionID, ownerID }
+ const updateExecution = (values: SessionExecutionClaim.Values = {}) =>
+ SessionExecutionClaim.update(db, claim, values)
+ const execution = yield* db
+ .select({ phase: SessionExecutionTable.phase })
+ .from(SessionExecutionTable)
+ .where(
+ and(
+ eq(SessionExecutionTable.session_id, claim.sessionID),
+ eq(SessionExecutionTable.id, ...
24352107c74d8245fcba7f8571ba0be4b7fc514e6c73cfbf0498f0c25f29f9ba /tmp/opencode/session-recovery-final-v20.patch aa98d64abb3bf6ac0ef88a940f9c41c6eb14ffeab3c3a7846921ba01ef46643d /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server ab9408c81cc9916177641ae8e9f08624fc27b5b9 M packages/client/src/generated/types.ts M packages/core/schema.json M packages/core/src/database/migration.gen.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/run-coordinator.ts M packages/core/src/session/runner/index.ts M packages/core/src/session/runner/llm.ts M packages/core/src/session/runner/publish-llm-event.ts M packages/core/src/session/sql.ts M ...
runningA provider error can publish Step.Failed while a local tool still runs, then wait for that tool at packages/core/src/session/runner/llm.ts:399-405.
If the user interrupts during that wait:
settleCancellation sees the assistant as completed.cancelled and clears the claim at packages/core/src/session/execution/local.ts:146-149.Step.Failed projector only completes the Step; it never settles pending or running tools at packages/core/src/session/message-updater.ts:225-230.The durable assistant can therefore remain completed with a running tool after the execution claim disappears. No recovery row remains to reconcile it.
The existing test follows this exact path but only checks Step and claim rows, not tool state: packages/core/test/session-runner.test.ts:3952-3997.
Cancellation cleanup must reconcile unresolved tools after all finalizers join and before clearing the claim, even when the Step was already failed.
packages/core/test/session-runner.test.ts:3906-3949 installs a failure trigger for session.next.tool.failed.1 at lines 3921-3927. Coordinator cleanup does not publish that event; it publishes Step.Interrupted at packages/core/src/session/execution/local.ts:151-163, whose projector settles the tools.
The trigger therefore never fires, and the test does not prove that failed interruption publication retains the cancelling claim. Add a deterministic failure on session.next.step.interrupted.1 and assert that:
cancelling,Date: Sep 17, 2026 * 🔴 (08:40) User established the continuation-safety invariant “never commits continuation before unresolved hosted tools are reconciled,” tested in `packages/core/test/session-runner.test.ts:1975`. * 🔴 (08:40) User established the provider-failure invariant “never commits a Step end after the provider stream fails,” tested in `packages/core/test/session-runner.test.ts:2033`;…
Date: Sep 17, 2026 * 🔴 (08:39) User established the ownership-safety invariant “never fails interrupted tools after ownership changes,” tested in `packages/core/test/session-runner.test.ts:845`. * 🔴 (08:39) User established the finalization-safety invariant “never marks a failed Step safe while a sibling tool finalizer is active,” tested in `packages/core/test/session-runner.test.ts:3788`. * 🟡…
Date: Sep 17, 2026 * 🔴 (08:39) User established the ownership-safety invariant “never dispatches a provider after ownership changes,” tested in `packages/core/test/session-runner.test.ts:752`. * 🔴 (08:39) User established the ownership-safety invariant “never publishes streamed output after ownership changes,” tested in `packages/core/test/session-runner.test.ts:778`. * 🔴 (08:39) User establis…
Date: Sep 17, 2026 * 🔴 (08:39) User established the recovery-safety invariant “never advances the Context Epoch after ownership changes,” tested in `packages/core/test/session-projector.test.ts:2603`. * 🔴 (08:39) User established the prompt-retry invariant “never wakes execution when retrying an already promoted prompt,” tested in `packages/core/test/session-prompt.test.ts:330`. * 🔴 (08:39) Us…
Date: Sep 17, 2026 * 🔴 (08:38) User established the recovery-safety invariant “never recovers a pre-promotion claim when input commits at the recovery boundary,” tested in `packages/core/test/session-projector.test.ts:1369`. * 🔴 (08:38) User established the recovery-safety invariant “never promotes a recovery superseded before scanner validation,” tested in `packages/core/test/session-projector…
Date: Sep 17, 2026 * 🔴 (08:38) User established the recovery-safety invariant “never recovers a live execution lease,” tested in `packages/core/test/session-projector.test.ts:304`. * 🔴 (08:38) User established the recovery-safety invariant “never recovers an execution superseded by a newer assistant,” tested in `packages/core/test/session-projector.test.ts:342`. * 🔴 (08:38) User established th…
Date: Sep 17, 2026 * 🔴 (08:38) User established the execution-safety invariant “never starts a second owner while the lease is live,” tested in `packages/core/test/session-execution-local.test.ts:116`. * 🔴 (08:38) User established the execution-safety invariant “never overwrites an expired lease,” tested in `packages/core/test/session-execution-local.test.ts:139`. * 🔴 (08:38) User established …
Date: Sep 17, 2026 * 🟡 (08:37) Search of `packages/core/schema.json` returned 57 matches for session-recovery-related schema artifacts, including tables `session_execution` and `session_recovery`; columns `wake_pending` and `wake_attempts`; foreign keys `fk_session_execution_session_id_session_id_fk`, `fk_session_recovery_session_id_session_id_fk`, `fk_session_recovery_assistant_message_id_sessi…
Date: Sep 17, 2026 * 🔴 (08:37) User stated the `/doc` response should remain lazily constructed so processes that never serve it—specifically CLI and scripts—do not pay its cost at module load. * 🟡 (08:37) `packages/server/src/routes.ts` defines `applicationServices` with `Database.node`, `EventV2.node`, `httpClient`, `ToolOutputStore.cleanupNode`, `SessionV2.node`, `SessionRecovery.node`, `Per…
Date: Sep 17, 2026 * 🔴 (08:36) User directed that a newer turn supersede stale incomplete rows and that the system “never resume an older assistant projection.” This rule appears in both the session projection and runner projection logic. * 🟡 (08:36) `packages/core/src/session/context-epoch.ts` defines `SessionContextEpoch.initialize()` and `SessionContextEpoch.prepare()` around durable context…
Date: Sep 17, 2026 * 🔴 (08:36) User directed that local session-execution ownership be replaced with durable multi-node ownership when clustered. * 🟡 (08:36) `packages/core/src/session/runner/index.ts` is intended to remain orchestration over smaller collaborators rather than rebuilding the legacy implementation. * 🟡 (08:36) `packages/core/src/session/runner/index.ts` starts each recorded loca…
Date: Sep 17, 2026 * 🟡 (08:36) `packages/core/src/session/execution/local.ts` implements process-local session execution using `SessionRunCoordinator.make`; it generates a per-process `ownerID`, tracks claims in `activeClaims: Map<SessionSchema.ID, SessionExecutionClaim.Claim>`, and derives `leaseDuration` from `SESSION_EXECUTION_LEASE_MS`. * 🟡 (08:36) The drain path in `packages/core/src/sessi…
Date: Sep 17, 2026 * 🟡 (08:35) Review of `packages/core/src/session/input.ts` showed `SessionInput.admit` checks `isRecoveryInput(db, input.id)` and dies with `new LifecycleConflict({ id: input.id })` when a normal input ID conflicts with a recovery input. * 🟡 (08:35) `packages/core/src/session/input.ts` persists and evaluates `SessionInputTable.wake_pending`; its wake decision returns `true` i…
Date: Sep 17, 2026 * 🔴 (08:35) User’s execution-lease invariant states that an expired claim never renews itself; lease timestamps use node wall clocks, and `SESSION_EXECUTION_LEASE_MS` must exceed maximum deployment clock skew plus one renewal interval. * 🟡 (08:35) Review diff statistics for the 29 tracked files showed 7,385 insertions and 479 deletions; largest changes included `packages/core…
Date: Sep 17, 2026 * 🔴 (08:34) User’s repository guidance requires runtime dependencies to flow Schema → Core and Protocol → Server; Client runtime code may depend on Schema and Protocol but never Core or Server; `sdk-next` composes Client, Core, and Server. * 🔴 (08:34) User’s import style requires: never alias imports (`import { foo as bar }` and renamed imports such as `resolve as pathResolve…
Date: Sep 17, 2026 * 🔴 [requested-review] (08:32) User requested a strict READ-ONLY correctness/adversarial review of frozen v20 in `/tmp/opencode/session-recovery-v20-review`, requiring findings first with `MUST-FIX`/`CONCERN` severity and exact `file:line` evidence; if no findings, explicitly state so; response must end exactly `MERGE` or `DO-NOT-MERGE`. * 🔴 [enforced-workflow] (08:32) User p…