Session 0FuoGMgZhzwJ

No files found

<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 ...

f051a53df476dd924bda0a14c4cd91a63c9e7eafff53bbe71f0460571335fcbd  /tmp/opencode/session-recovery-full.patch
1ecc9afe36c12b31a8892cdbfb8a1560ceec97255c3537c073b795351233be40  packages/opencode/dist/server/opencode-server
dc661f30cb2055ad6248fdc59b14998d834497be
commit
commit
 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/compaction.ts
 M packages/core/src/session/execution/local.ts
 M packages/core/src/session/message-updater.ts
 M packages/core/src/session/projector.ts
 M packages/core/src/session/recovery.ts
 M packages/core/src/session/runner/index.ts
 M packages/core/src/session/runner/llm.ts
 M packages/core/src/session/runner/publish-llm-event.ts
 M packages/core/src/session/sql.ts
 M packages/core/test/session-execution-local.test.ts
 M packages/core/test/session-projector.test.ts
 M packages/core/test/session-runner-recorded.test.ts
 M ...

<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>/tmp/opencode/session-recovery-full.patch</path>
<type>file</type>
<content>
1: diff --git a/packages/core/schema.json b/packages/core/schema.json
2: index d0eeeebd5c..25475f6d34 100644
3: --- a/packages/core/schema.json
4: +++ b/packages/core/schema.json
5: @@ -1,8 +1,10 @@
6:  {
7:    "version": "7",
8:    "dialect": "sqlite",
9: -  "id": "f14a9b18-8207-487e-a3d3-227e629ba9ad",
10: -  "prevIds": ["169a0f0f-d58f-479f-b024-fa1c7b9a09db"],
11: +  "id": "ab874548-0fd0-4748-9f7d-762a6e5e7479",
12: +  "prevIds": [
13: +    "57591e35-6f8f-4cda-932c-6a08e85caae7"
14: +  ],
15:    "ddl": [
16:      {
17:        "name": "workspace",
18: @@ -60,6 +62,10 @@
19:        "name": "session_context_epoch",
20:        "entityType": "tables"
21:      },
22: +    {
23: +      "name": "session_execution",
24: +      "entityType": "tables"
25: +    },
26:      {
27:        "name": "session_input",
28:        "entityType": "tables"
29: @@ -68,6 +74,10 @@
30:        "name": "session_message",
31:      ...

<path>/tmp/opencode/session-recovery-full.patch</path>
<type>file</type>
<content>
1501: -                    settlement.outputPaths ?? [],
1502: +                  ).pipe(
1503: +                    Effect.flatMap((settlement) =>
1504: +                      publish(
1505: +                        LLMEvent.toolResult({
1506: +                          id: event.id,
1507: +                          name: event.name,
1508: +                          result: settlement.result,
1509: +                          output: settlement.output,
1510: +                        }),
1511: +                        settlement.outputPaths ?? [],
1512: +                      ),
1513: +                    ),
1514:                    ),
1515:                  ),
1516:                ),
1517: @@ -283,6 +317,7 @@ const layer = Layer.effect(
1518:  
1519:        return yield* Effect.uninterruptibleMask((restore) =>
1520:          Effect.gen(function* () {
1521: +          yield* updateExecution({ phase: ...

<path>/tmp/opencode/session-recovery-full.patch</path>
<type>file</type>
<content>
2715: +  id: "20260914235657_session-execution-lease",
2716: +  up(tx) {
2717: +    return Effect.gen(function* () {
2718: +      yield* tx.run(`ALTER TABLE \`session_execution\` ADD \`expires_at\` integer NOT NULL;`)
2719: +    })
2720: +  },
2721: +} satisfies DatabaseMigration.Migration

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

Found 24 matches
/tmp/opencode/session-recovery-full.patch:
  Line 1: diff --git a/packages/core/schema.json b/packages/core/schema.json

  Line 732: diff --git a/packages/core/src/database/migration.gen.ts b/packages/core/src/database/migration.gen.ts

  Line 746: diff --git a/packages/core/src/database/migration/20260914170650_session-recovery.ts b/packages/core/src/database/migration/20260914170650_session-recovery.ts

  Line 777: diff --git a/packages/core/src/database/migration/20260914214636_session-execution.ts b/packages/core/src/database/migration/20260914214636_session-execution.ts

  Line 809: diff --git a/packages/core/src/database/migration/20260914222526_session-execution-phase.ts b/packages/core/src/database/migration/20260914222526_session-execution-phase.ts

  Line 826: diff --git a/packages/core/src/database/schema.gen.ts b/packages/core/src/database/schema.gen.ts

  Line 891: diff --git a/packages/core/src/session/compaction.ts ...

<path>/home/byk/Code/opencode/packages/core/src/session/execution/local.ts</path>
<type>file</type>
<content>
1: import { and, eq, inArray, lt, or } from "drizzle-orm"
2: import { Cause, Duration, Effect, Exit, Layer, Schedule } from "effect"
3: import { Database } from "../../database/database"
4: import { LocationServiceMap } from "../../location-service-map"
5: import { makeGlobalNode } from "../../effect/app-node"
6: import { SessionRunCoordinator } from "../run-coordinator"
7: import { SessionRunner } from "../runner"
8: import { SessionSchema } from "../schema"
9: import { SessionStore } from "../store"
10: import { SessionExecution } from "../execution"
11: import { SESSION_EXECUTION_LEASE_MS, SessionExecutionTable } from "../sql"
12: 
13: /** Current-process routing for implicit-local Locations. Future remote placement belongs here. */
14: export const make = Effect.fnUntraced(function* (input: {
15:   readonly run: (
16:     sessionID: SessionSchema.ID,
17:     force: ...

<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, desc, eq, isNull, lt } from "drizzle-orm"
4: import { DateTime, Effect, Layer, Schedule } 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 { SessionExecutionTable, SessionRecoveryTable, SessionMessageTable } from "./sql"
13: 
14: export const recover = Effect.fn("SessionRecovery.recover")(function* () {
15:   const { db } = yield* Database.Service
16:   const events = yield* EventV2.Service
17:   const execution = yield* SessionExecution.Service
18:   const claims = yield* db
19:     .select()
20:     ...

<path>/home/byk/Code/opencode/packages/core/src/session/runner/llm.ts</path>
<type>file</type>
<content>
150:           Cause.isDieReason(reason) &&
151:           (reason.defect instanceof PermissionV2.DeclinedError || reason.defect instanceof QuestionV2.RejectedError),
152:       )
153: 
154:     type TurnTransition =
155:       // Automatic compaction completed; rebuild the request from compacted history.
156:       | { readonly _tag: "ContinueAfterCompaction"; readonly step: number }
157:       // Overflow compaction completed; rebuild once through the path without overflow recovery. ...

<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:   readonly startCommit: (assistantMessageID: SessionMessage.ID) => Effect.Effect<void>
15:   readonly terminalCommit: (assistantMessageID: SessionMessage.ID) => Effect.Effect<void>
16:   readonly eventCommit: () => Effect.Effect<void>
17: }
18: 
19: const safe = (value: number | undefined) => Math.max(0, Number.isFinite(value) ? ...

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

/home/byk/Code/opencode/packages/core/src/event.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> = ...

sha256sum: /tmp/opencode/session-recovery-full.patch: No such file or directory
1ecc9afe36c12b31a8892cdbfb8a1560ceec97255c3537c073b795351233be40  packages/opencode/dist/server/opencode-server

dc661f30cb2055ad6248fdc59b14998d834497be
commit
commit
 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/compaction.ts
 M packages/core/src/session/execution/local.ts
 M packages/core/src/session/message-updater.ts
 M packages/core/src/session/projector.ts
 M packages/core/src/session/recovery.ts
 M packages/core/src/session/runner/index.ts
 M packages/core/src/session/runner/llm.ts
 M packages/core/src/session/runner/publish-llm-event.ts
 M packages/core/src/session/sql.ts
 M packages/core/test/session-execution-local.test.ts
 M packages/core/test/session-projector.test.ts
 M packages/core/test/session-runner-recorded.test.ts
 M packages/core/test/session-runner-tool-events.test.ts
 M packages/core/test/session-runner.test.ts
 M packages/schema/src/session-event.ts
?? packages/core/src/database/migration/20260914235657_session-execution-lease.ts
?? perf.data
?? ...

<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?: ...

f051a53df476dd924bda0a14c4cd91a63c9e7eafff53bbe71f0460571335fcbd  /tmp/opencode/session-recovery-full.patch
1ecc9afe36c12b31a8892cdbfb8a1560ceec97255c3537c073b795351233be40  packages/opencode/dist/server/opencode-server
dc661f30cb2055ad6248fdc59b14998d834497be
commit
 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/compaction.ts
 M packages/core/src/session/execution/local.ts
 M packages/core/src/session/message-updater.ts
 M packages/core/src/session/projector.ts
 M packages/core/src/session/recovery.ts
 M packages/core/src/session/runner/index.ts
 M packages/core/src/session/runner/llm.ts
 M packages/core/src/session/runner/publish-llm-event.ts
 M packages/core/src/session/sql.ts
 M packages/core/test/session-execution-local.test.ts
 M packages/core/test/session-projector.test.ts
 M packages/core/test/session-runner-recorded.test.ts
 M ...

Found 86 matches
/home/byk/Code/opencode/packages/core/test/session-runner.test.ts:
  Line 409:     yield* events.replayAll(


/home/byk/Code/opencode/packages/core/test/session-projector.test.ts:
  Line 150:       yield* events.replayAll(


/home/byk/Code/opencode/packages/core/test/session-prompt.test.ts:
  Line 430:       yield* events.replayAll(


/home/byk/Code/opencode/packages/core/test/session-create.test.ts:
  Line 258:         expect(yield* events.replayAll(serialized.slice(0, 2))).toBe(created.id)

  Line 268:         expect(yield* events.replayAll(serialized.slice(2))).toBe(created.id)


/home/byk/Code/opencode/packages/core/test/event.test.ts:
  Line 551:       yield* events.replay({

  Line 570:       yield* events.replay({

  Line 606:           .replay({

  Line 639:       yield* events.replay({

  Line 647:         .replay({

  Line 671:       yield* events.replay({

  Line 687:         .replay({

  Line 704:       const source = yield* events.replayAll([

  Line 731: ...

<path>/home/byk/Code/opencode/packages/core/src/session/projector.ts</path>
<type>file</type>
<content>
340:         .set({ agent: event.data.agent, time_updated: DateTime.toEpochMillis(event.data.timestamp) })
341:         .where(eq(SessionTable.id, event.data.sessionID))
342:         .run()
343:         .pipe(Effect.orDie, Effect.andThen(run(db, event))),
344:     )
345:     yield* events.project(SessionEvent.ModelSwitched, (event) =>
346:       Effect.gen(function* () {
347:         yield* db
348:           .update(SessionTable)
349:           .set({ model: event.data.model, time_updated: DateTime.toEpochMillis(event.data.timestamp) })
350:           .where(eq(SessionTable.id, event.data.sessionID))
351:           .run()
352:           .pipe(Effect.orDie)
353:         yield* run(db, event)
354:       }),
355:     )
356:     yield* events.project(SessionEvent.Prompted, (event) =>
357:       Effect.gen(function* () {
358:         if (event.durable === undefined) return yield* ...

<path>/home/byk/Code/opencode/packages/core/src/session/message-updater.ts</path>
<type>file</type>
<content>
205:             }),
206:           )
207:         })
208:       },
209:       "session.next.step.ended": (event) => {
210:         return updateOwnedAssistant(event.data.assistantMessageID, (draft) => {
211:           draft.time.completed = event.data.timestamp
212:           draft.finish = event.data.finish
213:           draft.cost = event.data.cost
214:           draft.tokens = event.data.tokens
215:           if (event.data.snapshot || event.data.files)
216:             draft.snapshot = {
217:               ...draft.snapshot,
218:               end: event.data.snapshot,
219:               files: event.data.files ? Array.from(event.data.files) : undefined,
220:             }
221:         })
222:       },
223:       "session.next.step.failed": (event) => {
224:         return updateOwnedAssistant(event.data.assistantMessageID, (draft) => {
225:           ...

Found 51 matches
/home/byk/Code/opencode/packages/codemode/src/interpreter/runtime.ts:
  Line 2204:             yield* Fiber.interrupt(item.fiber)


/home/byk/Code/opencode/packages/sdk-next/test/embedded.test.ts:
  Line 62:       yield* opencode.sessions.interrupt({ sessionID })

  Line 70:           opencode.sessions.interrupt({ sessionID: missingSessionID }).pipe(Effect.flip),


/home/byk/Code/opencode/packages/httpapi-codegen/test/generated-consumer.ts:
  Line 12:     const interrupt = client.session.interrupt({ sessionID: "session" })


/home/byk/Code/opencode/packages/httpapi-codegen/test/generate.test.ts:
  Line 440:       expect(await client.session.interrupt({ sessionID: "session" })).toBeUndefined()


/home/byk/Code/opencode/packages/client/test/promise.test.ts:
  Line 138:   await client.sessions.interrupt({ sessionID: "ses_test" })


/home/byk/Code/opencode/packages/client/test/effect.test.ts:
  Line 148:     yield* client.sessions.interrupt({ sessionID: ...

<path>/home/byk/Code/opencode/packages/core/src/session.ts</path>
<type>file</type>
<content>
390:       skill: Effect.fn("V2Session.skill")(function* () {
391:         return yield* new OperationUnavailableError({ operation: "skill" })
392:       }),
393:       switchAgent: Effect.fn("V2Session.switchAgent")(function* (input) {
394:         yield* result.get(input.sessionID)
395:         yield* events.publish(SessionEvent.AgentSwitched, {
396:           sessionID: input.sessionID,
397:           messageID: SessionMessage.ID.create(),
398:           timestamp: yield* DateTime.now,
399:           agent: input.agent,
400:         })
401:       }),
402:       switchModel: Effect.fn("V2Session.switchModel")(function* (input) {
403:         const session = yield* result.get(input.sessionID)
404:         if (
405:           session.model?.providerID === input.model.providerID &&
406:           session.model.id === input.model.id &&
407:           (session.model.variant ?? ...

<path>/home/byk/Code/opencode/packages/opencode/src/server/routes/instance/httpapi/handlers/sync.ts</path>
<type>file</type>
<content>
1: import { Workspace } from "@/control-plane/workspace"
2: import * as InstanceState from "@/effect/instance-state"
3: import { Session } from "@/session/session"
4: import { Database } from "@opencode-ai/core/database/database"
5: import { EventV2 } from "@opencode-ai/core/event"
6: import { EventV2Bridge } from "@/event-v2-bridge"
7: import { EventTable } from "@opencode-ai/core/event/sql"
8: import { asc } from "drizzle-orm"
9: import { and } from "drizzle-orm"
10: import { eq } from "drizzle-orm"
11: import { lte } from "drizzle-orm"
12: import { not } from "drizzle-orm"
13: import { or } from "drizzle-orm"
14: import { Effect, Scope } from "effect"
15: import { HttpApiBuilder, HttpApiError } from "effect/unstable/httpapi"
16: import { InstanceHttpApi } from "../api"
17: import { HistoryPayload, ReplayPayload, SessionPayload } from ...

<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:       ...