Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (Updated to V7.5 - Fixed TP Wipe Bug + Added ATR Trailing Logic)
+# trade_manager.py (Updated to V7.6 - Exponential Backoff for Timeouts)
 import asyncio
 import json
 import time
@@ -17,7 +17,11 @@ except ImportError:
 
 try:
     import ccxt.async_support as ccxtasync
+    # 🔴 --- START OF CHANGE (V7.6) --- 🔴
+    # (نحتاج لاستيراد الأخطاء للتعامل معها)
+    from ccxt.base.errors import RequestTimeout, RateLimitExceeded
     CCXT_ASYNC_AVAILABLE = True
+    # 🔴 --- END OF CHANGE --- 🔴
 except ImportError:
     print("❌❌❌ خطأ فادح: فشل استيراد 'ccxt.async_support'. ❌❌❌")
     CCXT_ASYNC_AVAILABLE = False
@@ -52,12 +56,10 @@ class TacticalData:
         self.indicators_1m = {} 
         self.last_1m_candle_timestamp = None
         
-        # 🔴 --- START OF CHANGE (V7.5) --- 🔴
         # (إضافة مؤشرات 1h لـ ATR Trailing)
         self.ohlcv_1h = deque(maxlen=100) 
         self.indicators_1h = {} 
         self.last_1h_candle_timestamp = None
-        # 🔴 --- END OF CHANGE --- 🔴
         
         self.ohlcv_5m = deque(maxlen=100) 
         self.last_5m_candle_timestamp = None
@@ -147,8 +149,6 @@ class TacticalData:
         if new_candles_added and len(self.ohlcv_1m) >= 26: 
             self._analyze_1m_indicators()
             
-    # 🔴 --- START OF CHANGE (V7.5) --- 🔴
-    # (دالة جديدة لحساب مؤشرات 1h لـ ATR)
     def add_1h_ohlcv(self, ohlcv_data: List):
         """(جديد V7.5) إضافة شموع 1-ساعة (لـ ATR Trailing Stop)"""
         if not ohlcv_data:
@@ -167,7 +167,6 @@ class TacticalData:
         
         if new_candles_added and len(self.ohlcv_1h) >= 20: # (ATR يحتاج 14)
             self._analyze_1h_indicators()
-    # 🔴 --- END OF CHANGE --- 🔴
 
     def _analyze_1m_indicators(self):
         """حساب مؤشرات 1-دقيقة الحقيقية (للدخول)"""
@@ -209,7 +208,6 @@ class TacticalData:
         except Exception as e:
             self.indicators_1m = {}
             
-    # 🔴 --- START OF CHANGE (V7.5) --- 🔴
     def _analyze_1h_indicators(self):
         """(جديد V7.5) حساب مؤشرات 1-ساعة (فقط ATR حالياً)"""
         if ta is None or len(self.ohlcv_1h) < 15: # (ATR يحتاج 14)
@@ -231,7 +229,6 @@ class TacticalData:
                 
         except Exception as e:
             self.indicators_1h = {}
-    # 🔴 --- END OF CHANGE --- 🔴
             
     def add_5m_ohlcv(self, ohlcv_data: List):
         """(جديد V7.0) إضافة شموع 5-دقائق (لحماية الأرباح)"""
@@ -292,6 +289,14 @@ class TradeManager:
         self.polling_interval = 1.5
         self.confirmation_polling_interval = 3.0
         
+        # 🔴 --- START OF CHANGE (V7.6) --- 🔴
+        # (زيادة المهلة الافتراضية للاتصال العام)
+        self.kucoin_rest_config = {
+            'enableRateLimit': True,
+            'timeout': 60000, # (زيادة المهلة إلى 60 ثانية)
+        }
+        # 🔴 --- END OF CHANGE --- 🔴
+        
         self.sentry_technical_analyzer = AdvancedTechnicalAnalyzer()
         
         if self.data_manager and self.data_manager.pattern_analyzer:
@@ -311,7 +316,11 @@ class TradeManager:
             print("🔄 [Sentry] تهيئة منصات التداول (KuCoin REST ومنصات التأكيد)...")
             
             print("   [Sentry] تهيئة KuCoin للبيانات العامة (وضع المحاكاة).")
-            self.kucoin_rest = ccxtasync.kucoin()
+            # 🔴 --- START OF CHANGE (V7.6) --- 🔴
+            # (استخدام الإعدادات الجديدة مع المهلة الممددة)
+            self.kucoin_rest = ccxtasync.kucoin(self.kucoin_rest_config)
+            # 🔴 --- END OF CHANGE --- 🔴
+            
             await self.kucoin_rest.load_markets()
             print("✅ [Sentry] منصة REST الأساسية (KuCoin) جاهزة (بيانات عامة فقط).")
 
@@ -321,7 +330,8 @@ class TradeManager:
             print(f"   [Sentry] تهيئة منصات التأكيد (Confirmation Exchanges): {', '.join(confirmation_exchange_ids)}")
             for ex_id in confirmation_exchange_ids:
                 try:
-                    exchange = getattr(ccxtasync, ex_id)()
+                    # (تطبيق نفس المهلة الممددة على منصات التأكيد أيضاً)
+                    exchange = getattr(ccxtasync, ex_id)(self.kucoin_rest_config)
                     await exchange.load_markets()
                     self.confirmation_exchanges[ex_id] = exchange
                     print(f"   ✅ [Sentry] منصة التأكيد {ex_id} جاهزة (REST).")
@@ -466,8 +476,15 @@ class TradeManager:
         if symbol not in self.tactical_data_cache:
             self.tactical_data_cache[symbol] = TacticalData(symbol)
 
+        # 🔴 --- START OF CHANGE (V7.6) --- 🔴
+        # (إضافة متغيرات الترا��ع الأسي الخاصة بهذه المهمة)
+        kucoin_backoff_delay = 5.0 # (البدء بـ 5 ثوانٍ)
+        MAX_BACKOFF = 60.0 # (الحد الأقصى 60 ثانية)
+        # 🔴 --- END OF CHANGE --- 🔴
+
         tasks_to_gather = [
-            self._poll_kucoin_data(symbol), 
+            # (تمرير متغيرات التراجع)
+            self._poll_kucoin_data(symbol, kucoin_backoff_delay, MAX_BACKOFF), 
             self._poll_confirmation_data(symbol), 
             self._run_tactical_analysis_loop(symbol, strategy_hint)
         ]
@@ -486,8 +503,13 @@ class TradeManager:
             if symbol in self.tactical_data_cache: 
                 del self.tactical_data_cache[symbol]
 
-    async def _poll_kucoin_data(self, symbol):
-        """(محدث V7.5) حلقة Polling لبيانات KuCoin (تتضمن 1m, 5m, 1h)"""
+    # 🔴 --- START OF CHANGE (V7.6) --- 🔴
+    # (تعديل الدالة لتقبل متغيرات التراجع)
+    async def _poll_kucoin_data(self, symbol, kucoin_backoff_delay, MAX_BACKOFF):
+        """(محدث V7.6) حلقة Polling لبيانات KuCoin (مع التراجع الأسي)"""
+        
+        base_polling_interval = self.polling_interval # (الفترة العادية)
+        
         while self.is_running:
             try:
                 if not self.kucoin_rest:
@@ -500,7 +522,6 @@ class TradeManager:
                     'trades': asyncio.create_task(self.kucoin_rest.fetch_trades(symbol, since=int((time.time() - 60) * 1000), limit=50)),
                     'ohlcv_1m': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '1m', limit=50)),
                     'ohlcv_5m': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '5m', limit=50)),
-                    # (إضافة 1h لـ ATR Trailing Stop)
                     'ohlcv_1h': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '1h', limit=50))
                 }
 
@@ -509,14 +530,20 @@ class TradeManager:
                 if symbol not in self.tactical_data_cache:
                     continue 
 
+                # (التحقق من الأخطاء بشكل فردي لتجنب انهيار الحلقة)
                 if not tasks['ob'].exception():
                     self.tactical_data_cache[symbol].set_order_book(tasks['ob'].result())
+                else: 
+                    # (رمي الخطأ ليتم التقاطه أدناه)
+                    raise tasks['ob'].exception()
 
                 if not tasks['trades'].exception():
                     trades = tasks['trades'].result()
                     trades.sort(key=lambda x: x['timestamp'])
                     for trade in trades:
                         self.tactical_data_cache[symbol].add_trade(trade)
+                else:
+                    raise tasks['trades'].exception()
                 
                 if not tasks['ohlcv_1m'].exception():
                     self.tactical_data_cache[symbol].add_1m_ohlcv(tasks['ohlcv_1m'].result())
@@ -524,21 +551,34 @@ class TradeManager:
                 if not tasks['ohlcv_5m'].exception():
                     self.tactical_data_cache[symbol].add_5m_ohlcv(tasks['ohlcv_5m'].result())
                     
-                # 🔴 --- START OF CHANGE (V7.5) --- 🔴
                 if not tasks['ohlcv_1h'].exception():
                     self.tactical_data_cache[symbol].add_1h_ohlcv(tasks['ohlcv_1h'].result())
-                # 🔴 --- END OF CHANGE --- 🔴
 
-                await asyncio.sleep(self.polling_interval)
+                # (نجاح! إعادة تعيين التراجع والانتظار العادي)
+                kucoin_backoff_delay = base_polling_interval # (إعادة تعيين)
+                await asyncio.sleep(base_polling_interval)
+
+            except RateLimitExceeded as e:
+                print(f"⏳ [Sentry Polling] {symbol} KuCoin Rate Limit Exceeded: {e}. زيادة فترة الانتظار (30 ثانية)...")
+                await asyncio.sleep(30)
+                # (لا نزيد التراجع الأسي هنا، ننتظر فقط)
+            
+            except RequestTimeout as e:
+                print(f"⏳ [Sentry Polling] {symbol} KuCoin Request Timeout: {e}. التراجع الأسي (الانتظار {kucoin_backoff_delay:.1f} ثانية)...")
+                await asyncio.sleep(kucoin_backoff_delay)
+                # (مضاعفة فترة الانتظار للمرة القادمة، بحد أقصى)
+                kucoin_backoff_delay = min(kucoin_backoff_delay * 2, MAX_BACKOFF)
 
-            except ccxtasync.RateLimitExceeded as e:
-                print(f"⏳ [Sentry Polling] {symbol} KuCoin Rate Limit Exceeded: {e}. زيادة فترة الانتظار...")
-                await asyncio.sleep(10)
             except asyncio.CancelledError:
                 raise 
+            
             except Exception as e:
+                # (التقاط أخطاء أخرى (مثل 404 Not Found أو أخطاء التحليل))
                 print(f"⚠️ [Sentry Polling] خ��أ في {symbol} KuCoin data polling: {e}")
-                await asyncio.sleep(5)
+                # (إعادة تعيين التراجع عند الأخطاء العامة)
+                kucoin_backoff_delay = base_polling_interval
+                await asyncio.sleep(10) # (انتظار أطول من 5 ثوانٍ)
+    # 🔴 --- END OF CHANGE --- 🔴
     
     async def _poll_confirmation_data(self, symbol):
         if not self.confirmation_exchanges:
@@ -574,15 +614,22 @@ class TradeManager:
                 for trade in trades:
                     self.tactical_data_cache[symbol].add_confirmation_trade(ex_id, trade)
         
-        except ccxtasync.RateLimitExceeded:
-            print(f"⏳ [Sentry Conf] {ex_id} Rate Limit لـ {symbol}. الانتظار...")
-            await asyncio.sleep(15) 
+        # 🔴 --- START OF CHANGE (V7.6) --- 🔴
+        # (التعامل مع الأخطاء الشائعة هنا أيضاً)
+        except RateLimitExceeded:
+            print(f"⏳ [Sentry Conf] {ex_id} Rate Limit لـ {symbol}. الانتظار (30 ثانية)...")
+            await asyncio.sleep(30) 
+        except RequestTimeout:
+            print(f"⏳ [Sentry Conf] {ex_id} Timeout لـ {symbol}. الانتظار (15 ثانية)...")
+            await asyncio.sleep(15)
+        # 🔴 --- END OF CHANGE --- 🔴
+        
         except asyncio.CancelledError:
             raise 
         except Exception as e:
+            # (نتجاهل الأخطاء بصمت هنا حتى لا نوقف الحلقة الرئيسية)
             pass
     
-    # 🔴 --- START OF CHANGE (V7.5) --- 🔴
     async def _run_tactical_analysis_loop(self, symbol: str, strategy_hint: str):
         """(محدث V7.5) (دماغ الحارس) يشغل التحليل التكتيكي + ATR Trailing"""
         while self.is_running:
@@ -677,7 +724,6 @@ class TradeManager:
             except asyncio.CancelledError:
                 raise 
             except Exception as e: print(f"❌ [Sentry] خطأ في حلقة التحليل التكتيكي لـ {symbol}: {e}"); traceback.print_exc()
-    # 🔴 --- END OF CHANGE --- 🔴
 
 
     def _check_entry_trigger(self, symbol: str, strategy_hint: str, data: Dict, all_weights: Dict) -> bool:
@@ -753,18 +799,15 @@ class TradeManager:
             default=None
         )
 
-        # 🔴 --- START OF CHANGE (V7.5) --- 🔴
         # (التحقق فقط إذا كانت القيمة أكبر من صفر)
         if hard_stop and hard_stop > 0 and current_price_for_sl and current_price_for_sl <= hard_stop: 
             return f"Strategic Stop Loss hit: {current_price_for_sl} <= {hard_stop}"
         
         if take_profit and take_profit > 0 and current_price_for_tp and current_price_for_tp >= take_profit: 
             return f"Strategic Take Profit hit: {current_price_for_tp} >= {take_profit}"
-        # 🔴 --- END OF CHANGE --- 🔴
         
         return None 
 
-    # 🔴 --- START OF CHANGE (V7.5) --- 🔴
     async def _check_atr_trailing_stop(self, trade: Dict, snapshot: Dict, current_price: float) -> str:
         """(جديد V7.5) يحسب ويحدث وقف الخسارة المتحرك ATR"""
         
@@ -787,7 +830,7 @@ class TradeManager:
             # (السعر الحالي - (قيمة ATR * المضاعف))
             new_trailing_stop = current_price - (atr_1h * atr_multiplier)
             
-            # 4. جلب وقف الخسارة الحالي (الديناميكي)
+            # 4. جلب وقف الخsارة الحالي (الديناميكي)
             current_dynamic_sl = trade.get('dynamic_stop_loss', 0)
             
             # 5. منطق التحديث (لا تخفض الوقف أبداً)
@@ -809,7 +852,6 @@ class TradeManager:
         except Exception as e:
             print(f"❌ [Sentry ATR] {trade['symbol']}: Error calculating ATR stop: {e}")
             return None
-    # 🔴 --- END OF CHANGE --- 🔴
 
 
     def _create_dataframe_5m(self, candles: List) -> pd.DataFrame:
@@ -1132,7 +1174,6 @@ class TradeManager:
         finally:
             if self.r2_service.lock_acquired: self.r2_service.release_lock()
 
-    # 🔴 --- START OF CHANGE (V7.5) --- 🔴
     async def update_trade_strategy(self, trade_to_update, re_analysis_decision):
         """
         (محدث V7.5)
@@ -1177,9 +1218,7 @@ class TradeManager:
         except Exception as e: 
             print(f"❌ (Explorer) فشل تحديث استراتيجية {symbol}: {e}"); 
             raise
-    # 🔴 --- END OF CHANGE --- 🔴
 
-    # 🔴 --- START OF CHANGE (V7.5) --- 🔴
     async def _update_trade_dynamic_sl_in_r2(self, trade_id: str, new_dynamic_sl: float):
         """(جديد V7.5) دالة مساعدة لتحديث الوقف الديناميكي فقط في R2"""
         try:
@@ -1198,7 +1237,6 @@ class TradeManager:
             
         except Exception as e:
             print(f"❌ [Sentry ATR] فشل حفظ الوقف المتحرك الجديد في R2: {e}")
-    # 🔴 --- END OF CHANGE --- 🔴
 
     async def _archive_closed_trade(self, closed_trade):
         try:
@@ -1237,4 +1275,4 @@ class TradeManager:
         except Exception as e: print(f"❌ Failed to get trade by symbol {symbol}: {e}"); return None
 
 
-print(f"✅ Trade Manager loaded - V7.5 (Fixed TP Wipe Bug + ATR Trailing Logic) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")
+print(f"✅ Trade Manager loaded - V7.6 (Exponential Backoff) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")