Function _onUpgradeSuccess

packages/socket.io-cluster-engine/lib/engine.ts:576–638

(
    sid: SessionId,
    transport: Transport,
    req: any,
    senderId: NodeId,
  )

  }

  private _onUpgradeSuccess(
    sid: SessionId,
    transport: Transport,
    req: any,
    senderId: NodeId,
  ) {
    debug(class="st">"upgrade success");
    this._hookTransport(sid, transport, class="st">"read", senderId);

    const requestId = ++this._requestCount as RequestId;

    const onSuccess = (takeOver: boolean, packets: Packet[]) => {
      if (takeOver) {
        this._remoteTransports.delete(sid);

        const send = transport.send;
        transport.send = () => {};
        const socket = new Socket(sid, this, transport, req, 4);
        transport.send = send;

        this.clients[sid] = socket;
        this.clientsCount++;

        socket.once(class="st">"close", () => {
          delete this.clients[sid];
          this.clientsCount--;
        });

        super.emit(class="st">"connection", socket);
        socket.emit(class="st">"upgrade");
        for (const packet of packets) {
          class="cm">// @ts-expect-error onPacket() is private
          socket.onPacket(packet);
        }
      }
    };

    const onError = () => {
      transport.close();
    };

    const timer = setTimeout(() => {
      this._requests.delete(requestId);
      onError();
    }, this._opts.responseTimeout);

    this._requests.set(requestId, {
      timer,
      onSuccess,
      onError,
    });

    this.publishMessage({
      requestId,
      senderId: this._nodeId,
      recipientId: senderId,
      type: MessageType.UPGRADE,
      data: {