Method connect

client-sdks/client-js/src/transport/websocket.ts:72–124

* 连接到 WebSocket 服务器

(url: string)

   * 连接到 WebSocket 服务器
   */
  async connect(url: string): Promise<void> {
    if (this.state === WebSocketState.CONNECTED || this.state === WebSocketState.CONNECTING) {
      console.warn("[WebSocket] Already connected or connecting");
      return;
    }

    this.url = url;
    this.setState(WebSocketState.CONNECTING);

    return new Promise((resolve, reject) => {
      try {
        // 在浏览器和 Node.js 中使用不同的 WebSocket
        const WebSocketImpl = typeof window !== "undefined" ? window.WebSocket : require("ws");

        this.ws = new WebSocketImpl(url);

        if (this.ws) {
          this.ws.onopen = () => {
            console.log("[WebSocket] Connected");
            this.setState(WebSocketState.CONNECTED);
            this.reconnectAttempts = 0;
            this.startHeartbeat();
            this.flushMessageQueue();
            resolve();
          };

          this.ws.onmessage = (event) => {
            this.handleMessage(event.data);
          };

          this.ws.onerror = (error) => {
            console.error("[WebSocket] Error:", error);
            reject(error);
          };

          this.ws.onclose = (event) => {
            console.log("[WebSocket] Closed:", event.code, event.reason);
            this.stopHeartbeat();

            if (this.state !== WebSocketState.DISCONNECTING) {
              this.handleReconnect();
            } else {
              this.setState(WebSocketState.DISCONNECTED);
            }
          };
        }
      } catch (error) {
        console.error("[WebSocket] Connection failed:", error);
        this.setState(WebSocketState.FAILED);
        reject(error);
      }
    });
  }

  /**
   * 断开连接