refactor: remove all crypto/Binance code, update to US stock symbols

1 files changed, 12 insertions, 12 deletions

diff --git a/services/strategy-engine/tests/test_multi_symbol.py b/services/strategy-engine/tests/test_multi_symbol.py
index cb8088c..671a9d3 100644
--- a/services/strategy-engine/tests/test_multi_symbol.py
+++ b/services/strategy-engine/tests/test_multi_symbol.py
@@ -22,7 +22,7 @@ async def test_engine_processes_multiple_streams():
     broker = AsyncMock()
 
     candle_btc = Candle(
-        symbol="BTCUSDT",
+        symbol="AAPL",
         timeframe="1m",
         open_time=datetime(2025, 1, 1, tzinfo=timezone.utc),
         open=Decimal("50000"),
@@ -32,7 +32,7 @@ async def test_engine_processes_multiple_streams():
         volume=Decimal("10"),
     )
     candle_eth = Candle(
-        symbol="ETHUSDT",
+        symbol="MSFT",
         timeframe="1m",
         open_time=datetime(2025, 1, 1, tzinfo=timezone.utc),
         open=Decimal("3000"),
@@ -45,16 +45,16 @@ async def test_engine_processes_multiple_streams():
     btc_events = [CandleEvent(data=candle_btc).to_dict()]
     eth_events = [CandleEvent(data=candle_eth).to_dict()]
 
-    # First call returns BTC event, second ETH, then empty
-    call_count = {"btc": 0, "eth": 0}
+    # First call returns AAPL event, second MSFT, then empty
+    call_count = {"aapl": 0, "msft": 0}
 
     async def mock_read(stream, **kwargs):
-        if "BTC" in stream:
-            call_count["btc"] += 1
-            return btc_events if call_count["btc"] == 1 else []
-        elif "ETH" in stream:
-            call_count["eth"] += 1
-            return eth_events if call_count["eth"] == 1 else []
+        if "AAPL" in stream:
+            call_count["aapl"] += 1
+            return btc_events if call_count["aapl"] == 1 else []
+        elif "MSFT" in stream:
+            call_count["msft"] += 1
+            return eth_events if call_count["msft"] == 1 else []
         return []
 
     broker.read = AsyncMock(side_effect=mock_read)
@@ -65,8 +65,8 @@ async def test_engine_processes_multiple_streams():
     engine = StrategyEngine(broker=broker, strategies=[strategy])
 
     # Process both streams
-    await engine.process_once("candles.BTCUSDT", "$")
-    await engine.process_once("candles.ETHUSDT", "$")
+    await engine.process_once("candles.AAPL", "$")
+    await engine.process_once("candles.MSFT", "$")
 
     # Strategy should have been called with both candles
     assert strategy.on_candle.call_count == 2