Session 0t3bcaq7M5JS

/home/byk/Code/opencode/AGENTS.md
/home/byk/Code/opencode/packages/codemode/AGENTS.md
/home/byk/Code/opencode/packages/session-ui/AGENTS.md
/home/byk/Code/opencode/packages/schema/AGENTS.md
/home/byk/Code/opencode/packages/effect-drizzle-sqlite/AGENTS.md
/home/byk/Code/opencode/packages/llm/AGENTS.md
/home/byk/Code/opencode/packages/opencode/AGENTS.md
/home/byk/Code/opencode/packages/opencode/test/AGENTS.md
/home/byk/Code/opencode/packages/stats/AGENTS.md
/home/byk/Code/opencode/packages/core/src/tool/AGENTS.md
/home/byk/Code/opencode/packages/ui/AGENTS.md
/home/byk/Code/opencode/packages/opencode/test/server/AGENTS.md
/home/byk/Code/opencode/packages/opencode/src/session/llm/AGENTS.md
/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/AGENTS.md
/home/byk/Code/opencode/packages/app/AGENTS.md
/home/byk/Code/opencode/packages/app/e2e/AGENTS.md
/home/byk/Code/opencode/packages/app/e2e/performance/AGENTS.md
/home/byk/Code/opencode/packages/desktop/AGENTS.md

/home/byk/Code/opencode/CONTRIBUTING.md

/home/byk/Code/opencode/packages/sdk-next/tsconfig.json
/home/byk/Code/opencode/packages/sdk-next/test/import-boundaries.test.ts
/home/byk/Code/opencode/packages/sdk-next/test/embedded.test.ts
/home/byk/Code/opencode/packages/sdk-next/sst-env.d.ts
/home/byk/Code/opencode/packages/sdk-next/src/opencode.ts
/home/byk/Code/opencode/packages/sdk-next/src/tool.ts
/home/byk/Code/opencode/packages/sdk-next/src/index.ts
/home/byk/Code/opencode/packages/sdk-next/package.json
/home/byk/Code/opencode/packages/schema/tsconfig.json
/home/byk/Code/opencode/packages/schema/test/v1-isolation.test.ts
/home/byk/Code/opencode/packages/schema/test/legacy-event.test.ts
/home/byk/Code/opencode/packages/schema/test/event.test.ts
/home/byk/Code/opencode/packages/schema/test/event-manifest.test.ts
/home/byk/Code/opencode/packages/schema/test/contract-hygiene.test.ts
/home/byk/Code/opencode/packages/schema/test/compatibility.test.ts
/home/byk/Code/opencode/packages/schema/sst-env.d.ts
/home/byk/Code/opencode/pac...

/home/byk/Code/opencode/packages/core/src/session/projector.ts
/home/byk/Code/opencode/packages/core/src/session/compaction.ts
/home/byk/Code/opencode/packages/core/src/session/todo.ts
/home/byk/Code/opencode/packages/core/src/session/store.ts
/home/byk/Code/opencode/packages/core/src/session/sql.ts
/home/byk/Code/opencode/packages/core/src/session/schema.ts
/home/byk/Code/opencode/packages/core/src/session/run-coordinator.ts
/home/byk/Code/opencode/packages/core/src/session/revert.ts
/home/byk/Code/opencode/packages/core/src/session/prompt.ts
/home/byk/Code/opencode/packages/core/src/session/message.ts
/home/byk/Code/opencode/packages/core/src/session/message-updater.ts
/home/byk/Code/opencode/packages/core/src/session/input.ts
/home/byk/Code/opencode/packages/core/src/session/info.ts
/home/byk/Code/opencode/packages/core/src/session/history.ts
/home/byk/Code/opencode/packages/core/src/session/execution.ts
/home/byk/Code/opencode/packages/core/src/session/event.ts
/home/byk/Code/openc...

/home/byk/Code/opencode/packages/core/test/session-runner.test.ts
/home/byk/Code/opencode/packages/core/test/session-projector.test.ts
/home/byk/Code/opencode/packages/core/test/session-compaction.test.ts
/home/byk/Code/opencode/packages/core/test/session-runner-tool-registry.test.ts
/home/byk/Code/opencode/packages/core/test/session-runner-recorded.test.ts
/home/byk/Code/opencode/packages/core/test/session-prompt.test.ts
/home/byk/Code/opencode/packages/core/test/session-history.test.ts
/home/byk/Code/opencode/packages/core/test/session-create.test.ts
/home/byk/Code/opencode/packages/core/test/move-session.test.ts
/home/byk/Code/opencode/packages/core/test/session-tool-progress.test.ts
/home/byk/Code/opencode/packages/core/test/session-todo.test.ts
/home/byk/Code/opencode/packages/core/test/session-runner-tool-events.test.ts
/home/byk/Code/opencode/packages/core/test/session-runner-model.test.ts
/home/byk/Code/opencode/packages/core/test/session-runner-message.test.ts
/home/byk/Code/o...

/home/byk/Code/opencode/packages/server/src/routes.ts
/home/byk/Code/opencode/packages/server/src/auth.ts
/home/byk/Code/opencode/packages/server/src/pty-environment.ts
/home/byk/Code/opencode/packages/server/src/location.ts
/home/byk/Code/opencode/packages/server/src/handlers.ts
/home/byk/Code/opencode/packages/server/src/api.ts
/home/byk/Code/opencode/packages/server/src/cors.ts
/home/byk/Code/opencode/packages/server/src/middleware/session-location.ts
/home/byk/Code/opencode/packages/server/src/middleware/schema-error.ts
/home/byk/Code/opencode/packages/server/src/middleware/authorization.ts
/home/byk/Code/opencode/packages/server/src/handlers/skill.ts
/home/byk/Code/opencode/packages/server/src/handlers/session.ts
/home/byk/Code/opencode/packages/server/src/handlers/reference.ts
/home/byk/Code/opencode/packages/server/src/handlers/question.ts
/home/byk/Code/opencode/packages/server/src/handlers/pty.ts
/home/byk/Code/opencode/packages/server/src/handlers/provider.ts
/home/byk/Code/o...

<skill_content name="effect">
# Skill: effect

# Effect

This codebase uses Effect for typed, composable TypeScript services, schemas, and workflows.

## Source Of Truth

Use the current Effect v4 / effect-smol source, not memory or older Effect v2/v3 examples.

1. If `.opencode/references/effect-smol` is missing, clone `https://github.com/Effect-TS/effect-smol` there. Do this in the project, not in the skill folder.
2. Search `.opencode/references/effect-smol` for exact APIs, examples, tests, and naming patterns before answering or implementing Effect-specific code.
3. Also inspect existing repo code for local house style before introducing new patterns.
4. Prefer answers and implementations backed by specific source files or nearby repo examples.

## Guidelines

- Prefer current Effect v4 APIs and project-local patterns over old blog posts, examples, or package-memory guesses.
- Use `Effect.gen(function* () { ... })` for multi-step workflows.
- Use `Effect.fn("Name")` or ...

<path>/home/byk/Code/opencode/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>/home/byk/Code/opencode/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 issue`](https://github.com/anomalyco/opencode/issues?q=is%3Aissue%20state%3Aopen%20label%3A%22good%20first%20issue%22)
19: - ...

<path>/home/byk/Code/opencode/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:     "random": "echo ...

<path>/home/byk/Code/opencode/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": "./src/database/sqlite.bun.ts",
28:       ...

<path>/home/byk/Code/opencode/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>/home/byk/Code/opencode/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>/home/byk/Code/opencode/packages/schema/src/session.ts</path>
<type>file</type>
<content>
1: export * as Session from "./session"
2: 
3: import { Schema } from "effect"
4: import { Agent } from "./agent"
5: import { Location } from "./location"
6: import { Model } from "./model"
7: import { Project } from "./project"
8: import { DateTimeUtcFromMillis, optional, RelativePath } from "./schema"
9: import { SessionEvent } from "./session-event"
10: import { SessionID } from "./session-id"
11: import { Revert } from "./revert"
12: 
13: export const ID = SessionID
14: export type ID = SessionID
15: 
16: export const Event = SessionEvent
17: 
18: export interface Info extends Schema.Schema.Type<typeof Info> {}
19: export const Info = Schema.Struct({
20:   id: ID,
21:   parentID: ID.pipe(optional),
22:   projectID: Project.ID,
23:   agent: Agent.ID.pipe(optional),
24:   model: Model.Ref.pipe(optional),
25:   cost: Schema.Finite,
26:   tokens: Schema.Struct({
27:     input: ...

<path>/home/byk/Code/opencode/packages/schema/src/session-message.ts</path>
<type>file</type>
<content>
1: export * as SessionMessage from "./session-message"
2: 
3: import { Schema } from "effect"
4: import { optional } from "./schema"
5: import { ProviderMetadata, ToolContent } from "./llm"
6: import { Model } from "./model"
7: import { FileAttachment, Prompt } from "./prompt"
8: import { DateTimeUtcFromMillis, RelativePath, statics } from "./schema"
9: import { SessionID } from "./session-id"
10: import { ascending } from "./identifier"
11: 
12: export const ID = Schema.String.check(Schema.isStartsWith("msg_")).pipe(
13:   Schema.brand("Session.Message.ID"),
14:   statics((schema) => ({ create: () => schema.make("msg_" + ascending()) })),
15: )
16: export type ID = typeof ID.Type
17: 
18: export interface UnknownError extends Schema.Schema.Type<typeof UnknownError> {}
19: export const UnknownError = Schema.Struct({
20:   type: Schema.Literal("unknown"),
21:   message: ...

<path>/home/byk/Code/opencode/packages/schema/src/session-input.ts</path>
<type>file</type>
<content>
1: export * as SessionInput from "./session-input"
2: 
3: import { Schema } from "effect"
4: import { optional } from "./schema"
5: import { Prompt } from "./prompt"
6: import { DateTimeUtcFromMillis, NonNegativeInt } from "./schema"
7: import { SessionDelivery } from "./session-delivery"
8: import { SessionID } from "./session-id"
9: import { SessionMessage } from "./session-message"
10: 
11: export const Delivery = SessionDelivery.Delivery
12: export type Delivery = SessionDelivery.Delivery
13: 
14: export interface Admitted extends Schema.Schema.Type<typeof Admitted> {}
15: export const Admitted = Schema.Struct({
16:   admittedSeq: NonNegativeInt,
17:   id: SessionMessage.ID,
18:   sessionID: SessionID,
19:   prompt: Prompt,
20:   delivery: Delivery,
21:   timeCreated: DateTimeUtcFromMillis,
22:   promotedSeq: NonNegativeInt.pipe(optional),
23: }).annotate({ identifier: ...

<path>/home/byk/Code/opencode/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 Source extends ...

<path>/home/byk/Code/opencode/packages/schema/src/session-event.ts</path>
<type>file</type>
<content>
361:     ...options,
362:     schema: {
363:       ...ToolBase,
364:       error: UnknownError,
365:       result: Schema.Unknown.pipe(optional),
366:       provider: Schema.Struct({
367:         executed: Schema.Boolean,
368:         metadata: ProviderMetadata.pipe(optional),
369:       }),
370:     },
371:   })
372:   export type Failed = typeof Failed.Type
373: }
374: 
375: export const RetryError = Schema.Struct({
376:   message: Schema.String,
377:   statusCode: Schema.Finite.pipe(optional),
378:   isRetryable: Schema.Boolean,
379:   responseHeaders: Schema.Record(Schema.String, Schema.String).pipe(optional),
380:   responseBody: Schema.String.pipe(optional),
381:   metadata: Schema.Record(Schema.String, Schema.String).pipe(optional),
382: }).annotate({
383:   identifier: "session.next.retry_error",
384: })
385: export interface RetryError extends Schema.Schema.Type<typeof ...

<path>/home/byk/Code/opencode/packages/core/src/session/schema.ts</path>
<type>file</type>
<content>
1: export * as SessionSchema from "./schema"
2: 
3: import { Session } from "@opencode-ai/schema/session"
4: 
5: export const ID = Session.ID
6: export type ID = typeof ID.Type
7: 
8: export const Info = Session.Info
9: export type Info = Session.Info

(End of file - total 9 lines)
</content>

<path>/home/byk/Code/opencode/packages/core/src/session/sql.ts</path>
<type>file</type>
<content>
1: import { sqliteTable, text, integer, index, primaryKey, real, uniqueIndex } from "drizzle-orm/sqlite-core"
2: import * as DatabasePath from "../database/path"
3: import { ProjectTable } from "../project/sql"
4: import type { SessionMessage } from "./message"
5: import type { Prompt } from "./prompt"
6: import type { SessionInput } from "./input"
7: import type { Snapshot } from "../snapshot"
8: import { PermissionV1 } from "../v1/permission"
9: import { ProjectV2 } from "../project"
10: import type { SessionSchema } from "./schema"
11: import type { MessageID, PartID, SessionV1 } from "../v1/session"
12: import { WorkspaceV2 } from "../workspace"
13: import { Timestamps } from "../database/schema.sql"
14: import type { SystemContext } from "../system-context/index"
15: import { AgentV2 } from "../agent"
16: import type { Revert } from "@opencode-ai/schema/revert"
17: 
18: type ...

<path>/home/byk/Code/opencode/packages/core/src/session/store.ts</path>
<type>file</type>
<content>
1: export * as SessionStore from "./store"
2: 
3: import { eq } from "drizzle-orm"
4: import { Context, Effect, Layer, Schema } from "effect"
5: import { Database } from "../database/database"
6: import { makeGlobalNode } from "../effect/app-node"
7: import { SessionHistory } from "./history"
8: import { MessageDecodeError } from "./error"
9: import { SessionMessage } from "./message"
10: import { SessionSchema } from "./schema"
11: import { SessionMessageTable, SessionTable } from "./sql"
12: import { fromRow } from "./info"
13: 
14: export interface Interface {
15:   readonly get: (sessionID: SessionSchema.ID) => Effect.Effect<SessionSchema.Info | undefined>
16:   readonly context: (sessionID: SessionSchema.ID) => Effect.Effect<SessionMessage.Message[], MessageDecodeError>
17:   readonly runnerContext: (
18:     sessionID: SessionSchema.ID,
19:     baselineSeq: number,
20:   ) => ...

<path>/home/byk/Code/opencode/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 { WorkspaceV2 } from "../workspace"
15: import { MessageTable, PartTable, SessionInputTable, SessionMessageTable, SessionTable } from "./sql"
16: import type { DeepMutable } from "../schema"
17: 
18: type DatabaseService = Database.Interface["db"]
19: 
20: ...

<path>/home/byk/Code/opencode/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: 
6: export type MemoryState = {
7:   messages: SessionMessage.Message[]
8: }
9: 
10: export interface Adapter {
11:   readonly getCurrentAssistant: () => Effect.Effect<SessionMessage.Assistant | undefined>
12:   readonly getAssistant: (messageID: SessionMessage.ID) => Effect.Effect<SessionMessage.Assistant | undefined>
13:   readonly getCurrentShell: (callID: string) => Effect.Effect<SessionMessage.Shell | undefined>
14:   readonly updateAssistant: (assistant: SessionMessage.Assistant) => Effect.Effect<void>
15:   readonly updateShell: (shell: SessionMessage.Shell) => Effect.Effect<void>
16:   readonly appendMessage: (message: SessionMessage.Message) => Effect.Effect<void>
17: }
18: 
19: ...

<path>/home/byk/Code/opencode/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>

<path>/home/byk/Code/opencode/packages/core/src/session/input.ts</path>
<type>file</type>
<content>
1: export * as SessionInput from "./input"
2: 
3: import { and, asc, eq, isNull, lte } from "drizzle-orm"
4: import { DateTime, Effect, Schema } from "effect"
5: import { Admitted, Delivery } from "@opencode-ai/schema/session-input"
6: import type { Database } from "../database/database"
7: import type { EventV2 } from "../event"
8: import { SessionEvent } from "./event"
9: import { SessionMessage } from "./message"
10: import { Prompt } from "./prompt"
11: import { SessionSchema } from "./schema"
12: import { SessionInputTable, SessionMessageTable } from "./sql"
13: 
14: type DatabaseService = Database.Interface["db"]
15: 
16: export { Admitted, Delivery }
17: 
18: const decodePrompt = Schema.decodeUnknownSync(Prompt)
19: const encodePrompt = Schema.encodeSync(Prompt)
20: 
21: const fromRow = (row: typeof SessionInputTable.$inferSelect): Admitted =>
22:   Admitted.make({
23:     ...

<path>/home/byk/Code/opencode/packages/core/src/session/prompt.ts</path>
<type>file</type>
<content>
1: export { AgentAttachment, FileAttachment, Prompt, Source } from "@opencode-ai/schema/prompt"

(End of file - total 1 lines)
</content>

/home/byk/Code/opencode/packages/core/src/session.ts

<path>/home/byk/Code/opencode/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>/home/byk/Code/opencode/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 { ContextSnapshotDecodeError, MessageDecodeError } from "../error"
7: import { SessionRunnerModel } from "./model"
8: import type { SystemContext } from "../../system-context/index"
9: import type { ToolOutputStore } from "../../tool-output-store"
10: 
11: export type RunError =
12:   | LLMError
13:   | SessionRunnerModel.Error
14:   | MessageDecodeError
15:   | ContextSnapshotDecodeError
16:   | SystemContext.InitializationBlocked
17:   | ToolOutputStore.Error
18: 
19: /** Runs one local continuation from already-recorded Session history. */
20: export interface Interface {
21:   /** Drains eligible durable work. ...

Found 3 matches
/home/byk/Code/opencode/packages/core/src/session/runner/llm.ts:
  Line 173:     const runTurnAttempt = Effect.fn("SessionRunner.runTurn")(function* (

  Line 390:     const run = Effect.fn("SessionRunner.run")(function* (input: {


/home/byk/Code/opencode/packages/core/src/session/execution/local.ts:
  Line 20:         return yield* SessionRunner.Service.use((runner) => runner.run({ sessionID, force })).pipe(

<path>/home/byk/Code/opencode/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, FiberSet, Layer, Option, Semaphore, Stream } from "effect"
12: import { AgentV2 } from "../../agent"
13: import { Config } from "../../config"
14: import { Database } from "../../database/database"
15: import { EventV2 } from "../../event"
16: import { Location } from "../../location"
17: import { ModelV2 } from "../../model"
18: import { PermissionV2 } from "../../permission"
19: import { ProviderV2 } from "../../provider"
20: import { QuestionV2 } from "../../question"
21: import { SystemContext } from "../../system-context/index"
22: import { SystemContextRegistry } from "../../system-context/registry"
23: import { SkillGuidance } from ...

<path>/home/byk/Code/opencode/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: }
15: 
16: const safe = (value: number | undefined) => Math.max(0, Number.isFinite(value) ? (value ?? 0) : 0)
17: 
18: const tokens = (usage: Usage | undefined) => {
19:   const reasoning = safe(usage?.reasoningTokens)
20:   const read = safe(usage?.cacheReadInputTokens)
21:   const write = safe(usage?.cacheWriteInputTokens)
22:   ...

<path>/home/byk/Code/opencode/packages/core/src/session/runner/to-llm-message.ts</path>
<type>file</type>
<content>
1: import {
2:   Message,
3:   ToolCallPart,
4:   ToolOutput,
5:   ToolResultPart,
6:   type ContentPart,
7:   type Model,
8:   type ProviderMetadata,
9: } from "@opencode-ai/llm"
10: import { SessionMessage } from "../message"
11: import type { FileAttachment } from "../prompt"
12: 
13: const media = (file: FileAttachment): ContentPart => ({
14:   type: "media",
15:   mediaType: file.mime,
16:   data: file.uri,
17:   filename: file.name,
18:   metadata: file.description === undefined ? undefined : { description: file.description },
19: })
20: 
21: const toolInput = (tool: SessionMessage.AssistantTool) => {
22:   if (tool.state.status !== "pending") return tool.state.input
23:   try {
24:     return JSON.parse(tool.state.input) as unknown
25:   } catch {
26:     return tool.state.input
27:   }
28: }
29: 
30: const toolCall = (tool: SessionMessage.AssistantTool, ...

<path>/home/byk/Code/opencode/packages/core/src/session/execution.ts</path>
<type>file</type>
<content>
1: export * as SessionExecution from "./execution"
2: 
3: import { Context, Effect, Layer } from "effect"
4: import { LayerNode } from "../effect/layer-node"
5: import { Node } from "../effect/app-node"
6: import { SessionRunner } from "./runner/index"
7: import { SessionSchema } from "./schema"
8: 
9: export interface Interface {
10:   /** Snapshots active execution owned by this process. */
11:   readonly active: Effect.Effect<ReadonlySet<SessionSchema.ID>>
12:   /** Starts execution while idle or joins the active execution. */
13:   readonly resume: (sessionID: SessionSchema.ID) => Effect.Effect<void, SessionRunner.RunError>
14:   /** Registers newly recorded work. Repeated wakeups may coalesce. */
15:   readonly wake: (sessionID: SessionSchema.ID) => Effect.Effect<void>
16:   /** Interrupt active work owned by this process. Idle interruption is a no-op. ...

<path>/home/byk/Code/opencode/packages/core/src/session/execution/local.ts</path>
<type>file</type>
<content>
1: import { Cause, Effect, Layer } from "effect"
2: import { LocationServiceMap } from "../../location-service-map"
3: import { makeGlobalNode } from "../../effect/app-node"
4: import { SessionRunCoordinator } from "../run-coordinator"
5: import { SessionRunner } from "../runner"
6: import { SessionSchema } from "../schema"
7: import { SessionStore } from "../store"
8: import { SessionExecution } from "../execution"
9: 
10: /** Current-process routing for implicit-local Locations. Future remote placement belongs here. */
11: const layer = Layer.effect(
12:   SessionExecution.Service,
13:   Effect.gen(function* () {
14:     const store = yield* SessionStore.Service
15:     const locations = yield* LocationServiceMap.Service
16:     const coordinator = yield* SessionRunCoordinator.make<SessionSchema.ID, SessionRunner.RunError>({
17:       drain: Effect.fnUntraced(function* ...

Found 100 matches (more matches available)
/home/byk/Code/opencode/packages/sdk-next/src/opencode.ts:
  Line 2: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"

  Line 3: import { LayerNode } from "@opencode-ai/core/effect/layer-node"


/home/byk/Code/opencode/packages/core/test/session-runner.test.ts:
  Line 14: import { makeLocationNode } from "@opencode-ai/core/effect/app-node"

  Line 15: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"

  Line 16: import { LayerNodePlatform } from "@opencode-ai/core/effect/app-node-platform"

  Line 17: import { LayerNode } from "@opencode-ai/core/effect/layer-node"

  Line 275:       SessionV2.node,


/home/byk/Code/opencode/packages/core/test/session-projector.test.ts:
  Line 5: import { LayerNode } from "@opencode-ai/core/effect/layer-node"

  Line 6: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"

  Line 28: const sessionsLayer = ...

<path>/home/byk/Code/opencode/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 { ToolOutputStore } from ...

/home/byk/Code/opencode/packages/core/src/event/sql.ts

<path>/home/byk/Code/opencode/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 = Definition> = ...

<path>/home/byk/Code/opencode/packages/core/src/event/sql.ts</path>
<type>file</type>
<content>
1: import { sqliteTable, text, integer, index, uniqueIndex } from "drizzle-orm/sqlite-core"
2: import type { EventV2 } from "../event"
3: 
4: export const EventSequenceTable = sqliteTable("event_sequence", {
5:   aggregate_id: text().notNull().primaryKey(),
6:   seq: integer().notNull(),
7:   owner_id: text(),
8: })
9: 
10: export const EventTable = sqliteTable(
11:   "event",
12:   {
13:     id: text().$type<EventV2.ID>().primaryKey(),
14:     aggregate_id: text()
15:       .notNull()
16:       .references(() => EventSequenceTable.aggregate_id, { onDelete: "cascade" }),
17:     seq: integer().notNull(),
18:     type: text().notNull(),
19:     data: text({ mode: "json" }).$type<Record<string, unknown>>().notNull(),
20:   },
21:   (table) => [
22:     uniqueIndex("event_aggregate_seq_idx").on(table.aggregate_id, table.seq),
23:     index("event_aggregate_type_seq_idx").on(table.aggregate_id, ...

No files found

/home/byk/Code/opencode/packages/core/script/migration.ts
/home/byk/Code/opencode/packages/core/test/database-migration.test.ts
/home/byk/Code/opencode/packages/core/src/database/migration.ts
/home/byk/Code/opencode/packages/core/src/database/migration.gen.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260511000411_data_migration_state.ts
/home/byk/Code/opencode/packages/core/src/data-migration.sql.ts

No files found

No files found

<path>/home/byk/Code/opencode/packages/core/src/database/migration.ts</path>
<type>file</type>
<content>
1: export * as DatabaseMigration from "./migration"
2: 
3: import { sql } from "drizzle-orm"
4: import { Effect, Semaphore } from "effect"
5: import type { EffectDrizzleSqlite } from "@opencode-ai/effect-drizzle-sqlite"
6: import { migrations } from "./migration.gen"
7: import schema from "./schema.gen"
8: 
9: type Database = EffectDrizzleSqlite.EffectSQLiteDatabase
10: type Transaction = Parameters<Parameters<Database["transaction"]>[0]>[0]
11: const lock = Semaphore.makeUnsafe(1)
12: 
13: export type Migration = {
14:   id: string
15:   up: (tx: Transaction) => Effect.Effect<void, unknown>
16: }
17: 
18: export function apply(db: Database) {
19:   return lock.withPermit(
20:     Effect.gen(function* () {
21:       const tables = yield* db.all<{ name: string }>(
22:         sql`SELECT name FROM sqlite_master WHERE type = 'table' AND name NOT LIKE 'sqlite_%'`,
23:       )
24:       ...

<path>/home/byk/Code/opencode/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 NULL
24:         ...

<path>/home/byk/Code/opencode/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:     import("./migration/20260413175956_chief_energizer"),
17:     ...

/home/byk/Code/opencode/packages/core/src/database/migration/20260410174513_workspace-name.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260622202450_simplify_session_input.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260622170816_reset_v2_session_state.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260622142730_simplify_session_context_epoch.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260612174303_project_dir_strategy.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260611192811_lush_chimera.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260611035744_credential.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260605042240_add_context_epoch_agent.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260605003541_add_session_context_snapshot.ts
/home/byk/Code/opencode/packages/core/src/database/migration/20260604172448_event_sourced_session_i...

<path>/home/byk/Code/opencode/packages/core/script/migration.ts</path>
<type>file</type>
<content>
1: #!/usr/bin/env bun
2: 
3: import { $ } from "bun"
4: import fs from "fs/promises"
5: import os from "os"
6: import path from "path"
7: import { pathToFileURL } from "url"
8: import { parseArgs } from "util"
9: 
10: const root = path.resolve(import.meta.dirname, "../../..")
11: const snapshot = path.join(root, "packages/core/schema.json")
12: const tsDir = path.join(root, "packages/core/src/database/migration")
13: const registry = path.join(root, "packages/core/src/database/migration.gen.ts")
14: const schema = path.join(root, "packages/core/src/database/schema.gen.ts")
15: const args = parseArgs({
16:   args: process.argv.slice(2),
17:   options: {
18:     check: { type: "boolean" },
19:     name: { type: "string" },
20:   },
21: })
22: 
23: if (args.values.check) {
24:   await check()
25:   process.exit(0)
26: }
27: 
28: await generate()
29: 
30: async function generate() {
31:   ...

<path>/home/byk/Code/opencode/packages/schema/src/event.ts</path>
<type>file</type>
<content>
1: export * as Event from "./event"
2: 
3: import { Schema } from "effect"
4: import { optional } from "./schema"
5: import { ascending } from "./identifier"
6: import { Location } from "./location"
7: import { statics } from "./schema"
8: 
9: export const ID = Schema.String.check(Schema.isStartsWith("evt_")).pipe(
10:   Schema.brand("Event.ID"),
11:   statics((schema) => ({ create: () => schema.make("evt_" + ascending()) })),
12: )
13: export type ID = typeof ID.Type
14: 
15: export type Definition<
16:   Type extends string = string,
17:   DataSchema extends Schema.Codec<unknown, unknown> = Schema.Codec<unknown, unknown>,
18: > = Schema.Top & {
19:   readonly type: Type
20:   readonly durable?: {
21:     readonly version: number
22:     readonly aggregate: string
23:   }
24:   readonly data: DataSchema
25: }
26: 
27: export type Data<D extends Definition> = Schema.Schema.Type<D["data"]>
28: ...

<path>/home/byk/Code/opencode/packages/schema/src/prompt.ts</path>
<type>file</type>
<content>
1: import { Schema } from "effect"
2: import { optional } from "./schema"
3: import { statics } from "./schema"
4: 
5: export interface Source extends Schema.Schema.Type<typeof Source> {}
6: export const Source = Schema.Struct({
7:   start: Schema.Finite,
8:   end: Schema.Finite,
9:   text: Schema.String,
10: }).annotate({ identifier: "Prompt.Source" })
11: 
12: export interface FileAttachment extends Schema.Schema.Type<typeof FileAttachment> {}
13: export const FileAttachment = Schema.Struct({
14:   uri: Schema.String,
15:   mime: Schema.String,
16:   name: Schema.String.pipe(optional),
17:   description: Schema.String.pipe(optional),
18:   source: Source.pipe(optional),
19: })
20:   .annotate({ identifier: "Prompt.FileAttachment" })
21:   .pipe(
22:     statics((schema) => ({
23:       create: (input: FileAttachment) =>
24:         schema.make({
25:           uri: input.uri,
26:           ...

<path>/home/byk/Code/opencode/packages/protocol/src/groups/session.ts</path>
<type>file</type>
<content>
1: import { SessionMessage } from "@opencode-ai/schema/session-message"
2: import { SessionInput } from "@opencode-ai/schema/session-input"
3: import { PromptInput } from "@opencode-ai/schema/prompt-input"
4: import { Session } from "@opencode-ai/schema/session"
5: import { Project } from "@opencode-ai/schema/project"
6: import { AbsolutePath, NonNegativeInt, PositiveInt, RelativePath, statics } from "@opencode-ai/schema/schema"
7: import { Workspace } from "@opencode-ai/schema/workspace"
8: import { Context, Effect, Encoding, Result, Schema, Struct } from "effect"
9: import { HttpApiEndpoint, HttpApiGroup, HttpApiMiddleware, HttpApiSchema, OpenApi } from "effect/unstable/httpapi"
10: import {
11:   ConflictError,
12:   InvalidCursorError,
13:   InvalidRequestError,
14:   MessageNotFoundError,
15:   ServiceUnavailableError,
16:   SessionNotFoundError,
17:   UnknownError,
18: } from ...

<path>/home/byk/Code/opencode/packages/schema/src/durable-event-manifest.ts</path>
<type>file</type>
<content>
1: export * as DurableEventManifest from "./durable-event-manifest"
2: 
3: import { Event } from "./event"
4: import { SessionEvent } from "./session-event"
5: import { SessionV1 } from "./session-v1"
6: 
7: export const SessionDurable = {
8:   definitions: Event.durable(SessionEvent.DurableDefinitions),
9:   schema: SessionEvent.Durable,
10: } as const
11: 
12: export const Durable = Event.durable([
13:   ...SessionV1.Event.Definitions.filter((definition) => definition.durable !== undefined),
14:   ...SessionEvent.DurableDefinitions,
15: ])

(End of file - total 15 lines)
</content>

Found 100 matches (more matches available)
/home/byk/Code/opencode/packages/core/test/session-runner.test.ts:
  Line 95:     }) as unknown as LLMClientShape["stream"],

  Line 106: const recoveryModel = Model.make({

  Line 107:   id: "recovery",

  Line 358:   currentModel = recoveryModel

  Line 402:   readonly expectedAssistant: unknown

  Line 403:   readonly expectedContent: unknown

  Line 459:       const expectedContent = { type: "tool", id, state: { status: "pending", input: text } }

  Line 519:         error: { type: "unknown", message: "Provider unavailable" },

  Line 530:     const fixture = fragmentFixture(kind, fragmentID(kind, "interrupted"), ["Partial"])

  Line 547:         error: { type: "unknown", message: "Provider turn interrupted" },

  Line 550:             ? { type: "tool", id: fragmentID(kind, "interrupted"), state: { status: "error" } }

  Line 1241:   it.effect("persists a second context overflow after one recovery", () =>

  Line 1292:   ...

<path>/home/byk/Code/opencode/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
2230:     }),
2231:   )
2232: 
2233:   it.effect("runs steering input accepted while the active provider turn fails", () =>
2234:     Effect.gen(function* () {
2235:       yield* setup
2236:       const session = yield* SessionV2.Service
2237:       yield* session.prompt({ sessionID, prompt: Prompt.make({ text: "Start working" }), resume: false })
2238: 
2239:       requests.length = 0
2240:       responses = undefined
2241:       response = []
2242:       streamFailure = providerUnavailable()
2243:       streamGate = yield* Deferred.make<void>()
2244:       streamStarted = yield* Deferred.make<void>()
2245: 
2246:       const first = yield* session.resume(sessionID).pipe(Effect.forkChild)
2247:       yield* Deferred.await(streamStarted)
2248:       yield* session.prompt({ sessionID, prompt: Prompt.make({ text: "Recover with this" }) })
2249:       yield* ...

<path>/home/byk/Code/opencode/packages/core/src/session/history.ts</path>
<type>file</type>
<content>
1: import { and, asc, desc, eq, gt, gte, ne, or } from "drizzle-orm"
2: import { Effect, Schema } from "effect"
3: import { Database } from "../database/database"
4: import { MessageDecodeError } from "./error"
5: import { SessionMessage } from "./message"
6: import { SessionSchema } from "./schema"
7: import { SessionContextEpochTable, SessionMessageTable } from "./sql"
8: 
9: type DatabaseService = Database.Interface["db"]
10: 
11: const decode = Schema.decodeUnknownEffect(SessionMessage.Message)
12: 
13: export const latestCompaction = Effect.fnUntraced(function* (db: DatabaseService, sessionID: SessionSchema.ID) {
14:   return yield* db
15:     .select({ seq: SessionMessageTable.seq })
16:     .from(SessionMessageTable)
17:     .where(and(eq(SessionMessageTable.session_id, sessionID), eq(SessionMessageTable.type, "compaction")))
18:     .orderBy(desc(SessionMessageTable.seq))
19:  ...

<path>/home/byk/Code/opencode/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 and waits for its cleanup. */
14:   readonly interrupt: (key: Key) => Effect.Effect<void>
15: }
16: 
17: type Entry<E> = {
18:   readonly done: Deferred.Deferred<void, E>
19:   owner?: ...

Found 51 matches
/home/byk/Code/opencode/packages/core/src/global.ts:
  Line 73: export const node = makeGlobalNode({ service: Service, layer: layer, deps: [] })


/home/byk/Code/opencode/packages/core/src/ripgrep.ts:
  Line 284: export const node = makeGlobalNode({ service: Service, layer: layer, deps: [RipgrepBinary.node, AppProcess.node] })


/home/byk/Code/opencode/packages/core/src/repository-cache.ts:
  Line 243: export const node = makeGlobalNode({


/home/byk/Code/opencode/packages/core/src/models-dev.ts:
  Line 264: export const node = makeGlobalNode({ service: Service, layer: layer, deps: [FSUtil.node, EventV2.node, httpClient] })


/home/byk/Code/opencode/packages/core/src/fs-util.ts:
  Line 221:   export const node = makeGlobalNode({ service: Service, layer: layer, deps: [filesystem] })


/home/byk/Code/opencode/packages/core/src/tool-output-store.ts:
  Line 200: export const cleanupLayer = Layer.effectDiscard(

  Line 207: export const cleanupNode = ...

<path>/home/byk/Code/opencode/packages/core/src/tool-output-store.ts</path>
<type>file</type>
<content>
180:         if (!entry.startsWith("tool_")) continue
181:         const file = path.join(directory, entry)
182:         const info = yield* fs.stat(file).pipe(Effect.catch(() => Effect.void))
183:         const modified = info?.mtime.pipe(
184:           Option.map((date) => date.getTime()),
185:           Option.getOrElse(() => 0),
186:         )
187:         if (modified !== undefined && modified < cutoff) yield* fs.remove(file).pipe(Effect.catch(() => Effect.void))
188:       }
189:     })
190: 
191:     return Service.of({ limits, bound, cleanup })
192:   }),
193: )
194: 
195: export const node = makeLocationNode({ service: Service, layer, deps: [FSUtil.node, Global.node, Config.node] })
196: 
197: export const nodeWithoutConfig = makeLocationNode({ service: Service, layer, deps: [FSUtil.node, Global.node] })
198: 
199: /** Runs retention scanning once globally rather than once ...

<path>/home/byk/Code/opencode/packages/sdk-next/src/opencode.ts</path>
<type>file</type>
<content>
1: import { OpenCode } from "@opencode-ai/client/effect"
2: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
3: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
4: import { PermissionSaved } from "@opencode-ai/core/permission/saved"
5: import { ApplicationTools } from "@opencode-ai/core/tool/application-tools"
6: import { createEmbeddedRoutes } from "@opencode-ai/server/routes"
7: import { Context, Effect, Layer, Scope } from "effect"
8: import { FetchHttpClient, HttpRouter, HttpServer } from "effect/unstable/http"
9: 
10: export const create = Effect.fn("OpenCode.create")(function* () {
11:   const scope = yield* Scope.Scope
12:   const memoMap = yield* Layer.makeMemoMap
13:   const context = yield* Layer.buildWithMemoMap(
14:     AppNodeBuilder.build(LayerNode.group([ApplicationTools.node, PermissionSaved.node])),
15:     memoMap,
16:     ...

/home/byk/Code/opencode/specs/v2/session.md

<path>/home/byk/Code/opencode/specs/v2/session.md</path>
<type>file</type>
<content>
1: # Session API
2: 
3: ## Current V2 Core Slice
4: 
5: The Effect-native core facade treats prompt recording and execution as separate responsibilities:
6: 
7: ```text
8: sessions.create({ id?, location, ... })
9:   -> omitted ID generates one internal Session ID
10:   -> supplied ID creates the Session when absent
11:   -> reused ID returns the existing Session identity
12: 
13: sessions.prompt({ id?, sessionID, prompt, delivery?, resume? })
14:   -> omitted ID generates one internal message ID
15:   -> supplied ID inserts one durable Session inbox row when absent
16:   -> exact reuse returns the same admission receipt
17:   -> reusing one message ID for another Session, prompt, or delivery mode fails
18:   -> exact retry schedules another wake unless resume is false
19:   -> resume omitted or true schedules execution after admission
20:   -> resume false admits only
21: 
22: ...

Found 10 matches
/home/byk/Code/opencode/packages/core/src/ripgrep/binary.ts:
  Line 64:             `$global:ProgressPreference = 'SilentlyContinue'; Expand-Archive -LiteralPath '${archive.replaceAll("'", "''")}' -DestinationPath '${dir.replaceAll("'", "''")}' -Force`,


/home/byk/Code/opencode/packages/core/src/v1/config/config.ts:
  Line 180:         description: "Continue the agent loop when a tool call is denied",


/home/byk/Code/opencode/packages/core/src/session/runner/llm.ts:
  Line 77:  *   - [x] Continue for durable user steering accepted during an active provider turn.

  Line 78:  *   - [ ] Continue for compaction or another continuation condition when required. ...

Found 6 matches
/home/byk/Code/opencode/packages/core/src/session/projector.ts:
  Line 376:     yield* events.project(SessionEvent.Synthetic, (event) => run(db, event))


/home/byk/Code/opencode/packages/core/src/session/message-updater.ts:
  Line 149:       "session.next.synthetic": (event) => {

  Line 151:           SessionMessage.Synthetic.make({

  Line 155:             type: "synthetic",


/home/byk/Code/opencode/packages/core/src/session/runner/to-llm-message.ts:
  Line 132:     case "synthetic":


/home/byk/Code/opencode/packages/core/src/session/compaction.ts:
  Line 118:   if (message.type === "synthetic") return `[Synthetic context]: ${message.text}`

Found 12 matches
/home/byk/Code/opencode/packages/schema/src/session-event.ts:
  Line 113:   type: "session.next.synthetic",


/home/byk/Code/opencode/packages/core/test/session-projector.test.ts:
  Line 280:       yield* events.publish(SessionEvent.Synthetic, {

  Line 396:       yield* events.publish(SessionEvent.Synthetic, { sessionID, messageID: id, timestamp: created, text: "keep me" })


/home/byk/Code/opencode/packages/client/src/generated/types.ts:
  Line 796:         readonly type: "session.next.synthetic"

  Line 1254:       readonly type: "session.next.synthetic"


/home/byk/Code/opencode/packages/core/test/session-prompt.test.ts:
  Line 523:       yield* events.publish(SessionEvent.Synthetic, {


/home/byk/Code/opencode/packages/core/src/session/projector.ts:
  Line 376:     yield* events.project(SessionEvent.Synthetic, (event) => run(db, event))


/home/byk/Code/opencode/packages/core/src/session/message-updater.ts:
  Line 149:       "session.next.synthetic": (event) => ...

<path>/home/byk/Code/opencode/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
1: import { describe, expect } from "bun:test"
2: import { DateTime, Effect, Schema } from "effect"
3: import { asc, eq, sql } from "drizzle-orm"
4: import { Database } from "@opencode-ai/core/database/database"
5: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
6: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
7: import { EventV2 } from "@opencode-ai/core/event"
8: import { EventTable } from "@opencode-ai/core/event/sql"
9: import { ModelV2 } from "@opencode-ai/core/model"
10: import { Project } from "@opencode-ai/core/project"
11: import { ProjectTable } from "@opencode-ai/core/project/sql"
12: import { ProviderV2 } from "@opencode-ai/core/provider"
13: import { AbsolutePath } from "@opencode-ai/core/schema"
14: import { SessionV2 } from "@opencode-ai/core/session"
15: import { SessionEvent } from ...

<path>/home/byk/Code/opencode/packages/core/test/session-projector.test.ts</path>
<type>file</type>
<content>
439:   it.effect("updates only the newest incomplete assistant projection", () =>
440:     Effect.gen(function* () {
441:       const { db } = yield* Database.Service
442:       yield* db
443:         .insert(ProjectTable)
444:         .values({ id: Project.ID.global, worktree: AbsolutePath.make("/project"), sandboxes: [] })
445:         .run()
446:         .pipe(Effect.orDie)
447:       yield* db
448:         .insert(SessionTable)
449:         .values({
450:           id: sessionID,
451:           project_id: Project.ID.global,
452:           slug: "test",
453:           directory: "/project",
454:           title: "test",
455:           version: "test",
456:         })
457:         .run()
458:         .pipe(Effect.orDie)
459:       yield* db
460:         .insert(SessionMessageTable)
461:         .values([
462:           assistantRow(SessionMessage.ID.make("msg_assistant_1"), ...

Found 76 matches
/home/byk/Code/opencode/specs/v2/config.md:
  Line 154: | `enterprise` | Enterprise URL configuration                    | keep   | Keep `{ url?: string }`; currently selects the legacy sharing service endpoint when no organization account is active. |

  Line 178: | `model`              | Default model selection                           | keep     | Keep as the fallback model when an active session or agent does not specify a model.                                         |

  Line 208: Keep `model` as the default model fallback. It is application-wide behavior used when an active session or agent has no explicit model selection, so it does not belong inside any individual provider configuration.

  Line 218: Do not port legacy provider model `reasoning`, `temperature`, or `interleaved` flags as first-class config fields; provider/request behavior belongs in structured `options` or model variants. ...

<path>/home/byk/Code/opencode/specs/v2/todo.md</path>
<type>file</type>
<content>
45:   unbounded in the current local slice while SQLite publication stays serialized
46: - remove the public in-memory `@opencode-ai/llm` tool loop after replacing its
47:   remaining one-turn native-adapter use with a narrow typed dispatcher
48: - batch streamed deltas and add covering context indexes
49: - expose replayable Session event cursors over HTTP and the generated SDK where remote consumers need them
50: - integrate the new BackgroundJob service with V2 tool execution: support background
51:   bash jobs and background agent dispatch with durable status observation,
52:   completion delivery, and explicit cancellation / continuation semantics
53: - add durable/clustered interruption, retries, and stale-owner fencing only as
54:   their slices become concrete
55: 
56: ### Deferred durable continuation recovery
57: 
58: Do not infer that ambiguous provider work is safe to retry from an advisory ...

<path>/home/byk/Code/opencode/packages/schema/src/session-status-event.ts</path>
<type>file</type>
<content>
1: export * as SessionStatusEvent from "./session-status-event"
2: 
3: import { Schema } from "effect"
4: import { optional } from "./schema"
5: import { Event } from "./event"
6: import { NonNegativeInt } from "./schema"
7: import { SessionID } from "./session-id"
8: 
9: export const Info = Schema.Union([
10:   Schema.Struct({
11:     type: Schema.Literal("idle"),
12:   }),
13:   Schema.Struct({
14:     type: Schema.Literal("retry"),
15:     attempt: NonNegativeInt,
16:     message: Schema.String,
17:     action: optional(
18:       Schema.Struct({
19:         reason: Schema.String,
20:         provider: Schema.String,
21:         title: Schema.String,
22:         message: Schema.String,
23:         label: Schema.String,
24:         link: optional(Schema.String),
25:       }),
26:     ),
27:     next: NonNegativeInt,
28:   }),
29:   Schema.Struct({
30:     type: ...

<path>/home/byk/Code/opencode/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: import { Project } ...

Found 12 matches
/home/byk/Code/opencode/packages/core/test/session-runner.test.ts:
  Line 2270:       yield* events.publish(SessionEvent.Step.Started, {

  Line 2334:       yield* events.publish(SessionEvent.Step.Started, {

  Line 2394:       yield* events.publish(SessionEvent.Step.Started, {


/home/byk/Code/opencode/packages/core/test/session-projector.test.ts:
  Line 398:         .publish(SessionEvent.Step.Started, {

  Line 469:       yield* service.publish(SessionEvent.Step.Ended, {


/home/byk/Code/opencode/packages/core/test/session-tool-progress.test.ts:
  Line 51:       yield* service.publish(SessionEvent.Step.Started, {


/home/byk/Code/opencode/packages/core/src/session/projector.ts:
  Line 379:     yield* events.project(SessionEvent.Step.Started, (event) => run(db, event))

  Line 380:     yield* events.project(SessionEvent.Step.Ended, (event) => run(db, event))

  Line 381:     yield* events.project(SessionEvent.Step.Failed, (event) => run(db, ...

<path>/home/byk/Code/opencode/packages/core/src/database/database.ts</path>
<type>file</type>
<content>
1: export * as Database from "./database"
2: 
3: import { EffectDrizzleSqlite } from "@opencode-ai/effect-drizzle-sqlite"
4: import { layer as sqliteLayer } from "#sqlite"
5: import { Context, Effect, Layer } from "effect"
6: import { Global } from "../global"
7: import { Flag } from "../flag/flag"
8: import { isAbsolute, join } from "path"
9: import { DatabaseMigration } from "./migration"
10: import { InstallationChannel } from "../installation/version"
11: import { makeGlobalNode } from "../effect/app-node"
12: 
13: const makeDatabase = EffectDrizzleSqlite.makeWithDefaults()
14: type DatabaseShape = Effect.Success<typeof makeDatabase>
15: 
16: export interface Interface {
17:   db: DatabaseShape
18: }
19: 
20: export class Service extends Context.Service<Service, Interface>()("@opencode/v2/storage/Database") {}
21: 
22: const layer = Layer.effect(
23:   Service,
24:   ...

<path>/home/byk/Code/opencode/packages/core/src/session/info.ts</path>
<type>file</type>
<content>
1: import { DateTime } from "effect"
2: import { AgentV2 } from "../agent"
3: import { Location } from "../location"
4: import { ModelV2 } from "../model"
5: import { ProjectV2 } from "../project"
6: import { ProviderV2 } from "../provider"
7: import { AbsolutePath, RelativePath } from "../schema"
8: import { WorkspaceV2 } from "../workspace"
9: import { SessionSchema } from "./schema"
10: import { SessionTable } from "./sql"
11: import { SessionMessage } from "./message"
12: import { Snapshot } from "../snapshot"
13: 
14: export function fromRow(row: typeof SessionTable.$inferSelect): SessionSchema.Info {
15:   return SessionSchema.Info.make({
16:     id: SessionSchema.ID.make(row.id),
17:     projectID: ProjectV2.ID.make(row.project_id),
18:     title: row.title,
19:     parentID: row.parent_id ? SessionSchema.ID.make(row.parent_id) : undefined,
20:     agent: row.agent ? ...

Found 3 matches
/home/byk/Code/opencode/packages/schema/src/session-event.ts:
  Line 47:     version: 2,


/home/byk/Code/opencode/packages/schema/src/event.ts:
  Line 94: export function versionedType(type: string, version: number) {

  Line 102:       const key = versionedType(definition.type, definition.durable.version)

No files found

<path>/home/byk/Code/opencode/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(55)
13:     expect(EventManifest.Definitions.length).toBe(85)
14:     expect(SessionV1.Event.Definitions).toEqual([
15:       SessionV1.Event.Created,
16:       SessionV1.Event.Updated,
17:       SessionV1.Event.Deleted,
18:       ...

<path>/home/byk/Code/opencode/packages/schema/src/event-manifest.ts</path>
<type>file</type>
<content>
1: export * as EventManifest from "./event-manifest"
2: 
3: import { Catalog } from "./catalog"
4: import { Durable } from "./durable-event-manifest"
5: import { Event } from "./event"
6: import { FileSystem } from "./filesystem"
7: import { FileSystemWatcher } from "./filesystem-watcher"
8: import { InstallationEvent } from "./installation-event"
9: import { Integration } from "./integration"
10: import { LegacyEvent } from "./legacy-event"
11: import { LspEvent } from "./lsp-event"
12: import { McpEvent } from "./mcp-event"
13: import { ModelsDev } from "./models-dev"
14: import { Permission } from "./permission"
15: import { PermissionV1 } from "./permission-v1"
16: import { Plugin } from "./plugin"
17: import { Project } from "./project"
18: import { ProjectDirectories } from "./project-directories"
19: import { Pty } from "./pty"
20: import { Question } from "./question"
21: ...

<path>/home/byk/Code/opencode/packages/core/src/database/migration/20260603141458_session_input_inbox.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "../migration"
3: 
4: export default {
5:   id: "20260603141458_session_input_inbox",
6:   up(tx) {
7:     return Effect.gen(function* () {
8:       yield* tx.run(`
9:         CREATE TABLE \`session_input\` (
10:           \`seq\` integer PRIMARY KEY AUTOINCREMENT,
11:           \`id\` text NOT NULL UNIQUE,
12:           \`session_id\` text NOT NULL,
13:           \`prompt\` text NOT NULL,
14:           \`delivery\` text NOT NULL,
15:           \`promoted_seq\` integer,
16:           \`time_created\` integer NOT NULL,
17:           CONSTRAINT \`fk_session_input_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE
18:         );
19:       `)
20:       yield* tx.run(
21:         `CREATE INDEX ...

<path>/home/byk/Code/opencode/packages/core/src/database/migration/20260604172448_event_sourced_session_input.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "../migration"
3: 
4: export default {
5:   id: "20260604172448_event_sourced_session_input",
6:   up(tx) {
7:     return Effect.gen(function* () {
8:       yield* tx.run(`DELETE FROM \`session_input\`;`)
9:       yield* tx.run(`DELETE FROM \`session_message\`;`)
10:       yield* tx.run(`DELETE FROM \`event\`;`)
11:       yield* tx.run(`DELETE FROM \`event_sequence\`;`)
12:       yield* tx.run(`UPDATE \`session\` SET \`workspace_id\` = NULL;`)
13:       yield* tx.run(`DELETE FROM \`workspace\`;`)
14:       yield* tx.run(`DROP INDEX IF EXISTS \`event_aggregate_seq_idx\`;`)
15:       yield* tx.run(`CREATE UNIQUE INDEX \`event_aggregate_seq_idx\` ON \`event\` (\`aggregate_id\`,\`seq\`);`)
16:       yield* tx.run(`DROP INDEX IF EXISTS ...

<path>/home/byk/Code/opencode/packages/core/src/database/migration/20260622170816_reset_v2_session_state.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "../migration"
3: 
4: export default {
5:   id: "20260622170816_reset_v2_session_state",
6:   up(tx) {
7:     return Effect.gen(function* () {
8:       yield* tx.run(`DELETE FROM \`session_context_epoch\`;`)
9:       yield* tx.run(`DELETE FROM \`session_input\`;`)
10:       yield* tx.run(`DELETE FROM \`session_message\`;`)
11:       yield* tx.run(`DELETE FROM \`event\`;`)
12:       yield* tx.run(`DELETE FROM \`event_sequence\`;`)
13:       yield* tx.run(`UPDATE \`session\` SET \`workspace_id\` = NULL WHERE \`workspace_id\` IS NOT NULL;`)
14:       yield* tx.run(`DELETE FROM \`workspace\`;`)
15:     })
16:   },
17: } satisfies DatabaseMigration.Migration

(End of file - total 17 lines)
</content>

<path>/home/byk/Code/opencode/packages/core/src/database/migration/20260622202450_simplify_session_input.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "../migration"
3: 
4: export default {
5:   id: "20260622202450_simplify_session_input",
6:   up(tx) {
7:     return Effect.gen(function* () {
8:       yield* tx.run(`DELETE FROM \`session_context_epoch\`;`)
9:       yield* tx.run(`DELETE FROM \`session_input\`;`)
10:       yield* tx.run(`DELETE FROM \`session_message\`;`)
11:       yield* tx.run(`DELETE FROM \`event\`;`)
12:       yield* tx.run(`DELETE FROM \`event_sequence\`;`)
13:       yield* tx.run(`UPDATE \`session\` SET \`workspace_id\` = NULL WHERE \`workspace_id\` IS NOT NULL;`)
14:       yield* tx.run(`DELETE FROM \`workspace\`;`)
15:     })
16:   },
17: } satisfies DatabaseMigration.Migration

(End of file - total 17 lines)
</content>

<path>/home/byk/Code/opencode/packages/core/test/database-migration.test.ts</path>
<type>file</type>
<content>
130:         yield* DatabaseMigration.apply(db)
131: 
132:         expect(yield* db.get(sql`SELECT name FROM sqlite_master WHERE type = 'table' AND name = 'session'`)).toEqual({
133:           name: "session",
134:         })
135:         expect(
136:           yield* db.get(sql`SELECT name FROM sqlite_master WHERE type = 'table' AND name = 'session_input'`),
137:         ).toEqual({ name: "session_input" })
138:         expect(
139:           yield* db.get(sql`SELECT name FROM sqlite_master WHERE type = 'table' AND name = 'session_context_epoch'`),
140:         ).toEqual({ name: "session_context_epoch" })
141:         expect(
142:           yield* db.get(
143:             sql`SELECT name FROM pragma_table_info('session_context_epoch') WHERE name IN ('agent', 'replacement_seq', 'revision')`,
144:           ),
145:         ).toBeUndefined()
146:         expect(yield* ...

Found 100 matches (more matches available)
/home/byk/Code/opencode/packages/sdk-next/src/opencode.ts:
  Line 6: import { createEmbeddedRoutes } from "@opencode-ai/server/routes"


/home/byk/Code/opencode/packages/llm/test/exports.test.ts:
  Line 69:   test("protocol barrels expose supported low-level routes", () => {


/home/byk/Code/opencode/packages/llm/test/adapter.test.ts:
  Line 128:   it.effect("selects routes by model route value", () =>

  Line 139:   it.effect("builds models from configured routes", () =>


/home/byk/Code/opencode/packages/llm/test/provider.types.ts:
  Line 17:   routes: [],


/home/byk/Code/opencode/packages/protocol/src/groups/pty.ts:
  Line 143:   .annotateMerge(OpenApi.annotations({ title: "pty", description: "Experimental location-scoped PTY routes." }))


/home/byk/Code/opencode/packages/protocol/src/groups/skill.ts:
  Line 25:       description: "Experimental skill routes.",


/home/byk/Code/opencode/packages/protocol/src/groups/session.ts:
  Line 377: ...

<path>/home/byk/Code/opencode/packages/cli/src/commands/handlers/serve.ts</path>
<type>file</type>
<content>
1: import { NodeHttpServer } from "@effect/platform-node"
2: import { Credential } from "@opencode-ai/core/credential"
3: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
4: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
5: import { PermissionSaved } from "@opencode-ai/core/permission/saved"
6: import { Context, Layer, Option } from "effect"
7: import * as Effect from "effect/Effect"
8: import { HttpRouter, HttpServer } from "effect/unstable/http"
9: import { createServer } from "node:http"
10: import { createRoutes } from "@opencode-ai/server/routes"
11: import { Commands } from "../commands"
12: import { Runtime } from "../../framework/runtime"
13: import { Daemon } from "../../services/daemon"
14: 
15: export default Runtime.handler(
16:   Commands.commands.serve,
17:   Effect.fn("cli.serve")(function* (input) {
18:     return ...

<path>/home/byk/Code/opencode/packages/core/src/effect/app-node.ts</path>
<type>file</type>
<content>
1: import { LayerNode } from "./layer-node"
2: 
3: export const tags = LayerNode.tags({
4:   location: ["global"],
5:   global: [],
6: })
7: 
8: export type GlobalNode<A, E = never> = LayerNode.Node<A, E, (typeof tags.values)["global"]>
9: export type LocationNode<A, E = never> = LayerNode.Node<A, E, (typeof tags.values)["location"]>
10: 
11: export const makeGlobalNode = tags.make("global")
12: export const makeLocationNode = tags.make("location")
13: 
14: export * as Node from "./app-node"

(End of file - total 14 lines)
</content>

<path>/home/byk/Code/opencode/packages/core/src/effect/app-node-builder.ts</path>
<type>file</type>
<content>
1: import { buildLocationServiceMap } from "../location-services"
2: import { LocationServiceMap } from "../location-service-map"
3: import { LayerNode } from "./layer-node"
4: import { makeGlobalNode } from "./app-node"
5: 
6: export function build<A, E>(root: LayerNode.Node<A, E, any>, replacements: LayerNode.Replacements = []) {
7:   let allReplacements = replacements
8: 
9:   // Only build the location service map if it's actually needed
10:   if (LayerNode.hasUnbound(root, LocationServiceMap.node) && !hasReplacement(replacements, LocationServiceMap.node)) {
11:     const locationMap = buildLocationServiceMap(replacements)
12:     const locationMapNode = makeGlobalNode({ service: LocationServiceMap.Service, layer: locationMap, deps: [] })
13:     allReplacements = replacements.concat([[LocationServiceMap.node, locationMapNode]])
14:   }
15: 
16:   return ...

<path>/home/byk/Code/opencode/packages/core/src/location-services.ts</path>
<type>file</type>
<content>
1: import { Effect, Layer, LayerMap } from "effect"
2: import { AgentV2 } from "./agent"
3: import { AISDK } from "./aisdk"
4: import { Catalog } from "./catalog"
5: import { CommandV2 } from "./command"
6: import { Config } from "./config"
7: import { LayerNode } from "./effect/layer-node"
8: import { Node } from "./effect/app-node"
9: import { FileMutation } from "./file-mutation"
10: import { FileSystem } from "./filesystem"
11: import { FileSystemSearch } from "./filesystem/search"
12: import { Watcher } from "./filesystem/watcher"
13: import { Image } from "./image"
14: import { Integration } from "./integration"
15: import { Location } from "./location"
16: import { LocationMutation } from "./location-mutation"
17: import { LocationServiceMap } from "./location-service-map"
18: import { PermissionV2 } from "./permission"
19: import { PluginV2 } from "./plugin"
20: import { ...

<path>/home/byk/Code/opencode/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. ...

Found 3 matches
/home/byk/Code/opencode/packages/core/test/session-runner.test.ts:
  Line 1050:       yield* events.publish(SessionEvent.Compaction.Started, {

  Line 1351:       yield* events.publish(SessionEvent.Compaction.Started, {


/home/byk/Code/opencode/packages/core/test/session-projector.test.ts:
  Line 300:       yield* events.publish(SessionEvent.Compaction.Started, {

<path>/home/byk/Code/opencode/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
1020:         timestamp: DateTime.makeUnsafe(1),
1021:         model: { id: ModelV2.ID.make("replacement"), providerID: ProviderV2.ID.make("fake") },
1022:       })
1023:       systemUnavailable = true
1024:       yield* session.prompt({ sessionID, prompt: Prompt.make({ text: "Second" }), resume: false })
1025:       yield* session.resume(sessionID)
1026:       systemUnavailable = false
1027:       systemBaseline = "Replacement context"
1028:       yield* session.prompt({ sessionID, prompt: Prompt.make({ text: "Third" }), resume: false })
1029:       yield* session.resume(sessionID)
1030: 
1031:       expect(requests.map((request) => request.system.map((part) => part.text))).toEqual([
1032:         ["Initial context"],
1033:         ["Initial context"],
1034:         ["Initial context"],
1035:       ])
1036:     }),
1037:   )
1038: 
1039:   it.effect("rebuilds the baseline ...

<path>/home/byk/Code/opencode/packages/core/test/session-runner.test.ts</path>
<type>file</type>
<content>
3380: 
3381:       yield* session.resume(sessionID)
3382: 
3383:       expect(yield* session.context(sessionID)).toMatchObject([
3384:         { type: "user", text: "Two blocks" },
3385:         {
3386:           type: "assistant",
3387:           content: [
3388:             { type: "text", id: "text-1", text: "First" },
3389:             { type: "text", id: "text-2", text: "Second" },
3390:           ],
3391:         },
3392:       ])
3393:     }),
3394:   )
3395: 
3396:   for (const kind of fragmentKinds) {
3397:     it.effect(`broadcasts provider ${kind} deltas without storing projection rewrites`, () =>
3398:       verifyEphemeralDeltas(kind),
3399:     )
3400: 
3401:     it.effect(`durably closes partial ${kind} when the provider stream fails`, () => verifyPartialFlushOnFailure(kind))
3402: 
3403:     it.effect(`durably closes partial ${kind} when the provider stream is ...

Found 1 matches
/home/byk/Code/opencode/packages/opencode/test/server/httpapi-cors.test.ts:
  Line 66:         HttpApiApp.createRoutes().pipe(

Found 3 matches
/home/byk/Code/opencode/specs/v2/schema-changelog.md:
  Line 97: - `session.next.step.ended` and `session.next.step.failed` synchronized event version `2`.

  Line 413: - Durable `session.next.tool.success` and `session.next.tool.failed` events.

  Line 631: - Before assembling a provider request, durably fail local tools still projected as `running` from a previous process with the existing `session.next.tool.failed` shape and `Tool execution interrupted` message.

<path>/home/byk/Code/opencode/specs/v2/schema-changelog.md</path>
<type>file</type>
<content>
80: - Add replay-and-tail aggregate cursors backed by durable Session-event sequence.
81: - Encode synchronized event payloads before writing JSON storage and decode them while replaying so schema transforms remain explicit at the durable boundary.
82: 
83: Reason:
84: 
85: - Embedded Session execution needs a reconnect-safe replay stream over the existing durable log and derived chronological read model.
86: - Fragment streams are useful to connected renderers but must not advance durable cursors or inflate synchronized storage.
87: 
88: Compatibility:
89: 
90: - The `session.next.*` lifecycle event family predates this branch; this branch refines its experimental V2 durability and replay contracts.
91: - Durable replay cursors are per-aggregate event sequences; ephemeral deltas are intentionally absent after reconnect. ...

Found 4 matches
/home/byk/Code/opencode/packages/core/src/session/context-epoch.ts:
  Line 75:     { commit: () => advance(db, sessionID, result.snapshot).pipe(Effect.orDie) },


/home/byk/Code/opencode/packages/core/src/session.ts:
  Line 178:     readonly commit: (sessionID: SessionSchema.ID) => Effect.Effect<void, NotFoundError>

  Line 449:         commit: Effect.fn("V2Session.revert.commit")(function* (sessionID) {


/home/byk/Code/opencode/packages/core/src/project.ts:
  Line 49:   readonly commit: (input: { store: AbsolutePath; id: ID }) => Effect.Effect<void>

<path>/home/byk/Code/opencode/packages/core/src/session/context-epoch.ts</path>
<type>file</type>
<content>
45: ) {
46:   const [value, stored, compaction] = yield* Effect.all(
47:     [context, find(db, sessionID), SessionHistory.latestCompaction(db, sessionID)],
48:     { concurrency: "unbounded" },
49:   )
50:   if (!stored) {
51:     const generation = yield* SystemContext.initialize(value)
52:     const baselineSeq = yield* insert(db, sessionID, generation)
53:     return { baseline: generation.baseline, baselineSeq }
54:   }
55: 
56:   const snapshot = yield* Schema.decodeUnknownEffect(SystemContext.Snapshot)(stored.snapshot).pipe(
57:     Effect.mapError((error) => new ContextSnapshotDecodeError({ sessionID, details: String(error) })),
58:   )
59:   const replacementSeq = compaction !== undefined && compaction.seq > stored.baseline_seq ? compaction.seq : undefined
60:   const result = replacementSeq
61:     ? yield* SystemContext.replace(value, snapshot)
62:     : yield* ...

Found 5 matches
/home/byk/Code/opencode/packages/core/src/session/projector.ts:
  Line 104:       time_updated: sql`${SessionTable.time_updated}`,

  Line 332:         .set({ agent: event.data.agent, time_updated: DateTime.toEpochMillis(event.data.timestamp) })

  Line 341:           .set({ model: event.data.model, time_updated: DateTime.toEpochMillis(event.data.timestamp) })

  Line 408:         .set({ revert: null, time_updated: DateTime.toEpochMillis(event.data.timestamp) })

  Line 446:           .set({ revert: null, time_updated: DateTime.toEpochMillis(event.data.timestamp) })

<path>/home/byk/Code/opencode/packages/core/test/event.test.ts</path>
<type>file</type>
<content>
320:     }),
321:   )
322: 
323:   it.effect("ends only an overflowing bounded subscriber without blocking other listeners", () =>
324:     Effect.gen(function* () {
325:       const events = yield* EventV2.Service
326:       const consuming = yield* Deferred.make<void>()
327:       const release = yield* Deferred.make<void>()
328:       const slowStream = yield* EventV2.allBounded(events, 1)
329:       const fastStream = yield* EventV2.allBounded(events, 8)
330:       const slow = yield* slowStream.pipe(
331:         Stream.runForEach(() => Deferred.succeed(consuming, undefined).pipe(Effect.andThen(Deferred.await(release)))),
332:         Effect.forkScoped,
333:       )
334:       const fast = yield* fastStream.pipe(Stream.take(4), Stream.runCollect, Effect.forkScoped)
335: 
336:       yield* events.publish(Message, { text: "one" })
337:       yield* Deferred.await(consuming)
338:       ...

Found 17 matches
/home/byk/Code/opencode/packages/core/test/session-runner.test.ts:
  Line 2441:   it.effect("retries inbox input after prompt projection rolls back", () =>

  Line 3397:     it.effect(`broadcasts provider ${kind} deltas without storing projection rewrites`, () =>


/home/byk/Code/opencode/packages/core/test/session-projector.test.ts:
  Line 414:   it.effect("does not revive a stale incomplete in-memory assistant projection", () =>

  Line 439:   it.effect("updates only the newest incomplete assistant projection", () =>

  Line 497:   it.effect("does not revive a stale incomplete assistant projection", () =>


/home/byk/Code/opencode/packages/core/test/database-migration.test.ts:
  Line 14: import sessionMessageProjectionOrderMigration from "@opencode-ai/core/database/migration/20260603040000_session_message_projection_order"

  Line 414:           sql`INSERT INTO session_message (id, session_id, type, time_created, time_updated, data) VALUES ('stale_projection', ...

<path>/home/byk/Code/opencode/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 { Format } from ...

/home/byk/Code/opencode/CONTRIBUTING.md

<path>/home/byk/Code/opencode/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 issue`](https://github.com/anomalyco/opencode/issues?q=is%3Aissue%20state%3Aopen%20label%3A%22good%20first%20issue%22)
19: - ...

<path>/home/byk/Code/opencode/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": "./src/database/sqlite.bun.ts",
28:       ...

Found 7 matches
/home/byk/Code/opencode/packages/core/src/session/sql.ts:
  Line 22: export const SessionTable = sqliteTable(

  Line 68: export const MessageTable = sqliteTable(

  Line 82: export const PartTable = sqliteTable(

  Line 100: export const TodoTable = sqliteTable(

  Line 119: export const SessionMessageTable = sqliteTable(

  Line 140: export const SessionInputTable = sqliteTable(

  Line 168: export const SessionContextEpochTable = sqliteTable("session_context_epoch", {

<path>/home/byk/Code/opencode/packages/core/src/session/sql.ts</path>
<type>file</type>
<content>
1: import { sqliteTable, text, integer, index, primaryKey, real, uniqueIndex } from "drizzle-orm/sqlite-core"
2: import * as DatabasePath from "../database/path"
3: import { ProjectTable } from "../project/sql"
4: import type { SessionMessage } from "./message"
5: import type { Prompt } from "./prompt"
6: import type { SessionInput } from "./input"
7: import type { Snapshot } from "../snapshot"
8: import { PermissionV1 } from "../v1/permission"
9: import { ProjectV2 } from "../project"
10: import type { SessionSchema } from "./schema"
11: import type { MessageID, PartID, SessionV1 } from "../v1/session"
12: import { WorkspaceV2 } from "../workspace"
13: import { Timestamps } from "../database/schema.sql"
14: import type { SystemContext } from "../system-context/index"
15: import { AgentV2 } from "../agent"
16: import type { Revert } from "@opencode-ai/schema/revert"
17: 
18: type ...

Found 2 matches
/home/byk/Code/opencode/packages/core/src/database/migration.ts:
  Line 6: import { migrations } from "./migration.gen"

  Line 7: import schema from "./schema.gen"

<path>/home/byk/Code/opencode/packages/core/script/migration.ts</path>
<type>file</type>
<content>
1: #!/usr/bin/env bun
2: 
3: import { $ } from "bun"
4: import fs from "fs/promises"
5: import os from "os"
6: import path from "path"
7: import { pathToFileURL } from "url"
8: import { parseArgs } from "util"
9: 
10: const root = path.resolve(import.meta.dirname, "../../..")
11: const snapshot = path.join(root, "packages/core/schema.json")
12: const tsDir = path.join(root, "packages/core/src/database/migration")
13: const registry = path.join(root, "packages/core/src/database/migration.gen.ts")
14: const schema = path.join(root, "packages/core/src/database/schema.gen.ts")
15: const args = parseArgs({
16:   args: process.argv.slice(2),
17:   options: {
18:     check: { type: "boolean" },
19:     name: { type: "string" },
20:   },
21: })
22: 
23: if (args.values.check) {
24:   await check()
25:   process.exit(0)
26: }
27: 
28: await generate()
29: 
30: async function generate() {
31:   ...

<path>/home/byk/Code/opencode/packages/core/drizzle.config.ts</path>
<type>file</type>
<content>
1: import { defineConfig } from "drizzle-kit"
2: 
3: export default defineConfig({
4:   dialect: "sqlite",
5:   schema: ["./src/**/*.sql.ts", "./src/**/sql.ts"],
6:   out: "./migration",
7:   dbCredentials: {
8:     url: "/home/thdxr/.local/share/opencode/opencode.db",
9:   },
10: })

(End of file - total 10 lines)
</content>

Found 32 matches
/home/byk/Code/opencode/packages/server/src/routes.ts:
  Line 2: import { LayerNode } from "@opencode-ai/core/effect/layer-node"

  Line 4: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"

  Line 10: import { SessionExecution } from "@opencode-ai/core/session/execution"

  Line 12: import { SessionExecutionLocal } from "@opencode-ai/core/session/execution/local"

  Line 16: import { Layer, Option } from "effect"

  Line 20: import { authorizationLayer } from "./middleware/authorization"

  Line 21: import { schemaErrorLayer } from "./middleware/schema-error"

  Line 23: import { layer as locationLayer } from "./location"

  Line 24: import { sessionLocationLayer } from "./middleware/session-location"

  Line 26: const applicationServices = LayerNode.group([

  Line 27:   Database.node,

  Line 28:   EventV2.node,

  Line 31:   SessionV2.node,

  Line 32:   PermissionSaved.node,

  Line 33:   PtyTicket.node,

  Line 34:   Credential.node,

  ...

<path>/home/byk/Code/opencode/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 { ToolOutputStore } from ...

Found 46 matches
/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/server.ts:
  Line 2: import { HttpApiBuilder, OpenApi } from "effect/unstable/httpapi"

  Line 54: import { AppNodeBuilderV1 } from "@/effect/app-node-builder-v1"

  Line 55: import { LayerNode } from "@opencode-ai/core/effect/layer-node"

  Line 67: import { SessionExecution } from "@opencode-ai/core/session/execution"

  Line 68: import * as SessionExecutionLocal from "@opencode-ai/core/session/execution/local"

  Line 99: import { sessionHandlers } from "./handlers/session"

  Line 136: const authOnlyRouterLayer = authorizationRouterMiddleware.layer.pipe(Layer.provide(ServerAuth.Config.layer))

  Line 137: const httpApiAuthLayer = authorizationLayer.pipe(Layer.provide(ServerAuth.Config.layer))

  Line 138: const ptyConnectHttpApiAuthLayer = ptyConnectAuthorizationLayer.pipe(Layer.provide(ServerAuth.Config.layer))

  Line 139: const serverHttpApiAuthLayer = ...

<path>/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/server.ts</path>
<type>file</type>
<content>
45: import { Discovery } from "@/skill/discovery"
46: import { Snapshot } from "@/snapshot"
47: import { Storage } from "@/storage/storage"
48: import { ToolRegistry } from "@/tool/registry"
49: import { Truncate } from "@/tool/truncate"
50: import { Worktree } from "@/worktree"
51: import { RuntimeFlags } from "@/effect/runtime-flags"
52: import { MoveSession } from "@opencode-ai/core/control-plane/move-session"
53: import { Database } from "@opencode-ai/core/database/database"
54: import { AppNodeBuilderV1 } from "@/effect/app-node-builder-v1"
55: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
56: import { httpClient } from "@opencode-ai/core/effect/app-node-platform"
57: import { EventV2 } from "@opencode-ai/core/event"
58: import { ModelsDev } from "@opencode-ai/core/models-dev"
59: import { Npm } from "@opencode-ai/core/npm"
60: import { ...

<path>/home/byk/Code/opencode/packages/core/src/effect/layer-node.ts</path>
<type>file</type>
<content>
1: import { Brand, Context, Layer } from "effect"
2: 
3: type AnyNode = Node<unknown, unknown, any>
4: type RuntimeLayer = Layer.Layer<never, unknown, unknown>
5: type NodeList<Item extends AnyNode = AnyNode> = readonly [] | readonly [Item, ...Item[]]
6: export type Output<Item> = [Item] extends [never] ? never : Item extends Node<infer A, unknown, any> ? A : never
7: export type Error<Item> = [Item] extends [never] ? never : Item extends Node<unknown, infer E, any> ? E : never
8: type NodeTag<Item> = [Item] extends [never] ? undefined : Item extends Node<unknown, unknown, infer T> ? T : never
9: type Missing<Required, Dependencies extends NodeList> = Exclude<Required, Output<Dependencies[number]>>
10: type CheckDependencies<Implementation extends Layer.Any, Dependencies extends NodeList> = [
11:   Missing<Layer.Services<Implementation>, Dependencies>,
12: ] extends [never]
13:   ? ...

Found 6 matches
/home/byk/Code/opencode/packages/core/src/effect/app-node.ts:
  Line 4:   location: ["global"],

  Line 5:   global: [],

  Line 8: export type GlobalNode<A, E = never> = LayerNode.Node<A, E, (typeof tags.values)["global"]>

  Line 9: export type LocationNode<A, E = never> = LayerNode.Node<A, E, (typeof tags.values)["location"]>

  Line 11: export const makeGlobalNode = tags.make("global")

  Line 12: export const makeLocationNode = tags.make("location")

<path>/home/byk/Code/opencode/packages/core/src/effect/app-node.ts</path>
<type>file</type>
<content>
1: import { LayerNode } from "./layer-node"
2: 
3: export const tags = LayerNode.tags({
4:   location: ["global"],
5:   global: [],
6: })
7: 
8: export type GlobalNode<A, E = never> = LayerNode.Node<A, E, (typeof tags.values)["global"]>
9: export type LocationNode<A, E = never> = LayerNode.Node<A, E, (typeof tags.values)["location"]>
10: 
11: export const makeGlobalNode = tags.make("global")
12: export const makeLocationNode = tags.make("location")
13: 
14: export * as Node from "./app-node"

(End of file - total 14 lines)
</content>

Found 33 matches
/home/byk/Code/opencode/packages/core/src/global.ts:
  Line 73: export const node = makeGlobalNode({ service: Service, layer: layer, deps: [] })


/home/byk/Code/opencode/packages/core/src/ripgrep.ts:
  Line 284: export const node = makeGlobalNode({ service: Service, layer: layer, deps: [RipgrepBinary.node, AppProcess.node] })


/home/byk/Code/opencode/packages/core/src/repository-cache.ts:
  Line 243: export const node = makeGlobalNode({


/home/byk/Code/opencode/packages/core/src/models-dev.ts:
  Line 264: export const node = makeGlobalNode({ service: Service, layer: layer, deps: [FSUtil.node, EventV2.node, httpClient] })


/home/byk/Code/opencode/packages/core/src/fs-util.ts:
  Line 221:   export const node = makeGlobalNode({ service: Service, layer: layer, deps: [filesystem] })


/home/byk/Code/opencode/packages/core/src/tool-output-store.ts:
  Line 207: export const cleanupNode = makeGlobalNode({


/home/byk/Code/opencode/packages/core/src/session.ts:
  Line 474: ...

<path>/home/byk/Code/opencode/packages/core/src/effect/app-node-builder.ts</path>
<type>file</type>
<content>
1: import { buildLocationServiceMap } from "../location-services"
2: import { LocationServiceMap } from "../location-service-map"
3: import { LayerNode } from "./layer-node"
4: import { makeGlobalNode } from "./app-node"
5: 
6: export function build<A, E>(root: LayerNode.Node<A, E, any>, replacements: LayerNode.Replacements = []) {
7:   let allReplacements = replacements
8: 
9:   // Only build the location service map if it's actually needed
10:   if (LayerNode.hasUnbound(root, LocationServiceMap.node) && !hasReplacement(replacements, LocationServiceMap.node)) {
11:     const locationMap = buildLocationServiceMap(replacements)
12:     const locationMapNode = makeGlobalNode({ service: LocationServiceMap.Service, layer: locationMap, deps: [] })
13:     allReplacements = replacements.concat([[LocationServiceMap.node, locationMapNode]])
14:   }
15: 
16:   return ...

Found 9 matches
/home/byk/Code/opencode/packages/core/package.json:
  Line 10:     "migration": "bun run script/migration.ts",


/home/byk/Code/opencode/packages/core/test/database-migration.test.ts:
  Line 118:       const result = await $`bun ${fileURLToPath(new URL("../script/migration.ts", import.meta.url))} --check`


/home/byk/Code/opencode/packages/core/script/migration.ts:
  Line 75:         "Core schema has ungenerated database migrations. Run `bun script/migration.ts` from packages/core.",

  Line 82:       throw new Error("Current database schema is stale. Run `bun script/migration.ts` from packages/core.")

  Line 87:       throw new Error("Database migration registry is stale. Run `bun script/migration.ts` from packages/core.")

  Line 103:   await $`bun drizzle-kit generate --config ${config} ${name ? ["--name", name] : []}`.cwd(


/home/byk/Code/opencode/packages/core/src/git.ts:
  Line 441:           list(["diff-files", "--name-only", "-z", "--", input.scope]),

  Line ...

<path>/home/byk/Code/opencode/packages/opencode/src/effect/app-node-builder-v1.ts</path>
<type>file</type>
<content>
1: import { AppNodeBuilder } from "@opencode-ai/core/effect/app-node-builder"
2: import { LayerNode } from "@opencode-ai/core/effect/layer-node"
3: import { InstanceBootstrap } from "@/project/bootstrap"
4: import { InstanceStore } from "@/project/instance-store"
5: 
6: const bootstrapReplacement = [InstanceStore.bootstrapNode, InstanceBootstrap.node] as const
7: 
8: export function build<A, E>(root: LayerNode.Node<A, E, any>, replacements: LayerNode.Replacements = []) {
9:   return AppNodeBuilder.build(root, replacements.concat([bootstrapReplacement]))
10: }
11: 
12: export * as AppNodeBuilderV1 from "./app-node-builder-v1"

(End of file - total 12 lines)
</content>

<path>/home/byk/Code/opencode/packages/core/src/session/projector.ts</path>
<type>file</type>
<content>
430:             and(eq(SessionMessageTable.session_id, event.data.sessionID), gt(SessionMessageTable.seq, boundary.seq)),
431:           )
432:           .run()
433:           .pipe(Effect.orDie)
434:         yield* db
435:           .delete(SessionInputTable)
436:           .where(
437:             and(
438:               eq(SessionInputTable.session_id, event.data.sessionID),
439:               or(gt(SessionInputTable.admitted_seq, boundary.seq), gt(SessionInputTable.promoted_seq, boundary.seq)),
440:             ),
441:           )
442:           .run()
443:           .pipe(Effect.orDie)
444:         yield* db
445:           .update(SessionTable)
446:           .set({ revert: null, time_updated: DateTime.toEpochMillis(event.data.timestamp) })
447:           .where(eq(SessionTable.id, event.data.sessionID))
448:           .run()
449:           .pipe(Effect.orDie)
450:       ...

<path>/home/byk/Code/opencode/packages/core/src/database/migration/20260622202450_simplify_session_input.ts</path>
<type>file</type>
<content>
1: import { Effect } from "effect"
2: import type { DatabaseMigration } from "../migration"
3: 
4: export default {
5:   id: "20260622202450_simplify_session_input",
6:   up(tx) {
7:     return Effect.gen(function* () {
8:       yield* tx.run(`DELETE FROM \`session_context_epoch\`;`)
9:       yield* tx.run(`DELETE FROM \`session_input\`;`)
10:       yield* tx.run(`DELETE FROM \`session_message\`;`)
11:       yield* tx.run(`DELETE FROM \`event\`;`)
12:       yield* tx.run(`DELETE FROM \`event_sequence\`;`)
13:       yield* tx.run(`UPDATE \`session\` SET \`workspace_id\` = NULL WHERE \`workspace_id\` IS NOT NULL;`)
14:       yield* tx.run(`DELETE FROM \`workspace\`;`)
15:     })
16:   },
17: } satisfies DatabaseMigration.Migration

(End of file - total 17 lines)
</content>

<path>/home/byk/Code/opencode/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:     import("./migration/20260413175956_chief_energizer"),
17:     ...

<path>/home/byk/Code/opencode/packages/core/src/tool-output-store.ts</path>
<type>file</type>
<content>
180:         if (!entry.startsWith("tool_")) continue
181:         const file = path.join(directory, entry)
182:         const info = yield* fs.stat(file).pipe(Effect.catch(() => Effect.void))
183:         const modified = info?.mtime.pipe(
184:           Option.map((date) => date.getTime()),
185:           Option.getOrElse(() => 0),
186:         )
187:         if (modified !== undefined && modified < cutoff) yield* fs.remove(file).pipe(Effect.catch(() => Effect.void))
188:       }
189:     })
190: 
191:     return Service.of({ limits, bound, cleanup })
192:   }),
193: )
194: 
195: export const node = makeLocationNode({ service: Service, layer, deps: [FSUtil.node, Global.node, Config.node] })
196: 
197: export const nodeWithoutConfig = makeLocationNode({ service: Service, layer, deps: [FSUtil.node, Global.node] })
198: 
199: /** Runs retention scanning once globally rather than once ...

Found 3 matches
/home/byk/Code/opencode/packages/core/src/effect/layer-node.ts:
  Line 225:       if (node.kind === "group") {

  Line 250: export function compile<A, E, const Items extends Replacements = readonly []>(

  Line 330:   return node.kind === "group" ? node.dependencies.flatMap(flatten) : [node]

<path>/home/byk/Code/opencode/packages/core/src/effect/layer-node.ts</path>
<type>file</type>
<content>
211: export function hoist<A, E, T extends Tag, const Items extends Replacements = readonly []>(
212:   root: Node<A, E, any>,
213:   tag: T,
214:   replacements?: ValidReplacements<Items>,
215: ): {
216:   readonly node: Node<A, E>
217:   readonly hoisted: Node<unknown, E>
218: } {
219:   const hoisted = new Map<string, AnyNode>()
220:   const replacementMap = replacementMapFrom(replacements)
221: 
222:   const node = walk<AnyNode>(
223:     root,
224:     (node, context) => {
225:       if (node.kind === "group") {
226:         return { ...node, dependencies: node.dependencies.map(context.visit) }
227:       }
228:       if (node.tag === tag) {
229:         const existing = hoisted.get(node.name)
230:         if (existing && existing !== node) {
231:           throw new Error(`Tag ${tag} has conflicting implementations for ${node.name}`)
232:         }
233:         ...

No files found

 M .lore.md
 M AGENTS.md
 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/message-updater.ts
 M packages/core/src/session/projector.ts
 M packages/core/src/session/sql.ts
 M packages/opencode/src/server/routes/instance/httpapi/server.ts
 M packages/schema/src/session-event.ts
 M packages/server/src/routes.ts
?? packages/core/src/database/migration/20260914170650_session-recovery.ts
?? packages/core/src/session/recovery.ts
?? perf.data
?? perf.data.old
.lore.md
AGENTS.md
packages/core/schema.json
packages/core/src/database/migration.gen.ts
packages/core/src/database/schema.gen.ts
packages/core/src/session/message-updater.ts
packages/core/src/session/projector.ts
packages/core/src/session/sql.ts
packages/opencode/src/server/routes/instance/httpapi/server.ts
packages/schema/src/session-event.ts
packages/server/src/routes.ts

<path>/home/byk/Code/opencode/packages/core/src/session/recovery.ts</path>
<type>file</type>
<content>
1: export * as SessionRecovery from "./recovery"
2: 
3: import { and, asc, desc, eq } from "drizzle-orm"
4: import { DateTime, Effect, Layer, 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 { SessionMessage } from "./message"
11: import { SessionProjector } from "./projector"
12: import { Prompt } from "./prompt"
13: import { SessionRecoveryTable, SessionMessageTable } from "./sql"
14: 
15: const decodeMessage = Schema.decodeUnknownSync(SessionMessage.Message)
16: const continuation = Prompt.make({ text: "continue" })
17: 
18: const layer = Layer.effectDiscard(
19:   Effect.gen(function* () {
20:     const { db } = yield* Database.Service
21:     const events = ...

<path>/home/byk/Code/opencode/packages/core/src/session/sql.ts</path>
<type>file</type>
<content>
115:     index("todo_session_idx").on(table.session_id),
116:   ],
117: )
118: 
119: export const SessionMessageTable = sqliteTable(
120:   "session_message",
121:   {
122:     id: text().$type<SessionMessage.ID>().primaryKey(),
123:     session_id: text()
124:       .$type<SessionSchema.ID>()
125:       .notNull()
126:       .references(() => SessionTable.id, { onDelete: "cascade" }),
127:     type: text().$type<SessionMessage.Type>().notNull(),
128:     seq: integer().notNull(),
129:     ...Timestamps,
130:     data: text({ mode: "json" }).notNull().$type<SessionMessageData>(),
131:   },
132:   (table) => [
133:     uniqueIndex("session_message_session_seq_idx").on(table.session_id, table.seq),
134:     index("session_message_session_type_seq_idx").on(table.session_id, table.type, table.seq),
135:     index("session_message_session_time_created_id_idx").on(table.session_id, ...

<path>/home/byk/Code/opencode/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(`
9:         CREATE TABLE \`session_recovery\` (
10:           \`session_id\` text NOT NULL,
11:           \`assistant_message_id\` text NOT NULL,
12:           \`continuation_message_id\` text NOT NULL,
13:           \`time_created\` integer NOT NULL,
14:           CONSTRAINT \`session_recovery_pk\` PRIMARY KEY(\`session_id\`, \`assistant_message_id\`),
15:           CONSTRAINT \`fk_session_recovery_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE,
16:           CONSTRAINT \`fk_session_recovery_assistant_message_id_session_message_id_fk\` FOREIGN KEY ...

Found 14 matches
/home/byk/Code/opencode/packages/core/src/database/schema.gen.ts:
  Line 182:         CREATE TABLE \`session_recovery\` (

  Line 187:           CONSTRAINT \`session_recovery_pk\` PRIMARY KEY(\`session_id\`, \`assistant_message_id\`),

  Line 188:           CONSTRAINT \`fk_session_recovery_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE,

  Line 189:           CONSTRAINT \`fk_session_recovery_assistant_message_id_session_message_id_fk\` FOREIGN KEY (\`assistant_message_id\`) REFERENCES \`session_message\`(\`id\`) ON DELETE CASCADE,

  Line 190:           CONSTRAINT \`fk_session_recovery_continuation_message_id_session_input_id_fk\` FOREIGN KEY (\`continuation_message_id\`) REFERENCES \`session_input\`(\`id\`) ON DELETE CASCADE

  Line 281:         `CREATE UNIQUE INDEX \`session_recovery_continuation_message_idx\` ON \`session_recovery\` ...

<path>/home/byk/Code/opencode/packages/core/src/database/migration.gen.ts</path>
<type>file</type>
<content>
36:     import("./migration/20260605042240_add_context_epoch_agent"),
37:     import("./migration/20260611035744_credential"),
38:     import("./migration/20260611192811_lush_chimera"),
39:     import("./migration/20260612174303_project_dir_strategy"),
40:     import("./migration/20260622142730_simplify_session_context_epoch"),
41:     import("./migration/20260622170816_reset_v2_session_state"),
42:     import("./migration/20260622202450_simplify_session_input"),
43:     import("./migration/20260914170650_session-recovery"),
44:   ])
45: ).map((module) => module.default) satisfies DatabaseMigration.Migration[]

(End of file - total 45 lines)
</content>

<path>/home/byk/Code/opencode/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 ...

Found 5 matches
/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/server.ts:
  Line 69: import { SessionRecovery } from "@opencode-ai/core/session/recovery"

  Line 213: const app = LayerNode.group([

  Line 292:       AppNodeBuilderV1.build(MoveSession.node, [[LocationServiceMap.node, locationServiceMapV2]]),

  Line 300:       AppNodeBuilderV1.build(LayerNode.group([SessionV2.node, SessionRecovery.node]), [

  Line 307:     Layer.provide(AppNodeBuilderV1.build(app)),

<path>/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/server.ts</path>
<type>file</type>
<content>
60: import { PermissionSaved } from "@opencode-ai/core/permission/saved"
61: import { ProjectV2 } from "@opencode-ai/core/project"
62: import { ProjectCopy } from "@opencode-ai/core/project/copy"
63: import { PtyTicket } from "@opencode-ai/core/pty/ticket"
64: import { Ripgrep } from "@opencode-ai/core/ripgrep"
65: import { SessionProjector } from "@opencode-ai/core/session/projector"
66: import { SessionV2 } from "@opencode-ai/core/session"
67: import { SessionExecution } from "@opencode-ai/core/session/execution"
68: import * as SessionExecutionLocal from "@opencode-ai/core/session/execution/local"
69: import { SessionRecovery } from "@opencode-ai/core/session/recovery"
70: import { lazy } from "@/util/lazy"
71: import { CorsConfig, isAllowedCorsOrigin, type CorsOptions } from "@opencode-ai/server/cors"
72: import { serveUIEffect } from ...

<path>/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/server.ts</path>
<type>file</type>
<content>
205: 
206: type RouteRequirements =
207:   | HttpRouter.HttpRouter
208:   | HttpRouter.Request<"Error", unknown>
209:   | HttpRouter.Request<"GlobalError", unknown>
210:   | HttpRouter.Request<"Requires", unknown>
211:   | HttpRouter.Request<"GlobalRequires", never>
212: 
213: const app = LayerNode.group([
214:   Npm.node,
215:   FSUtil.node,
216:   Database.node,
217:   Auth.node,
218:   Account.node,
219:   Config.node,
220:   Env.node,
221:   Git.node,
222:   Ripgrep.node,
223:   Storage.node,
224:   Snapshot.node,
225:   Plugin.node,
226:   ModelsDev.node,
227:   Provider.node,
228:   ProviderAuth.node,
229:   Agent.node,
230:   Skill.node,
231:   Discovery.node,
232:   Question.node,
233:   Permission.node,
234:   PermissionSaved.node,
235:   Todo.node,
236:   Session.node,
237:   SessionProjector.node,
238:   SessionStatus.node,
239:   ...

Found 5 matches
/home/byk/Code/opencode/packages/core/src/session/projector.ts:
  Line 20:   SessionRecoveryTable,

  Line 389:     yield* events.project(SessionEvent.Step.Recovered, (event) =>

  Line 407:           id: event.data.continuationMessageID,

  Line 415:           .insert(SessionRecoveryTable)

  Line 419:             continuation_message_id: event.data.continuationMessageID,

<path>/home/byk/Code/opencode/packages/core/src/session/projector.ts</path>
<type>file</type>
<content>
370:       Effect.gen(function* () {
371:         if (event.durable === undefined) return yield* Effect.die("Durable Session event is missing aggregate sequence")
372:         yield* SessionInput.projectAdmitted(db, {
373:           admittedSeq: event.durable.seq,
374:           id: event.data.messageID,
375:           sessionID: event.data.sessionID,
376:           prompt: event.data.prompt,
377:           delivery: event.data.delivery,
378:           timeCreated: event.data.timestamp,
379:         })
380:       }),
381:     )
382:     yield* events.project(SessionEvent.ContextUpdated, (event) => run(db, event))
383:     yield* events.project(SessionEvent.Synthetic, (event) => run(db, event))
384:     yield* events.project(SessionEvent.Shell.Started, (event) => run(db, event))
385:     yield* events.project(SessionEvent.Shell.Ended, (event) => run(db, event))
386:     yield* ...

<path>/home/byk/Code/opencode/packages/core/src/session/execution/local.ts</path>
<type>file</type>
<content>
1: import { and, eq } from "drizzle-orm"
2: import { Cause, Effect, Exit, Layer } 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 { SessionSchema } from "../schema"
9: import { SessionStore } from "../store"
10: import { SessionExecution } from "../execution"
11: import { SessionExecutionTable } from "../sql"
12: 
13: /** Current-process routing for implicit-local Locations. Future remote placement belongs here. */
14: const layer = Layer.effect(
15:   SessionExecution.Service,
16:   Effect.gen(function* () {
17:     const { db } = yield* Database.Service
18:     const store = yield* SessionStore.Service
19:     const ...

Found 5 matches
/home/byk/Code/opencode/packages/core/src/session/sql.ts:
  Line 168: export const SessionRecoveryTable = sqliteTable(

  Line 191: export const SessionExecutionTable = sqliteTable(

  Line 192:   "session_execution",

  Line 203:     uniqueIndex("session_execution_session_idx").on(table.session_id),

  Line 204:     index("session_execution_owner_idx").on(table.owner_id),

<path>/home/byk/Code/opencode/packages/core/src/session/sql.ts</path>
<type>file</type>
<content>
165:   ],
166: )
167: 
168: export const SessionRecoveryTable = sqliteTable(
169:   "session_recovery",
170:   {
171:     session_id: text()
172:       .$type<SessionSchema.ID>()
173:       .notNull()
174:       .references(() => SessionTable.id, { onDelete: "cascade" }),
175:     assistant_message_id: text()
176:       .$type<SessionMessage.ID>()
177:       .notNull()
178:       .references(() => SessionMessageTable.id, { onDelete: "cascade" }),
179:     continuation_message_id: text()
180:       .$type<SessionMessage.ID>()
181:       .notNull()
182:       .references(() => SessionInputTable.id, { onDelete: "cascade" }),
183:     time_created: integer().notNull(),
184:   },
185:   (table) => [
186:     primaryKey({ columns: [table.session_id, table.assistant_message_id] }),
187:     uniqueIndex("session_recovery_continuation_message_idx").on(table.continuation_message_id),
188:   ],
189: ...

No files found

No files found

<path>/home/byk/Code/opencode/packages/core/src/database/schema.gen.ts</path>
<type>file</type>
<content>
165:           \`time_created\` integer NOT NULL,
166:           CONSTRAINT \`fk_session_input_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE
167:         );
168:       `)
169:       yield* tx.run(`
170:         CREATE TABLE \`session_message\` (
171:           \`id\` text PRIMARY KEY,
172:           \`session_id\` text NOT NULL,
173:           \`type\` text NOT NULL,
174:           \`seq\` integer NOT NULL,
175:           \`time_created\` integer NOT NULL,
176:           \`time_updated\` integer NOT NULL,
177:           \`data\` text NOT NULL,
178:           CONSTRAINT \`fk_session_message_session_id_session_id_fk\` FOREIGN KEY (\`session_id\`) REFERENCES \`session\`(\`id\`) ON DELETE CASCADE
179:         );
180:       `)
181:       yield* tx.run(`
182:         CREATE TABLE \`session_recovery\` (
183:           ...