Method connect

packages/client/src/ws/StreamerbotClient.ts:182–235

* Connect to a Streamer.bot WebSocket server

(timeout: number = 10_000)

   */
  public get ready(): boolean {
    if (!this.socket || this.socket.readyState !== this.socket.OPEN) return false;
    if (this._authEnabled && !this._authenticated) return false;
    return !!this.info && !!this.version;
  }

  /**
   * Connect to a Streamer.bot WebSocket server
   */
  public async connect(timeout: number = 10_000): Promise<void> {
    if (this.socket?.readyState !== this.socket?.CLOSED) {
      try {
        await this.disconnect();
      } catch (e) {
        this.logger?.warn('Unexpected error while calling disconnect():', e);
      }
    }

    this._explicitlyClosed = false;

    this._connectController.abort();
    this._connectController = new AbortController();
    const controller = new AbortController();
    const { signal } = controller;

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

    return await withTimeout(
      new Promise<void>((res, rej) => {
        try {
          if (this.options.password) this._authEnabled = true;

          const uri = `${this.options.scheme}://${this.options.host}:${this.options.port}${this.options.endpoint}`;
          this.logger?.debug(
            'Connecting to Streamer.bot WebSocket server at',
            uri,
            this._authEnabled ? 'with authentication' : '',
          );

          this.socket = new WebSocket(uri);

          this.socket.onmessage = this.onMessage.bind(this);
          this.socket.onopen = this.onOpen.bind(this);
          this.socket.onclose = this.onClose.bind(this);
          this.socket.onerror = this.onError.bind(this);

          this.socket.addEventListener(
            'open',
            () => {
              if (!this.socket) return rej(new Error('WebSocket not initialized'));
              res();
            },
            { once: true, signal },
          );