Method handshake

packages/client/src/ws/StreamerbotClient.ts:269–318

()

    this._explicitlyClosed = true;
    this._connectController.abort();
    if (this._reconnectTimeout) clearTimeout(this._reconnectTimeout);
    if (!this.socket || this.socket.readyState === this.socket.CLOSED) return;

    const controller = new AbortController();
    const signal = controller.signal;

    this._connectController.signal.addEventListener('abort', () => controller.abort(), {
      once: true,
      signal,
    });

    return await withTimeout(
      new Promise<void>((res, rej) => {
        if (!this.socket) return;

        this.socket.addEventListener(
          'close',
          () => {
            this.logger?.debug('Disconnected from Streamer.bot WebSocket server');
            res();
          },
          { signal },
        );

        if (this.socket.readyState !== this.socket.CLOSING) {
          try {
            this.socket?.close(code);
          } catch (error) {
            rej(error);
          }
        }
      }),
      {
        timeout,
        message: 'Timeout exceeded while closing connection',
        controller,
        signal: this._connectController.signal,
      },
    );
  }

  private async handshake(): Promise<void> {
    if (!this.socket) throw new Error('WebSocket not initialized');

    const controller = new AbortController();
    const { signal } = controller;

    this._connectController.signal.addEventListener('abort', () => controller.abort(), {
      once: true,
      signal,
    });

    const response = await withTimeout(