import { HttpApiBuilder } from "effect/unstable/httpapi";
import { Context, Effect } from "effect";

import { addGroup, capture } from "@executor-js/api";
import type {
  OpenApiConfiguredValueInput,
  OpenApiConfigureInput,
  OpenApiPluginExtension,
  OpenApiPreviewSpecFetchCredentialsInput,
  OpenApiSpecFetchCredentialsInput,
} from "../sdk/plugin";
import { StoredSourceSchema } from "../sdk/store";
import { OpenApiGroup } from "./group";

// ---------------------------------------------------------------------------
// Service tag
//
// Holds the `Captured` shape — every method's `StorageFailure`
// channel has been swapped for `InternalError({ traceId })`. The cloud
// app provides an already-wrapped extension via
// `Layer.succeed(OpenApiExtensionService, withCapture(executor.openapi))`.
// Handlers see `InternalError` in the error union, which matches
// `.addError(InternalError)` on the group — no per-handler translation.
// ---------------------------------------------------------------------------

export class OpenApiExtensionService extends Context.Service<
  OpenApiExtensionService,
  OpenApiPluginExtension
>()("OpenApiExtensionService") {}

// ---------------------------------------------------------------------------
// Composed API — core + openapi group
// ---------------------------------------------------------------------------

const ExecutorApiWithOpenApi = addGroup(OpenApiGroup);

// ---------------------------------------------------------------------------
// Handlers
//
// Each handler is exactly: yield the extension service, call the method,
// return. Plugin SDK errors flow through the typed channel and are
// schema-encoded to 4xx by HttpApi (see group.ts `.addError(...)` calls).
// Defects bubble up and are captured + downgraded to `InternalError(traceId)`
// by the API-level observability middleware.
// ---------------------------------------------------------------------------

export const OpenApiHandlers = HttpApiBuilder.group(ExecutorApiWithOpenApi, "openapi", (handlers) =>
  handlers
    .handle("previewSpec", ({ payload }) =>
      capture(
        Effect.gen(function* () {
          const ext = yield* OpenApiExtensionService;
          return yield* ext.previewSpec({
            spec: payload.spec,
            specFetchCredentials: payload.specFetchCredentials as
              | OpenApiPreviewSpecFetchCredentialsInput
              | undefined,
          });
        }),
      ),
    )
    .handle("addSpec", ({ params: path, payload }) =>
      capture(
        Effect.gen(function* () {
          const ext = yield* OpenApiExtensionService;
          const result = yield* ext.addSpec({
            spec: payload.spec,
            specFetchCredentials: payload.specFetchCredentials as
              | OpenApiSpecFetchCredentialsInput
              | undefined,
            scope: path.scopeId,
            name: payload.name,
            baseUrl: payload.baseUrl,
            namespace: payload.namespace,
            headers: payload.headers as Record<string, OpenApiConfiguredValueInput> | undefined,
            queryParams: payload.queryParams as
              | Record<string, OpenApiConfiguredValueInput>
              | undefined,
            oauth2: payload.oauth2,
          });
          return {
            toolCount: result.toolCount,
            namespace: result.sourceId,
          };
        }),
      ),
    )
    .handle("getSource", ({ params: path }) =>
      capture(
        Effect.gen(function* () {
          const ext = yield* OpenApiExtensionService;
          const source = yield* ext.getSource(path.namespace, path.scopeId);
          return source
            ? StoredSourceSchema.make({
                namespace: source.namespace,
                scope: source.scope,
                name: source.name,
                config: {
                  sourceUrl: source.config.sourceUrl,
                  baseUrl: source.config.baseUrl,
                  namespace: source.config.namespace,
                  headers: source.config.headers,
                  queryParams: source.config.queryParams,
                  specFetchCredentials: source.config.specFetchCredentials,
                  oauth2: source.config.oauth2,
                },
              })
            : null;
        }),
      ),
    )
    .handle("configure", ({ payload }) =>
      capture(
        Effect.gen(function* () {
          const ext = yield* OpenApiExtensionService;
          return yield* ext.configure(payload.source, payload as OpenApiConfigureInput);
        }),
      ),
    ),
);