Method onOpen

packages/client/src/ws/StreamerbotClient.ts:361–407

()

      this.logger?.debug('Connected to Streamer.bot WebSocket server', response.info);
      this.info = response.info;
      this.version = response.info.version;
      return;
    }

    throw new Error('Handshake failed (unknown)');
  }

  private async authenticate(data: StreamerbotHelloRequest): Promise<void> {
    if (!this._authEnabled || !this.options.password) {
      this.logger?.debug(
        'No password provided for authentication. Checking if auth is enforced for all requests...',
      );
      const res = await this.getInfo();
      if (res.status === 'ok') {
        this._authenticated = false;
        this.version = data.info.version;
        this.info = data.info;
        return;
      }
      await this.disconnect();
      throw new Error('Authentication required');
    }

    if (!data.authentication) {
      this.logger?.debug('Missing authentication payload');
      await this.disconnect();
      throw new Error('Invalid authentication payload');
    }

    this.logger?.debug('Authenticating with Streamer.bot WebSocket server...');

    const { salt, challenge } = data.authentication;
    const secret = await sha256base64(`${this.options.password}${salt}`);
    const authentication = await sha256base64(`${secret}${challenge}`);

    const response = await this.request({
      request: 'Authenticate',
      authentication,
    });

    if (response.status === 'ok') {
      this._authenticated = true;
      this.version = data.info.version;
      this.info = data.info;
    } else {
      await this.disconnect();
      throw new Error('Authentication failed');
    }
  }