Method connect

web/lib/collaboration/socket.ts:228–264

(wsUrl: string)

  }

  connect(wsUrl: string): void {
    this.wsUrl = wsUrl;
    if (this.ws?.readyState === WebSocket.OPEN) return;

    const url = new URL(wsUrl);
    url.searchParams.set("sessionId", this.sessionId);
    url.searchParams.set("token", this.token);

    this.ws = new WebSocket(url.toString());

    this.ws.onopen = () => {
      this.isConnected = true;
      this.reconnectAttempts = 0;
      this.onConnectionChange?.(true);
      this.startPing();
    };

    this.ws.onmessage = (event) => {
      try {
        const data = JSON.parse(event.data as string) as CollabEvent;
        this.dispatch(data);
      } catch {
        // ignore malformed frames
      }
    };

    this.ws.onclose = () => {
      this.isConnected = false;
      this.onConnectionChange?.(false);
      this.stopPing();
      this.scheduleReconnect();
    };

    this.ws.onerror = () => {
      this.ws?.close();
    };
  }

  disconnect(): void {
    // Set max attempts to prevent reconnect