Function toWebHandlerRuntime

packages/platform/src/HttpApp.ts:211–241

(runtime: Runtime.Runtime<R>)

 * @category conversions
 */
export const toWebHandlerRuntime = <R>(runtime: Runtime.Runtime<R>) => {
  const httpRuntime: Types.Mutable<Runtime.Runtime<R>> = Runtime.make(runtime)
  const run = Runtime.runFork(httpRuntime)
  return <E>(self: Default<E, R | Scope.Scope>, middleware?: HttpMiddleware | undefined) => {
    const resolveSymbol = Symbol.for("@effect/platform/HttpApp/resolve")
    const httpApp = toHandled(self, (request, response) => {
      response = unsafeEjectStreamScope(response)
      ;(request as any)[resolveSymbol](
        ServerResponse.toWeb(response, { withoutBody: request.method === "HEAD", runtime })
      )
      return Effect.void
    }, middleware)
    return (request: Request, context?: Context.Context<never> | undefined): Promise<Response> =>
      new Promise((resolve) => {
        const contextMap = new Map<string, any>(runtime.context.unsafeMap)
        if (Context.isContext(context)) {
          for (const [key, value] of context.unsafeMap) {
            contextMap.set(key, value)
          }
        }
        const httpServerRequest = ServerRequest.fromWeb(request)
        contextMap.set(ServerRequest.HttpServerRequest.key, httpServerRequest)
        ;(httpServerRequest as any)[resolveSymbol] = resolve
        httpRuntime.context = Context.unsafeMake(contextMap)
        const fiber = run(httpApp as any)
        request.signal?.addEventListener("abort", () => {
          fiber.unsafeInterruptAsFork(ServerError.clientAbortFiberId)
        }, { once: true })
      })
  }
}

/**
 * @since 1.0.0