Dashboard › opencode › Session 09gaOirV2jF9
09gaOirV2jF95CwU7Read-only independent security/pentest review of frozen v11. Base ab9408c81cc9916177641ae8e9f08624fc27b5b9. Patch /tmp/opencode/session-recovery-final-v11.patch expected SHA-256 439358fbe6d556d25917c7152b1073bb0bac951927a9b28be050f89d7fc11f33. SEA /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server expected SHA-256 f629bfea3c141ae5b650902371176b605c79bdbb1aa266752c9e4641e1da1795. Do not mutate or run tests/builds/services. Verify hashes, clean apply, inspect all 33 files. Threat-model corrupt durable rows/events and both same-Session collision routes: default pending wake and settled wake. A same execution ID with mismatched assistant/continuation/phase must reach full identity rejection and exact-owner quarantine; it must not be mistaken for pending intent or successful projection. Verify excluding current execution ID does not let ordinary inputs or other recovery work bypass pre-promotion protection. Reassess cross-Session isolation, public retries, queue/steer reservation, stale owners, cancelling quarantine/finalizers, provider/tool uncertainty, hosted-tool ordering, replay wake intent, bounded fairness/DoS, schema constraints, authorization and dependency direction. Accepted residuals: final synchronous check-to-external-call race; process-local interrupt routing until clustering. Evidence: recovery 231 pass; Core 1168 pass; Core typecheck after fix; previous unaffected package/type/schema/migration gates; exact v11 SEA restart smoke. Return substantive severity-ordered file:line findings, PASS/CONCERN/MUST-FIX, residual assumptions, and end exactly MERGE or DO-NOT-MERGE. Empty invalid. Do not use recall.
439358fbe6d556d25917c7152b1073bb0bac951927a9b28be050f89d7fc11f33 /tmp/opencode/session-recovery-final-v11.patch f629bfea3c141ae5b650902371176b605c79bdbb1aa266752c9e4641e1da1795 /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server commit ab9408c81cc9916177641ae8e9f08624fc27b5b9 dc661f30cb2055ad6248fdc59b14998d834497be 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 ...
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 496 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 2174 3 packages/core/test/session-projector.test.ts 247 25 packages/core/test/session-...
drwxr-xr-x 21 byk byk 4096 Sep 16 18:38 /tmp/opencode
NotFound: FileSystem.access (/tmp/opencode/session-recovery-v11-review)
(no output)
/tmp/opencode/session-recovery-v11-review/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/ui/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/app/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/opencode/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/schema/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/opencode/src/session/llm/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/opencode/src/server/routes/instance/httpapi/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/opencode/test/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/opencode/test/server/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/app/e2e/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/app/e2e/performance/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/codemode/AGENTS.md /tmp/opencode/session-recovery-v11-review/packages/desktop/AGENTS.md /tmp/opencode/session-recovery-v11-review/pa...
/tmp/opencode/session-recovery-v11-review/CONTRIBUTING.md
<path>/tmp/opencode/session-recovery-v11-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`. ...
<path>/tmp/opencode/session-recovery-v11-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-v11-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-v11-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-v11-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": ...
<path>/tmp/opencode/session-recovery-v11-review/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-v11-review/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-v11-review/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-v11-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 } 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: number) ...
<path>/tmp/opencode/session-recovery-v11-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-v11-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-v11-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 } 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: const ...
<path>/tmp/opencode/session-recovery-v11-review/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. Future remote placement belongs here. ...
<path>/tmp/opencode/session-recovery-v11-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-v11-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-v11-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-v11-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: ...
No files found
/tmp/opencode/session-recovery-v11-review/packages/core/src/event.ts
Found 44 matches
/tmp/opencode/session-recovery-v11-review/packages/core/src/event.ts:
Line 122: /** Local operational projection committed atomically with a new durable event. Not replayed or serialized. */
Line 123: readonly commit?: (seq: number) => Effect.Effect<void>
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 205: function commitDurableEvent(
Line 214: commit?: (seq: number) => ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/src/event.ts</path>
<type>file</type>
<content>
200: )
201: yield* Effect.forEach(pubsub.typed.values(), PubSub.shutdown, { discard: true })
202: }),
203: )
204:
205: function commitDurableEvent(
206: definition: Definition,
207: event: Payload,
208: input?: {
209: readonly seq: number
210: readonly aggregateID: string
211: readonly ownerID?: string
212: readonly strictOwner?: boolean
213: },
214: commit?: (seq: number) => Effect.Effect<void>,
215: ) {
216: return Effect.gen(function* () {
217: const durable = definition?.durable
218: if (durable) {
219: const aggregateID = (event.data as Record<string, unknown>)[durable.aggregate]
220: if (typeof aggregateID !== "string") {
221: yield* Effect.die(
222: new ...
Found 59 matches
/tmp/opencode/session-recovery-v11-review/packages/core/test/session-projector.test.ts:
Line 440: it.effect("quarantines a malformed recovery row without blocking a valid wake", () =>
Line 494: it.effect("quarantines a full batch of poison recovery rows before redriving valid work", () =>
Line 559: it.effect("fairly redrives recovery and ordinary work beyond a full bounded batch", () =>
Line 567: const ordinarySessions = Array.from({ length: failedCount + 1 }, (_, index) =>
Line 568: SessionV2.ID.make(`ses_ordinary_failed_wake_${index.toString().padStart(3, "0")}`),
Line 577: [...recoverySessions, ...ordinarySessions].map((id) => ({
Line 599: ordinarySessions,
Line 602: id: SessionMessage.ID.make(`msg_ordinary_failed_wake_${index.toString().padStart(3, "0")}`),
Line 623: expect(firstWakes).not.toContain(ordinarySessions[failedCount])
Line 629: ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
929: it.effect("redrives durable ordinary input execution intent after a lost advisory wake", () =>
930: Effect.gen(function* () {
931: const { db } = yield* Database.Service
932: const events = yield* EventV2.Service
933: yield* db
934: .insert(ProjectTable)
935: .values({ id: Project.ID.global, worktree: AbsolutePath.make("/project"), sandboxes: [] })
936: .run()
937: yield* db
938: .insert(SessionTable)
939: .values({
940: id: sessionID,
941: project_id: Project.ID.global,
942: slug: "test",
943: directory: "/project",
944: title: "test",
945: version: "test",
946: })
947: .run()
948: yield* SessionInput.admit(db, events, {
949: id: SessionMessage.ID.make("msg_lost_ordinary_wake"),
950: ...
Found 4 matches
/tmp/opencode/session-recovery-v11-review/packages/core/test/session-runner.test.ts:
Line 2245: LLMEvent.toolCall({ id: "call-recovery", name: "echo", input: { text: "settled" } }),
/tmp/opencode/session-recovery-v11-review/packages/core/test/session-projector.test.ts:
Line 821: executionID: "recovery-settled-at-cas",
Line 834: WHEN OLD.execution_id = 'recovery-settled-at-cas'
Line 2565: const id = SessionMessage.ID.make("msg_creator_collision")
Found 71 matches
/tmp/opencode/session-recovery-final-v11.patch:
Line 4002: +import { testEffect } from "./lib/effect"
Line 4005: +const it = testEffect(Database.layerFromPath(":memory:"))
Line 4033: + it.effect("clears the claim after a successful drain", () =>
Line 4042: + it.effect("preserves the claim when its scope closes", () =>
Line 4058: + it.effect("clears the claim after explicit interruption", () =>
Line 4072: + it.effect("never starts a second owner while the lease is live", () =>
Line 4095: + it.effect("never overwrites an expired lease", () =>
Line 4122: + it.effect("never re-enters its own uncertain live lease", () =>
Line 4149: + it.effect("renews heartbeat expiry from the current clock", () =>
Line 4172: + it.effect("never revives an expired claim on heartbeat", () =>
Line 4190: + it.effect("settles cancellation before starting a pending successor", () =>
Line 4234: + it.effect("fails cancellation when cleanup loses ...
Found 7 matches
/tmp/opencode/session-recovery-v11-review/packages/core/test/session-projector.test.ts:
Line 246: phase: "continue",
Line 251: phase: "continue",
Line 1273: executionID: "conflicting-recovery-identity",
Line 1274: phase: "continue",
Line 1279: id: "conflicting-recovery-identity",
Line 1291: id: "conflicting-recovery-identity",
Line 1295: expect.objectContaining({ execution_id: "conflicting-recovery-identity", phase: "continue" }),
<path>/tmp/opencode/session-recovery-v11-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-v11-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-v11-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-v11-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) => 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-v11-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-v11-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-v11-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-v11-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-v11-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-v11-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: ...
Found 20 matches
/tmp/opencode/session-recovery-v11-review/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-v11-review/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\` ...
Found 54 matches /tmp/opencode/session-recovery-v11-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 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 1231: ...
<path>/tmp/opencode/session-recovery-v11-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 ...
Your prior result was empty and invalid. Retry the unchanged frozen v11 review using only immutable Git objects and local files. Do not use recall, Lore, or network search. You must return either substantive severity-ordered findings with exact candidate file:line evidence or the exact tool/command error that blocked inspection. Verify base ab9408c81cc9916177641ae8e9f08624fc27b5b9, patch /tmp/opencode/session-recovery-final-v11.patch SHA-256 439358fbe6d556d25917c7152b1073bb0bac951927a9b28be050f89d7fc11f33, SEA /home/byk/Code/opencode/packages/opencode/dist/server/opencode-server SHA-256 f629bfea3c141ae5b650902371176b605c79bdbb1aa266752c9e4641e1da1795, clean apply, and all 33 paths. Primary closure: for both wake_pending=true and false, a same-Session same-execution recovery row with mismatched assistant/continuation/phase must not suppress full identity rejection and exact-owner quarantine. Confirm the initial pending-intent query excludes only the current execution ID while preserving ordinary and other-recovery intent. Reassess the full security scope from the previous prompt. Accepted residuals are only the final synchronous ownership-check-to-external-call race and process-local interrupt routing until clustering. Classify PASS/CONCERN/MUST-FIX and end exactly MERGE or DO-NOT-MERGE. Empty output is invalid.
Found 6 matches
/tmp/opencode/session-recovery-v11-review/packages/server/src/handlers/session.ts:
Line 140: "session.prompt",
Line 144: .prompt({
Line 147: prompt: ctx.payload.prompt,
Line 149: resume: ctx.payload.resume,
Line 366: "session.interrupt",
Line 368: yield* session.interrupt(ctx.params.sessionID)
<path>/tmp/opencode/session-recovery-v11-review/packages/server/src/handlers/session.ts</path>
<type>file</type>
<content>
125: Effect.fn(function* (ctx) {
126: yield* session.switchModel({ sessionID: ctx.params.sessionID, model: ctx.payload.model }).pipe(
127: Effect.catchTag("Session.NotFoundError", (error) =>
128: Effect.fail(
129: new SessionNotFoundError({
130: sessionID: error.sessionID,
131: message: `Session not found: ${error.sessionID}`,
132: }),
133: ),
134: ),
135: )
136: return HttpApiSchema.NoContent.make()
137: }),
138: )
139: .handle(
140: "session.prompt",
141: Effect.fn(function* (ctx) {
142: return {
143: data: yield* session
144: .prompt({
145: sessionID: ctx.params.sessionID,
146: id: ctx.payload.id,
147: ...
<path>/tmp/opencode/session-recovery-v11-review/packages/server/src/middleware/session-location.ts</path>
<type>file</type>
<content>
1: import { Database } from "@opencode-ai/core/database/database"
2: import { LocationServiceMap } from "@opencode-ai/core/location-services"
3: import { Location } from "@opencode-ai/core/location"
4: import { AbsolutePath } from "@opencode-ai/core/schema"
5: import { SessionV2 } from "@opencode-ai/core/session"
6: import { SessionTable } from "@opencode-ai/core/session/sql"
7: import { WorkspaceV2 } from "@opencode-ai/core/workspace"
8: import { eq } from "drizzle-orm"
9: import { Effect, Layer, Schema } from "effect"
10: import { HttpRouter } from "effect/unstable/http"
11: import { HttpApiMiddleware } from "effect/unstable/httpapi"
12: import { InvalidRequestError, SessionNotFoundError } from "@opencode-ai/protocol/errors"
13: import type { LocationServices } from "../location"
14:
15: export class SessionLocationMiddleware extends ...
Found 23 matches
/tmp/opencode/session-recovery-v11-review/packages/sdk/js/src/v2/gen/types.gen.ts:
Line 24: | EventSessionNextPromptExecutionRequested
Line 874: requestExecution?: boolean
Line 983: type: "session.next.step.recovered"
Line 987: executionID: string
Line 989: phase: "ready" | "unknown" | "continue"
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 3613: executionID: string
Line 3615: phase: "ready" | "unknown" | "continue"
Line 4362: requestExecution?: boolean
Line 4366: export type SessionNextPromptExecutionRequested = {
Line 4565: type: "session.next.step.recovered"
Line 4575: ...
<path>/tmp/opencode/session-recovery-v11-review/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 12 matches
/tmp/opencode/session-recovery-v11-review/packages/sdk/openapi.json:
Line 17899: "requestExecution": {
Line 17919: "enum": ["session.next.prompt.execution_requested"]
Line 18289: "enum": ["session.next.step.recovered"]
Line 25709: "requestExecution": {
Line 25740: "enum": ["session.next.prompt.execution_requested.1"]
Line 26299: "enum": ["session.next.step.recovered.1"]
Line 28599: "requestExecution": {
Line 28622: "enum": ["session.next.prompt.execution_requested"]
Line 29190: "enum": ["session.next.step.recovered"]
Line 34811: "requestExecution": {
Line 34831: "enum": ["session.next.prompt.execution_requested"]
Line 35201: "enum": ["session.next.step.recovered"]
<path>/tmp/opencode/session-recovery-v11-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: ...
Found 50 matches
/tmp/opencode/session-recovery-v11-review/packages/core/test/database-migration.test.ts:
Line 9: import { DatabaseMigration } from "@opencode-ai/core/database/migration"
Line 10: import { migrations } from "@opencode-ai/core/database/migration.gen"
Line 11: import workspaceNameMigration from "@opencode-ai/core/database/migration/20260410174513_workspace-name"
Line 12: import sessionUsageMigration from "@opencode-ai/core/database/migration/20260510033149_session_usage"
Line 13: import normalizeStoragePathsMigration from "@opencode-ai/core/database/migration/20260601010001_normalize_storage_paths"
Line 14: import sessionMessageProjectionOrderMigration from "@opencode-ai/core/database/migration/20260603040000_session_message_projection_order"
Line 15: import eventSourcedSessionInputMigration from "@opencode-ai/core/database/migration/20260604172448_event_sourced_session_input"
Line 16: import contextEpochAgentMigration from ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/database-migration.test.ts</path>
<type>file</type>
<content>
105: test("serializes concurrent embedded initialization for one database path", async () => {
106: await using tmp = await tmpdir()
107: const filename = path.join(tmp.path, "embedded.sqlite")
108: const layers = [Database.layerFromPath(filename), Database.layerFromPath(filename)]
109:
110: await Effect.runPromise(
111: Effect.all(
112: layers.map((layer) => Effect.scoped(Layer.build(layer))),
113: { concurrency: "unbounded" },
114: ),
115: )
116: })
117: if (process.platform === "linux") {
118: test("declared schema has no ungenerated migrations", async () => {
119: const result = await $`bun ${fileURLToPath(new URL("../script/migration.ts", import.meta.url))} --check`
120: .quiet()
121: .nothrow()
122: expect(result.exitCode, result.stderr.toString()).toBe(0)
123: ...
Found 55 matches
/tmp/opencode/session-recovery-v11-review/packages/core/test/session-prompt.test.ts:
Line 19: import { SessionRecovery } from "@opencode-ai/core/session/recovery"
Line 26: const wakeCalls: SessionV2.ID[] = []
Line 40: wake: (sessionID) =>
Line 42: wakeCalls.push(sessionID)
Line 134: wake: (id) => Effect.sync(() => wakeCalls.push(id)).pipe(Effect.asVoid),
Line 152: wakeCalls.length = 0
Line 155: expect(wakeCalls).toEqual([])
Line 265: wakeCalls.length = 0
Line 271: expect(wakeCalls).toEqual([])
Line 310: it.effect("wakes execution when an exact prompt retry recovers a committed message", () =>
Line 321: wakeCalls.length = 0
Line 326: expect(wakeCalls).toEqual([sessionID])
Line 330: it.effect("never wakes execution when retrying an already promoted prompt", () =>
Line 349: wakeCalls.length = 0
Line 358: expect(wakeCalls).toEqual([])
Line 362: ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-prompt.test.ts</path>
<type>file</type>
<content>
300:
301: const first = yield* session.prompt(input)
302: const retried = yield* session.prompt(input)
303:
304: expect(retried).toEqual(first)
305: expect(yield* session.messages({ sessionID })).toEqual([])
306: expect(yield* admittedCount).toBe(1)
307: }),
308: )
309:
310: it.effect("wakes execution when an exact prompt retry recovers a committed message", () =>
311: Effect.gen(function* () {
312: yield* setup
313: const session = yield* SessionV2.Service
314: const input = {
315: sessionID,
316: id: messageID,
317: prompt: Prompt.make({ text: "Recover committed prompt" }),
318: resume: false,
319: }
320: const first = yield* session.prompt(input)
321: wakeCalls.length = 0
322:
323: const retried = yield* session.prompt({ ...input, resume: ...
<path>/tmp/opencode/session-recovery-v11-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 ...
<path>/tmp/opencode/session-recovery-v11-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-v11-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 15 matches
/tmp/opencode/session-recovery-v11-review/packages/core/test/session-runner.test.ts:
Line 619: it.effect("redrives only the synthetic recovery continuation", () =>
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 1495: it.effect("keeps automatic compaction unknown until Compaction.Ended commits", () =>
Line 1975: it.effect("never commits continuation before unresolved hosted tools are reconciled", () =>
Line 2027: it.effect("never commits a Step end after the provider stream fails", () =>
Line 2049: it.effect("keeps a running assistant recoverable when Step failure publication defects", () =>
Line 2085: it.effect("never records assistant ...
<path>/tmp/opencode/session-recovery-v11-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: ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
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: "compaction",
1467: summary: "## Objective\n- Preserve the task",
1468: })
1469:
1470: requests.length = 0
1471: executions.length = 0
1472: responses = [
1473: fragmentFixture("text", "text-summary-2", ["## Objective\n- Preserve the updated task"]).completeEvents,
1474: fragmentFixture("text", "text-final-2", ["Continued ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
1940: LLMEvent.stepFinish({ index: 0, reason: "stop" }),
1941: LLMEvent.finish({ reason: "stop" }),
1942: ],
1943: ]
1944:
1945: yield* session.resume(sessionID)
1946:
1947: expect(requests).toHaveLength(2)
1948: expect(requests[1]?.messages.map((message) => message.role)).toEqual(["user", "assistant", "tool"])
1949: expect(authorizations).toMatchObject([{ sessionID, toolCallID: "call-echo" }])
1950: expect(executions).toEqual(["hello"])
1951: expect(yield* session.context(sessionID)).toMatchObject([
1952: { type: "user", text: "Echo this" },
1953: {
1954: type: "assistant",
1955: finish: "tool-calls",
1956: content: [
1957: {
1958: type: "tool",
1959: id: "call-echo",
1960: name: ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
3540: }),
3541: })
3542: yield* session.prompt({ sessionID, prompt: Prompt.make({ text: "Call declined" }), resume: false })
3543:
3544: requests.length = 0
3545: response = [
3546: LLMEvent.stepStart({ index: 0 }),
3547: LLMEvent.toolCall({ id: "call-declined", name: "declined", input: {} }),
3548: LLMEvent.stepFinish({ index: 0, reason: "tool-calls" }),
3549: LLMEvent.finish({ reason: "tool-calls" }),
3550: ]
3551:
3552: const exit = yield* session.resume(sessionID).pipe(Effect.exit)
3553:
3554: expect(exit._tag).toBe("Failure")
3555: if (exit._tag === "Failure") expect(Cause.hasInterruptsOnly(exit.cause)).toBe(true)
3556: expect(requests).toHaveLength(1)
3557: expect(yield* session.context(sessionID)).toMatchObject([
3558: { type: "user", text: "Call ...
No files found
No files found
Found 1 matches /tmp/opencode/session-recovery-v11-review/packages/server/src/handlers/pty.ts: Line 216: Effect.ensuring(Effect.sync(() => attachment.detach())),
<path>/tmp/opencode/session-recovery-v11-review/packages/opencode/src/server/routes/instance/httpapi/handlers/sync.ts</path>
<type>file</type>
<content>
1: import { Workspace } from "@/control-plane/workspace"
2: import * as InstanceState from "@/effect/instance-state"
3: import { Session } from "@/session/session"
4: import { Database } from "@opencode-ai/core/database/database"
5: import { EventV2 } from "@opencode-ai/core/event"
6: import { EventV2Bridge } from "@/event-v2-bridge"
7: import { EventTable } from "@opencode-ai/core/event/sql"
8: import { asc } from "drizzle-orm"
9: import { and } from "drizzle-orm"
10: import { eq } from "drizzle-orm"
11: import { lte } from "drizzle-orm"
12: import { not } from "drizzle-orm"
13: import { or } from "drizzle-orm"
14: import { Effect, Scope } from "effect"
15: import { HttpApiBuilder, HttpApiError } from "effect/unstable/httpapi"
16: import { InstanceHttpApi } from "../api"
17: import { HistoryPayload, ReplayPayload, SessionPayload } ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
2470: const compactionID = SessionMessage.ID.create()
2471: yield* events.publish(SessionEvent.Compaction.Started, {
2472: sessionID,
2473: messageID: compactionID,
2474: timestamp: created,
2475: reason: "manual",
2476: })
2477: yield* events.publish(SessionEvent.Compaction.Delta, {
2478: sessionID,
2479: messageID: compactionID,
2480: timestamp: created,
2481: text: "partial",
2482: })
2483: expect(
2484: yield* db
2485: .select({ id: EventTable.id })
2486: .from(EventTable)
2487: .where(eq(EventTable.type, SessionEvent.Compaction.Delta.type))
2488: .all()
2489: .pipe(Effect.orDie),
2490: ).toEqual([])
2491: expect(
2492: yield* db
2493: .select({ id: ...
<path>/tmp/opencode/session-recovery-v11-review/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
780: SessionExecution.Service,
781: SessionExecution.Service.of({
782: ...recoveryExecution,
783: wake: () => Effect.sync(() => wakes++).pipe(Effect.asVoid),
784: }),
785: ),
786: )
787:
788: expect(wakes).toBe(1)
789: expect(yield* db.select({ wakeAttempts: SessionTable.wake_attempts }).from(SessionTable).get()).toEqual({
790: wakeAttempts: 1,
791: })
792: expect(yield* db.get<{ count: number }>(sql`SELECT count FROM ordinary_redrive_input_updates`)).toEqual({ count: 0 })
793: }),
794: )
795:
796: it.effect("never wakes work settled between selection and redrive CAS", () =>
797: Effect.gen(function* () {
798: const { db } = yield* Database.Service
799: const events = yield* EventV2.Service
800: const ordinarySessionID = ...
ab9408c81cc9916177641ae8e9f08624fc27b5b9 d3323b963b9ef2de41a7ff9884299c74b93886ba
ab9408c81cc9916177641ae8e9f08624fc27b5b9 (tree d3323b963b9ef2de41a7ff9884299c74b93886ba).439358fbe6d556d25917c7152b1073bb0bac951927a9b28be050f89d7fc11f33.f629bfea3c141ae5b650902371176b605c79bdbb1aa266752c9e4641e1da1795.The scanner rejects a superseded execution only when assistant_message_id is non-null:
packages/core/src/session/recovery.ts:142-156 loads the latest assistant, but line 152 gates the identity comparison with claim.assistant_message_id !== null.packages/core/src/session/recovery.ts:157-169 then emits an assistant-less recovery for every continue claim and every claim whose assistant ID is null.Assistant-less recoverable states are normal:
packages/core/src/session/runner/llm.ts:281-284 records automatic compaction continuation as phase: "continue", assistant_message_id: null.packages/core/src/session/runner/llm.ts:362-365 records pre-assistant provider uncertainty with a null assistant ID.packages/core/src/session/runner/llm.ts:385-389 does the same for overflow compaction continuation.A corrupt or replayed newer Step.Started event inserted before recovery does not stop these claims:
packages/core/src/session/projector.ts:424-440 validates latest-assistant identity only when the recovery event ...