Update whale_news_data.py

whale_news_data.py

@@ -20,6 +20,7 @@ class EnhancedWhaleMonitor:
         
         self.whale_threshold_usd = 100000
         self.contracts_db = contracts_db or {}
+        self.data_manager = None
         
         self.address_labels = {}
         self._initialize_dynamic_labels()
@@ -72,7 +73,6 @@ class EnhancedWhaleMonitor:
         if self.infura_key:
             infura_endpoint = f"https://mainnet.infura.io/v3/{self.infura_key}"
             self.rpc_endpoints['ethereum'].insert(0, infura_endpoint)
-            print(f"✅ تم تكوين Infura بنجاح - الشبكة: Ethereum")
         
         self.current_rpc_index = {network: 0 for network in self.rpc_endpoints.keys()}
         self.rpc_failures = {network: 0 for network in self.rpc_endpoints.keys()}
@@ -85,11 +85,8 @@ class EnhancedWhaleMonitor:
             'bsc': 'BNB'
         }
         
-        # نظام تسجيل أداء أنماط الحيتان
         self.pattern_performance = {}
         self.pattern_success_rates = {}
-        
-        print("🎯 نظام تتبع الحيتان المحسن - تحليل صافي التدفق الذكي مفعل")
 
     def _initialize_dynamic_labels(self):
         self.address_categories = {
@@ -188,8 +185,6 @@ class EnhancedWhaleMonitor:
                 self.netflow_data[network][token_symbol]['inflow'].append(value_usd)
                 self.netflow_data[network][token_symbol]['timestamps'].append(datetime.now())
                 
-                print(f"📥 تدفق إلى منصة: {value_usd:,.0f} USD ({token_symbol})")
-            
             if self._is_exchange_address(from_address):
                 if token_symbol not in self.netflow_data[network]:
                     self._initialize_token_metrics(network, token_symbol)
@@ -197,8 +192,6 @@ class EnhancedWhaleMonitor:
                 self.netflow_data[network][token_symbol]['outflow'].append(value_usd)
                 self.netflow_data[network][token_symbol]['timestamps'].append(datetime.now())
                 
-                print(f"📤 تدفق من منصة: {value_usd:,.0f} USD ({token_symbol})")
-            
             if token_symbol in self.netflow_data[network]:
                 current_inflow = sum(list(self.netflow_data[network][token_symbol]['inflow'])[-12:])
                 current_outflow = sum(list(self.netflow_data[network][token_symbol]['outflow'])[-12:])
@@ -207,7 +200,7 @@ class EnhancedWhaleMonitor:
                 self.netflow_data[network][token_symbol]['netflow'].append(current_netflow)
                 
         except Exception as e:
-            print(f"⚠️ خطأ في تحديث مقاييس صافي التدفق: {e}")
+            print(f"خطأ في تحديث مقاييس صافي التدفق: {e}")
 
     def _initialize_token_metrics(self, network, token_symbol):
         self.netflow_data[network][token_symbol] = {
@@ -247,7 +240,7 @@ class EnhancedWhaleMonitor:
             return zscore
             
         except Exception as e:
-            print(f"⚠️ خطأ في حساب Z-score: {e}")
+            print(f"خطأ في حساب Z-score: {e}")
             return 0
 
     def _generate_netflow_signal(self, network, token_symbol):
@@ -322,7 +315,7 @@ class EnhancedWhaleMonitor:
             return signal
             
         except Exception as e:
-            print(f"⚠️ خطأ في توليد إشارة التداول: {e}")
+            print(f"خطأ في توليد إشارة التداول: {e}")
             return None
 
     async def _scan_single_evm_network(self, network):
@@ -330,10 +323,11 @@ class EnhancedWhaleMonitor:
         trading_signals = []
         
         try:
-            # الحصول على السعر من DataManager بدلاً من هنا
-            price_usd = await self._get_native_price_from_external()
+            if not self.data_manager:
+                return [], []
+                
+            price_usd = await self.data_manager.get_native_coin_price(network)
             if price_usd is None:
-                print(f"⚠️ سعر {network} غير متوفر، تخطي المسح")
                 return [], []
 
             latest_block_hex = await self._call_rpc_async(network, 'eth_blockNumber')
@@ -400,16 +394,13 @@ class EnhancedWhaleMonitor:
             if signal:
                 trading_signals.append(signal)
                     
-            print(f"✅ مسح {network}: {scanned_blocks} كتل، {len(whale_alerts)} تنبيهات، {len(trading_signals)} إشارات")
+            return whale_alerts, trading_signals
                     
         except Exception as e:
-            print(f"⚠️ خطأ في مسح شبكة {network}: {e}")
-            
-        return whale_alerts, trading_signals
+            print(f"خطأ في مسح شبكة {network}: {e}")
+            return [], []
 
     async def get_general_whale_activity(self):
-        print("🌊 بدء مراقبة الحيتان وتحليل صافي التدفق...")
-        
         try:
             tasks = []
             networks_to_scan = ['ethereum', 'bsc']
@@ -537,23 +528,12 @@ class EnhancedWhaleMonitor:
                 'trading_signals': []
             }
 
-    async def _get_native_price_from_external(self):
-        """الحصول على الأسعار من DataManager بدلاً من هنا"""
-        try:
-            # محاكاة الحصول على السعر من DataManager
-            # في التطبيق الفعلي، سيتم استدعاء DataManager
-            return 3500.0  # قيمة افتراضية
-        except Exception as e:
-            print(f"⚠️ فشل جلب السعر من DataManager: {e}")
-            return None
-
     async def _call_rpc_async(self, network, method, params=[]):
         max_retries = 2
         
         for attempt in range(max_retries):
             endpoint = self._get_next_rpc_endpoint(network)
             if not endpoint:
-                print(f"❌ لا توجد نقاط نهاية RPC متاحة لـ {network}")
                 return None
                 
             try:
@@ -571,11 +551,9 @@ class EnhancedWhaleMonitor:
                     response = await client.post(endpoint, json=payload)
                     
                     if response.status_code == 401:
-                        print(f"🔐 خطأ مصادقة في {endpoint}")
                         self.rpc_failures[network] += 1
                         continue
                     elif response.status_code == 429:
-                        print(f"⏳ Rate limit على {endpoint}")
                         await asyncio.sleep(2 * (attempt + 1))
                         continue
                         
@@ -587,26 +565,21 @@ class EnhancedWhaleMonitor:
                     
             except httpx.HTTPStatusError as e:
                 if e.response.status_code == 429:
-                    print(f"⚠️ Rate limit على {endpoint} لـ {network}")
                     self.rpc_failures[network] += 1
                     await asyncio.sleep(3 * (attempt + 1))
                     continue
                 elif e.response.status_code == 401:
-                    print(f"🔐 خطأ مصادقة في {endpoint}")
                     self.rpc_failures[network] += 1
                     continue
                 else:
-                    print(f"⚠️ خطأ HTTP {e.response.status_code} في {endpoint}")
                     self.rpc_failures[network] += 1
                     
             except Exception as e:
-                print(f"⚠️ فشل اتصال RPC لـ {network}: {e}")
                 self.rpc_failures[network] += 1
                 
             if attempt < max_retries - 1:
                 await asyncio.sleep(1 * (attempt + 1))
         
-        print(f"❌ فشل جميع محاولات RPC لـ {network}")
         return None
 
     def _get_next_rpc_endpoint(self, network):
@@ -662,21 +635,17 @@ class EnhancedWhaleMonitor:
         if api_name == 'etherscan':
             if stats['requests_per_second'] > 4:
                 delay = 0.2 * (stats['requests_per_second'] - 4)
-                print(f"⏳ تأخير {delay:.2f} ثانية لـ {api_name}")
                 await asyncio.sleep(delay)
             
             if stats['requests_today'] > 95000:
-                print(f"🚨 تجاوز الحد اليومي لطلبات {api_name}")
                 return True
         
         elif api_name == 'infura':
             if stats['requests_per_second'] > 400:
                 delay = 0.1 * (stats['requests_per_second'] - 400)
-                print(f"⏳ تأخير {delay:.2f} ثانية لـ {api_name}")
                 await asyncio.sleep(delay)
             
             if stats['requests_today'] > 2800000:
-                print(f"🚨 تجاوز الحد اليومي لطلبات {api_name}")
                 return True
         
         return False
@@ -691,8 +660,6 @@ class EnhancedWhaleMonitor:
             if not contract_address:
                 return await self._scan_networks_for_symbol(symbol, base_symbol)
             
-            print(f"🔍 جلب بيانات الحيتان لـ {symbol}")
-            
             api_data = await self._get_combined_api_data(contract_address)
             
             if api_data:
@@ -739,7 +706,6 @@ class EnhancedWhaleMonitor:
             self._update_api_usage_stats('etherscan')
             
             if await self._api_rate_limit_delay('etherscan'):
-                print("⚠️ تجاوز حدود Etherscan، تخطي الطلب")
                 return []
             
             params = {
@@ -754,13 +720,10 @@ class EnhancedWhaleMonitor:
             
             base_url = "https://api.etherscan.io/api"
             
-            print(f"🔍 جلب بيانات Etherscan للعقد: {contract_address[:10]}...")
-            
             async with httpx.AsyncClient(timeout=10.0) as client:
                 response = await client.get(base_url, params=params)
                 
                 if response.status_code == 429:
-                    print("⏳ تجاوز حد معدل Etherscan")
                     await asyncio.sleep(2)
                     return []
                 
@@ -769,18 +732,13 @@ class EnhancedWhaleMonitor:
                 
                 if data.get('status') == '1' and data.get('message') == 'OK':
                     result = data.get('result', [])
-                    print(f"✅ بيانات Etherscan: {len(result)} تحويل")
                     return result
                 else:
-                    error_message = data.get('message', 'Unknown error')
-                    print(f"⚠️ خطأ في استجابة Etherscan: {error_message}")
                     return []
                     
         except httpx.HTTPStatusError as e:
-            print(f"⚠️ خطأ HTTP في Etherscan API: {e.response.status_code}")
             return []
         except Exception as e:
-            print(f"⚠️ فشل جلب بيانات Etherscan: {e}")
             return []
 
     async def _get_moralis_token_data(self, contract_address):
@@ -796,14 +754,11 @@ class EnhancedWhaleMonitor:
             
             if response.status_code == 200:
                 result = response.json().get('result', [])
-                print(f"✅ بيانات Moralis: {len(result)} تحويل")
                 return result
             else:
-                print(f"⚠️ خطأ Moralis API: {response.status_code}")
                 return []
                 
         except Exception as e:
-            print(f"⚠️ Moralis API error: {e}")
             return []
 
     async def _enrich_api_data_with_timing(self, api_data):
@@ -829,7 +784,6 @@ class EnhancedWhaleMonitor:
                 enriched_data.append(enriched_transfer)
                 
             except Exception as e:
-                print(f"⚠️ خطأ في إثراء بيانات التحويل: {e}")
                 continue
                 
         return enriched_data
@@ -903,28 +857,24 @@ class EnhancedWhaleMonitor:
             if symbol_lower in key.lower():
                 return address
         
-        print(f"🔍 لم يتم العثور على عقد لـ {symbol} في قاعدة البيانات")
         return None
 
     async def _scan_networks_for_symbol(self, symbol, base_symbol):
-        print(f"🔍 مسح الشبكات للعثور على {symbol}...")
-        
         networks_to_scan = ['ethereum', 'bsc']
         
         for network in networks_to_scan:
             try:
-                price = await self._get_native_price_from_external()
-                if price:
-                    print(f"✅ تم العثور على {symbol} على شبكة {network} بسعر ${price:.2f}")
-                    return {
-                        'data_available': True,
-                        'description': f'تم اكتشاف {symbol} على شبكة {network}',
-                        'network': network,
-                        'price_usd': price,
-                        'source': 'network_scan'
-                    }
+                if self.data_manager:
+                    price = await self.data_manager.get_native_coin_price(network)
+                    if price:
+                        return {
+                            'data_available': True,
+                            'description': f'تم اكتشاف {symbol} على شبكة {network}',
+                            'network': network,
+                            'price_usd': price,
+                            'source': 'network_scan'
+                        }
             except Exception as e:
-                print(f"⚠️ فشل مسح {network} لـ {symbol}: {e}")
                 continue
         
         return {
@@ -958,9 +908,7 @@ class EnhancedWhaleMonitor:
         
         return stats
 
-    # دوال تحليل الحيتان المنقولة من ML.py
     def _calculate_whale_activity_score(self, whale_data):
-        """حساب درجة نشاط الحيتان - منقول من ML.py"""
         if not whale_data.get('data_available', False):
             return 0.0
         
@@ -981,7 +929,6 @@ class EnhancedWhaleMonitor:
         return min(score, 0.5)
 
     async def generate_whale_trading_signal(self, symbol, whale_data, market_context):
-        """توليد إشارة تداول مباشرة من بيانات الحيتان"""
         try:
             if not whale_data.get('data_available', False):
                 return None
@@ -1023,11 +970,9 @@ class EnhancedWhaleMonitor:
             return signal
             
         except Exception as e:
-            print(f"⚠️ خطأ في توليد إشارة تداول الحيتان: {e}")
             return None
 
     async def track_pattern_outcome(self, symbol, pattern_analysis, success, profit_percent):
-        """تتبع أداء أنماط الحيتان - منقول من ML.py"""
         if not pattern_analysis:
             return
         
@@ -1050,19 +995,10 @@ class EnhancedWhaleMonitor:
             if success:
                 stats['successful_trades'] += 1
                 stats['total_profit'] += profit_percent
-            
-            success_rate = stats['successful_trades'] / stats['total_trades']
-            avg_profit = stats['total_profit'] / stats['successful_trades'] if stats['successful_trades'] > 0 else 0
-            avg_confidence = stats['total_confidence'] / stats['total_trades']
-            
-            print(f"📊 تحديث أداء النمط {pattern_name}: نجاح {success_rate:.1%}, ربح متوسط {avg_profit:.2f}%")
 
     def get_pattern_reliability(self, pattern_name):
-        """الحصول على موثوقية النمط - منقول من ML.py"""
         if pattern_name in self.pattern_performance:
             stats = self.pattern_performance[pattern_name]
             if stats['total_trades'] > 0:
                 return stats['successful_trades'] / stats['total_trades']
-        return 0.5
-
-whale_monitor_global = EnhancedWhaleMonitor()
+        return 0.5