Update data_manager.py

data_manager.py

@@ -45,7 +45,7 @@ class DataManager:
                 return
                 
             print("🔄 جلب أحدث بيانات الأسواق من KuCoin...")
-            await asyncio.to_thread(self.exchange.load_markets)
+            self.exchange.load_markets()
             self.market_cache = self.exchange.markets
             self.last_market_load = datetime.now()
             print(f"✅ تم تحميل {len(self.market_cache)} سوق من KuCoin")
@@ -155,12 +155,12 @@ class DataManager:
         try:
             prices = {'bitcoin': None, 'ethereum': None}
             
-            btc_ticker = await asyncio.to_thread(self.exchange.fetch_ticker, 'BTC/USDT')
+            btc_ticker = self.exchange.fetch_ticker('BTC/USDT')
             btc_price = float(btc_ticker.get('last', 0)) if btc_ticker.get('last') else None
             if btc_price and btc_price > 0:
                 prices['bitcoin'] = btc_price
             
-            eth_ticker = await asyncio.to_thread(self.exchange.fetch_ticker, 'ETH/USDT')
+            eth_ticker = self.exchange.fetch_ticker('ETH/USDT')
             eth_price = float(eth_ticker.get('last', 0)) if eth_ticker.get('last') else None
             if eth_price and eth_price > 0:
                 prices['ethereum'] = eth_price
@@ -261,7 +261,7 @@ class DataManager:
             if not self.exchange:
                 return []
                 
-            tickers = await asyncio.to_thread(self.exchange.fetch_tickers)
+            tickers = self.exchange.fetch_tickers()
             
             volume_data = []
             processed = 0
@@ -390,7 +390,7 @@ class DataManager:
     async def _process_single_symbol(self, symbol: str) -> Dict[str, Any]:
         """معالجة رمز واحد لجلب بيانات الحجم"""
         try:
-            ticker = await asyncio.to_thread(self.exchange.fetch_ticker, symbol)
+            ticker = self.exchange.fetch_ticker(symbol)
             if not ticker:
                 return None
             
@@ -448,7 +448,7 @@ class DataManager:
     async def _get_detailed_symbol_data(self, symbol: str) -> Dict[str, Any]:
         """جلب بيانات تفصيلية للرمز"""
         try:
-            ticker = await asyncio.to_thread(self.exchange.fetch_ticker, symbol)
+            ticker = self.exchange.fetch_ticker(symbol)
             if not ticker:
                 return None
             
@@ -708,7 +708,7 @@ class DataManager:
         
         for attempt in range(max_retries):
             try:
-                ohlcv_data = await asyncio.to_thread(self.exchange.fetch_ohlcv, symbol, timeframe, limit)
+                ohlcv_data = self.exchange.fetch_ohlcv(symbol, timeframe, limit=limit)
                 
                 if ohlcv_data and len(ohlcv_data) > 0:
                     return ohlcv_data
@@ -728,8 +728,8 @@ class DataManager:
                 print(f"❌ Exchange غير مهيأ لـ {symbol}")
                 return None
 
-            # ✅ الإصلاح: استخدام asyncio.to_thread لتشغيل fetch_ticker في thread منفصل
-            ticker = await asyncio.to_thread(self.exchange.fetch_ticker, symbol)
+            # ✅ الإصلاح الرئيسي: إزالة asyncio.create_task واستخدام fetch_ticker مباشرة
+            ticker = self.exchange.fetch_ticker(symbol)
             
             if not ticker:
                 print(f"❌ لم يتم العثور على ticker لـ {symbol}")