Method request

packages/client/src/ws/StreamerbotClient.ts:534–599

* Make a request to the Streamer.bot WebSocket, * wait for the response, and return the response data

(
    request: StreamerbotRequest,
    id: string = '',
    timeout: number = 10_000
  )

      if (this.options.onData) this?.options?.onData(payload);
    } catch (e) {
      this.logger?.warn('Error occurred within user-provided onData callback', e);
    }

    // any listeners called from `.on`
    if (payload?.event?.source && payload?.event?.type) {
      for (const listener of this.listeners) {
        if (!listener.events?.length) continue;
        if (
          !listener.events.find((event) => {
            return (
              event === '*' ||
              event === `${payload?.event?.source}.${payload?.event?.type}` ||
              (event.split('.', 2)?.[1] === '*' &&
                event.split('.', 2)?.[0] === payload?.event?.source)
            );
          })
        )
          continue;

        try {
          listener.callback(payload);
        } catch (e) {
          this.logger?.warn(
            `Error occurred within user-provided event callback (${listener.events})`,
            e,
          );
        }
      }
    }
  }

  protected onError(event: Event): void {
    this.logger?.debug('WebSocket onError', event);
    if (!!this.socket && this.socket.readyState !== this.socket.OPEN) {
      this._connectController.abort();
    }
    try {
      this?.options?.onError?.(new Error('WebSocket Error'));
    } catch (e) {
      this.logger?.warn('Error occurred within user-provided onError callback', e);
    }
  }

  protected cleanup(): void {
    if (this.socket) {
      this.socket.onopen = null;
      this.socket.onclose = null;
      this.socket.onerror = null;
      this.socket.onmessage = null;
      this.socket = undefined;
    }
    this.listeners = [];
    this._retried = 0;
    this._connectController.abort();
    if (this._reconnectTimeout) clearTimeout(this._reconnectTimeout);
  }

  /**