Update data_manager.py

data_manager.py

@@ -168,6 +168,7 @@ class DataManager:
             return prices
             
         except Exception as e:
+            print(f"⚠️ فشل جلب الأسعار من KuCoin: {e}")
             return {'bitcoin': None, 'ethereum': None}
 
     async def _get_prices_from_coingecko(self):
@@ -176,7 +177,6 @@ class DataManager:
             await asyncio.sleep(0.5)
             url = "https://api.coingecko.com/api/v3/simple/price?ids=bitcoin,ethereum&vs_currencies=usd"
             
-            # إضافة headers لتجنب rate limiting
             headers = {
                 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
                 'Accept': 'application/json'
@@ -201,6 +201,7 @@ class DataManager:
                     return {'bitcoin': None, 'ethereum': None}
                     
         except Exception as e:
+            print(f"⚠️ فشل جلب الأسعار من CoinGecko: {e}")
             return {'bitcoin': None, 'ethereum': None}
 
     def _get_minimal_market_context(self):
@@ -302,6 +303,7 @@ class DataManager:
             return volume_data
             
         except Exception as e:
+            print(f"❌ خطأ في جلب بيانات الحجم المثلى: {e}")
             return []
 
     async def _get_volume_data_direct_api(self) -> List[Dict[str, Any]]:
@@ -349,6 +351,7 @@ class DataManager:
                 return volume_data
                 
         except Exception as e:
+            print(f"❌ خطأ في جلب بيانات الحجم المباشر: {e}")
             return []
 
     async def _get_volume_data_traditional(self) -> List[Dict[str, Any]]:
@@ -385,6 +388,7 @@ class DataManager:
             return volume_data
             
         except Exception as e:
+            print(f"❌ خطأ في جلب بيانات الحجم التقليدية: {e}")
             return []
 
     async def _process_single_symbol(self, symbol: str) -> Dict[str, Any]:
@@ -593,7 +597,7 @@ class DataManager:
         print(f"📊 جلب بيانات OHLCV كاملة لـ {len(symbols)} عملة بشكل متوازي...")
         
         # تقسيم الرموز إلى دفعات لتجنب rate limits
-        batch_size = 15  # العودة إلى الحجم الأصلي
+        batch_size = 15  # تقليل حجم الدفعة لتحسين الاستقرار
         batches = [symbols[i:i + batch_size] for i in range(0, len(symbols), batch_size)]
         
         all_results = []
@@ -629,7 +633,7 @@ class DataManager:
             
             # انتظار قصير بين الدفعات لتجنب rate limits
             if batch_num < len(batches) - 1:
-                await asyncio.sleep(1)  # العودة إلى الوقت الأصلي
+                await asyncio.sleep(1)  # زيادة وقت الانتظار
         
         print(f"✅ تم تجميع بيانات OHLCV كاملة لـ {len(all_results)} عملة من أصل {len(symbols)}")
         return all_results
@@ -813,4 +817,4 @@ class DataManager:
                 'source': 'whale_analysis'
             }
 
-print("✅ DataManager loaded - Fixed get_latest_price_async & Restored Original Logic")
+print("✅ DataManager loaded - Fixed get_latest_price_async Function")