Method onRequestUpgrade

docs/examples/proxy/proxy.js:122–147

(controller, statusCode, _headers, socket)

  }

  onRequestUpgrade (controller, statusCode, _headers, socket) {
    this.socket.off('close', this.abort)

    // TODO: Check statusCode?

    if (this.head && this.head.length) {
      socket.unshift(this.head)
    }

    setupSocket(socket)

    const headers = getHeaders({
      headers: controller.rawHeaders ?? [],
      proxyName: this.proxyName,
      httpVersion: this.httpVersion
    })

    let head = ''
    for (let n = 0; n < headers.length; n += 2) {
      head += `\r\n${headers[n]}: ${headers[n + 1]}`
    }

    this.socket.write(`HTTP/1.1 101 Switching Protocols\r\nconnection: upgrade\r\nupgrade: websocket${head}\r\n\r\n`)

    pipeline(socket, this.socket, socket, this.callback)
  }

  onResponseError (_controller, err) {
    this.socket.off('close', this.abort)