import { HttpApiBuilder, HttpMiddleware, HttpRouter, HttpServer } from "@effect/platform";import { Effect, Layer } from "effect"; import { CoreExecutorApi, InternalError, observabilityMiddleware } from "@executor/api";import { CoreHandlers } from "@executor/api/server";import { OpenApiGroup, OpenApiHandlers } from "@executor/plugin-openapi/api";import { McpGroup, McpHandlers } from "@executor/plugin-mcp/api";import { GraphqlGroup, GraphqlHandlers } from "@executor/plugin-graphql/api"; import { OrgAuth } from "../auth/middleware";import { OrgAuthLive, SessionAuthLive } from "../auth/middleware-live";import { UserStoreService } from "../auth/context";import { CloudAuthPublicHandlers, CloudSessionAuthHandlers, NonProtectedApi,} from "../auth/handlers";import { DbService } from "../services/db";import { TelemetryLive } from "../services/telemetry";import { OrgHttpApi } from "../org/compose";import { OrgHandlers } from "../org/handlers";import { ErrorCaptureLive } from "../observability"; import { CoreSharedServices } from "./core-shared-services"; export { CoreSharedServices }; const ProtectedCloudApi = CoreExecutorApi.add(OpenApiGroup) .add(McpGroup) .add(GraphqlGroup) .addError(InternalError) .middleware(OrgAuth); const ObservabilityLive = observabilityMiddleware(ProtectedCloudApi); const DbLive = DbService.Live;const UserStoreLive = UserStoreService.Live.pipe(Layer.provide(DbLive)); export const SharedServices = Layer.mergeAll( DbLive, UserStoreLive, CoreSharedServices, HttpServer.layerContext, TelemetryLive,); export const RouterConfig = HttpRouter.setRouterConfig({ maxParamLength: 1000 }); export const ProtectedCloudApiLive = HttpApiBuilder.api(ProtectedCloudApi).pipe( Layer.provide( Layer.mergeAll( CoreHandlers, OpenApiHandlers, McpHandlers, GraphqlHandlers, OrgAuthLive, ObservabilityLive, ), ), Layer.provide(ErrorCaptureLive),); const NonProtectedApiLive = HttpApiBuilder.api(NonProtectedApi).pipe( Layer.provide(Layer.mergeAll(CloudAuthPublicHandlers, CloudSessionAuthHandlers)), Layer.provideMerge(SessionAuthLive),); const OrgApiLive = HttpApiBuilder.api(OrgHttpApi).pipe( Layer.provide(OrgHandlers), Layer.provideMerge(OrgAuthLive),); const NonProtectedRequestLayer = NonProtectedApiLive.pipe( Layer.provideMerge(RouterConfig), Layer.provideMerge(HttpServer.layerContext), Layer.provideMerge(HttpApiBuilder.Router.Live), Layer.provideMerge(HttpApiBuilder.Middleware.layer),); const OrgRequestLayer = OrgApiLive.pipe( Layer.provideMerge(RouterConfig), Layer.provideMerge(HttpServer.layerContext), Layer.provideMerge(HttpApiBuilder.Router.Live), Layer.provideMerge(HttpApiBuilder.Middleware.layer),); export const NonProtectedApiApp = Effect.flatMap( HttpApiBuilder.httpApp.pipe(Effect.provide(NonProtectedRequestLayer)), HttpMiddleware.logger,).pipe(Effect.provide(SharedServices)); export const OrgApiApp = Effect.flatMap( HttpApiBuilder.httpApp.pipe(Effect.provide(OrgRequestLayer)), HttpMiddleware.logger,).pipe(Effect.provide(SharedServices));
import { HttpApiBuilder, HttpMiddleware, HttpRouter, HttpServer } from "@effect/platform";
import { Effect, Layer } from "effect";
import { CoreExecutorApi, InternalError, observabilityMiddleware } from "@executor/api";
import { CoreHandlers } from "@executor/api/server";
import { OpenApiGroup, OpenApiHandlers } from "@executor/plugin-openapi/api";
import { McpGroup, McpHandlers } from "@executor/plugin-mcp/api";
import { GraphqlGroup, GraphqlHandlers } from "@executor/plugin-graphql/api";
import { OrgAuth } from "../auth/middleware";
import { OrgAuthLive, SessionAuthLive } from "../auth/middleware-live";
import { UserStoreService } from "../auth/context";
import {
CloudAuthPublicHandlers,
CloudSessionAuthHandlers,
NonProtectedApi,
} from "../auth/handlers";
import { DbService } from "../services/db";
import { TelemetryLive } from "../services/telemetry";
import { OrgHttpApi } from "../org/compose";
import { OrgHandlers } from "../org/handlers";
import { ErrorCaptureLive } from "../observability";
import { CoreSharedServices } from "./core-shared-services";
export { CoreSharedServices };
const ProtectedCloudApi = CoreExecutorApi.add(OpenApiGroup)
.add(McpGroup)
.add(GraphqlGroup)
.addError(InternalError)
.middleware(OrgAuth);
const ObservabilityLive = observabilityMiddleware(ProtectedCloudApi);
const DbLive = DbService.Live;
const UserStoreLive = UserStoreService.Live.pipe(Layer.provide(DbLive));
export const SharedServices = Layer.mergeAll(
DbLive,
UserStoreLive,
CoreSharedServices,
HttpServer.layerContext,
TelemetryLive,
);
export const RouterConfig = HttpRouter.setRouterConfig({ maxParamLength: 1000 });
export const ProtectedCloudApiLive = HttpApiBuilder.api(ProtectedCloudApi).pipe(
Layer.provide(
Layer.mergeAll(
CoreHandlers,
OpenApiHandlers,
McpHandlers,
GraphqlHandlers,
OrgAuthLive,
ObservabilityLive,
),
),
Layer.provide(ErrorCaptureLive),
);
const NonProtectedApiLive = HttpApiBuilder.api(NonProtectedApi).pipe(
Layer.provide(Layer.mergeAll(CloudAuthPublicHandlers, CloudSessionAuthHandlers)),
Layer.provideMerge(SessionAuthLive),
);
const OrgApiLive = HttpApiBuilder.api(OrgHttpApi).pipe(
Layer.provide(OrgHandlers),
Layer.provideMerge(OrgAuthLive),
);
const NonProtectedRequestLayer = NonProtectedApiLive.pipe(
Layer.provideMerge(RouterConfig),
Layer.provideMerge(HttpServer.layerContext),
Layer.provideMerge(HttpApiBuilder.Router.Live),
Layer.provideMerge(HttpApiBuilder.Middleware.layer),
);
const OrgRequestLayer = OrgApiLive.pipe(
Layer.provideMerge(RouterConfig),
Layer.provideMerge(HttpServer.layerContext),
Layer.provideMerge(HttpApiBuilder.Router.Live),
Layer.provideMerge(HttpApiBuilder.Middleware.layer),
);
export const NonProtectedApiApp = Effect.flatMap(
HttpApiBuilder.httpApp.pipe(Effect.provide(NonProtectedRequestLayer)),
HttpMiddleware.logger,
).pipe(Effect.provide(SharedServices));
export const OrgApiApp = Effect.flatMap(
HttpApiBuilder.httpApp.pipe(Effect.provide(OrgRequestLayer)),
HttpMiddleware.logger,
).pipe(Effect.provide(SharedServices));