Class MockChannel

packages/core/src/__tests__/test-utils.ts:319–393

}

export class MockChannel {
  public topic: string;
  public params: Record<string, any>;
  public joinPayload: Record<string, any> | null = null;
  public pushLog: Array<{ event: string; payload: any; push: MockPush }> = [];
  public left = false;

  private handlers = new Map<
    string,
    Array<{ ref: number; callback: (payload: any) => void }>
  >();
  private joinPush = new MockPush();
  private errorHandlers: Array<(reason?: any) => void> = [];
  private nextRef = 1;

  constructor(topic: string = "", params: Record<string, any> = {}) {
    this.topic = topic;
    this.params = params;
  }

  on(event: string, callback: (payload: any) => void): number {
    if (!this.handlers.has(event)) {
      this.handlers.set(event, []);
    }
    const ref = this.nextRef++;
    this.handlers.get(event)!.push({ ref, callback });
    return ref;
  }

  off(event: string, ref?: number): void {
    if (!this.handlers.has(event)) return;
    if (ref === undefined) {
      this.handlers.delete(event);
    } else {
      const filtered = this.handlers.get(event)!.filter((h) => h.ref !== ref);
      this.handlers.set(event, filtered);
    }
  }

  onError(callback: (reason?: any) => void): void {
    this.errorHandlers.push(callback);
  }

  join(payload?: Record<string, any>): MockPush {
    this.joinPayload = payload ?? null;
    return this.joinPush;
  }

  push(event: string, payload: any): MockPush {
    const mockPush = new MockPush();
    this.pushLog.push({ event, payload, push: mockPush });
    return mockPush;
  }

  leave(): void {
    this.left = true;
  }