Function make

packages/platform-node/src/internal/httpClientUndici.ts:43–73

(dispatcher: Undici.Dispatcher)

/** @internal */
export const make = (dispatcher: Undici.Dispatcher): Client.HttpClient =>
  Client.make((request, url, signal, fiber) => {
    const context = fiber.getFiberRef(FiberRef.currentContext)
    const options: Undici.Dispatcher.RequestOptions = context.unsafeMap.get(undiciOptionsTagKey) ?? {}
    return convertBody(request.body).pipe(
      Effect.flatMap((body) =>
        Effect.tryPromise({
          try: () =>
            dispatcher.request({
              ...options,
              signal,
              method: request.method,
              headers: request.headers,
              origin: url.origin,
              path: url.pathname + url.search + url.hash,
              body,
              // leave timeouts to Effect.timeout etc
              headersTimeout: 60 * 60 * 1000,
              bodyTimeout: 0
            }),
          catch: (cause) =>
            new Error.RequestError({
              request,
              reason: "Transport",
              cause
            })
        })
      ),
      Effect.map((response) => new ClientResponseImpl(request, response))
    )
  })

function convertBody(
  body: Body.HttpBody