Update data_manager.py

data_manager.py

@@ -6,9 +6,11 @@ import time
 from datetime import datetime
 import ccxt.pro as ccxt
 import numpy as np
-from state import MARKET_STATE_OK
+import logging
 
-from helpers import safe_float_conversion
+# تعطيل تسجيل HTTP المزعج
+logging.getLogger("httpx").setLevel(logging.WARNING)
+logging.getLogger("httpcore").setLevel(logging.WARNING)
 
 class DataManager:
     def __init__(self, contracts_db, whale_monitor):
@@ -20,12 +22,10 @@ class DataManager:
                 'sandbox': False,
                 'enableRateLimit': True,
                 'timeout': 30000,
-                'verbose': False
+                'verbose': False  # تعطيل التسجيل التفصيلي
             })
             self.exchange.rateLimit = 800
-            print("✅ تم تهيئة اتصال KuCoin بنجاح")
         except Exception as e:
-            print(f"❌ فشل تهيئة اتصال KuCoin: {e}")
             self.exchange = None
             
         self._whale_data_cache = {}
@@ -50,9 +50,6 @@ class DataManager:
             'INFURA_KEY': "🟢 متوفر" if os.getenv('INFURA_KEY') else "🔴 غير متوفر"
         }
         
-        for key, status in api_status.items():
-            print(f"   {key}: {status}")
-        
         await self._load_markets()
     
     async def _load_markets(self):
@@ -60,14 +57,12 @@ class DataManager:
             if not self.exchange:
                 return
                 
-            print("🔄 جلب أحدث بيانات الأسواق من KuCoin...")
             await self.exchange.load_markets()
             self.market_cache = self.exchange.markets
             self.last_market_load = datetime.now()
-            print(f"✅ تم تحميل {len(self.market_cache)} سوق من KuCoin")
             
         except Exception as e:
-            print(f"❌ فشل تحميل بيانات الأسواق: {e}")
+            pass
 
     async def close(self):
         if self.http_client: 
@@ -106,7 +101,6 @@ class DataManager:
             return None
             
         except Exception as e:
-            print(f"❌ فشل جلب سعر {network}: {e}")
             return None
 
     async def _get_price_from_kucoin(self, symbol):
@@ -230,7 +224,8 @@ class DataManager:
                     'data_sources': {
                         'prices': bitcoin_price is not None and ethereum_price is not None,
                         'sentiment': sentiment_data is not None,
-                        'general_whale_data': general_whale_activity.get('data_available', False) if general_whale_activity else False
+                        'general_whale_data': general_whale_activity.get('data_available', False) if general_whale_activity else False,
+                        'netflow_analysis': general_whale_activity.get('netflow_analysis', {}).get('market_impact', 'UNKNOWN') if general_whale_activity else 'UNKNOWN'
                     },
                     'data_quality': 'HIGH',
                     'risk_assessment': self._assess_market_risk(general_whale_activity, sentiment_data)
@@ -435,7 +430,8 @@ class DataManager:
             'bitcoin_price_usd': None,
             'ethereum_price_usd': None,
             'fear_and_greed_index': None,
-            'sentiment_class': 'UNKNOWN'
+            'sentiment_class': 'UNKNOWN',
+            'missing_data': ['غير متوفر - أسعار البيتكوين', 'غير متوفر - أسعار الإيثيريوم', 'غير متوفر - بيانات المشاعر', 'غير متوفر - بيانات الحيتان']
         }
 
     def _determine_market_trend(self, bitcoin_price, sentiment_data, whale_activity):
@@ -568,8 +564,6 @@ class DataManager:
 
     async def find_high_potential_candidates(self, count=20):
         try:
-            print(f"🔍 البحث عن {count} رمز ذو إمكانات عالية بناءً على المؤشرات التقنية...")
-            
             if not self.exchange:
                 return []
 
@@ -581,16 +575,12 @@ class DataManager:
                 if symbol.endswith('/USDT') and self.market_cache[symbol].get('active', False)
             ]
             
-            print(f"✅ تم العثور على {len(usdt_symbols)} رمز USDT نشط في KuCoin")
-            
             candidates_with_scores = []
             analyzed_count = 0
             
             for symbol in usdt_symbols[:100]:
                 try:
                     analyzed_count += 1
-                    if analyzed_count % 10 == 0:
-                        print(f"📊 تم تحليل {analyzed_count} رمز من أصل {min(100, len(usdt_symbols))}")
                     
                     ohlcv_1h = await self.exchange.fetch_ohlcv(symbol, '1h', limit=50)
                     
@@ -627,20 +617,13 @@ class DataManager:
             candidates_with_scores.sort(key=lambda x: x['technical_score'], reverse=True)
             top_candidates = candidates_with_scores[:count]
             
-            print(f"✅ تم العثور على {len(top_candidates)} مرشح عالي الجودة")
-            
-            for candidate in top_candidates[:5]:
-                print(f"   🥇 {candidate['symbol']}: درجة {candidate['technical_score']:.3f}")
-            
             return top_candidates
             
         except Exception as e:
-            print(f"❌ خطأ في find_high_potential_candidates: {e}")
             return []
 
     async def get_fast_pass_data_async(self, candidates):
         try:
-            print(f"📊 جلب بيانات OHLCV لـ {len(candidates)} مرشح من KuCoin...")
             results = []
             
             timeframes = [
@@ -648,7 +631,8 @@ class DataManager:
                 ('15m', 200), 
                 ('1h', 200),
                 ('4h', 200),
-                ('1d', 200)
+                ('1d', 200),
+                ('1w', 200)
             ]
             
             for candidate in candidates:
@@ -667,7 +651,8 @@ class DataManager:
                                 break
                                 
                             ohlcv_data[timeframe] = ohlcv
-                            await asyncio.sleep(0.1)
+                            
+                            await asyncio.sleep(0.05)
                             
                         except Exception as e:
                             has_sufficient_data = False
@@ -682,18 +667,13 @@ class DataManager:
                         }
                         
                         results.append(result_data)
-                        print(f"✅ تم تجميع بيانات {symbol} بنجاح")
-                    else:
-                        print(f"❌ فشل تجميع بيانات كافية لـ {symbol}")
                     
                 except Exception as symbol_error:
                     continue
             
-            print(f"✅ تم تجميع بيانات لـ {len(results)} مرشح بنجاح")
             return results
             
         except Exception as e:
-            print(f"❌ خطأ في get_fast_pass_data_async: {e}")
             return []
 
     async def get_latest_price_async(self, symbol):