import { HttpApiBuilder } from "effect/unstable/httpapi";import { Context, Effect } from "effect"; import { addGroup, capture } from "@executor-js/api";import type { GoogleDiscoveryAddSourceInput, GoogleDiscoveryPluginExtension } from "../sdk/plugin";import { GoogleDiscoveryStoredSourceSchema } from "../sdk/stored-source";import { GoogleDiscoveryGroup } from "./group"; // ---------------------------------------------------------------------------// Service tag//// Holds the `Captured` shape — every method's `StorageFailure` channel// has been swapped for `InternalError({ traceId })`. The host app// provides an already-wrapped extension via// `Layer.succeed(GoogleDiscoveryExtensionService, withCapture(executor.googleDiscovery))`.// Handlers see `InternalError` in the error union, which matches// `.addError(InternalError)` on the group — no per-handler translation.// --------------------------------------------------------------------------- export class GoogleDiscoveryExtensionService extends Context.Service<  GoogleDiscoveryExtensionService,  GoogleDiscoveryPluginExtension>()("GoogleDiscoveryExtensionService") {} // ---------------------------------------------------------------------------// Composed API// --------------------------------------------------------------------------- const ExecutorApiWithGoogleDiscovery = addGroup(GoogleDiscoveryGroup); // ---------------------------------------------------------------------------// 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).// `StorageFailure` has already been translated to `InternalError` by// `withCapture` on the service instance; defects bubble up and are// captured + downgraded to `InternalError(traceId)` by the API-level// observability middleware.//// OAuth start/complete/callback live on the shared `/scopes/:scopeId/oauth/*`// group in `@executor-js/api` now — the plugin has no OAuth-specific handlers.// --------------------------------------------------------------------------- export const GoogleDiscoveryHandlers = HttpApiBuilder.group(  ExecutorApiWithGoogleDiscovery,  "googleDiscovery",  (handlers) =>    handlers      .handle("probeDiscovery", ({ payload }) =>        capture(          Effect.gen(function* () {            const ext = yield* GoogleDiscoveryExtensionService;            return yield* ext.probeDiscovery({              discoveryUrl: payload.discoveryUrl,              credentials: payload.credentials,            });          }),        ),      )      .handle("addSource", ({ params: path, payload }) =>        capture(          Effect.gen(function* () {            const ext = yield* GoogleDiscoveryExtensionService;            return yield* ext.addSource({              ...(payload as Omit<GoogleDiscoveryAddSourceInput, "scope">),              scope: path.scopeId,            });          }),        ),      )      .handle("getSource", ({ params: path }) =>        capture(          Effect.gen(function* () {            const ext = yield* GoogleDiscoveryExtensionService;            const source = yield* ext.getSource(path.namespace, path.scopeId);            return source              ? new GoogleDiscoveryStoredSourceSchema({                  namespace: source.namespace,                  name: source.name,                  config: source.config,                })              : null;          }),        ),      )      .handle("updateSource", ({ params: path, payload }) =>        capture(          Effect.gen(function* () {            const ext = yield* GoogleDiscoveryExtensionService;            yield* ext.updateSource(path.namespace, path.scopeId, {              name: payload.name,              auth: payload.auth,            });            return { updated: true };          }),        ),      ),);