Function resolveSpecForInput

packages/plugins/openapi/src/sdk/plugin.ts:646–690

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

  });

  const resolveSpecForInput = (
    config: Pick<
      OpenApiSpecConfig,
      "spec" | "specFormat" | "specOverrides" | "headers" | "queryParams" | "baseUrl"
    >,
    httpClientLayer: Layer.Layer<HttpClient.HttpClient, never, never>,
  ): Effect.Effect<
    ResolvedSpec,
    OpenApiParseError | OpenApiExtractionError | OpenApiOAuthError | OpenApiSpecOverrideError
  > =>
    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",
          });
        }
        const resolved = yield* adapter.fetch({
          urls: [config.spec.url],
          credentials: {
            ...(config.headers ? { headers: config.headers } : {}),
            ...(config.queryParams ? { queryParams: config.queryParams } : {}),
          },
          httpClientLayer,
        });
        return yield* applyOverridesToResolvedSpec(resolved, config.specOverrides);
      }
      if (config.spec.kind === "url") {
        const specText = yield* resolveSpecText(config.spec.url).pipe(
          Effect.provide(httpClientLayer),
        );
        return yield* applyOverridesToResolvedSpec(
          { specText, specUrl: config.spec.url },
          config.specOverrides,
        );
      }
      return yield* applyOverridesToResolvedSpec(
        { specText: config.spec.value },
        config.specOverrides,
      );
    });

  return {
    id: "openapi" as const,