Update data_manager.py

data_manager.py

@@ -1,4 +1,4 @@
-# data_manager.py (Updated to V10.1 - Balanced 53% + MC Fix)
+# data_manager.py (Updated to V10.2 - Whale Learning Data Link)
 import os
 import asyncio
 import httpx
@@ -81,7 +81,7 @@ class DataManager:
             print(f"❌ [DataManager V9.8] فشل تهيئة الرانكر V9.8: {e}")
             self.layer1_ranker = None 
 
-        print("✅ DataManager initialized - V10.1 (Balanced Threshold 53%)")
+        print("✅ DataManager initialized - V10.2 (Whale Learning Data Link)")
 
     async def _load_markets(self):
         try:
@@ -508,11 +508,44 @@ class DataManager:
         except Exception: 
             return None
             
-    async def get_whale_data_for_symbol(self, symbol):
+    # 🔴 --- START OF CHANGE (V10.2) --- 🔴
+    async def get_symbol_daily_volume(self, symbol: str) -> float:
+        """
+        (جديد) دالة مساعدة لجلب حجم التداول اليومي (بالدولار) لعملة واحدة.
+        (تستخدم في إعادة التحليل).
+        """
+        try:
+            if not self.exchange: return 0.0
+            ticker = self.exchange.fetch_ticker(symbol)
+            if not ticker: return 0.0
+            
+            current_price = ticker.get('last', 0)
+            quote_volume = ticker.get('quoteVolume', 0)
+            
+            if quote_volume is not None and quote_volume > 0:
+                return float(quote_volume)
+            elif current_price is not None and current_price > 0:
+                base_volume = ticker.get('baseVolume', 0)
+                if base_volume is not None:
+                    return float(base_volume) * float(current_price)
+            
+            return 0.0
+        except Exception:
+            return 0.0
+
+    async def get_whale_data_for_symbol(self, symbol: str, daily_volume_usd: float = 0.0):
+        """
+        (محدث V10.2)
+        تمرير حجم التداول اليومي إلى مراقب الحيتان لتفعيل المقاييس النسبية.
+        """
         try:
-            return await self.whale_monitor.get_symbol_whale_activity(symbol) if self.whale_monitor else None
+            if self.whale_monitor:
+                return await self.whale_monitor.get_symbol_whale_activity(symbol, daily_volume_usd=daily_volume_usd)
+            else:
+                return None
         except Exception: 
             return None
+    # 🔴 --- END OF CHANGE --- 🔴
             
     async def get_whale_trading_signal(self, symbol, whale_data, market_context):
         try:
@@ -520,4 +553,4 @@ class DataManager:
         except Exception as e:
             return {'action': 'HOLD', 'confidence': 0.3, 'reason': f'Error: {str(e)}', 'source': 'whale_analysis'}
 
-print("✅ DataManager loaded - V10.1 (Balanced Threshold 53%)")
+print("✅ DataManager loaded - V10.2 (Whale Learning Data Link)")