Class DashboardClient

packages/dashboard/src/dashboardClient.ts:27–86

};

export class DashboardClient {
  private _transport: Transport;
  private _listeners = new Map<string, Set<Function>>();

  onopen?: () => void;
  onclose?: (reason?: string) => void;

  private constructor(transport: Transport) {
    this._transport = transport;
    this._transport.onopen = () => {
      this.onopen?.();
    };
    this._transport.onevent = (method: string, params: any) => {
      this._fireEvent(method, params);
    };
    this._transport.onclose = (reason?: string) => {
      this.onclose?.(reason);
    };
  }

  static create(url: string): DashboardClientChannel {
    const transport = new Transport(url);
    const client = new DashboardClient(transport);
    return new Proxy(client, {
      get(target: DashboardClient, prop: string | symbol, receiver: any): any {
        if (typeof prop === 'symbol' || prop in target)
          return Reflect.get(target, prop, receiver);
        // Prevent the proxy from being treated as a thenable.
        if (prop === 'then')
          return undefined;
        return (params?: any) => target._transport.send(prop, params);
      }
    }) as unknown as DashboardClientChannel;
  }

  private _fireEvent(event: string, params: any) {
    const set = this._listeners.get(event);
    if (set) {
      for (const listener of set)
        listener(params);
    }
  }

  on(event: string, listener: Function): void {
    let set = this._listeners.get(event);
    if (!set) {
      set = new Set();
      this._listeners.set(event, set);
    }
    set.add(listener);
  }

  off(event: string, listener: Function): void {
    this._listeners.get(event)?.delete(listener);
  }

  close() {
    this._transport.close();