Function resolveSpecForInput

packages/plugins/openapi/src/sdk/plugin.ts:599–630

(
    config: Pick<OpenApiSpecConfig, "spec" | "specFormat" | "headers" | "queryParams" | "baseUrl">,
    httpClientLayer: Layer.Layer<HttpClient.HttpClient, never, never>,
  )

  OpenApiPluginOptions
>((options?: OpenApiPluginOptions) => {
  const resolveSpecForInput = (
    config: Pick<OpenApiSpecConfig, "spec" | "specFormat" | "headers" | "queryParams" | "baseUrl">,
    httpClientLayer: Layer.Layer<HttpClient.HttpClient, never, never>,
  ): Effect.Effect<ConvertedSpec, OpenApiParseError | OpenApiExtractionError | OpenApiOAuthError> =>
    Effect.gen(function* () {
      const adapter = yield* resolveSpecFormatAdapter(
        options?.specFormats ?? [],
        config.specFormat,
      );
      if (adapter) {
        if (config.spec.kind !== "url") {
          return yield* new OpenApiParseError({
            message: "Spec format adapters require a URL spec input",
          });
        }
        return yield* adapter.fetch({
          urls: [config.spec.url],
          credentials: {
            ...(config.headers ? { headers: config.headers } : {}),
            ...(config.queryParams ? { queryParams: config.queryParams } : {}),
          },
          httpClientLayer,
        });
      }
      if (config.spec.kind === "url") {
        const specText = yield* resolveSpecText(config.spec.url).pipe(
          Effect.provide(httpClientLayer),
        );
        return { specText, specUrl: config.spec.url };
      }
      return { specText: config.spec.value };
    });

  return {
    id: "openapi" as const,