mirror of
https://github.com/anomalyco/opencode.git
synced 2026-08-04 01:06:16 -04:00
Kit Langton
24 lines
1.1 KiB
TypeScript
24 lines
1.1 KiB
TypeScript
export * as SessionExecution from "./execution"
|
|
|
|
import { Context, Effect, Layer } from "effect"
|
|
import { SessionRunner } from "./runner/index"
|
|
import { SessionSchema } from "./schema"
|
|
|
|
export interface Interface {
|
|
/** Starts execution while idle or joins the active execution. */
|
|
readonly resume: (sessionID: SessionSchema.ID) => Effect.Effect<void, SessionRunner.RunError>
|
|
/** Registers newly recorded work. Repeated wakeups may coalesce. */
|
|
readonly wake: (sessionID: SessionSchema.ID) => Effect.Effect<void>
|
|
/** Interrupt active work owned by this process. Idle interruption is a no-op. */
|
|
readonly interrupt: (sessionID: SessionSchema.ID) => Effect.Effect<void>
|
|
}
|
|
|
|
/** Routes execution from a Session ID to the runner owned by that Session's Location. */
|
|
export class Service extends Context.Service<Service, Interface>()("@opencode/v2/SessionExecution") {}
|
|
|
|
/** Low-level compatibility layer for callers that only need durable Session recording. */
|
|
export const noopLayer = Layer.succeed(
|
|
Service,
|
|
Service.of({ resume: () => Effect.void, wake: () => Effect.void, interrupt: () => Effect.void }),
|
|
)
|