import { EnvironmentHttpApi } from "@t3tools/contracts";import * as Effect from "effect/Effect";import * as Layer from "effect/Layer";import { FetchHttpClient, HttpRouter, HttpServer } from "effect/unstable/http";import * as HttpApiBuilder from "effect/unstable/httpapi/HttpApiBuilder"; import * as ServerConfig from "./config.ts";import {  otlpTracesProxyRouteLayer,  assetRouteLayer,  serverEnvironmentHttpApiLayer,  staticAndDevRouteLayer,  browserApiCorsLayer,} from "./http.ts";import { fixPath } from "./os-jank.ts";import { websocketRpcRouteLayer } from "./ws.ts";import * as ExternalLauncher from "./process/externalLauncher.ts";import { layerConfig as SqlitePersistenceLayerLive } from "./persistence/Layers/Sqlite.ts";import * as ServerLifecycleEvents from "./serverLifecycleEvents.ts";import * as AnalyticsService from "./telemetry/AnalyticsService.ts";import { ProviderSessionDirectoryLive } from "./provider/Layers/ProviderSessionDirectory.ts";import * as ProviderSessionRuntime from "./persistence/ProviderSessionRuntime.ts";import { ProviderAdapterRegistryLive } from "./provider/Layers/ProviderAdapterRegistry.ts";import * as ProviderEventLoggers from "./provider/Layers/ProviderEventLoggers.ts";import { ProviderServiceLive } from "./provider/Layers/ProviderService.ts";import { ProviderSessionReaperLive } from "./provider/Layers/ProviderSessionReaper.ts";import * as OpenCodeRuntime from "./provider/opencodeRuntime.ts";import * as CheckpointDiffQuery from "./checkpointing/CheckpointDiffQuery.ts";import * as CheckpointStore from "./checkpointing/CheckpointStore.ts";import * as AzureDevOpsCli from "./sourceControl/AzureDevOpsCli.ts";import * as BitbucketApi from "./sourceControl/BitbucketApi.ts";import * as GitHubCli from "./sourceControl/GitHubCli.ts";import * as GitLabCli from "./sourceControl/GitLabCli.ts";import * as TextGeneration from "./textGeneration/TextGeneration.ts";import { ProviderInstanceRegistryHydrationLive } from "./provider/Layers/ProviderInstanceRegistryHydration.ts";import * as TerminalManager from "./terminal/Manager.ts";import * as McpHttpServer from "./mcp/McpHttpServer.ts";import * as McpSessionRegistry from "./mcp/McpSessionRegistry.ts";import * as PreviewAutomationBroker from "./mcp/PreviewAutomationBroker.ts";import * as PreviewManager from "./preview/Manager.ts";import * as PortScanner from "./preview/PortScanner.ts";import * as ProcessRunner from "./processRunner.ts";import * as GitManager from "./git/GitManager.ts";import * as Keybindings from "./keybindings.ts";import * as ServerRuntimeStartup from "./serverRuntimeStartup.ts";import { OrchestrationReactorLive } from "./orchestration/Layers/OrchestrationReactor.ts";import { RuntimeReceiptBusLive } from "./orchestration/Layers/RuntimeReceiptBus.ts";import { ProviderRuntimeIngestionLive } from "./orchestration/Layers/ProviderRuntimeIngestion.ts";import { ProviderCommandReactorLive } from "./orchestration/Layers/ProviderCommandReactor.ts";import { CheckpointReactorLive } from "./orchestration/Layers/CheckpointReactor.ts";import { ThreadDeletionReactorLive } from "./orchestration/Layers/ThreadDeletionReactor.ts";import * as AgentAwarenessRelay from "./relay/AgentAwarenessRelay.ts";import { hasCloudPublicConfig } from "./cloud/publicConfig.ts";import { ProviderRegistryLive } from "./provider/Layers/ProviderRegistry.ts";import * as ServerSettings from "./serverSettings.ts";import * as ProjectFaviconResolver from "./project/ProjectFaviconResolver.ts";import * as T3ProjectFileLoader from "./project/T3ProjectFileLoader.ts";import * as RepositoryIdentityResolver from "./project/RepositoryIdentityResolver.ts";import * as WorkspaceEntries from "./workspace/WorkspaceEntries.ts";import * as WorkspaceFileSystem from "./workspace/WorkspaceFileSystem.ts";import * as WorkspacePaths from "./workspace/WorkspacePaths.ts";import * as GitVcsDriver from "./vcs/GitVcsDriver.ts";import * as VcsDriverRegistry from "./vcs/VcsDriverRegistry.ts";import * as VcsProjectConfig from "./vcs/VcsProjectConfig.ts";import * as VcsProcess from "./vcs/VcsProcess.ts";import * as VcsProvisioningService from "./vcs/VcsProvisioningService.ts";import * as VcsStatusBroadcaster from "./vcs/VcsStatusBroadcaster.ts";import * as GitWorkflowService from "./git/GitWorkflowService.ts";import * as ReviewService from "./review/ReviewService.ts";import * as SourceControlProviderRegistry from "./sourceControl/SourceControlProviderRegistry.ts";import * as SourceControlRepositoryService from "./sourceControl/SourceControlRepositoryService.ts";import * as ProjectSetupScriptRunner from "./project/ProjectSetupScriptRunner.ts";import { ObservabilityLive } from "./observability/Layers/Observability.ts";import * as ServerEnvironment from "./environment/ServerEnvironment.ts";import { authHttpApiLayer, environmentAuthenticatedAuthLayer } from "./auth/http.ts";import * as ServerSecretStore from "./auth/ServerSecretStore.ts";import * as EnvironmentAuth from "./auth/EnvironmentAuth.ts";import { connectHttpApiLayer, reconcileDesiredCloudLink } from "./cloud/http.ts";import { serverRelayBrokerTracingLayer } from "./cloud/relayTracing.ts";import * as CloudManagedEndpointRuntime from "./cloud/ManagedEndpointRuntime.ts";import * as CloudCliTokenManager from "./cloud/CliTokenManager.ts";import * as CloudCliState from "./cloud/CliState.ts";import * as ServerSelfUpdate from "./cloud/selfUpdate.ts";import * as ProcessDiagnostics from "./diagnostics/ProcessDiagnostics.ts";import * as ProcessResourceMonitor from "./diagnostics/ProcessResourceMonitor.ts";import * as TraceDiagnostics from "./diagnostics/TraceDiagnostics.ts";import { OrchestrationLayerLive } from "./orchestration/runtimeLayer.ts";import {  clearPersistedServerRuntimeState,  makePersistedServerRuntimeState,  persistServerRuntimeState,} from "./serverRuntimeState.ts";import { orchestrationHttpApiLayer } from "./orchestration/http.ts";import * as NetService from "@t3tools/shared/Net";import * as RelayClient from "@t3tools/shared/relayClient";import { disableTailscaleServe, ensureTailscaleServe } from "@t3tools/tailscale"; // Effect's default preemptive shutdown waits 20s before finalizing request scopes.// T3's primary transport is long-lived WebSocket RPC, whose Effect scope finalizer// already closes the websocket gracefully. Do not add an artificial drain before// those finalizers get a chance to run.const HTTP_PREEMPTIVE_SHUTDOWN_GRACE_MS = 0; const PtyAdapterLive = Layer.unwrap(  Effect.gen(function* () {    if (typeof Bun !== "undefined") {      const BunPtyAdapter = yield* Effect.promise(() => import("./terminal/BunPtyAdapter.ts"));      return BunPtyAdapter.layer;    } else {      const NodePtyAdapter = yield* Effect.promise(() => import("./terminal/NodePtyAdapter.ts"));      return NodePtyAdapter.layer;    }  }),); const RelayClientLive = Layer.unwrap(  Effect.gen(function* () {    const config = yield* ServerConfig.ServerConfig;    return RelayClient.layerCloudflared({ baseDir: config.baseDir });  }),); const HttpServerLive = Layer.unwrap(  Effect.gen(function* () {    const config = yield* ServerConfig.ServerConfig;    if (typeof Bun !== "undefined") {      const BunHttpServer = yield* Effect.promise(        () => import("@effect/platform-bun/BunHttpServer"),      );      return BunHttpServer.layer({        port: config.port,        hostname: config.host ?? "127.0.0.1",        gracefulShutdownTimeout: HTTP_PREEMPTIVE_SHUTDOWN_GRACE_MS,      });    } else {      const [NodeHttpServer, NodeHttp] = yield* Effect.all([        Effect.promise(() => import("@effect/platform-node/NodeHttpServer")),        Effect.promise(() => import("node:http")),      ]);      return NodeHttpServer.layer(NodeHttp.createServer, {        host: config.host ?? "127.0.0.1",        port: config.port,        gracefulShutdownTimeout: HTTP_PREEMPTIVE_SHUTDOWN_GRACE_MS,      });    }  }),); const PlatformServicesLive = Layer.unwrap(  Effect.gen(function* () {    if (typeof Bun !== "undefined") {      const { layer } = yield* Effect.promise(() => import("@effect/platform-bun/BunServices"));      return layer;    } else {      const { layer } = yield* Effect.promise(() => import("@effect/platform-node/NodeServices"));      return layer;    }  }),); const ReactorLayerLive = Layer.empty.pipe(  Layer.provideMerge(OrchestrationReactorLive),  Layer.provideMerge(ProviderRuntimeIngestionLive),  Layer.provideMerge(ProviderCommandReactorLive),  Layer.provideMerge(CheckpointReactorLive),  Layer.provideMerge(ThreadDeletionReactorLive),  Layer.provideMerge(AgentAwarenessRelay.layer.pipe(Layer.provide(ServerSecretStore.layer))),  Layer.provideMerge(RuntimeReceiptBusLive),); const ProviderSessionDirectoryLayerLive = ProviderSessionDirectoryLive.pipe(  Layer.provide(ProviderSessionRuntime.layer),); // `ProviderAdapterRegistryLive` is now a facade that resolves kind → adapter// by looking up the default `ProviderInstance` per driver in the instance// registry. Adapter construction itself moved inside each driver's// `create()`; `ProviderEventLoggersLive` owns the shared native/canonical// NDJSON writers and is provided at the outer runtime layer so both// `ProviderService` and the per-instance drivers read the same logger pair.const ProviderLayerLive = ProviderServiceLive.pipe(  Layer.provide(ProviderAdapterRegistryLive),  Layer.provideMerge(ProviderSessionDirectoryLayerLive),); const PersistenceLayerLive = Layer.empty.pipe(Layer.provideMerge(SqlitePersistenceLayerLive)); const VcsDriverRegistryLayerLive = VcsDriverRegistry.layer.pipe(  Layer.provide(VcsProjectConfig.layer),); const SourceControlProviderRegistryLayerLive = SourceControlProviderRegistry.layer.pipe(  Layer.provide(    Layer.mergeAll(AzureDevOpsCli.layer, BitbucketApi.layer, GitHubCli.layer, GitLabCli.layer),  ),  Layer.provideMerge(GitVcsDriver.layer),  Layer.provideMerge(VcsDriverRegistryLayerLive),); const GitManagerLayerLive = GitManager.layer.pipe(  Layer.provideMerge(ProjectSetupScriptRunner.layer),  Layer.provideMerge(GitVcsDriver.layer),  Layer.provideMerge(SourceControlProviderRegistryLayerLive),  Layer.provideMerge(TextGeneration.layer),); const GitLayerLive = Layer.empty.pipe(  Layer.provideMerge(GitManagerLayerLive),  Layer.provideMerge(GitVcsDriver.layer),); const GitWorkflowLayerLive = GitWorkflowService.layer.pipe(  Layer.provideMerge(VcsDriverRegistryLayerLive),  Layer.provideMerge(GitLayerLive),); const SourceControlRepositoryServiceLayerLive = SourceControlRepositoryService.layer.pipe(  Layer.provideMerge(GitVcsDriver.layer),  Layer.provideMerge(SourceControlProviderRegistryLayerLive),); const ReviewLayerLive = ReviewService.layer.pipe(  Layer.provideMerge(GitVcsDriver.layer),  Layer.provideMerge(VcsDriverRegistryLayerLive),); const VcsLayerLive = Layer.empty.pipe(  Layer.provideMerge(VcsProjectConfig.layer),  Layer.provideMerge(VcsDriverRegistryLayerLive),  Layer.provideMerge(VcsProvisioningService.layer.pipe(Layer.provide(VcsDriverRegistryLayerLive))),  Layer.provideMerge(GitWorkflowLayerLive),  Layer.provideMerge(ReviewLayerLive),  Layer.provideMerge(SourceControlRepositoryServiceLayerLive),  Layer.provideMerge(VcsStatusBroadcaster.layer.pipe(Layer.provide(GitWorkflowLayerLive))),); const CheckpointingLayerLive = Layer.empty.pipe(  Layer.provideMerge(CheckpointDiffQuery.layer),  Layer.provideMerge(CheckpointStore.layer.pipe(Layer.provide(VcsDriverRegistryLayerLive))),); const PortScannerLayerLive = PortScanner.layer.pipe(Layer.provide(ProcessRunner.layer)); const TerminalLayerLive = TerminalManager.layer.pipe(  Layer.provide(PtyAdapterLive),  Layer.provide(PortScannerLayerLive),); const PreviewLayerLive = Layer.empty.pipe(  Layer.provideMerge(PreviewManager.layer),  Layer.provideMerge(PortScannerLayerLive),); const WorkspaceEntriesLayerLive = WorkspaceEntries.layer.pipe(Layer.provide(WorkspacePaths.layer)); const WorkspaceFileSystemLayerLive = WorkspaceFileSystem.layer.pipe(  Layer.provide(WorkspacePaths.layer),  Layer.provide(WorkspaceEntriesLayerLive),); const WorkspaceLayerLive = Layer.mergeAll(  WorkspacePaths.layer,  WorkspaceEntriesLayerLive,  WorkspaceFileSystemLayerLive,); const ProjectFaviconResolverLayerLive = ProjectFaviconResolver.layer.pipe(  Layer.provide(WorkspacePaths.layer),  Layer.provide(T3ProjectFileLoader.layer),); const AuthLayerLive = EnvironmentAuth.layer.pipe(  Layer.provideMerge(PersistenceLayerLive),  Layer.provide(ServerSecretStore.layer),); const CloudManagedEndpointRuntimeLive = Layer.mergeAll(  RelayClientLive,  CloudManagedEndpointRuntime.layer.pipe(    Layer.provide(ServerSecretStore.layer),    Layer.provide(RelayClientLive),  ),); const ProviderRuntimeLayerLive = ProviderSessionReaperLive.pipe(  Layer.provideMerge(ProviderLayerLive),  Layer.provideMerge(OrchestrationLayerLive),); const RuntimeCoreDependenciesLive = ReactorLayerLive.pipe(  // Core Services  Layer.provideMerge(CheckpointingLayerLive),  Layer.provideMerge(SourceControlProviderRegistryLayerLive),  Layer.provideMerge(GitLayerLive),  Layer.provideMerge(VcsLayerLive),  Layer.provideMerge(ProviderRuntimeLayerLive),  Layer.provideMerge(Layer.mergeAll(TerminalLayerLive, PreviewLayerLive)),  Layer.provideMerge(PersistenceLayerLive),  Layer.provideMerge(Keybindings.layer),  Layer.provideMerge(ProviderRegistryLive),  // The instance registry is the new routing keystone — text generation,  // adapter lookup, and runtime ingestion all resolve `ProviderInstanceId`  // through this layer. Built-in drivers come from `BUILT_IN_DRIVERS`;  // `providerInstances` hydration merges `settings.providers.<kind>`  // with explicit `providerInstances` entries on boot.  Layer.provideMerge(ProviderInstanceRegistryHydrationLive),  // Shared native/canonical NDJSON writers used by both the per-instance  // drivers (native stream, written from inside each `<X>Adapter`) and  // `ProviderService` (canonical stream, written after event normalization).  // Provided once at the runtime level so every consumer sees the same  // logger instances.  Layer.provideMerge(ProviderEventLoggers.ProviderEventLoggersLive),  // `OpenCodeDriver.create()` yields `OpenCodeRuntime`; previously the old  // `ProviderRegistryLive` pulled `OpenCodeRuntimeLive` in for itself, but  // the rewritten registry reads snapshots off the instance registry and  // no longer transitively provides it. Exposing it at the runtime level  // keeps a single Live for all opencode consumers.  Layer.provideMerge(OpenCodeRuntime.OpenCodeRuntimeLive),  Layer.provideMerge(ServerSettings.layer.pipe(Layer.provide(ServerSecretStore.layer))),  Layer.provideMerge(WorkspaceLayerLive),  Layer.provideMerge(ProjectFaviconResolverLayerLive),  Layer.provideMerge(RepositoryIdentityResolver.layer),  Layer.provideMerge(ServerEnvironment.layer),  Layer.provideMerge(AuthLayerLive),  Layer.provideMerge(ServerSecretStore.layer),  Layer.provideMerge(    Layer.mergeAll(      CloudCliTokenManager.layer.pipe(        Layer.provide(ServerSecretStore.layer),        Layer.provide(ExternalLauncher.layer),      ),      CloudManagedEndpointRuntimeLive,    ),  ),); const RuntimeDependenciesLive = RuntimeCoreDependenciesLive.pipe(  // Misc.  Layer.provideMerge(ProcessDiagnostics.layer),  Layer.provideMerge(ProcessResourceMonitor.layer),  Layer.provideMerge(TraceDiagnostics.layer),  Layer.provideMerge(AnalyticsService.layer),  Layer.provideMerge(ExternalLauncher.layer),  Layer.provideMerge(ServerLifecycleEvents.layer),  Layer.provide(NetService.layer),); const RuntimeServicesLive = ServerRuntimeStartup.layer.pipe(  Layer.provideMerge(RuntimeDependenciesLive),); export const makeRoutesLayer = Layer.mergeAll(  Layer.mergeAll(    HttpApiBuilder.layer(EnvironmentHttpApi).pipe(      Layer.provide(authHttpApiLayer),      Layer.provide(connectHttpApiLayer),      Layer.provide(orchestrationHttpApiLayer),      Layer.provide(serverEnvironmentHttpApiLayer),      Layer.provide(environmentAuthenticatedAuthLayer),    ),    otlpTracesProxyRouteLayer,    assetRouteLayer,    staticAndDevRouteLayer,    websocketRpcRouteLayer,  ),  McpHttpServer.layer.pipe(Layer.provide(McpSessionRegistry.layer)),).pipe(  Layer.provide(PreviewAutomationBroker.layer),  Layer.provide(ServerSelfUpdate.layer),  Layer.provide(browserApiCorsLayer),); export const makeServerLayer = Layer.unwrap(  Effect.gen(function* () {    const config = yield* ServerConfig.ServerConfig;     yield* fixPath();     const httpListeningLayer = Layer.effectDiscard(      Effect.gen(function* () {        yield* HttpServer.HttpServer;        const startup = yield* ServerRuntimeStartup.ServerRuntimeStartup;        yield* startup.markHttpListening;      }),    );    const runtimeStateLayer = Layer.effectDiscard(      Effect.acquireRelease(        Effect.gen(function* () {          const server = yield* HttpServer.HttpServer;          const address = server.address;          if (typeof address === "string" || !("port" in address)) {            return;          }           const state = yield* makePersistedServerRuntimeState({            config,            port: address.port,          });          yield* persistServerRuntimeState({            path: config.serverRuntimeStatePath,            state,          });        }),        () => clearPersistedServerRuntimeState(config.serverRuntimeStatePath),      ),    );    const tailscaleServeLayer = config.tailscaleServeEnabled      ? Layer.effectDiscard(          Effect.acquireRelease(            Effect.gen(function* () {              const server = yield* HttpServer.HttpServer;              const address = server.address;              if (typeof address === "string" || !("port" in address)) {                return null;              }               const localPort = address.port;              return yield* ensureTailscaleServe({                localPort,                servePort: config.tailscaleServePort,                localHost: "127.0.0.1",              }).pipe(                Effect.as({ localPort, servePort: config.tailscaleServePort }),                Effect.tap(() =>                  Effect.logInfo("Tailscale Serve configured", {                    localPort,                    servePort: config.tailscaleServePort,                  }),                ),                Effect.catch((cause) =>                  Effect.logWarning("Failed to configure Tailscale Serve", {                    cause,                    localPort,                    servePort: config.tailscaleServePort,                  }).pipe(Effect.as(null)),                ),              );            }),            (configured) =>              configured                ? disableTailscaleServe({ servePort: configured.servePort }).pipe(                    Effect.tap(() =>                      Effect.logInfo("Tailscale Serve disabled", {                        servePort: configured.servePort,                      }),                    ),                    Effect.catch((cause) =>                      Effect.logWarning("Failed to disable Tailscale Serve", {                        cause,                        servePort: configured.servePort,                      }),                    ),                  )                : Effect.void,          ),        )      : Layer.empty;    const cloudDesiredLinkReconcileLayer = Layer.effectDiscard(      Effect.gen(function* () {        if (!hasCloudPublicConfig) return;        if (!(yield* CloudCliState.readCliDesiredCloudLink)) return;        const server = yield* HttpServer.HttpServer;        const address = server.address;        if (typeof address === "string" || !("port" in address)) return;        yield* Effect.forkScoped(          Effect.sleep("250 millis").pipe(            Effect.andThen(reconcileDesiredCloudLink(`http://127.0.0.1:${address.port}`)),            Effect.retry({ times: 4 }),            Effect.tap(() => Effect.logInfo("T3 Connect desired link reconciled on startup")),            Effect.catch((cause) =>              Effect.logWarning("Failed to reconcile T3 Connect desired link on startup", {                cause,              }),            ),          ),        );      }),    );     const serverApplicationLayer = Layer.mergeAll(      HttpRouter.serve(makeRoutesLayer, {        disableLogger: !config.logWebSocketEvents,      }),      httpListeningLayer,      runtimeStateLayer,      tailscaleServeLayer,      cloudDesiredLinkReconcileLayer,    );     return serverApplicationLayer.pipe(      Layer.provideMerge(RuntimeServicesLive),      Layer.provideMerge(serverRelayBrokerTracingLayer),      Layer.provideMerge(HttpServerLive),      Layer.provide(ObservabilityLive),      Layer.provideMerge(FetchHttpClient.layer),      Layer.provideMerge(VcsProcess.layer),      Layer.provideMerge(PlatformServicesLive),    );  }),);

Lines 1–500 of 503. Load more