Function invokeWithLayer

packages/plugins/openapi/src/sdk/invoke.ts:922–956

(
  operation: OperationBinding,
  args: Record<string, unknown>,
  baseUrl: string,
  resolvedHeaders: Record<string, string>,
  sourceQueryParams: Record<string, string>,
  httpClientLayer: Layer.Layer<HttpClient.HttpClient, never, never>,
)

// ---------------------------------------------------------------------------

export const invokeWithLayer = (
  operation: OperationBinding,
  args: Record<string, unknown>,
  baseUrl: string,
  resolvedHeaders: Record<string, string>,
  sourceQueryParams: Record<string, string>,
  httpClientLayer: Layer.Layer<HttpClient.HttpClient, never, never>,
) => {
  const effectiveBaseUrl = resolveRequestHost(operation.servers ?? [], args.server, baseUrl);
  const clientWithBaseUrl = effectiveBaseUrl
    ? Layer.effect(
        HttpClient.HttpClient,
        Effect.map(
          Effect.service(HttpClient.HttpClient),
          HttpClient.mapRequest(HttpClientRequest.prependUrl(effectiveBaseUrl)),
        ),
      ).pipe(Layer.provide(httpClientLayer))
    : httpClientLayer;

  return invoke(operation, args, resolvedHeaders, sourceQueryParams).pipe(
    Effect.provide(clientWithBaseUrl),
    // `invoke` annotates http.status_code on ITS span (`OpenApi.invoke`,
    // via Effect.fn) — annotateCurrentSpan inside it never reaches this
    // wrapper span. Stamp the status here too so queries against
    // `plugin.openapi.invoke` see the upstream outcome directly.
    Effect.tap((result) => Effect.annotateCurrentSpan({ "http.status_code": result.status })),
    Effect.withSpan("plugin.openapi.invoke", {
      attributes: {
        "plugin.openapi.method": operation.method.toUpperCase(),
        "plugin.openapi.path_template": operation.pathTemplate,
        "plugin.openapi.base_url": effectiveBaseUrl,
      },
    }),
  );
};

// ---------------------------------------------------------------------------
// Derive annotations from HTTP method