Class OpenSeaStreamClient

src/client.ts:23–226

import { ENDPOINTS } from './constants';

export class OpenSeaStreamClient {
  private socket: Socket;
  private channels: Map<string, Channel>;
  private logLevel: LogLevel;
  private onEvent: OnClientEvent;

  constructor({
    network = Network.MAINNET,
    token,
    apiUrl,
    connectOptions,
    logLevel = LogLevel.INFO,
    onError = (error) => this.error(error),
    onEvent = () => true
  }: ClientConfig) {
    const endpoint = apiUrl || ENDPOINTS[network];
    const webTransportDefault =
      typeof window !== 'undefined' ? window.WebSocket : undefined;
    this.socket = new Socket(endpoint, {
      params: { token },
      transport: webTransportDefault,
      ...connectOptions
    });

    this.socket.onError(onError);
    this.channels = new Map<string, Channel>();
    this.logLevel = logLevel;
    this.onEvent = onEvent;
  }

  private debug(message: unknown) {
    if (this.logLevel <= LogLevel.DEBUG) {
      console.debug(`[DEBUG]: ${message}`);
    }
  }

  private info(message: unknown) {
    if (this.logLevel <= LogLevel.INFO) {
      console.info(`[INFO]: ${message}`);
    }
  }

  private warn(message: unknown) {
    if (this.logLevel <= LogLevel.WARN) {
      console.warn(`[WARN]: ${message}`);
    }
  }

  private error(message: unknown) {
    if (this.logLevel <= LogLevel.ERROR) {
      console.error(`[ERROR]: ${message}`);
    }
  }

  public connect = () => {
    this.debug('Connecting to socket');
    this.socket.connect();
  };