From 53cadcf7e34f05f77082e84f0696b56bcbcbae36 Mon Sep 17 00:00:00 2001
From: TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>
Date: Thu, 2 Apr 2026 10:26:52 +0900
Subject: refactor: remove all crypto/Binance code, update to US stock symbols

---
 .../src/data_collector/ws_factory.py               | 34 ----------------------
 1 file changed, 34 deletions(-)
 delete mode 100644 services/data-collector/src/data_collector/ws_factory.py

(limited to 'services/data-collector/src/data_collector/ws_factory.py')

diff --git a/services/data-collector/src/data_collector/ws_factory.py b/services/data-collector/src/data_collector/ws_factory.py
deleted file mode 100644
index e068399..0000000
--- a/services/data-collector/src/data_collector/ws_factory.py
+++ /dev/null
@@ -1,34 +0,0 @@
-"""WebSocket factory for exchange-specific connections."""
-
-import logging
-
-from data_collector.binance_ws import BinanceWebSocket
-
-logger = logging.getLogger(__name__)
-
-# Supported exchanges for WebSocket streaming
-SUPPORTED_WS = {"binance": BinanceWebSocket}
-
-
-def create_websocket(exchange_id: str, **kwargs):
-    """Create an exchange-specific WebSocket handler.
-
-    Args:
-        exchange_id: Exchange identifier (e.g. 'binance')
-        **kwargs: Passed to the WebSocket constructor (symbols, timeframe, on_candle)
-
-    Returns:
-        WebSocket handler instance
-
-    Raises:
-        ValueError: If exchange is not supported for WebSocket streaming
-    """
-    ws_cls = SUPPORTED_WS.get(exchange_id)
-    if ws_cls is None:
-        supported = ", ".join(sorted(SUPPORTED_WS.keys()))
-        raise ValueError(
-            f"WebSocket streaming not supported for '{exchange_id}'. "
-            f"Supported: {supported}. "
-            f"Use REST polling as fallback for unsupported exchanges."
-        )
-    return ws_cls(**kwargs)
-- 
cgit v1.2.3