Function useWebSocket

ui/src/composables/useWebSocket.ts:20–72

()

}

export function useWebSocket() {
  const connect = async (url: string) => {
    if (wsInstance && connectionUrl.value === url) {
      console.log("♻️ Reusing existing WebSocket connection");
      return wsInstance;
    }

    if (wsInstance) {
      console.log("🔄 Disconnecting old WebSocket");
      wsInstance.disconnect();
    }

    console.log("🔌 Creating new WebSocket connection to:", url);

    wsInstance = new WebSocketClient({
      maxReconnectAttempts: 5,
      reconnectDelay: 1000,
      heartbeatInterval: 30000,
    });

    // 监听状态变化
    wsInstance.onStateChange((state) => {
      console.log("📡 WebSocket state changed:", state);
      isConnected.value = state === "CONNECTED";
    });

    await wsInstance.connect(url);
    connectionUrl.value = url;
    isConnected.value = true;

    console.log("✅ WebSocket connected successfully");

    return wsInstance;
  };

  const disconnect = () => {
    if (wsInstance) {
      wsInstance.disconnect();
      wsInstance = null;
      isConnected.value = false;
      connectionUrl.value = "";
    }
  };

  const getInstance = () => wsInstance;

  return {
    connect,
    disconnect,
    getInstance,
    isConnected,
  };
}