Function toHandled

packages/platform/src/HttpApp.ts:48–128

(
  self: Default<E, R>,
  handleResponse: (
    request: ServerRequest.HttpServerRequest,
    response: ServerResponse.HttpServerResponse
  ) => Effect.Effect<_, EH, RH>,
  middleware?: HttpMiddleware | undefined
)

 * @category combinators
 */
export const toHandled = <E, R, _, EH, RH>(
  self: Default<E, R>,
  handleResponse: (
    request: ServerRequest.HttpServerRequest,
    response: ServerResponse.HttpServerResponse
  ) => Effect.Effect<_, EH, RH>,
  middleware?: HttpMiddleware | undefined
): Effect.Effect<void, never, Exclude<R | RH | ServerRequest.HttpServerRequest, Scope.Scope>> => {
  const responded = Effect.withFiberRuntime<
    ServerResponse.HttpServerResponse,
    E | EH | ServerError.ResponseError,
    R | RH | ServerRequest.HttpServerRequest
  >((fiber) =>
    Effect.flatMap(self, (response) => {
      const request = Context.unsafeGet(fiber.currentContext, ServerRequest.HttpServerRequest)
      const handler = fiber.getFiberRef(currentPreResponseHandlers)
      if (handler._tag === "None") {
        ;(request as any)[handledSymbol] = true
        return Effect.as(handleResponse(request, response), response)
      }
      return Effect.tap(handler.value(request, response), (response) => {
        ;(request as any)[handledSymbol] = true
        return handleResponse(request, response)
      })
    })
  )

  const withErrorHandling = Effect.catchAllCause(
    responded,
    (cause) =>
      Effect.withFiberRuntime<
        ServerResponse.HttpServerResponse,
        E | EH | ServerError.ResponseError,
        ServerRequest.HttpServerRequest | RH
      >((fiber) =>
        Effect.flatMap(ServerError.causeResponse(cause), ([response, cause]) => {
          const request = Context.unsafeGet(fiber.currentContext, ServerRequest.HttpServerRequest)
          const handler = fiber.getFiberRef(currentPreResponseHandlers)
          if (handler._tag === "None") {
            ;(request as any)[handledSymbol] = true
            return Effect.zipRight(
              handleResponse(request, response),
              Cause.isEmptyType(cause) ? Effect.succeed(response) : Effect.failCause(cause)
            )
          }
          return Effect.zipRight(
            Effect.tap(handler.value(request, response), (response) => {
              ;(request as any)[handledSymbol] = true
              return handleResponse(request, response)
            }),
            Cause.isEmptyType(cause) ? Effect.succeed(response) : Effect.failCause(cause)
          )
        })
      )
  )

  const withMiddleware = unify(
    middleware === undefined ?