Compare commits

...
Sign in to create a new pull request.

1 commit

Author SHA1 Message Date
James Long
48b36530ad refactor(server): use nodes for global services 2026-06-12 14:59:03 -04:00
8 changed files with 32 additions and 9 deletions

View file

@ -3,6 +3,7 @@ export * as Credential from "./credential"
import { asc, eq } from "drizzle-orm" import { asc, eq } from "drizzle-orm"
import { Context, Effect, Layer, Schema } from "effect" import { Context, Effect, Layer, Schema } from "effect"
import { Database } from "./database/database" import { Database } from "./database/database"
import { LayerNode } from "./effect/layer-node"
import { IntegrationSchema } from "./integration/schema" import { IntegrationSchema } from "./integration/schema"
import { NonNegativeInt, withStatics } from "./schema" import { NonNegativeInt, withStatics } from "./schema"
import { Identifier } from "./util/identifier" import { Identifier } from "./util/identifier"
@ -144,3 +145,4 @@ export const layer = Layer.effect(
) )
export const defaultLayer = layer.pipe(Layer.provide(Database.defaultLayer)) export const defaultLayer = layer.pipe(Layer.provide(Database.defaultLayer))
export const node = LayerNode.make(layer, [Database.node])

View file

@ -3,6 +3,7 @@ export * as PermissionSaved from "./saved"
import { eq } from "drizzle-orm" import { eq } from "drizzle-orm"
import { Context, Effect, Layer, Schema } from "effect" import { Context, Effect, Layer, Schema } from "effect"
import { Database } from "../database/database" import { Database } from "../database/database"
import { LayerNode } from "../effect/layer-node"
import { ProjectV2 } from "../project" import { ProjectV2 } from "../project"
import { withStatics } from "../schema" import { withStatics } from "../schema"
import { Identifier } from "../util/identifier" import { Identifier } from "../util/identifier"
@ -85,3 +86,4 @@ export const layer = Layer.effect(
) )
export const defaultLayer = layer.pipe(Layer.provide(Database.defaultLayer)) export const defaultLayer = layer.pipe(Layer.provide(Database.defaultLayer))
export const node = LayerNode.make(layer, [Database.node])

View file

@ -2,6 +2,7 @@ export * as SessionV2 from "./session"
export * from "./session/schema" export * from "./session/schema"
import { Cause, DateTime, Effect, Layer, Schema, Context, Stream } from "effect" import { Cause, DateTime, Effect, Layer, Schema, Context, Stream } from "effect"
import { LayerNode } from "./effect/layer-node"
import { and, asc, desc, eq, gt, like, lt, or, type SQL } from "drizzle-orm" import { and, asc, desc, eq, gt, like, lt, or, type SQL } from "drizzle-orm"
import { ProjectV2 } from "./project" import { ProjectV2 } from "./project"
import { WorkspaceV2 } from "./workspace" import { WorkspaceV2 } from "./workspace"
@ -434,3 +435,11 @@ export const defaultLayer = layer.pipe(
Layer.provide(ProjectV2.defaultLayer), Layer.provide(ProjectV2.defaultLayer),
Layer.orDie, Layer.orDie,
) )
export const node = LayerNode.make(layer.pipe(Layer.orDie), [
Database.node,
EventV2.node,
ProjectV2.node,
SessionExecution.noopNode,
SessionProjector.node,
SessionStore.node,
])

View file

@ -1,6 +1,7 @@
export * as SessionExecution from "./execution" export * as SessionExecution from "./execution"
import { Context, Effect, Layer } from "effect" import { Context, Effect, Layer } from "effect"
import { LayerNode } from "../effect/layer-node"
import { SessionRunner } from "./runner/index" import { SessionRunner } from "./runner/index"
import { SessionSchema } from "./schema" import { SessionSchema } from "./schema"
@ -21,3 +22,4 @@ export const noopLayer = Layer.succeed(
Service, Service,
Service.of({ resume: () => Effect.void, wake: () => Effect.void, interrupt: () => Effect.void }), Service.of({ resume: () => Effect.void, wake: () => Effect.void, interrupt: () => Effect.void }),
) )
export const noopNode = LayerNode.make(noopLayer, [])

View file

@ -1,4 +1,5 @@
import { Effect, Layer } from "effect" import { Effect, Layer } from "effect"
import { LayerNode } from "../../effect/layer-node"
import { LocationServiceMap } from "../../location-layer" import { LocationServiceMap } from "../../location-layer"
import { SessionRunCoordinator } from "../run-coordinator" import { SessionRunCoordinator } from "../run-coordinator"
import { SessionRunner } from "../runner" import { SessionRunner } from "../runner"
@ -33,3 +34,6 @@ export const layer = Layer.effect(
) )
export const defaultLayer = layer.pipe(Layer.provide(SessionStore.defaultLayer)) export const defaultLayer = layer.pipe(Layer.provide(SessionStore.defaultLayer))
export const node = LayerNode.make(layer.pipe(Layer.provide(LocationServiceMap.layer)), [SessionStore.node])
export * as SessionExecutionLocal from "./local"

View file

@ -3,6 +3,7 @@ export * as SessionStore from "./store"
import { eq } from "drizzle-orm" import { eq } from "drizzle-orm"
import { Context, Effect, Layer, Schema } from "effect" import { Context, Effect, Layer, Schema } from "effect"
import { Database } from "../database/database" import { Database } from "../database/database"
import { LayerNode } from "../effect/layer-node"
import { SessionHistory } from "./history" import { SessionHistory } from "./history"
import { MessageDecodeError } from "./error" import { MessageDecodeError } from "./error"
import { SessionMessage } from "./message" import { SessionMessage } from "./message"
@ -60,3 +61,4 @@ export const layer = Layer.effect(
) )
export const defaultLayer = layer.pipe(Layer.provide(Database.defaultLayer)) export const defaultLayer = layer.pipe(Layer.provide(Database.defaultLayer))
export const node = LayerNode.make(layer, [Database.node])

View file

@ -1,6 +1,9 @@
import { SessionV2 } from "@opencode-ai/core/session" import { Credential } from "@opencode-ai/core/credential"
import { LayerNode } from "@opencode-ai/core/effect/layer-node"
import { LocationServiceMap } from "@opencode-ai/core/location-layer" import { LocationServiceMap } from "@opencode-ai/core/location-layer"
import { PermissionSaved } from "@opencode-ai/core/permission/saved" import { PermissionSaved } from "@opencode-ai/core/permission/saved"
import { SessionV2 } from "@opencode-ai/core/session"
import { SessionExecutionLocal } from "@opencode-ai/core/session/execution/local"
import { Layer } from "effect" import { Layer } from "effect"
import { layer as locationLayer } from "./groups/location" import { layer as locationLayer } from "./groups/location"
import { sessionLocationLayer } from "./middleware/session-location" import { sessionLocationLayer } from "./middleware/session-location"
@ -17,11 +20,9 @@ import { AgentHandler } from "./handlers/agent"
import { HealthHandler } from "./handlers/health" import { HealthHandler } from "./handlers/health"
import { QuestionHandler } from "./handlers/question" import { QuestionHandler } from "./handlers/question"
import { ReferenceHandler } from "./handlers/reference" import { ReferenceHandler } from "./handlers/reference"
import * as SessionExecutionLocal from "@opencode-ai/core/session/execution/local"
import { LocationHandler } from "./handlers/location" import { LocationHandler } from "./handlers/location"
import { IntegrationHandler } from "./handlers/integration" import { IntegrationHandler } from "./handlers/integration"
import { CredentialHandler } from "./handlers/credential" import { CredentialHandler } from "./handlers/credential"
import { Credential } from "@opencode-ai/core/credential"
import { ProjectCopyHandler } from "./handlers/project-copy" import { ProjectCopyHandler } from "./handlers/project-copy"
export const handlers = Layer.mergeAll( export const handlers = Layer.mergeAll(
@ -45,9 +46,9 @@ export const handlers = Layer.mergeAll(
).pipe( ).pipe(
Layer.provide(sessionLocationLayer), Layer.provide(sessionLocationLayer),
Layer.provide(locationLayer), Layer.provide(locationLayer),
Layer.provide(SessionV2.defaultLayer), Layer.provide(LayerNode.buildLayer(SessionV2.node)),
Layer.provide(SessionExecutionLocal.defaultLayer), Layer.provide(LayerNode.buildLayer(SessionExecutionLocal.node)),
Layer.provide(PermissionSaved.defaultLayer), Layer.provide(LayerNode.buildLayer(PermissionSaved.node)),
Layer.provide(LocationServiceMap.layer), Layer.provide(LocationServiceMap.layer),
Layer.provide(Credential.defaultLayer), Layer.provide(LayerNode.buildLayer(Credential.node)),
) )

View file

@ -1,4 +1,5 @@
import { Database } from "@opencode-ai/core/database/database" import { Database } from "@opencode-ai/core/database/database"
import { LayerNode } from "@opencode-ai/core/effect/layer-node"
import { EventV2 } from "@opencode-ai/core/event" import { EventV2 } from "@opencode-ai/core/event"
import { LocationServiceMap } from "@opencode-ai/core/location-layer" import { LocationServiceMap } from "@opencode-ai/core/location-layer"
import { FetchHttpClient, HttpRouter, HttpServer } from "effect/unstable/http" import { FetchHttpClient, HttpRouter, HttpServer } from "effect/unstable/http"
@ -21,8 +22,8 @@ export function createRoutes(password?: string) {
: ServerAuth.Config.defaultLayer, : ServerAuth.Config.defaultLayer,
), ),
Layer.provide(LocationServiceMap.layer), Layer.provide(LocationServiceMap.layer),
Layer.provide(Database.defaultLayer), Layer.provide(LayerNode.buildLayer(Database.node)),
Layer.provide(EventV2.defaultLayer), Layer.provide(LayerNode.buildLayer(EventV2.node)),
Layer.provide(FetchHttpClient.layer), Layer.provide(FetchHttpClient.layer),
) )
} }