Update data_manager.py

data_manager.py

@@ -8,7 +8,7 @@ import ccxt.pro as ccxt
 import numpy as np
 import logging
 
-# تعطيل تسجيل HTTP المزعج
+# تعطيل تسجيل HTTP المزعج فقط
 logging.getLogger("httpx").setLevel(logging.WARNING)
 logging.getLogger("httpcore").setLevel(logging.WARNING)
 
@@ -22,10 +22,12 @@ 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,6 +52,9 @@ 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):
@@ -57,12 +62,14 @@ 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:
-            pass
+            print(f"❌ فشل تحميل بيانات الأسواق: {e}")
 
     async def close(self):
         if self.http_client: 
@@ -101,6 +108,7 @@ class DataManager:
             return None
             
         except Exception as e:
+            print(f"❌ فشل جلب سعر {network}: {e}")
             return None
 
     async def _get_price_from_kucoin(self, symbol):
@@ -111,6 +119,7 @@ class DataManager:
             trading_symbol = f"{symbol}/USDT"
             
             if trading_symbol not in self.market_cache:
+                print(f"⚠️ السوق {trading_symbol} غير متوفر في KuCoin")
                 return None
                 
             ticker = await self.exchange.fetch_ticker(trading_symbol)
@@ -118,9 +127,11 @@ class DataManager:
             if price and price > 0:
                 return float(price)
             else:
+                print(f"⚠️ لم يتم العثور على سعر صالح لـ {symbol}")
                 return None
             
         except Exception as e:
+            print(f"❌ فشل جلب سعر {symbol} من KuCoin: {e}")
             return None
 
     async def _get_price_from_coingecko_fallback(self, network):
@@ -144,11 +155,14 @@ class DataManager:
                 
                 price = data.get(coin_id, {}).get('usd')
                 if price and price > 0:
+                    print(f"✅ سعر {network.upper()} (CoinGecko): ${price:,.2f}")
                     return price
                 else:
+                    print(f"⚠️ لم يتم العثور على سعر {network} في CoinGecko")
                     return None
                     
         except Exception as e:
+            print(f"❌ فشل جلب سعر {network} من CoinGecko: {e}")
             return None
 
     async def get_sentiment_safe_async(self):
@@ -171,6 +185,7 @@ class DataManager:
                         "timestamp": datetime.now().isoformat()
                     }
             except Exception as e:
+                print(f"❌ فشل جلب بيانات المشاعر (المحاولة {attempt + 1}): {e}")
                 if attempt < max_retries - 1:
                     await asyncio.sleep(1)
         
@@ -234,6 +249,7 @@ class DataManager:
                 return market_context
                 
             except Exception as e:
+                print(f"❌ فشل جلب سياق السوق (المحاولة {attempt + 1}): {e}")
                 if attempt < max_retries - 1:
                     await asyncio.sleep(3)
 
@@ -358,6 +374,7 @@ class DataManager:
             return {'bitcoin': None, 'ethereum': None}
             
         except Exception as e:
+            print(f"❌ فشل جلب الأسعار: {e}")
             return {'bitcoin': None, 'ethereum': None}
 
     async def _get_prices_from_kucoin_safe(self):
@@ -373,8 +390,11 @@ class DataManager:
                 if btc_price and btc_price > 0:
                     prices['bitcoin'] = btc_price
                     self.price_cache['bitcoin'] = btc_price
+                    print(f"✅ سعر BTC: ${btc_price:,.2f}")
+                else:
+                    print("⚠️ لم يتم العثور على سعر BTC صالح")
             except Exception as e:
-                pass
+                print(f"❌ فشل جلب سعر BTC: {e}")
             
             try:
                 eth_ticker = await self.exchange.fetch_ticker('ETH/USDT')
@@ -382,12 +402,16 @@ class DataManager:
                 if eth_price and eth_price > 0:
                     prices['ethereum'] = eth_price
                     self.price_cache['ethereum'] = eth_price
+                    print(f"✅ سعر ETH: ${eth_price:,.2f}")
+                else:
+                    print("⚠️ لم يتم العثور على سعر ETH صالح")
             except Exception as e:
-                pass
+                print(f"❌ فشل جلب سعر ETH: {e}")
             
             return prices
             
         except Exception as e:
+            print(f"❌ خطأ في _get_prices_from_kucoin_safe: {e}")
             return {'bitcoin': None, 'ethereum': None}
 
     async def _get_prices_from_coingecko(self):
@@ -405,11 +429,15 @@ class DataManager:
                 if btc_price and eth_price:
                     self.price_cache['bitcoin'] = btc_price
                     self.price_cache['ethereum'] = eth_price
+                    print(f"✅ سعر BTC (CoinGecko): ${btc_price:,.2f}")
+                    print(f"✅ سعر ETH (CoinGecko): ${eth_price:,.2f}")
                     return {'bitcoin': btc_price, 'ethereum': eth_price}
                 else:
+                    print("⚠️ لم يتم العثور على أسعار صالحة من CoinGecko")
                     return {'bitcoin': None, 'ethereum': None}
                     
         except Exception as e:
+            print(f"❌ فشل جلب الأسعار من CoinGecko: {e}")
             return {'bitcoin': None, 'ethereum': None}
 
     def _get_minimal_market_context(self):
@@ -560,11 +588,15 @@ class DataManager:
             return final_score
             
         except Exception as e:
+            print(f"❌ خطأ في حساب الدرجة التقنية لـ {symbol}: {e}")
             return 0.0
 
     async def find_high_potential_candidates(self, count=20):
         try:
+            print(f"🔍 البحث عن {count} رمز ذو إمكانات عالية بناءً على المؤشرات التقنية...")
+            
             if not self.exchange:
+                print("❌ لا يوجد اتصال بـ KuCoin")
                 return []
 
             if not self.market_cache or not self.last_market_load or (datetime.now() - self.last_market_load).total_seconds() > 3600:
@@ -575,12 +607,16 @@ 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)
                     
@@ -612,18 +648,27 @@ class DataManager:
                         })
                     
                 except Exception as e:
+                    if "rate limit" not in str(e).lower():
+                        print(f"⚠️ خطأ في تحليل الرمز {symbol}: {e}")
                     continue
             
             candidates_with_scores.sort(key=lambda x: x['technical_score'], reverse=True)
             top_candidates = candidates_with_scores[:count]
             
+            print(f"✅ تم العثور على {len(top_candidates)} مرشح عالي الجودة من أصل {analyzed_count} رمز تم تحليله")
+            
+            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 = [
@@ -647,14 +692,17 @@ class DataManager:
                             ohlcv = await self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
                             
                             if not ohlcv or len(ohlcv) < 50:
+                                print(f"⚠️ بيانات غير كافية للرمز {symbol} في الإطار {timeframe}: {len(ohlcv) if ohlcv else 0} شمعة")
                                 has_sufficient_data = False
                                 break
                                 
                             ohlcv_data[timeframe] = ohlcv
+                            print(f"   ✅ {symbol} - {timeframe}: {len(ohlcv)} شمعة")
                             
-                            await asyncio.sleep(0.05)
+                            await asyncio.sleep(0.1)
                             
                         except Exception as e:
+                            print(f"❌ خطأ في جلب بيانات {symbol} للإطار {timeframe}: {e}")
                             has_sufficient_data = False
                             break
                     
@@ -667,21 +715,29 @@ class DataManager:
                         }
                         
                         results.append(result_data)
+                        print(f"✅ تم تجميع بيانات {symbol} بنجاح")
+                    else:
+                        print(f"❌ فشل تجميع بيانات كافية لـ {symbol}")
                     
                 except Exception as symbol_error:
+                    print(f"❌ خطأ في معالجة الرمز {symbol}: {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):
         try:
             if not self.exchange:
+                print("❌ لا يوجد اتصال بـ KuCoin")
                 return None
 
             if symbol not in self.market_cache:
+                print(f"⚠️ السوق {symbol} غير متوفر في KuCoin")
                 return None
 
             ticker = await self.exchange.fetch_ticker(symbol)
@@ -690,9 +746,11 @@ class DataManager:
             if current_price:
                 return float(current_price)
             else:
+                print(f"❌ لم يتم العثور على سعر لـ {symbol}")
                 return None
             
         except Exception as e:
+            print(f"❌ خطأ في get_latest_price_async لـ {symbol}: {e}")
             return None
 
     async def get_available_symbols(self):
@@ -711,6 +769,7 @@ class DataManager:
             return usdt_symbols
             
         except Exception as e:
+            print(f"❌ خطأ في get_available_symbols: {e}")
             return []
 
     async def validate_symbol(self, symbol):
@@ -724,6 +783,7 @@ class DataManager:
             return symbol in self.market_cache and self.market_cache[symbol].get('active', False)
             
         except Exception as e:
+            print(f"❌ خطأ في validate_symbol لـ {symbol}: {e}")
             return False
 
 print("✅ DataManager loaded - Real-time market data from KuCoin ready")