Method constructor

packages/web/src/clients/websocket/channel.ts:37–75

(client: WebSocketClient, topic: string, events: { incoming: I; outgoing: O })

  private readonly receive: <K extends keyof I & string>(event: K, payload: z.TypeOf<I[K]>) => void;

  constructor(client: WebSocketClient, topic: string, events: { incoming: I; outgoing: O }) {
    this.topic = topic;
    this.queue = [];
    this.client = client;
    this.events = events;
    this.callbacks = {};
    this.subscribed = false;
    this.subscriptionId = null;

    this.receive = <K extends keyof I & string>(event: K, payload: z.TypeOf<I[K]>) => {
      if (event === 'subscribed') {
        this.receiveSubscribedEvent(payload);
        return;
      }

      // Ignore events until we are subscribed.
      if (!this.subscribed) {
        return;
      }

      const schema = this.events.incoming[event];

      if (schema === undefined) {
        throw new Error(`Channel received unknown event '${event}' for topic '${this.topic}'`);
      }

      const result = schema.safeParse(payload);

      if (!result.success) {
        throw new Error(
          `Channel received invalid payload for '${event}' and topic '${this.topic}':\n\n${JSON.stringify(payload)}\n\n`,
        );
      }

      for (const callback of this.callbacks[event] || []) {
        callback(result.data);
      }
    };
  }

  subscribe() {
    if (this.subscribed) {