export * as OpenCode from "./opencode" import { Context, Effect, Layer } from "effect" import { Database } from "../database/database" import { EventV2 } from "../event" import { LocationServiceMap } from "../location-layer" import { ProjectV2 } from "../project" import { SessionV2 } from "../session" import * as SessionExecutionLocal from "../session/execution/local" import { SessionProjector } from "../session/projector" import { SessionStore } from "../session/store" import { ApplicationTools } from "../tool/application-tools" import { Session } from "./session" import { Tool } from "./tool" export interface Interface { readonly sessions: Session.Interface readonly tools: Tool.Interface } /** Intentional public native API for Effect applications embedding OpenCode. */ export class Service extends Context.Service()("@opencode/public/OpenCode") {} const SessionsLayer = SessionV2.layer.pipe( Layer.provide(SessionProjector.layer), Layer.provide(SessionExecutionLocal.layer), Layer.provide(SessionStore.layer), Layer.provide(EventV2.layer), Layer.provide(Database.defaultLayer), Layer.provide(ProjectV2.defaultLayer), Layer.provide(LocationServiceMap.layer.pipe(Layer.provide(ApplicationTools.layer))), Layer.orDie, ) // TODO: Accept explicit storage so tests and embeddings can select disposable or application-owned persistence. export const layer = Layer.effect( Service, Effect.gen(function* () { const sessions = yield* SessionV2.Service const tools = yield* ApplicationTools.Service return Service.of({ tools: { register: tools.register }, sessions: { create: (input) => sessions.create({ id: input.id, agent: input.agent, model: input.model, location: input.location, }), get: sessions.get, list: sessions.list, switchModel: sessions.switchModel, interrupt: sessions.interrupt, prompt: (input) => sessions.prompt({ id: input.id, sessionID: input.sessionID, prompt: input.prompt, delivery: input.delivery, }), messages: (input) => sessions.messages({ sessionID: input.sessionID, limit: input.limit, order: input.order, cursor: input.cursor, }), message: (input) => sessions.message({ sessionID: input.sessionID, messageID: input.messageID }), context: sessions.context, events: (input) => sessions.events({ sessionID: input.sessionID, after: input.after }), }, }) }), ).pipe(Layer.provide(Layer.merge(ApplicationTools.layer, SessionsLayer))) // TODO: Add OpenCode.create(...) as the Promise facade over the same native API semantics.