Update whale_monitor/core.py

whale_monitor/core.py

@@ -1,5 +1,5 @@
 # whale_monitor/core.py
-# (V2 - محدث بالكامل لخطة "التراكم والتدفق")
+# (V2.1 - إصلاح منطق الأولوية (Gather) + إضافة دعم Solscan)
 # المنطق الأساسي لـ EnhancedWhaleMonitor
 
 import os
@@ -32,7 +32,7 @@ logging.getLogger("httpcore").setLevel(logging.WARNING)
 
 class EnhancedWhaleMonitor:
     def __init__(self, contracts_db=None, r2_service=None):
-        print("🔄 [WhaleMonitor V2] بدء التهيئة...")
+        print("🔄 [WhaleMonitor V2.1] بدء التهيئة...")
         
         # 1. الخدمات الخارجية
         self.r2_service = r2_service
@@ -47,8 +47,7 @@ class EnhancedWhaleMonitor:
             verify=self.ssl_context
         )
 
-        # 3. تهيئة "الوكيل الذكي" (RPC Manager V2)
-        # (لم نعد بحاجة لجلب المفاتيح هنا، المدير يفعل ذلك)
+        # 3. تهيئة "الوكيل الذكي" (RPC Manager V2.1)
         self.rpc_manager = AdaptiveRpcManager(self.http_client)
         
         # 4. تحميل الإعدادات من config.py (عبر المدير)
@@ -70,13 +69,13 @@ class EnhancedWhaleMonitor:
         if self.r2_service:
             asyncio.create_task(self._load_contracts_from_r2())
         
-        print("✅ [WhaleMonitor V2] تم التهيئة بنجاح باستخدام مدير RPC/API الذكي V2.")
+        print("✅ [WhaleMonitor V2.1] تم التهيئة بنجاح باستخدام مدير RPC/API الذكي V2.1.")
 
     # --- (دوال التهيئة وقواعد البيانات - لا تغيير جوهري) ---
     
     def _initialize_contracts_db(self, initial_contracts):
         """تهيئة قاعدة بيانات العقود مع تحسين تخزين الشبكات"""
-        print("🔄 [WhaleMonitor V2] تهيئة قاعدة بيانات العقود...")
+        print("🔄 [WhaleMonitor V2.1] تهيئة قاعدة بيانات العقود...")
         for symbol, contract_data in initial_contracts.items():
             symbol_lower = symbol.lower()
             if isinstance(contract_data, dict) and 'address' in contract_data and 'network' in contract_data:
@@ -86,7 +85,7 @@ class EnhancedWhaleMonitor:
                     'address': contract_data,
                     'network': self._detect_network_from_address(contract_data)
                 }
-        print(f"✅ [WhaleMonitor V2] تم تحميل {len(self.contracts_db)} عقد في قاعدة البيانات")
+        print(f"✅ [WhaleMonitor V2.1] تم تحميل {len(self.contracts_db)} عقد في قاعدة البيانات")
 
     def _detect_network_from_address(self, address):
         """اكتشاف الشبكة من عنوان العقد"""
@@ -119,7 +118,7 @@ class EnhancedWhaleMonitor:
                     self.address_categories['dex'].add(addr_lower)
                 elif 'wormhole' in category:
                      self.address_categories['bridge'].add(addr_lower)
-        print(f"✅ [WhaleMonitor V2] تم تهيئة {len(self.address_labels)} عنوان منصة (احتياطي).")
+        print(f"✅ [WhaleMonitor V2.1] تم تهيئة {len(self.address_labels)} عنوان منصة (احتياطي).")
 
     async def _load_contracts_from_r2(self):
         # (لا تغيير في هذه الدالة)
@@ -136,12 +135,12 @@ class EnhancedWhaleMonitor:
                     new_format = {'address': contract_data, 'network': self._detect_network_from_address(contract_data)}
                     updated_contracts_db[symbol_lower] = new_format; loaded_count += 1; updated_count +=1
             self.contracts_db = updated_contracts_db
-            print(f"✅ [WhaleMonitor V2] تم تحميل {loaded_count} عقد من R2.")
+            print(f"✅ [WhaleMonitor V2.1] تم تحميل {loaded_count} عقد من R2.")
             if updated_count > 0: print(f"   ℹ️ تم تحديث صيغة {updated_count} عقد."); await self._save_contracts_to_r2()
         except ClientError as e:
-            if e.response['Error']['Code'] == 'NoSuchKey': print("⚠️ [WhaleMonitor V2] لم يتم العثور على قاعدة بيانات العقود في R2.")
-            else: print(f"❌ [WhaleMonitor V2] خطأ ClientError أثناء تحميل العقود من R2: {e}")
-        except Exception as e: print(f"❌ [WhaleMonitor V2] خطأ عام أثناء تحميل العقود من R2: {e}")
+            if e.response['Error']['Code'] == 'NoSuchKey': print("⚠️ [WhaleMonitor V2.1] لم يتم العثور على قاعدة بيانات العقود في R2.")
+            else: print(f"❌ [WhaleMonitor V2.1] خطأ ClientError أثناء تحميل العقود من R2: {e}")
+        except Exception as e: print(f"❌ [WhaleMonitor V2.1] خطأ عام أثناء تحميل العقود من R2: {e}")
 
     async def _save_contracts_to_r2(self):
         # (لا تغيير في هذه الدالة)
@@ -151,22 +150,22 @@ class EnhancedWhaleMonitor:
             for symbol, data in self.contracts_db.items():
                 if isinstance(data, dict) and 'address' in data and 'network' in data: contracts_to_save[symbol] = data
                 elif isinstance(data, str): contracts_to_save[symbol] = {'address': data, 'network': self._detect_network_from_address(data)}
-            if not contracts_to_save: print("⚠️ [WhaleMonitor V2] لا توجد بيانات عقود صالحة للحفظ في R2."); return
+            if not contracts_to_save: print("⚠️ [WhaleMonitor V2.1] لا توجد بيانات عقود صالحة للحفظ في R2."); return
             data_json = json.dumps(contracts_to_save, indent=2).encode('utf-8')
             self.r2_service.s3_client.put_object(Bucket="trading", Key=key, Body=data_json, ContentType="application/json")
-            print(f"✅ [WhaleMonitor V2] تم حفظ قاعدة بيانات العقود ({len(contracts_to_save)} إدخال) إلى R2")
-        except Exception as e: print(f"❌ [WhaleMonitor V2] فشل حفظ قاعدة البيانات العقود: {e}")
+            print(f"✅ [WhaleMonitor V2.1] تم حفظ قاعدة بيانات العقود ({len(contracts_to_save)} إدخال) إلى R2")
+        except Exception as e: print(f"❌ [WhaleMonitor V2.1] فشل حفظ قاعدة البيانات العقود: {e}")
 
-    # --- (المنطق الأساسي - محدث بالكامل V2) ---
+    # --- (المنطق الأساسي - محدث بالكامل V2.1) ---
 
     async def get_symbol_whale_activity(self, symbol: str, daily_volume_usd: float = 0.0) -> Dict[str, Any]:
         """
-        (محدث V2 - "التراكم والتدفق")
+        (محدث V2.1 - "التراكم والتدفق")
         الدالة الرئيسية لتحليل الحيتان.
         تنفذ منطق "جلب 1، تحليل N" وتسجل البيانات للتعلم.
         """
         try:
-            print(f"🔍 [WhaleMonitor V2] بدء مراقبة الحيتان (تدفق + تراكم) لـ: {symbol}")
+            print(f"🔍 [WhaleMonitor V2.1] بدء مراقبة الحيتان (تدفق + تراكم) لـ: {symbol}")
             
             # 1. تصفير إحصائيات الجلسة
             self.rpc_manager.reset_session_stats()
@@ -204,7 +203,7 @@ class EnhancedWhaleMonitor:
                 print(f"⚠️ لم يتم العثور على أي تحويلات للعملة {symbol} في آخر 24 ساعة.")
                 return self._create_no_transfers_response(symbol)
 
-            print(f"📊 [WhaleMonitor V2] تم جلب {len(all_transfers_24h)} تحويلة (24س). بدء التحليل المقارن...")
+            print(f"📊 [WhaleMonitor V2.1] تم جلب {len(all_transfers_24h)} تحويلة (24س). بدء التحليل المقارن...")
 
             # 5. التقسيم والتحليل (تحليل N)
             analysis_windows = [
@@ -278,7 +277,7 @@ class EnhancedWhaleMonitor:
         إنشاء السجل الأولي "PENDING" وإرساله إلى R2Service.
         """
         if not self.r2_service:
-            print("⚠️ [WhaleMonitor V2] خدمة R2 غير متاحة، تخطي تسجيل التعلم.")
+            print("⚠️ [WhaleMonitor V2.1] خدمة R2 غير متاحة، تخطي تسجيل التعلم.")
             return
             
         try:
@@ -300,74 +299,92 @@ class EnhancedWhaleMonitor:
                 "api_stats": api_stats
             }
             
-            # (نفترض أن R2Service لديها هذه الدالة - سنضيفها لاحقاً)
             if hasattr(self.r2_service, 'save_whale_learning_record_async'):
                 await self.r2_service.save_whale_learning_record_async(record)
-                print(f"✅ [WhaleMonitor V2] تم تسجيل بيانات التعلم (PENDING) لـ {symbol} بنجاح.")
+                print(f"✅ [WhaleMonitor V2.1] تم تسجيل بيانات التعلم (PENDING) لـ {symbol} بنجاح.")
             else:
-                print("❌ [WhaleMonitor V2] R2Service تفتقد دالة save_whale_learning_record_async")
+                print("❌ [WhaleMonitor V2.1] R2Service تفتقد دالة save_whale_learning_record_async")
 
         except Exception as e:
-            print(f"❌ [WhaleMonitor V2] فشل في حفظ سجل التعلم لـ {symbol}: {e}")
+            print(f"❌ [WhaleMonitor V2.1] فشل في حفظ سجل التعلم لـ {symbol}: {e}")
             traceback.print_exc()
 
-    # --- (دوال جلب البيانات - محدثة بالكامل V2) ---
+    # --- (دوال جلب البيانات - محدثة بالكامل V2.1) ---
 
     async def _get_targeted_transfer_data(self, contract_address: str, network: str, hours: int, price: float, decimals: int) -> List[Dict[str, Any]]:
         """
-        (محدث V2)
-        الوظيفة الرئيسية لجلب البيانات. تعطي الأولوية لـ Moralis.
+        (محدث V2.1)
+        الوظيفة الرئيسية لجلب البيانات. تطبق منطق الأولوية الصحيح (Solscan > Moralis > Scanners > RPC)
+        وتقوم بتجميع النتائج.
         """
-        print(f"🌐 [WhaleMonitor V2] جلب بيانات {hours} ساعة لشبكة {network}...")
+        print(f"🌐 [WhaleMonitor V2.1] جلب بيانات {hours} ساعة لشبكة {network} (منطق تجميعي)...")
         
-        # 1. تحديد الأولوية
-        moralis_key = self.rpc_manager.get_api_key('moralis')
         net_config = self.supported_networks.get(network, {})
-        moralis_chain_id = net_config.get('moralis_chain_id')
-        
         all_transfers = []
         
-        # الأولوية 1: Moralis (لأنه "ذكي" ويعطي الأسماء)
-        if moralis_key and moralis_chain_id:
-            try:
-                print(f"   -> [أولوية 1] محاولة Moralis (Chain: {moralis_chain_id})...")
-                moralis_transfers = await self._get_moralis_token_data(contract_address, moralis_chain_id, hours, price, decimals)
-                if moralis_transfers:
-                    all_transfers.extend(moralis_transfers)
-                    print(f"   ✅ [Moralis] تم جلب {len(moralis_transfers)} تحويلة.")
-            except Exception as e:
-                print(f"   ⚠️ [Moralis] فشل: {e}. اللجوء إلى Scanners.")
+        # 🔴 --- START OF CHANGE (V2.1 - Logic Fix) --- 🔴
         
-        # الأولوية 2: Scanners (Etherscan, BscScan, ...)
-        # (نستخدمها إذا فشل Moralis أو لجلب المزيد من البيانات)
-        if not all_transfers:
-            try:
-                print("   -> [أولوية 2] محاولة Scanners (Etherscan/BscScan...)...")
-                scanner_transfers = await self._get_scanner_token_data(contract_address, network, hours, price, decimals)
-                if scanner_transfers:
-                    all_transfers.extend(scanner_transfers)
-                    print(f"   ✅ [Scanners] تم جلب {len(scanner_transfers)} تحويلة.")
-            except Exception as e:
-                 print(f"   ⚠️ [Scanners] فشل: {e}. اللجوء إلى RPC.")
-
-        # الأولوية 3: RPC (eth_getLogs) (كآخر حل)
-        if not all_transfers and net_config.get('type') == 'evm':
+        if network == 'solana':
+            # --- منطق سولانا (أولوية Solscan) ---
+            print(f"   -> [أولوية 1 - SOL] محاولة Solscan API...")
             try:
-                print("   -> [أولوية 3] محاولة RPC (eth_getLogs)...")
-                rpc_transfers = await self._get_rpc_token_data(contract_address, network, hours, price, decimals)
-                if rpc_transfers:
-                    all_transfers.extend(rpc_transfers)
-                    print(f"   ✅ [RPC] تم جلب {len(rpc_transfers)} تحويلة.")
+                solscan_transfers = await self._get_solscan_token_data(contract_address, hours, price)
+                if solscan_transfers:
+                    all_transfers.extend(solscan_transfers)
+                    print(f"   ✅ [Solscan] تم جلب {len(solscan_transfers)} تحويلة.")
             except Exception as e:
-                print(f"   ⚠️ [RPC] فشل: {e}.")
+                print(f"   ⚠️ [Solscan] فشل: {e}. اللجوء إلى Moralis...")
 
-        # (ملاحظة: Solana RPC معقد ويحتاج معالجة خاصة، Moralis هو الأفضل لـ Solana)
+            # (اللجوء إلى Moralis فقط إذا فشل Solscan)
+            if not all_transfers:
+                print(f"   -> [أولوية 2 - SOL] محاولة Moralis...")
+                try:
+                    moralis_transfers = await self._get_moralis_token_data(contract_address, 'sol', hours, price, decimals)
+                    if moralis_transfers:
+                        all_transfers.extend(moralis_transfers)
+                        print(f"   ✅ [Moralis] تم جلب {len(moralis_transfers)} تحويلة.")
+                except Exception as e:
+                    print(f"   ⚠️ [Moralis] فشل: {e}.")
         
+        elif net_config.get('type') == 'evm':
+            # --- منطق EVM (تجميعي) ---
+            tasks = []
+            
+            # المهمة 1: Moralis
+            if self.rpc_manager.get_api_key('moralis') and net_config.get('moralis_chain_id'):
+                print(f"   -> [EVM] إضافة مهمة Moralis...")
+                tasks.append(asyncio.create_task(self._get_moralis_token_data(contract_address, net_config['moralis_chain_id'], hours, price, decimals)))
+            
+            # المهمة 2: Scanners
+            if self.rpc_manager.get_explorer_config(network):
+                print(f"   -> [EVM] إضافة مهمة Scanners...")
+                tasks.append(asyncio.create_task(self._get_scanner_token_data(contract_address, network, hours, price, decimals)))
+                
+            # (تنفيذ Moralis و Scanners بالتوازي)
+            results = await asyncio.gather(*tasks, return_exceptions=True)
+            
+            for res in results:
+                if isinstance(res, list): all_transfers.extend(res)
+                elif isinstance(res, Exception): print(f"   ⚠️ [EVM Gather] فشلت إحدى المهام: {res}")
+            
+            # المهمة 3: RPC (فقط إذا فشلت الواجهات الخاصة بالكامل)
+            if not all_transfers:
+                print(f"   -> [EVM] فشلت الواجهات الخاصة، اللجوء إلى RPC...")
+                try:
+                    rpc_transfers = await self._get_rpc_token_data(contract_address, network, hours, price, decimals)
+                    if rpc_transfers:
+                        all_transfers.extend(rpc_transfers)
+                        print(f"   ✅ [RPC] تم جلب {len(rpc_transfers)} تحويلة.")
+                except Exception as e:
+                    print(f"   ⚠️ [RPC] فشل: {e}.")
+
+        # 🔴 --- END OF CHANGE --- 🔴
+
         if not all_transfers:
-            print(f"❌ [WhaleMonitor V2] فشلت جميع المصادر في جلب التحويلات لـ {network}.")
+            print(f"❌ [WhaleMonitor V2.1] فشلت جميع المصادر في جلب التحويلات لـ {network}.")
             return []
             
-        # إزالة التكرار (الأولوية لـ Moralis/Scanner)
+        # إزالة التكرار (الأولوية لـ Moralis/Scanner/Solscan)
         final_transfers = []; seen_keys = set()
         for t in all_transfers:
              key = f"{t.get('hash')}-{t.get('logIndex','N/A')}"
@@ -376,6 +393,57 @@ class EnhancedWhaleMonitor:
                  
         return final_transfers
 
+    # 🔴 --- START OF CHANGE (V2.1) --- 🔴
+    async def _get_solscan_token_data(self, token_address: str, hours: int, price: float) -> List[Dict]:
+        """(جديد V2.1) جلب التحويلات باستخدام Solscan Pro API"""
+        print(f"     🔍 [Solscan] جلب التحويلات لـ {token_address}")
+        
+        # (Solscan يستخدم 'limit' بدلاً من الساعات، سنأخذ آخر 50 ونفلترها)
+        params = {"limit": 50}
+        path = f"/v2.0/token/transfer/{token_address}"
+        
+        data = await self.rpc_manager.get_solscan_api(path, params)
+        
+        if not data or not data.get('data'):
+            print("     ⚠️ [Solscan] لا توجد نتائج.")
+            return []
+            
+        transfers = []
+        cutoff_timestamp = int((datetime.now(timezone.utc) - timedelta(hours=hours)).timestamp())
+        
+        for tx in data['data']:
+            try:
+                timestamp = tx.get('blockTime')
+                if not timestamp or timestamp < cutoff_timestamp:
+                    continue # (تخطي التحويلات القديمة)
+                    
+                change_amount_raw = tx.get('changeAmount')
+                if not change_amount_raw: continue
+                
+                # (Solscan يعطينا الكسور العشرية مباشرة!)
+                decimals = tx.get('token', {}).get('decimals', 9) # (افتراضي 9 لسولانا)
+                value_usd = self._calculate_value_usd(int(change_amount_raw), decimals, price)
+                if value_usd < 1000: continue
+
+                transfers.append({
+                    'hash': tx.get('signature'),
+                    'logIndex': tx.get('innerInstruction', [{}])[0].get('index', 0), # (محاولة للحصول على معرف فريد)
+                    'from': tx.get('changeOwner', {}).get('from'),
+                    'to': tx.get('changeOwner', {}).get('to'),
+                    'value': change_amount_raw,
+                    'value_usd': value_usd,
+                    'timeStamp': str(timestamp),
+                    'blockNumber': str(tx.get('slot')),
+                    'network': 'solana',
+                    'source': 'solscan'
+                    # (Solscan لا يوفر تصنيفات العناوين مثل Moralis)
+                })
+            except Exception as e:
+                print(f"   ⚠️ [Solscan] خطأ في تحليل تحويلة: {e}")
+                continue
+        return transfers
+    # 🔴 --- END OF CHANGE --- 🔴
+
     async def _get_moralis_token_data(self, contract_address: str, chain_id: str, hours: int, price: float, decimals: int) -> List[Dict]:
         """(جديد V2) جلب التحويلات باستخدام Moralis API"""
         
@@ -434,7 +502,6 @@ class EnhancedWhaleMonitor:
              print(f"     ⚠️ لا توجد إعدادات مستكشف لشبكة {network}")
              return []
              
-        # (محاولة استخدام المفتاح المخصص للشبكة، أو اللجوء إلى مفتاح "etherscan" العام)
         api_key = self.rpc_manager.get_api_key(explorer_config['api_key_name']) or self.rpc_manager.get_api_key('etherscan')
         if not api_key:
              print(f"     ⚠️ لا يوجد مفتاح API لـ {network} (أو مفتاح etherscan العام)")
@@ -462,13 +529,12 @@ class EnhancedWhaleMonitor:
             try:
                 timestamp = int(tx.get('timeStamp', '0'))
                 if timestamp < cutoff_timestamp:
-                    break # (البيانات مرتبة تنازلياً، توقف عند الوصول للبيانات القديمة)
-
+                    break 
                 value_raw = tx.get('value')
                 if not value_raw or not value_raw.isdigit(): continue
                 
                 value_usd = self._calculate_value_usd(int(value_raw), decimals, price)
-                if value_usd < 1000: continue # (فلترة أولية للضجيج)
+                if value_usd < 1000: continue 
 
                 transfers.append({
                     'hash': tx.get('hash'),
@@ -491,8 +557,6 @@ class EnhancedWhaleMonitor:
         """(محدث V2) جلب التحويلات باستخدام eth_getLogs عبر RpcManager"""
         
         try:
-            # (تقريب عدد الكتل بناءً على الوقت - تقدير متحفظ)
-            # (نفترض 15 ثانية للكتلة لـ ETH/Polygon, و 3 ثوان لـ BSC)
             avg_block_time = 15 if network not in ['bsc'] else 3
             blocks_to_scan = int((hours * 3600) / avg_block_time)
             
@@ -522,7 +586,6 @@ class EnhancedWhaleMonitor:
                 print(f"     ✅ [RPC] لا توجد سجلات تحويل لـ {contract_address}."); return []
 
             transfers = []
-            # (نحتاج لجلب الوقت الفعلي للكتل)
             block_timestamps = await self._get_block_timestamps_rpc(network, [log.get('blockNumber') for log in logs])
             
             for log in logs:
@@ -534,7 +597,7 @@ class EnhancedWhaleMonitor:
                         
                     value_int = int(value_raw, 16)
                     value_usd = self._calculate_value_usd(value_int, decimals, price)
-                    if value_usd < 1000: continue # (فلترة أولية للضجيج)
+                    if value_usd < 1000: continue
 
                     timestamp = block_timestamps.get(block_num_hex, str(int(time.time())))
                     
@@ -581,10 +644,10 @@ class EnhancedWhaleMonitor:
                     pass
         return timestamps
 
-    # --- (دوال جلب الأسعار والكسور العشرية - محدثة V2) ---
+    # --- (دوال جلب الأسعار والكسور العشرية - محدثة V2.1) ---
 
     async def _get_token_decimals(self, contract_address, network):
-        """(محدث V2) جلب الكسور العشرية (يستخدم RpcManager)"""
+        """(محدث V2.1) جلب الكسور العشرية (يستخدم RpcManager ويدعم Solscan)"""
         cache_key = f"{contract_address.lower()}_{network}"
         if cache_key in self.token_decimals_cache:
             return self.token_decimals_cache[cache_key]
@@ -603,7 +666,23 @@ class EnhancedWhaleMonitor:
                     return decimals
                 except Exception: pass
         
-        # (يمكن إضافة دعم Solana هنا إذا لزم الأمر)
+        # 🔴 --- START OF CHANGE (V2.1 - Solscan Decimals Fix) --- 🔴
+        elif network == 'solana':
+            print(f"     🔍 [Solscan] جلب الكسور العشرية لـ {contract_address}...")
+            path = f"/v2.0/token/meta"
+            params = {"tokenAddress": contract_address}
+            data = await self.rpc_manager.get_solscan_api(path, params)
+            
+            if data and data.get('data') and data['data'].get('decimals') is not None:
+                try:
+                    decimals = int(data['data']['decimals'])
+                    self.token_decimals_cache[cache_key] = decimals
+                    print(f"     ✅ [Solscan] تم العثور على الكسور العشرية: {decimals}")
+                    return decimals
+                except Exception as e:
+                    print(f"     ⚠️ [Solscan] فشل تحليل الكسور العشرية: {e}")
+        # 🔴 --- END OF CHANGE --- 🔴
+        
         print(f"❌ فشل جلب الكسور العشرية لـ {contract_address} على {network}.")
         return None
 
@@ -669,11 +748,38 @@ class EnhancedWhaleMonitor:
             if not coin_id: return None
 
             print(f"     🔍 [CoinGecko] جلب تفاصيل المعرف: {coin_id}")
-            detail_data = await self.rpc_manager.get_coingecko_api(params={"ids": coin_id, "localization": "false", "tickers": "false", "market_data": "false", "community_data": "false", "developer_data": "false", "sparkline": "false"})
+            # (نستخدم مسار API مختلف لجلب العقود)
+            path = f"/api/v3/coins/{coin_id}"
+            detail_data = await self.rpc_manager.get_coingecko_api(params={"localization": "false", "tickers": "false", "market_data": "false", "community_data": "false", "developer_data": "false", "sparkline": "false"}, custom_path=path) # (ملاحظة: get_coingecko_api قد يحتاج تعديل لدعم custom_path)
+            
+            # (تعديل: نفترض أن get_coingecko_api لا يدعم custom_path ونستخدم استدعاء مباشر)
+            # (هذا الكود مكرر ولكنه ضروري إذا لم يتم تعديل rpc_manager)
+            base_url = COINGECKO_BASE_URL
+            full_url = f"{base_url}/coins/{coin_id}"
+            params={"localization": "false", "tickers": "false", "market_data": "false", "community_data": "false", "developer_data": "false", "sparkline": "false"}
+            detail_data = await self.rpc_manager.get_coingecko_api(params=params, custom_base_url=full_url) # (افتراض أن الدالة تدعم هذا)
+
+            # (إعادة كتابة ليتوافق مع rpc_manager V2.1 الحالي)
+            base_url = "https://api.coingecko.com/api/v3" # (COINGECKO_BASE_URL)
+            full_url = f"{base_url}/coins/{coin_id}"
+            params = {"localization": "false", "tickers": "false", "market_data": "false", "community_data": "false", "developer_data": "false", "sparkline": "false"}
             
-            if not detail_data or not detail_data.get(coin_id) or not detail_data[coin_id].get('platforms'):
+            async with self.rpc_manager.coingecko_semaphore:
+                 # (تطبيق "الخنق")
+                current_time = time.time()
+                time_since_last = current_time - self.rpc_manager.last_coingecko_call
+                if time_since_last < self.rpc_manager.COINGECKO_REQUEST_DELAY:
+                    await asyncio.sleep(self.rpc_manager.COINGECKO_REQUEST_DELAY - time_since_last)
+                self.rpc_manager.last_coingecko_call = time.time()
+                
+                response = await self.http_client.get(full_url, params=params)
+                response.raise_for_status()
+                detail_data = response.json()
+
+
+            if not detail_data or not detail_data.get('platforms'):
                  print(f"       ❌ [CoinGecko] فشل جلب تفاصيل المنصات لـ {coin_id}"); return None
-            platforms = detail_data[coin_id]['platforms']
+            platforms = detail_data['platforms']
 
             network_priority = ['ethereum', 'binance-smart-chain', 'polygon-pos', 'arbitrum-one', 'optimistic-ethereum', 'avalanche', 'fantom', 'solana']
             network_map = {'ethereum': 'ethereum', 'binance-smart-chain': 'bsc', 'polygon-pos': 'polygon', 'arbitrum-one': 'arbitrum', 'optimistic-ethereum': 'optimism', 'avalanche': 'avalanche', 'fantom': 'fantom', 'solana': 'solana'}
@@ -689,12 +795,15 @@ class EnhancedWhaleMonitor:
         except Exception as e:
             print(f"❌ فشل عام في _find_contract_via_coingecko لـ {symbol}: {e}"); traceback.print_exc(); return None
 
-    # --- (دوال التحليل والمساعدة - محدثة V2) ---
+    # --- (دوال التحليل والمساعدة - محدثة V2.1) ---
     
     def _calculate_value_usd(self, raw_value: int, decimals: int, price: float) -> float:
         """(جديد V2) دالة مساعدة لحساب القيمة بالدولار بأمان"""
         try:
             if price == 0: return 0.0
+            if decimals is None: 
+                print("   ⚠️ [Calc] حساب القيمة فشل بسبب 'decimals' غير موجودة.")
+                return 0.0
             token_amount = raw_value / (10 ** decimals)
             return token_amount * price
         except Exception:
@@ -714,15 +823,12 @@ class EnhancedWhaleMonitor:
         }
         
         for tx in transfers:
-            # (نستخدم القيمة المحسوبة مسبقاً إذا كانت موجودة، وإلا نستخدم 0)
             value_usd = tx.get('value_usd', 0.0)
             if value_usd == 0.0: continue
 
-            # (نستخدم التصنيف "الذكي" من Moralis أولاً)
             is_to_exchange = tx.get('to_label') is not None
             is_from_exchange = tx.get('from_label') is not None
             
-            # (إذا فشل Moralis، نستخدم القائمة الاحتياطية)
             if not is_to_exchange and not is_from_exchange:
                 is_to_exchange = self._is_exchange_address(tx.get('to'))
                 is_from_exchange = self._is_exchange_address(tx.get('from'))
@@ -740,24 +846,18 @@ class EnhancedWhaleMonitor:
                     stats['withdrawal_count'] += 1
                     stats['top_withdrawals'].append({'v': value_usd, 'from': tx.get('from_label', self._classify_address(tx.get('from')))})
         
-        # --- حساب المقاييس النهائية (المطلقة) ---
         net_flow_usd = stats['to_exchanges_usd'] - stats['from_exchanges_usd']
         
-        # --- حساب المقاييس النهائية (النسبية) ---
         relative_net_flow_percent = 0.0
         transaction_density = 0.0
         
         if daily_volume_usd > 0:
-            # (المقياس الذكي 1: نسبة صافي التدفق)
             relative_net_flow_percent = (net_flow_usd / daily_volume_usd) * 100
-            
-            # (المقياس الذكي 2: كثافة التحويلات)
             total_transactions = stats['deposit_count'] + stats['withdrawal_count']
             volume_in_millions = daily_volume_usd / 1_000_000
             if volume_in_millions > 0:
                 transaction_density = total_transactions / volume_in_millions
 
-        # (فرز أفضل 3 تحويلات)
         top_deposits = sorted(stats['top_deposits'], key=lambda x: x['v'], reverse=True)[:3]
         top_withdrawals = sorted(stats['top_withdrawals'], key=lambda x: x['v'], reverse=True)[:3]
 
@@ -771,11 +871,8 @@ class EnhancedWhaleMonitor:
             'net_flow_usd': net_flow_usd,
             'deposit_count': stats['deposit_count'],
             'withdrawal_count': stats['withdrawal_count'],
-            
-            # (المقاييس الذكية للتعلم)
             'relative_net_flow_percent': relative_net_flow_percent,
             'transaction_density': transaction_density,
-            
             'top_deposits': top_deposits,
             'top_withdrawals': top_withdrawals
         }
@@ -826,7 +923,7 @@ class EnhancedWhaleMonitor:
     async def _find_contract_address_enhanced(self, symbol):
         """(محدث V2) بحث متقدم عن عقد العملة (يستخدم RpcManager)"""
         base_symbol = symbol.split("/")[0].upper() if '/' in symbol else symbol.upper(); symbol_lower = base_symbol.lower()
-        print(f"🔍 [WhaleMonitor V2] البحث عن عقد للعملة: {symbol}")
+        print(f"🔍 [WhaleMonitor V2.1] البحث عن عقد للعملة: {symbol}")
         
         if symbol_lower in self.contracts_db:
             contract_info = self.contracts_db[symbol_lower]
@@ -837,13 +934,56 @@ class EnhancedWhaleMonitor:
                 print(f"   ✅ وجد في قاعدة البيانات المحلية: {contract_info}"); return contract_info
         
         print(f"   🔍 البحث في CoinGecko عن {base_symbol}...")
-        coingecko_result = await self._find_contract_via_coingecko(base_symbol)
-        if coingecko_result:
-            address, network = coingecko_result; contract_info = {'address': address, 'network': network}
-            self.contracts_db[symbol_lower] = contract_info
-            print(f"   ✅ تم العثور على عقد {symbol} عبر CoinGecko على شبكة {network}: {address}")
-            if self.r2_service: await self._save_contracts_to_r2()
-            return contract_info
+        
+        # (إصلاح V2.1: إصلاح استدعاء CoinGecko)
+        try:
+            search_params = {"query": base_symbol}
+            data = await self.rpc_manager.get_coingecko_api(params=search_params) # (استخدام الدالة الأساسية)
+            if not data or not data.get('coins'): return None
+            
+            coins = data.get('coins', [])
+            best_coin = next((coin for coin in coins if coin.get('symbol', '').lower() == symbol_lower), coins[0] if coins else None)
+            coin_id = best_coin.get('id')
+            if not coin_id: return None
+
+            print(f"     🔍 [CoinGecko] جلب تفاصيل المعرف: {coin_id}")
+            
+            # (استدعاء CoinGecko API مباشرة للحصول على تفاصيل العملة)
+            base_url = COINGECKO_BASE_URL
+            full_url = f"{base_url}/coins/{coin_id}"
+            params = {"localization": "false", "tickers": "false", "market_data": "false", "community_data": "false", "developer_data": "false", "sparkline": "false"}
+            
+            async with self.rpc_manager.coingecko_semaphore:
+                current_time = time.time()
+                time_since_last = current_time - self.rpc_manager.last_coingecko_call
+                if time_since_last < COINGECKO_REQUEST_DELAY:
+                    await asyncio.sleep(COINGECKO_REQUEST_DELAY - time_since_last)
+                self.rpc_manager.last_coingecko_call = time.time()
+                
+                response = await self.http_client.get(full_url, params=params)
+                response.raise_for_status()
+                detail_data = response.json()
+            
+            if not detail_data or not detail_data.get('platforms'):
+                 print(f"       ❌ [CoinGecko] فشل جلب تفاصيل المنصات لـ {coin_id}"); return None
+            platforms = detail_data['platforms']
+
+            network_priority = ['solana', 'ethereum', 'binance-smart-chain', 'polygon-pos', 'arbitrum-one', 'optimistic-ethereum', 'avalanche', 'fantom']
+            network_map = {'solana': 'solana', 'ethereum': 'ethereum', 'binance-smart-chain': 'bsc', 'polygon-pos': 'polygon', 'arbitrum-one': 'arbitrum', 'optimistic-ethereum': 'optimism', 'avalanche': 'avalanche', 'fantom': 'fantom'}
+
+            for platform_cg in network_priority:
+                address = platforms.get(platform_cg)
+                if address and isinstance(address, str) and address.strip():
+                    network = network_map.get(platform_cg)
+                    if network:
+                         print(f"       ✅ [CoinGecko] وجد عقداً على {network}: {address}")
+                         contract_info = {'address': address, 'network': network}
+                         self.contracts_db[symbol_lower] = contract_info
+                         if self.r2_service: await self._save_contracts_to_r2()
+                         return contract_info
+            return None
+        except Exception as e:
+            print(f"❌ فشل عام في _find_contract_via_coingecko لـ {symbol}: {e}"); traceback.print_exc(); return None
         
         print(f"   ❌ فشل العثور على عقد لـ {symbol} في جميع المصادر"); return None