Update data_manager.py

data_manager.py

@@ -1,4 +1,4 @@
-import os, asyncio, httpx, json, traceback, backoff, re, time
+import os, asyncio, httpx, json, traceback, backoff, re, time, base58
 from datetime import datetime, timedelta
 from functools import wraps
 import ccxt.pro as ccxt
@@ -7,7 +7,7 @@ import pandas as pd
 import numpy as np
 from state import MARKET_STATE_OK
 
-# --- 🐋 نظام تتبع الحيتان المحسن مع الوقت الدقيق ---
+# --- 🐋 نظام تتبع الحيتان المحسن مع دعم Solana ---
 class EnhancedWhaleMonitor:
     def __init__(self, contracts_db=None):
         self.http_client = httpx.AsyncClient(timeout=10.0, limits=httpx.Limits(max_connections=100, max_keepalive_connections=20))
@@ -24,6 +24,16 @@ class EnhancedWhaleMonitor:
             'polygon': 'https://polygon-rpc.com/',
             'arbitrum': 'https://arb1.arbitrum.io/rpc',
             'avalanche': 'https://api.avax.network/ext/bc/C/rpc',
+            'solana': 'https://api.mainnet-beta.solana.com',  # ✅ إضافة Solana
+        }
+        
+        # قاعدة بيانات للعناوين المشهورة على Solana
+        self.solana_known_tokens = {
+            'SWTCH': 'SW1TCHLmRGTfW5xZknqQdpdarB8PD95sJYWpNp9TbFx',
+            'BONK': 'DezXAZ8z7PnrnRJjz3wXBoRgixCa6xjnB7YaB1pPB263',
+            'WIF': 'EKpQGSJtjMFqKZ9KQanSqYXRcF8fBopzLHYxdM65zcjm',
+            'JUP': 'JUPyiwrYJFskUPiHa7hkeR8VUtAeFoSYbKedZNsDvCN',
+            'RAY': '4k3Dyjzvzp8eMZWUXbBCjEvwSkkk59S5iCNLY3QrkX6R'
         }
         
         self.price_cache = {}
@@ -37,7 +47,7 @@ class EnhancedWhaleMonitor:
 
         coin_map = {
             'ethereum': 'ethereum', 'bsc': 'binancecoin', 'polygon': 'matic-network',
-            'arbitrum': 'arbitrum', 'avalanche': 'avalanche-2'
+            'arbitrum': 'arbitrum', 'avalanche': 'avalanche-2', 'solana': 'solana'
         }
         coin_id = coin_map.get(network)
         if not coin_id: return 0
@@ -56,7 +66,17 @@ class EnhancedWhaleMonitor:
     async def _call_rpc_async(self, network, method, params=[]):
         """اتصال RPC غير متزامن"""
         try:
-            payload = {"jsonrpc": "2.0", "method": method, "params": params, "id": 1}
+            if network == 'solana':
+                # تنسيق مختلف لـ Solana RPC
+                payload = {
+                    "jsonrpc": "2.0",
+                    "id": 1,
+                    "method": method,
+                    "params": params
+                }
+            else:
+                payload = {"jsonrpc": "2.0", "method": method, "params": params, "id": 1}
+                
             response = await self.http_client.post(self.rpc_endpoints[network], json=payload)
             response.raise_for_status()
             return response.json().get('result')
@@ -114,10 +134,168 @@ class EnhancedWhaleMonitor:
             print(f"⚠️ خطأ في مسح شبكة {network}: {e}")
         return whale_alerts
 
+    async def _scan_solana_network(self, base_symbol):
+        """مسح شبكة Solana لتحويلات العملة"""
+        try:
+            print(f"🔍 مسح Solana لـ {base_symbol}...")
+            
+            # الحصول على عنوان العقد
+            token_address = await self._get_solana_token_address(base_symbol)
+            if not token_address:
+                return []
+            
+            whale_alerts = []
+            
+            # جلب آخر التوقيعات للعنوان
+            payload = {
+                "jsonrpc": "2.0",
+                "id": 1,
+                "method": "getSignaturesForAddress",
+                "params": [
+                    token_address,
+                    {"limit": 50}  # جلب آخر 50 توقيع
+                ]
+            }
+            
+            response = await self.http_client.post(self.rpc_endpoints['solana'], json=payload)
+            if response.status_code != 200:
+                return []
+                
+            data = response.json()
+            if 'result' not in data:
+                return []
+            
+            # الحصول على سعر SOL
+            sol_price = await self._get_native_coin_price('solana')
+            
+            # تحليل التوقيعات الحديثة (آخر 20 توقيع)
+            for signature_info in data['result'][:20]:
+                try:
+                    # جلب تفاصيل المعاملة
+                    tx_payload = {
+                        "jsonrpc": "2.0",
+                        "id": 1,
+                        "method": "getTransaction",
+                        "params": [
+                            signature_info['signature'],
+                            {"encoding": "jsonParsed", "maxSupportedTransactionVersion": 0}
+                        ]
+                    }
+                    
+                    tx_response = await self.http_client.post(self.rpc_endpoints['solana'], json=tx_payload)
+                    if tx_response.status_code == 200:
+                        tx_data = tx_response.json()
+                        if 'result' in tx_data and tx_data['result']:
+                            transaction = tx_data['result']
+                            
+                            # تحليل حجم التحويل
+                            transfer_value = await self._analyze_solana_transaction(transaction, base_symbol)
+                            if transfer_value > 0:
+                                # تحويل القيمة إلى USD
+                                value_usd = transfer_value * sol_price
+                                
+                                if value_usd >= self.whale_threshold_usd:
+                                    block_time = datetime.fromtimestamp(signature_info['blockTime'])
+                                    time_ago = (datetime.now() - block_time).total_seconds() / 60
+                                    
+                                    whale_alerts.append({
+                                        'network': 'solana',
+                                        'value_usd': value_usd,
+                                        'signature': signature_info['signature'][:10] + '...',
+                                        'timestamp': signature_info['blockTime'],
+                                        'human_time': block_time.isoformat(),
+                                        'minutes_ago': time_ago,
+                                        'transaction_type': 'solana_token_transfer',
+                                        'token_amount': transfer_value,
+                                        'sol_amount': transfer_value
+                                    })
+                except Exception as e:
+                    print(f"⚠️ خطأ في تحليل معاملة Solana: {e}")
+                    continue
+        
+            return whale_alerts
+            
+        except Exception as e:
+            print(f"❌ فشل مسح Solana لـ {base_symbol}: {e}")
+            return []
+
+    async def _get_solana_token_address(self, base_symbol):
+        """الحصول على عنوان الرمز على Solana"""
+        # البحث في قاعدة البيانات المحلية أولاً
+        contracts = self.contracts_db.get(base_symbol.upper(), {})
+        if contracts and 'solana' in contracts:
+            return contracts['solana']
+        
+        # البحث في قاعدة البيانات المحلية
+        if base_symbol.upper() in self.solana_known_tokens:
+            return self.solana_known_tokens[base_symbol.upper()]
+        
+        # البحث في CoinGecko
+        coin_id = await self._find_coin_id_by_symbol(base_symbol)
+        if coin_id:
+            solana_address = await self._get_solana_contract_from_coingecko(coin_id)
+            if solana_address:
+                return solana_address
+        
+        return None
+
+    async def _get_solana_contract_from_coingecko(self, coin_id):
+        """جلب عنوان Solana من CoinGecko"""
+        try:
+            url = f"https://api.coingecko.com/api/v3/coins/{coin_id}"
+            async with httpx.AsyncClient() as client:
+                response = await client.get(url, timeout=10)
+                response.raise_for_status()
+                data = response.json()
+                
+                platforms = data.get('platforms', {})
+                if 'solana' in platforms and platforms['solana']:
+                    return platforms['solana']
+                    
+        except Exception as e:
+            print(f"⚠️ فشل جلب عقد Solana من CoinGecko: {e}")
+        
+        return None
+
+    async def _analyze_solana_transaction(self, transaction, base_symbol):
+        """تحليل معاملة Solana للبحث عن تحويلات كبيرة"""
+        try:
+            if 'meta' not in transaction:
+                return 0
+                
+            meta = transaction['meta']
+            if 'preTokenBalances' not in meta or 'postTokenBalances' not in meta:
+                return 0
+            
+            # حساب التغير في الأرصدة
+            total_change = 0
+            
+            # تحليل تغيرات الرصيد قبل وبعد
+            pre_balances = {bal['accountIndex']: float(bal.get('uiTokenAmount', {}).get('uiAmount', 0)) 
+                          for bal in meta.get('preTokenBalances', [])}
+            post_balances = {bal['accountIndex']: float(bal.get('uiTokenAmount', {}).get('uiAmount', 0)) 
+                           for bal in meta.get('postTokenBalances', [])}
+            
+            for account_index, post_balance in post_balances.items():
+                pre_balance = pre_balances.get(account_index, 0)
+                change = post_balance - pre_balance
+                if change > 0:  # نبحث عن التحويلات الواردة الكبيرة
+                    total_change += change
+            
+            # إذا كان التغير كبيراً، نعتبره تحويل حوت
+            if total_change > 10000:  # حد أدنى لكمية الرمز
+                return total_change
+                
+            return 0
+            
+        except Exception as e:
+            print(f"⚠️ خطأ في تحليل معاملة Solana: {e}")
+            return 0
+
     async def get_general_whale_activity(self):
         """الوظيفة الرئيسية لمراقبة الحيتان العامة عبر RPC"""
         print("🌊 بدء مراقبة الحيتان عبر الشبكات المتعددة...")
-        tasks = [self._scan_single_evm_network(net) for net in self.rpc_endpoints.keys()]
+        tasks = [self._scan_single_evm_network(net) for net in self.rpc_endpoints.keys() if net != 'solana']
         results = await asyncio.gather(*tasks, return_exceptions=True)
         
         all_alerts = []
@@ -175,27 +353,42 @@ class EnhancedWhaleMonitor:
         if not contract_address:
             contract_address = await self._find_contract_address(base_symbol)
         
-        if not contract_address:
-            return await self._scan_networks_for_symbol(symbol, base_symbol)
+        # تحديد نوع الشبكة
+        network_type = self._detect_network_type(contract_address)
         
         try:
             print(f"🔍 جلب بيانات الحيتان لـ {symbol} مع العقد: {contract_address[:10]}...")
             
-            # الحصول على بيانات المصادر الأساسية
-            api_data = await self._get_combined_api_data(contract_address)
-            
-            if api_data:
-                # 🕒 إضافة معلومات الوقت للبيانات من API
-                enriched_data = await self._enrich_api_data_with_timing(api_data)
-                return self._analyze_symbol_specific_data(enriched_data, symbol)
+            if network_type == 'solana':
+                # مسح شبكة Solana
+                return await self._scan_solana_network(base_symbol)
             else:
-                # إذا فشلت المصادر الأساسية، جرب الشبكات المباشرة
-                return await self._scan_networks_for_symbol(symbol, base_symbol)
+                # الحصول على بيانات المصادر الأساسية لـ EVM
+                api_data = await self._get_combined_api_data(contract_address)
+                
+                if api_data:
+                    # 🕒 إضافة معلومات الوقت للبيانات من API
+                    enriched_data = await self._enrich_api_data_with_timing(api_data)
+                    return self._analyze_symbol_specific_data(enriched_data, symbol)
+                else:
+                    # إذا فشلت المصادر الأساسية، جرب الشبكات المباشرة
+                    return await self._scan_networks_for_symbol(symbol, base_symbol)
                 
         except Exception as e:
             print(f"❌ فشل جلب بيانات الحيتان لـ {symbol}: {e}")
             return await self._scan_networks_for_symbol(symbol, base_symbol)
 
+    def _detect_network_type(self, contract_address):
+        """كشف نوع الشبكة بناءً على عنوان العقد"""
+        if not contract_address:
+            return 'unknown'
+        
+        # Solana عناوين تكون base58 encoded بطول محدد
+        if len(contract_address) in [32, 44] and all(c in '123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz' for c in contract_address):
+            return 'solana'
+        else:
+            return 'evm'
+
     async def _get_combined_api_data(self, contract_address):
         """جلب البيانات المجمعة من مصادر API"""
         tasks = []
@@ -259,10 +452,13 @@ class EnhancedWhaleMonitor:
         whale_alerts = []
         tasks = []
         
-        # مسح جميع شبكات EVM
-        for network in ['ethereum', 'bsc', 'polygon', 'arbitrum', 'avalanche']:
+        # مسح جميع شبكات EVM + Solana
+        for network in ['ethereum', 'bsc', 'polygon', 'arbitrum', 'avalanche', 'solana']:
             if network in self.rpc_endpoints:
-                tasks.append(self._scan_network_for_token_transfers(network, base_symbol))
+                if network == 'solana':
+                    tasks.append(self._scan_solana_network(base_symbol))
+                else:
+                    tasks.append(self._scan_network_for_token_transfers(network, base_symbol))
         
         results = await asyncio.gather(*tasks, return_exceptions=True)
         
@@ -367,7 +563,7 @@ class EnhancedWhaleMonitor:
         if not alerts:
             return {
                 'data_available': False,
-                'description': f'لم يتم العثور على نشاط حيتان لـ {symbol} في آخر 50 كتلة',
+                'description': f'لم يتم العثور على نشاط حيتان لـ {symbol} في الشبكات المباشرة',
                 'total_volume': 0,
                 'transfer_count': 0
             }
@@ -454,12 +650,17 @@ class EnhancedWhaleMonitor:
         # 1. البحث في قاعدة البيانات المحلية أولاً
         contracts = self.contracts_db.get(base_symbol.upper(), {})
         if contracts:
-            for network in ['ethereum', 'bsc', 'polygon', 'arbitrum']:
+            for network in ['ethereum', 'bsc', 'polygon', 'arbitrum', 'solana']:  # ✅ إضافة Solana
                 if network in contracts:
                     print(f"✅ وجد عقد {base_symbol} في {network}: {contracts[network][:10]}...")
                     return contracts[network]
         
-        # 2. البحث في CoinGecko مباشرة
+        # 2. البحث في قاعدة البيانات المحلية للرموز المعروفة
+        if base_symbol.upper() in self.solana_known_tokens:
+            print(f"🎯 استخدام عنوان Solana المعروف لـ {base_symbol}")
+            return self.solana_known_tokens[base_symbol.upper()]
+        
+        # 3. البحث في CoinGecko مباشرة
         print(f"🔍 البحث عن عقد {base_symbol} في CoinGecko...")
         coin_id = await self._find_coin_id_by_symbol(base_symbol)
         if coin_id:
@@ -556,7 +757,7 @@ class DataManager:
     
     async def initialize(self):
         self.http_client = httpx.AsyncClient(timeout=30.0)
-        print("✅ DataManager initialized - Enhanced RPC Whale Monitoring with Timing Active")
+        print("✅ DataManager initialized - Enhanced RPC Whale Monitoring with Solana Support Active")
     
     async def close(self):
         if self.http_client: await self.http_client.aclose()
@@ -947,7 +1148,7 @@ class DataManager:
             contracts = self.contracts_db.get(base, {})
             contract_address = contracts.get("ethereum")  # الأولوية للشبكة الرئيسية
             
-            # استخدام النظام المحسن
+            # استخدام النظام المحسن مع دعم Solana
             whale_data = await self.whale_monitor.get_symbol_specific_whale_data(symbol, contract_address)
             
             if whale_data.get('data_available'):
@@ -1133,4 +1334,4 @@ async def fetch_contracts_from_coingecko():
     print("🚨 فشل جميع محاولات جلب عقود CoinGecko")
     return {}
 
-print("✅ Enhanced Data Manager Loaded - REAL-TIME WHALE TRACKING WITH PRECISE TIMING - 50 BLOCKS SCAN - NO SIMULATION - SENTIMENT FIXED")
+print("✅ Enhanced Data Manager Loaded - SOLANA SUPPORT ADDED - REAL-TIME WHALE TRACKING - 50 BLOCKS SCAN - NO SIMULATION")