Method upgrade

packages/platform/deno/src/DenoHttpServer.ts:446–513

()

  }

  get upgrade(): Effect.Effect<Socket.Socket, Error.HttpServerError> {
    return Effect.flatMap(
      Effect.try({
        try: () => Deno.upgradeWebSocket(this.source, this.websocketOptions),
        catch: (cause) =>
          new Error.HttpServerError({
            reason: new Error.RequestParseError({
              request: this,
              cause,
              description: "Not an upgradeable ServerRequest"
            })
          })
      }),
      (upgrade) => {
        const buffered: Array<MessageEvent> = []
        const buffer = (event: MessageEvent) => buffered.push(event)
        upgrade.socket.addEventListener("message", buffer)
        this.upgraded = true
        this.resolve(upgrade.response)

        return Effect.callback<Socket.Socket, Error.HttpServerError>((resume) => {
          const cleanup = () => {
            upgrade.socket.removeEventListener("open", onOpen)
            upgrade.socket.removeEventListener("error", onFailure)
            upgrade.socket.removeEventListener("close", onFailure)
          }
          const onFailure = (cause: Event) => {
            cleanup()
            upgrade.socket.removeEventListener("message", buffer)
            buffered.length = 0
            resume(Effect.fail(
              new Error.HttpServerError({
                reason: new Error.RequestParseError({
                  request: this,
                  cause,
                  description: "WebSocket upgrade failed before open"
                })
              })
            ))
          }
          const onOpen = () => {
            cleanup()
            resume(Socket.fromWebSocket(
              Effect.acquireRelease(
                Effect.succeed(upgrade.socket),
                (socket) => Effect.sync(() => socket.close(1000))
              ),
              {
                onInitialRun: (socket) => {
                  socket.removeEventListener("message", buffer)
                  return buffered.splice(0)
                }
              }
            ))
          }
          upgrade.socket.addEventListener("open", onOpen, { once: true })
          upgrade.socket.addEventListener("error", onFailure, { once: true })
          upgrade.socket.addEventListener("close", onFailure, { once: true })