Update whale_news_data.py

whale_news_data.py

@@ -124,7 +124,7 @@ class EnhancedWhaleMonitor:
                 'chain_id': 'mainnet-beta',
                 'native_coin': 'SOL',
                 'explorer': 'solscan',
-                'rpc_endpoints': self._get_solana_rpc_endpoints(), # ✅ استخدام الدالة المحدثة
+                'rpc_endpoints': self._get_solana_rpc_endpoints(),
                 'type': 'solana'
             }
         }
@@ -294,24 +294,18 @@ class EnhancedWhaleMonitor:
             'https://rpc.ankr.com/fantom'
         ]
 
-    # ✅✅✅ --- الدالة المحدثة لقائمة Solana RPC (بدون مفاتيح API) --- ✅✅✅
     def _get_solana_rpc_endpoints(self):
         """الحصول على نقاط RPC مجانية لشبكة Solana (بدون مفاتيح API)"""
         endpoints = [
-            'https://api.mainnet-beta.solana.com',      # الرسمي (قد يكون محدود الطلبات بشدة)
-            'https://ssc-dao.genesysgo.net/',           # GenesysGo (قديم نسبياً، لكن لا يزال يعمل أحياناً)
-            'https://solana-mainnet.rpc.extrnode.com',  # Extrnode (مزود عام)
-            'https://solana-mainnet.phantom.tech/',     # Phantom Wallet RPC (قد يكون للاستخدام المحدود)
-            'https://mainnet.rpc.solana.pyth.network',  # Pyth Network (قد يكون مخصصًا لبيانات Pyth)
-            # 'https://rpc.ankr.com/solana',            # Ankr (يسبب 403 غالباً بدون مفتاح) - نجعله في النهاية كخيار أخير
-            # --- نقاط عامة أخرى يمكن تجربتها إذا لزم الأمر ---
-            # 'https://solana.public-rpc.com' # سبب مشاكل SSL سابقاً
+            'https://api.mainnet-beta.solana.com',
+            'https://ssc-dao.genesysgo.net/',
+            'https://solana-mainnet.rpc.extrnode.com',
+            'https://solana-mainnet.phantom.tech/',
+            'https://mainnet.rpc.solana.pyth.network',
+            'https://rpc.ankr.com/solana',
         ]
-        # إضافة Ankr في النهاية
-        endpoints.append('https://rpc.ankr.com/solana')
         print(f"ℹ️ قائمة Solana RPC Endpoints (مجانية وبدون مفاتيح) المستخدمة: {endpoints}")
         return endpoints
-    # ✅✅✅ --- نهاية الدالة المحدثة --- ✅✅✅
 
     def _initialize_comprehensive_exchange_addresses(self):
         """تهيئة قاعدة بيانات شاملة لعناوين كل المنصات"""
@@ -336,11 +330,10 @@ class EnhancedWhaleMonitor:
             'gate': [ '0x0d0707963952f2fba59dd06f2b425ace40b492fe', '0xc6f9741f5a5a676b91171804cf3c500ab438bb6e' ], # إضافة Gate.io
             'uniswap': [ '0x3fc91a3afd70395cd496c647d5a6cc9d4b2b7fad', '0x68b3465833fb72a70ecdf485e0e4c7bd8665fc45' ],
             'pancakeswap': [ '0x10ed43c718714eb63d5aa57b78b54704e256024e', '0x13f4ea83d0bd40e75c8222255bc855a974568dd4' ],
-            # عناوين Solana (تحقق من صحتها وتحديثها إذا لزم الأمر)
             'solana_kucoin': ['F3a5ZLPKUCrCj6CGKP2m9wS9Y2L8RcUBoJq9L2D2sUYi', '2AQdpHJ2JpcEgPiATFnAKfV9hPMvouWJAhKvamQ2Krqy' ],
             'solana_binance': ['5tzFkiKscXHK5ZXCGbXZJpXaWuBtZ6RrH8eL2a7Yi7Vn', '9WzDXwBbmkg8ZTbNMqUxvQRApF22xwsgMj2SUZrchK2E'],
-            'solana_coinbase': ['CeBiLnAE3UAW9mCDSjD1VULKLeQjefjN4d941fVKazSM'], # مثال لعنوان أحدث محتمل
-            'solana_wormhole': ['worm2ZoG2kUd4vFXhvjh93UUH596ayRfgQ2MgjNMTth'] # بوابة Wormhole
+            'solana_coinbase': ['CeBiLnAE3UAW9mCDSjD1VULKLeQjefjN4d941fVKazSM'],
+            'solana_wormhole': ['worm2ZoG2kUd4vFXhvjh93UUH596ayRfgQ2MgjNMTth']
         }
 
         self.address_categories = {'exchange': set(), 'cex': set(), 'dex': set(), 'bridge': set(), 'whale': set(), 'unknown': set()}
@@ -352,7 +345,6 @@ class EnhancedWhaleMonitor:
                 self.address_labels[addr_lower] = category
                 self.address_categories['exchange'].add(addr_lower)
 
-                # تصنيف أدق
                 if category in ['kucoin', 'binance', 'coinbase', 'kraken', 'okx', 'gate', 'solana_kucoin', 'solana_binance', 'solana_coinbase']:
                     self.address_categories['cex'].add(addr_lower)
                 elif category in ['uniswap', 'pancakeswap']:
@@ -581,84 +573,85 @@ class EnhancedWhaleMonitor:
                     endpoint_name = endpoint.split('//')[1].split('/')[0] if '//' in endpoint else endpoint
                     print(f"   🔍 محاولة جلب سجلات التحويلات لـ {network} عبر {endpoint_name}...")
 
-                    async with self.http_client as client:
-                        payload_block = {"jsonrpc": "2.0", "method": "eth_blockNumber", "params": [], "id": int(time.time())}
-                        response_block = await client.post(endpoint, json=payload_block, timeout=15.0)
-                        response_block.raise_for_status()
-                        json_response_block = response_block.json()
-                        result_block = json_response_block.get('result')
-                        if not result_block:
-                            rpc_error = json_response_block.get('error')
-                            error_msg = rpc_error.get('message') if rpc_error else 'No block number result'
-                            print(f"     ❌ لم يتم الحصول على رقم أحدث كتلة من {endpoint_name}: {error_msg}")
-                            continue
-                        latest_block = int(result_block, 16)
-
-                        payload_latest_block_time = {"jsonrpc": "2.0", "method": "eth_getBlockByNumber", "params": [hex(latest_block), False], "id": int(time.time())+1}
-                        response_latest_time = await client.post(endpoint, json=payload_latest_block_time, timeout=15.0)
-                        latest_block_timestamp_approx = int(time.time())
-                        if response_latest_time.status_code == 200:
-                             latest_block_data = response_latest_time.json().get('result')
-                             if latest_block_data and latest_block_data.get('timestamp'):
-                                  latest_block_timestamp_approx = int(latest_block_data['timestamp'], 16)
-
-                        from_block = max(0, latest_block - blocks_to_scan)
-                        print(f"     📦 فحص الكتل من {from_block} إلى {latest_block} (آخر {blocks_to_scan} كتل تقريباً)")
-
-                        payload_logs = {
-                            "jsonrpc": "2.0", "method": "eth_getLogs",
-                            "params": [{"fromBlock": hex(from_block), "toBlock": hex(latest_block), "address": contract_address_checksum, "topics": [TRANSFER_EVENT_SIGNATURE]}],
-                            "id": int(time.time())+2
-                        }
-                        response_logs = await client.post(endpoint, json=payload_logs, timeout=45.0)
-                        response_logs.raise_for_status()
-                        json_response_logs = response_logs.json()
-                        logs = json_response_logs.get('result')
-
-                        if logs is None:
-                            rpc_error = json_response_logs.get('error')
-                            error_msg = rpc_error.get('message') if rpc_error else 'Invalid logs response'
-                            print(f"     ❌ استجابة السجلات غير صالحة من {endpoint_name}: {error_msg}")
-                            continue
-
-                        if not logs:
-                            print(f"     ✅ لا توجد سجلات تحويل لـ {contract_address} في آخر {blocks_to_scan} كتل عبر {endpoint_name}")
-                            successful_endpoint = endpoint_name
-                            break
-
-                        print(f"     📊 تم العثور على {len(logs)} سجل تحويل محتمل.")
-
-                        for log in logs:
-                            try:
-                                topics = log.get('topics', [])
-                                data = log.get('data', '0x')
-                                block_num_hex = log.get('blockNumber')
-                                tx_hash = log.get('transactionHash')
-                                log_index_hex = log.get('logIndex', '0x0')
-
-                                if len(topics) == 3 and data != '0x' and block_num_hex and tx_hash:
-                                    sender = '0x' + topics[1][26:]
-                                    receiver = '0x' + topics[2][26:]
-                                    value = str(int(data, 16))
-                                    block_num = str(int(block_num_hex, 16))
-                                    log_index = str(int(log_index_hex, 16))
-
-                                    transfers.append({
-                                        'hash': tx_hash, 'from': sender.lower(), 'to': receiver.lower(),
-                                        'value': value, 'timeStamp': str(latest_block_timestamp_approx),
-                                        'blockNumber': block_num, 'network': network, 'logIndex': log_index
-                                    })
-                                else:
-                                     print(f"       ⚠️ سجل غير متوافق مع Transfer Event: Topics={len(topics)}, Data={data[:10]}...")
-
-                            except (ValueError, TypeError, KeyError, IndexError) as log_parse_error:
-                                print(f"       ⚠️ خطأ في تحليل سجل فردي: {log_parse_error} - Log: {log}")
-                                continue
+                    # ✅ الإصلاح: عدم استخدام "async with self.http_client"
+                    # استخدام "self.http_client" مباشرة
+                    payload_block = {"jsonrpc": "2.0", "method": "eth_blockNumber", "params": [], "id": int(time.time())}
+                    response_block = await self.http_client.post(endpoint, json=payload_block, timeout=15.0)
+                    response_block.raise_for_status()
+                    json_response_block = response_block.json()
+                    result_block = json_response_block.get('result')
+                    if not result_block:
+                        rpc_error = json_response_block.get('error')
+                        error_msg = rpc_error.get('message') if rpc_error else 'No block number result'
+                        print(f"     ❌ لم يتم الحصول على رقم أحدث كتلة من {endpoint_name}: {error_msg}")
+                        continue
+                    latest_block = int(result_block, 16)
+
+                    payload_latest_block_time = {"jsonrpc": "2.0", "method": "eth_getBlockByNumber", "params": [hex(latest_block), False], "id": int(time.time())+1}
+                    response_latest_time = await self.http_client.post(endpoint, json=payload_latest_block_time, timeout=15.0)
+                    latest_block_timestamp_approx = int(time.time())
+                    if response_latest_time.status_code == 200:
+                         latest_block_data = response_latest_time.json().get('result')
+                         if latest_block_data and latest_block_data.get('timestamp'):
+                              latest_block_timestamp_approx = int(latest_block_data['timestamp'], 16)
+
+                    from_block = max(0, latest_block - blocks_to_scan)
+                    print(f"     📦 فحص الكتل من {from_block} إلى {latest_block} (آخر {blocks_to_scan} كتل تقريباً)")
+
+                    payload_logs = {
+                        "jsonrpc": "2.0", "method": "eth_getLogs",
+                        "params": [{"fromBlock": hex(from_block), "toBlock": hex(latest_block), "address": contract_address_checksum, "topics": [TRANSFER_EVENT_SIGNATURE]}],
+                        "id": int(time.time())+2
+                    }
+                    response_logs = await self.http_client.post(endpoint, json=payload_logs, timeout=45.0)
+                    response_logs.raise_for_status()
+                    json_response_logs = response_logs.json()
+                    logs = json_response_logs.get('result')
+
+                    if logs is None:
+                        rpc_error = json_response_logs.get('error')
+                        error_msg = rpc_error.get('message') if rpc_error else 'Invalid logs response'
+                        print(f"     ❌ استجابة السجلات غير صالحة من {endpoint_name}: {error_msg}")
+                        continue
 
-                        print(f"     ✅ تم تحليل {len(transfers)} تحويلة بنجاح من {endpoint_name}")
+                    if not logs:
+                        print(f"     ✅ لا توجد سجلات تحويل لـ {contract_address} في آخر {blocks_to_scan} كتل عبر {endpoint_name}")
                         successful_endpoint = endpoint_name
                         break
 
+                    print(f"     📊 تم العثور على {len(logs)} سجل تحويل محتمل.")
+
+                    for log in logs:
+                        try:
+                            topics = log.get('topics', [])
+                            data = log.get('data', '0x')
+                            block_num_hex = log.get('blockNumber')
+                            tx_hash = log.get('transactionHash')
+                            log_index_hex = log.get('logIndex', '0x0')
+
+                            if len(topics) == 3 and data != '0x' and block_num_hex and tx_hash:
+                                sender = '0x' + topics[1][26:]
+                                receiver = '0x' + topics[2][26:]
+                                value = str(int(data, 16))
+                                block_num = str(int(block_num_hex, 16))
+                                log_index = str(int(log_index_hex, 16))
+
+                                transfers.append({
+                                    'hash': tx_hash, 'from': sender.lower(), 'to': receiver.lower(),
+                                    'value': value, 'timeStamp': str(latest_block_timestamp_approx),
+                                    'blockNumber': block_num, 'network': network, 'logIndex': log_index
+                                })
+                            else:
+                                 print(f"       ⚠️ سجل غير متوافق مع Transfer Event: Topics={len(topics)}, Data={data[:10]}...")
+
+                        except (ValueError, TypeError, KeyError, IndexError) as log_parse_error:
+                            print(f"       ⚠️ خطأ في تحليل سجل فردي: {log_parse_error} - Log: {log}")
+                            continue
+
+                    print(f"     ✅ تم تحليل {len(transfers)} تحويلة بنجاح من {endpoint_name}")
+                    successful_endpoint = endpoint_name
+                    break
+
                 except ssl.SSLCertVerificationError as ssl_err:
                      print(f"     ❌ خطأ SSL مع {endpoint_name}: {ssl_err}")
                      continue
@@ -672,6 +665,11 @@ class EnhancedWhaleMonitor:
                      print(f"     ❌ خطأ في تحليل استجابة JSON من {endpoint_name}: {json_err}")
                      continue
                 except Exception as e:
+                    # ✅ التعامل مع الخطأ الذي أبلغت عنه
+                    if "Cannot reopen a client instance" in str(e):
+                         print(f"     ❌ فشل فادح: محاولة استخدام client مغلق. {e}")
+                         # هذا لا يجب أن يحدث الآن، ولكن كإجراء وقائي، نكسر الحلقة
+                         return transfers # إرجاع ما تم تجميعه حتى الآن
                     print(f"     ❌ فشل غير متوقع مع {endpoint_name}: {e}")
                     traceback.print_exc()
                     continue
@@ -711,8 +709,8 @@ class EnhancedWhaleMonitor:
                         "params": [ token_address, {"limit": limit, "commitment": "confirmed"} ]
                     }
 
-                    async with self.http_client as client:
-                        response_signatures = await client.post(endpoint, json=payload_signatures, timeout=20.0)
+                    # ✅ الإصلاح: عدم استخدام "async with self.http_client"
+                    response_signatures = await self.http_client.post(endpoint, json=payload_signatures, timeout=20.0)
 
                     if response_signatures.status_code == 403:
                         print(f"     ⚠️ Solana endpoint {endpoint_name} failed: 403 Forbidden")
@@ -746,12 +744,12 @@ class EnhancedWhaleMonitor:
 
                     processed_count = 0
                     transaction_tasks = []
-                    async with self.http_client as client_details:
-                        for signature in signatures[:20]:
-                            transaction_tasks.append(
-                                self._get_solana_transaction_detail_with_retry(signature, endpoint, client_details)
-                            )
-                        transaction_details = await asyncio.gather(*transaction_tasks)
+                    # ✅ الإصلاح: تمرير "self.http_client" مباشرة
+                    for signature in signatures[:20]:
+                        transaction_tasks.append(
+                            self._get_solana_transaction_detail_with_retry(signature, endpoint, self.http_client)
+                        )
+                    transaction_details = await asyncio.gather(*transaction_tasks)
 
                     for detail_result in transaction_details:
                         if detail_result and self._is_solana_token_transfer(detail_result, token_address):
@@ -777,6 +775,10 @@ class EnhancedWhaleMonitor:
                      print(f"     ❌ خطأ في تحليل استجابة JSON من Solana ({endpoint_name}): {json_err}")
                      continue
                 except Exception as e:
+                    # ✅ التعامل مع الخطأ الذي أبلغت عنه
+                    if "Cannot reopen a client instance" in str(e):
+                         print(f"     ❌ فشل فادح: محاولة استخدام client مغلق. {e}")
+                         return transfers
                     print(f"     ❌ فشل غير متوقع مع endpoint Solana ({endpoint_name}): {e}")
                     traceback.print_exc()
                     continue
@@ -860,7 +862,7 @@ class EnhancedWhaleMonitor:
              print(f"       ❌ خطأ SSL في getTransaction لـ {signature[:10]}... : {ssl_err}")
              raise ssl_err
         except json.JSONDecodeError as json_err:
-             print(f"       ❌ خطأ JSON في getTransaction لـ {signature[:10]}... : {json_err} - Response: {response.text[:200]}")
+             print(f"       ❌ خطأ JSON في getTransaction لـ {signature[:10]}... : {response.text[:200]}")
              return None
         except Exception as e:
             print(f"       ❌ استثناء غير متوقع في getTransaction لـ {signature[:10]}... : {e}")
@@ -890,18 +892,16 @@ class EnhancedWhaleMonitor:
             all_balances = (post_balances or []) + (pre_balances or [])
             for balance in all_balances:
                 if isinstance(balance, dict) and balance.get('mint') == token_address:
-                    # التحقق من وجود تغيير فعلي في الرصيد الخام
                     pre_amount = next((pb.get('uiTokenAmount',{}).get('amount','0') for pb in (pre_balances or []) if isinstance(pb, dict) and pb.get('owner') == balance.get('owner') and pb.get('mint') == token_address), '0')
                     post_amount = balance.get('uiTokenAmount',{}).get('amount','0')
                     try:
                          if int(post_amount) != int(pre_amount):
                               return True
                     except (ValueError, TypeError):
-                         pass # تجاهل إذا لم تكن الأرقام صحيحة
+                         pass
 
             return False
         except Exception as e:
-            # print(f"       ⚠️ خطأ في التحقق من نوع معاملة Solana: {e}")
             return False
 
     async def _parse_solana_transfer(self, transaction, token_address):
@@ -943,11 +943,9 @@ class EnhancedWhaleMonitor:
                         amount_raw = diff_raw
                     elif diff_raw < 0:
                         sender = owner
-                        # لا نعيد التعيين، يجب أن يتطابق الفرق
 
                 except (ValueError, TypeError):
                      print(f"       ⚠️ تحذير: فشل تحليل القيمة الخام لـ Solana ({owner}).")
-                     # محاولة استخدام uiAmount كبديل (أقل دقة)
                      pre_ui = pre_bal_data.get('uiAmount', 0.0) or 0.0
                      post_ui = post_bal_data.get('uiAmount', 0.0) or 0.0
                      diff_ui = post_ui - pre_ui
@@ -959,7 +957,6 @@ class EnhancedWhaleMonitor:
                      elif diff_ui < -1e-9:
                           sender = owner
 
-            # إذا لم نجد من الأرصدة، تحقق من التعليمات الداخلية
             if not sender or not receiver or amount_raw == 0:
                 inner_instructions = meta.get('innerInstructions', [])
                 for inner_inst_set in inner_instructions:
@@ -967,23 +964,20 @@ class EnhancedWhaleMonitor:
                          parsed = inst.get('parsed')
                          if isinstance(parsed, dict) and parsed.get('type') in ['transfer', 'transferChecked'] and parsed.get('info', {}).get('mint') == token_address:
                               info = parsed.get('info', {})
-                              sender_inner = info.get('source') or info.get('authority') # Authority قد يكون هو المرسل الفعلي
+                              sender_inner = info.get('source') or info.get('authority')
                               receiver_inner = info.get('destination')
-                              amount_inner_str = info.get('tokenAmount', {}).get('amount') or info.get('amount') # اسم الحقل قد يختلف
+                              amount_inner_str = info.get('tokenAmount', {}).get('amount') or info.get('amount')
                               try:
                                    amount_inner_raw = int(amount_inner_str)
                                    if sender_inner and receiver_inner and amount_inner_raw > 0:
                                         sender = sender_inner
                                         receiver = receiver_inner
                                         amount_raw = amount_inner_raw
-                                        # الخروج من الحلقات بمجرد العثور على تحويل داخلي صالح
                                         break
                               except (ValueError, TypeError): continue
-                         if sender and receiver and amount_raw > 0: break # الخروج من الحلقة الخارجية
-                    if sender and receiver and amount_raw > 0: break # الخروج من الحلقة الخارجية
-
+                         if sender and receiver and amount_raw > 0: break
+                    if sender and receiver and amount_raw > 0: break
 
-            # التحقق النهائي
             if sender and receiver and amount_raw > 0:
                 return {
                     'hash': signature, 'from': sender, 'to': receiver,
@@ -992,7 +986,6 @@ class EnhancedWhaleMonitor:
                     'type': 'solana_transfer', 'logIndex': '0'
                 }
             else:
-                 # print(f"       ℹ️ معاملة Solana {signature[:10]}... لم يتم التعرف عليها كتحويل صالح.")
                  return None
 
         except Exception as e:
@@ -1012,30 +1005,22 @@ class EnhancedWhaleMonitor:
                 'ethereum': {'url': 'https://api.etherscan.io/api', 'key': self.etherscan_key},
                  'bsc': {'url': 'https://api.bscscan.com/api', 'key': self.bscscan_key},
                  'polygon': {'url': 'https://api.polygonscan.com/api', 'key': self.polygonscan_key}
-                 # يمكن إضافة المزيد هنا للمستكشفات الأخرى إذا كان لديك مفاتيح API لها
             }
 
             if network not in explorer_config or not explorer_config[network].get('key'):
-                 # print(f"⚠️ لا يوجد مستكشف مدعوم أو مفتاح API لشبكة {network}")
                  return []
 
             config = explorer_config[network]
-            # تحديد المعامل الصحيح لعنوان العقد
-            address_param = "contractaddress" if network == 'ethereum' else "address" # BscScan و PolygonScan يستخدمان address
+            address_param = "contractaddress" if network == 'ethereum' else "address"
 
             params = {
-                "module": "account",
-                "action": "tokentx",
-                address_param: contract_address, # استخدام المعامل الصحيح
-                "page": 1,
-                "offset": 100,
-                "startblock": 0,
-                "endblock": 999999999,
-                "sort": "desc",
-                "apikey": config['key']
+                "module": "account", "action": "tokentx",
+                address_param: contract_address,
+                "page": 1, "offset": 100, "startblock": 0,
+                "endblock": 999999999, "sort": "desc", "apikey": config['key']
             }
 
-            async with httpx.AsyncClient(timeout=20.0) as client:
+            async with httpx.AsyncClient(timeout=20.0, verify=self.ssl_context) as client: # استخدام سياق SSL
                 response = await client.get(config['url'], params=params)
 
                 if response.status_code == 200:
@@ -1047,13 +1032,11 @@ class EnhancedWhaleMonitor:
                         transfers = data.get('result', [])
                         processed_transfers = []
                         for tf in transfers:
-                            # فلترة إضافية للتأكد من أنه توكن ERC20 وليس Native Coin Transfer
-                            # وأنه للعقد الصحيح (بعض APIs قد تعيد نتائج أوسع)
                             if tf.get('tokenSymbol') and tf.get('contractAddress','').lower() == contract_address.lower():
                                  tf['network'] = network
                                  if 'from' in tf: tf['from'] = tf['from'].lower()
                                  if 'to' in tf: tf['to'] = tf['to'].lower()
-                                 if 'logIndex' not in tf: tf['logIndex'] = 'N/A' # إضافة للتوحيد
+                                 if 'logIndex' not in tf: tf['logIndex'] = 'N/A'
                                  processed_transfers.append(tf)
 
                         print(f"     ✅ Explorer {network}: تم جلب {len(processed_transfers)} تحويلة توكن للعقد المحدد.")
@@ -1231,6 +1214,7 @@ class EnhancedWhaleMonitor:
             'llm_friendly_summary': llm_summary
         }
 
+
     async def _get_accurate_token_value_optimized(self, raw_value, decimals, symbol):
         """حساب القيمة بالدولار باستخدام decimals مُمررة والسعر الحالي"""
         try:
@@ -1276,8 +1260,8 @@ class EnhancedWhaleMonitor:
                             "params": [{"to": contract_address, "data": "0x313ce567"}, "latest"],
                             "id": int(time.time())
                         }
-                        async with self.http_client as client:
-                            response = await client.post(endpoint, json=payload, timeout=10.0)
+                        # ✅ الإصلاح: استخدام "self.http_client" مباشرة
+                        response = await self.http_client.post(endpoint, json=payload, timeout=10.0)
                         if response.status_code == 200:
                             result = response.json().get('result')
                             if result and result != '0x' and result.startswith('0x'):
@@ -1291,18 +1275,20 @@ class EnhancedWhaleMonitor:
                                      print(f"     ⚠️ فشل تحويل نتيجة decimals من RPC ({result}) لـ {contract_address} على {network}")
                                      continue
                     except Exception as rpc_decimal_error:
+                         # ✅ التعامل مع خطأ العميل المغلق
+                         if "Cannot reopen a client instance" in str(rpc_decimal_error):
+                             print(f"     ❌ فشل فادح (Decimals): محاولة استخدام client مغلق. {rpc_decimal_error}")
+                             return None # لا يمكن المتابعة
                          print(f"     ⚠️ خطأ RPC أثناء جلب decimals من {endpoint.split('//')[-1]}: {rpc_decimal_error}")
                          continue
 
             elif network == 'solana':
                  print(f"ℹ️ جلب decimals لـ Solana ({contract_address}) غير مدعوم حاليًا عبر RPC.")
-                 # تقدير شائع لـ SPL tokens، لكنه قد يكون خاطئًا
-                 estimated_decimals = 9 # أو 6 هي قيم شائعة أخرى
+                 estimated_decimals = 9
                  self.token_decimals_cache[cache_key] = estimated_decimals
                  print(f"   ⚠️ استخدام قيمة decimals تقديرية لـ Solana: {estimated_decimals}")
                  return estimated_decimals
 
-
             print(f"❌ فشل جلب الكسور العشرية للعقد {contract_address} على شبكة {network} من جميع المصادر.")
             return None
 
@@ -1319,13 +1305,11 @@ class EnhancedWhaleMonitor:
             if cache_entry and time.time() - cache_entry.get('timestamp', 0) < 300:
                 return cache_entry['price']
 
-            # المحاولة 1: CoinGecko API
             price = await self._get_token_price_from_coingecko(symbol)
             if price is not None and price > 0:
                 self.token_price_cache[base_symbol] = {'price': price, 'timestamp': time.time()}
                 return price
 
-            # المحاولة 2: KuCoin API (ccxt.pro)
             price = await self._get_token_price_from_kucoin(symbol)
             if price is not None and price > 0:
                 self.token_price_cache[base_symbol] = {'price': price, 'timestamp': time.time()}
@@ -1349,7 +1333,6 @@ class EnhancedWhaleMonitor:
                 'LTC': 'litecoin', 'XLM': 'stellar', 'TRX': 'tron', 'EOS': 'eos', 'XMR': 'monero',
                 'SOL': 'solana', 'MATIC': 'matic-network', 'AVAX': 'avalanche-2', 'LINK': 'chainlink',
                 'ATOM': 'cosmos', 'UNI': 'uniswap', 'AAVE': 'aave', 'KCS': 'kucoin-shares',
-                # يجب إضافة المزيد من العملات هنا لزيادة التغطية
                 'MAVIA': 'heroes-of-mavia', 'COMMON': 'commonwealth', 'WLFI': 'wolfi',
                 'PINGPONG': 'pingpong', 'YB': 'yourbusd', 'REACT': 'react', 'XMN': 'xmine',
                 'ANOME': 'anome', 'ZEN': 'zencash', 'AKT': 'akash-network', 'UB': 'unibit'
@@ -1358,7 +1341,7 @@ class EnhancedWhaleMonitor:
             base_symbol = symbol.split('/')[0].upper()
             coingecko_id = symbol_mapping.get(base_symbol)
             if not coingecko_id:
-                 coingecko_id = base_symbol.lower() # محاولة استخدام الرمز الصغير
+                 coingecko_id = base_symbol.lower()
                  print(f"ℹ️ رمز {base_symbol} غير موجود في symbol_mapping، استخدام {coingecko_id} لـ CoinGecko.")
 
 
@@ -1368,6 +1351,7 @@ class EnhancedWhaleMonitor:
             max_retries = 2
             for attempt in range(max_retries):
                 async with self.coingecko_semaphore:
+                    # ✅ الإصلاح: إنشاء client جديد ومؤقت هنا، وليس استخدام self.http_client
                     async with httpx.AsyncClient(timeout=10.0, headers=headers, verify=self.ssl_context) as client:
                         try:
                             response = await client.get(url)
@@ -1388,25 +1372,22 @@ class EnhancedWhaleMonitor:
                                      print(f"⚠️ استجابة CoinGecko تحتوي على سعر غير صالح لـ {symbol}: {price}")
                                      return 0
                             else:
-                                 # محاولة البحث عن المعرف الصحيح إذا فشلت المحاولة الأولى
                                  if attempt == 0:
                                       print(f"⚠️ لم يتم العثور على سعر لـ {coingecko_id} في CoinGecko، محاولة البحث عن المعرف...")
-                                      await asyncio.sleep(1.1) # انتظار قبل البحث
+                                      await asyncio.sleep(1.1)
                                       found_id = await self._find_coingecko_id_via_search(base_symbol, client)
                                       if found_id and found_id != coingecko_id:
                                            print(f"   🔄 تم العثور على معرف بديل: {found_id}. إعادة المحاولة...")
-                                           coingecko_id = found_id # تحديث المعرف وإعادة المحاولة في الحلقة
-                                           # تعديل URL
+                                           coingecko_id = found_id
                                            url = f"https://api.coingecko.com/api/v3/simple/price?ids={coingecko_id}&vs_currencies=usd"
-                                           continue # العودة لبداية الحلقة مع المعرف الجديد
+                                           continue
                                       else:
                                            print(f"   ❌ لم يتم العثور على معرف بديل لـ {base_symbol}.")
-                                           return 0 # فشل البحث عن المعرف
-                                 else: # فشل بعد المحاولة الثانية
+                                           return 0
+                                 else:
                                       print(f"⚠️ لم يتم العثور على سعر لـ {coingecko_id} في استجابة CoinGecko بعد البحث.")
                                       return 0
 
-                        # --- معالجة الأخطاء تبقى كما هي ---
                         except httpx.HTTPStatusError as http_err:
                             print(f"❌ خطأ HTTP من CoinGecko لـ {symbol}: {http_err.response.status_code}")
                             return 0
@@ -1424,8 +1405,8 @@ class EnhancedWhaleMonitor:
             print(f"❌ فشل عام في _get_token_price_from_coingecko لـ {symbol}: {e}")
             return 0
 
-    # دالة مساعدة للبحث عن معرف CoinGecko
     async def _find_coingecko_id_via_search(self, symbol, client: httpx.AsyncClient):
+        """دالة مساعدة للبحث عن معرف CoinGecko"""
         try:
             search_url = f"https://api.coingecko.com/api/v3/search?query={symbol}"
             response = await client.get(search_url)
@@ -1433,12 +1414,10 @@ class EnhancedWhaleMonitor:
             data = response.json()
             coins = data.get('coins', [])
             if coins:
-                 # البحث عن تطابق الرمز أولاً
                  search_symbol_lower = symbol.lower()
                  for coin in coins:
                       if coin.get('symbol', '').lower() == search_symbol_lower:
                            return coin.get('id')
-                 # إذا لم نجد، نأخذ معرف أول نتيجة
                  return coins[0].get('id')
             return None
         except Exception as e:
@@ -1450,12 +1429,11 @@ class EnhancedWhaleMonitor:
         """جلب سعر العملة من KuCoin كبديل (بشكل غير متزامن)"""
         exchange = None
         try:
-            # استخدام enableRateLimit مهم لـ ccxt.pro
             exchange = ccxt.kucoin({'enableRateLimit': True})
-            # التحقق من أن السوق موجود قبل محاولة جلبه
             markets = await exchange.load_markets()
             if symbol not in markets:
                  print(f"⚠️ الرمز {symbol} غير موجود في أسواق KuCoin.")
+                 await exchange.close() # الإغلاق عند عدم العثور على الرمز
                  return 0
 
             ticker = await exchange.fetch_ticker(symbol)
@@ -1480,7 +1458,6 @@ class EnhancedWhaleMonitor:
              print(f"❌ خطأ شبكة أثناء جلب السعر من KuCoin لـ {symbol}: {e}")
              return 0
         except ccxt.ExchangeError as e:
-             # تحسين طباعة الخطأ
              print(f"❌ خطأ منصة KuCoin ({type(e).__name__}) لـ {symbol}: {e}")
              return 0
         except Exception as e:
@@ -1500,50 +1477,42 @@ class EnhancedWhaleMonitor:
         abs_net_flow = abs(net_flow_usd)
         total_flow_volume = total_to_exchanges_usd + total_from_exchanges_usd
 
-        # مضاعف الثقة يعتمد بشكل أكبر على الحجم المطلق للتدفق وعدد التحويلات
         confidence_multiplier = min( (abs_net_flow / 500000.0) + (whale_transfers_count / 5.0) , 1.5)
-
         base_confidence = 0.5 + (network_strength * 0.1)
 
         action = 'HOLD'
         reason = f'نشاط حيتان عبر {len(network_stats)} شبكة: {whale_transfers_count} تحويلة كبيرة بقيمة إجمالية ${total_flow_volume:,.0f}. صافي التدفق ${net_flow_usd:,.0f}'
         critical_alert = False
 
-        # شروط البيع
-        if net_flow_usd > 500000 and deposit_count >= 2: # قوي
+        if net_flow_usd > 500000 and deposit_count >= 2:
             action = 'STRONG_SELL'
             confidence = min(0.7 + (base_confidence * confidence_multiplier * 0.3), 0.95)
             reason = f'ضغط بيعي قوي عبر {len(network_stats)} شبكة: ${net_flow_usd:,.0f} إيداع للمنصات ({deposit_count} تحويلة).'
             critical_alert = abs_net_flow > 1000000
-        elif net_flow_usd > 150000 and (deposit_count >= 1 or whale_transfers_count > 0): # عادي (حد أدنى أقل)
+        elif net_flow_usd > 150000 and (deposit_count >= 1 or whale_transfers_count > 0):
             action = 'SELL'
             confidence = min(0.6 + (base_confidence * confidence_multiplier * 0.2), 0.85)
             reason = f'ضغط بيعي محتمل عبر {len(network_stats)} شبكة: ${net_flow_usd:,.0f} إيداع للمنصات.'
             critical_alert = abs_net_flow > 750000
-
-        # شروط الشراء
-        elif net_flow_usd < -500000 and withdrawal_count >= 2: # قوي
+        elif net_flow_usd < -500000 and withdrawal_count >= 2:
             action = 'STRONG_BUY'
             confidence = min(0.7 + (base_confidence * confidence_multiplier * 0.3), 0.95)
             reason = f'تراكم شرائي قوي عبر {len(network_stats)} شبكة: ${abs_net_flow:,.0f} سحب من المنصات ({withdrawal_count} تحويلة).'
             critical_alert = abs_net_flow > 1000000
-        elif net_flow_usd < -150000 and (withdrawal_count >= 1 or whale_transfers_count > 0): # عادي (حد أدنى أقل)
+        elif net_flow_usd < -150000 and (withdrawal_count >= 1 or whale_transfers_count > 0):
             action = 'BUY'
             confidence = min(0.6 + (base_confidence * confidence_multiplier * 0.2), 0.85)
             reason = f'تراكم شرائي محتمل عبر {len(network_stats)} شبكة: ${abs_net_flow:,.0f} سحب من المنصات.'
             critical_alert = abs_net_flow > 750000
-
-        # حالة HOLD
         else:
             if whale_transfers_count > 0 and abs_net_flow < 100000:
                  confidence = min(base_confidence * 1.1, 0.6)
                  reason += " (صافي التدفق منخفض نسبياً)"
-            # تعديل: إذا كان هناك تحويلات حيتان لكن التدفق متعادل، قد تكون الثقة أقل من الأساسية
             elif whale_transfers_count > 0 and abs_net_flow < 50000:
-                 confidence = max(0.4, base_confidence * 0.9) # تقليل الثقة قليلاً للنشاط غير الواضح
+                 confidence = max(0.4, base_confidence * 0.9)
                  reason += " (صافي التدفق شبه متعادل)"
             elif whale_transfers_count == 0:
-                 confidence = 0.3 # ثقة منخفضة جدًا لعدم وجود حيتان
+                 confidence = 0.3
                  reason = 'لا توجد تحركات حيتان كبيرة في الساعات الأخيرة'
             else:
                  confidence = base_confidence
@@ -1581,33 +1550,29 @@ class EnhancedWhaleMonitor:
 
         print(f"🔍 البحث عن عقد للعملة: {symbol}")
 
-        # 1. البحث في قاعدة البيانات المحلية
         if symbol_lower in self.contracts_db:
             contract_info = self.contracts_db[symbol_lower]
-            if isinstance(contract_info, str): # التحويل للصيغة الجديدة إذا لزم الأمر
+            if isinstance(contract_info, str):
                 network = self._detect_network_from_address(contract_info)
                 contract_info = {'address': contract_info, 'network': network}
                 self.contracts_db[symbol_lower] = contract_info
-            # التأكد من وجود المفاتيح المطلوبة
             if 'address' in contract_info and 'network' in contract_info:
                  print(f"   ✅ وجد في قاعدة البيانات المحلية: {contract_info}")
                  return contract_info
             else:
                  print(f"   ⚠️ بيانات العقد غير مكتملة في القاعدة المحلية لـ {symbol}: {contract_info}")
-                 # سنحاول البحث عبر CoinGecko كبديل
 
-        # 2. البحث في CoinGecko
         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 # حفظ النتيجة في الذاكرة
+            self.contracts_db[symbol_lower] = contract_info
             print(f"   ✅ تم العثور على عقد {symbol} عبر CoinGecko على شبكة {network}: {address}")
 
             if self.r2_service:
-                await self._save_contracts_to_r2() # حفظ التحديث في R2
+                await self._save_contracts_to_r2()
 
             return contract_info
 
@@ -1624,6 +1589,7 @@ class EnhancedWhaleMonitor:
             max_retries = 2
             for attempt in range(max_retries):
                 async with self.coingecko_semaphore:
+                    # ✅ استخدام client جديد ومؤقت هنا
                     async with httpx.AsyncClient(timeout=15, headers=headers, verify=self.ssl_context) as client:
                         try:
                             print(f"     🔍 CoinGecko Search API Call (Attempt {attempt + 1}) for {symbol}")
@@ -1690,9 +1656,12 @@ class EnhancedWhaleMonitor:
                             print(f"       ❌ No contract found on supported platforms for {coin_id}")
                             return None
 
-                        # --- معالجة الأخطاء تبقى كما هي ---
-                        except httpx.HTTPStatusError as http_err: print(f"     ❌ HTTP Error from CoinGecko ({http_err.request.url}): {http_err.response.status_code}"); return None
-                        except httpx.RequestError as req_err: print(f"     ❌ Connection Error with CoinGecko ({req_err.request.url}): {req_err}"); return None
+                        except httpx.HTTPStatusError as http_err:
+                            print(f"     ❌ HTTP Error from CoinGecko ({http_err.request.url}): {http_err.response.status_code}")
+                            return None
+                        except httpx.RequestError as req_err:
+                            print(f"     ❌ Connection Error with CoinGecko ({req_err.request.url}): {req_err}")
+                            return None
                         except Exception as inner_e:
                              print(f"     ❌ Unexpected error during CoinGecko API call (Attempt {attempt + 1}): {inner_e}")
                              if attempt < max_retries - 1: await asyncio.sleep(1); continue
@@ -1790,9 +1759,7 @@ class EnhancedWhaleMonitor:
                 }
 
             whale_signal = whale_data.get('trading_signal', {})
-
-            # إضافة تفاصيل التحليل المتاحة
-            analysis_details = whale_data # استخدام القاموس الكامل كـ تفاصيل
+            analysis_details = whale_data # إرجاع كافة التفاصيل
 
             return {
                 'action': whale_signal.get('action', 'HOLD'),
@@ -1801,7 +1768,7 @@ class EnhancedWhaleMonitor:
                 'source': 'whale_analysis',
                 'critical_alert': whale_signal.get('critical_alert', False),
                 'data_available': True,
-                'whale_analysis_details': analysis_details # إرجاع كافة التفاصيل
+                'whale_analysis_details': analysis_details
             }
 
         except Exception as e:
@@ -1823,4 +1790,4 @@ class EnhancedWhaleMonitor:
                  print(f"⚠️ خطأ أثناء إغلاق HTTP client لمراقب الحيتان: {e}")
 
 
-print("✅ EnhancedWhaleMonitor loaded - Correct RPC (eth_getLogs), Robust Solana RPC Handling (Free Endpoints)")
+print("✅ EnhancedWhaleMonitor loaded - Correct RPC (eth_getLogs), Robust Solana RPC Handling (Free Endpoints), Fixed httpx client usage")