Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (V23.9 - GEM-Architect: KeyError Fix)
+# trade_manager.py (V23.10 - GEM-Architect: Data Depth Fix)
 
 import asyncio
 import uuid
@@ -26,7 +26,7 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V23.9] Initialized (KeyError Fixed).")
+        print(f"🛡️ [TradeManager V23.10] Initialized (Data Depth Boosted).")
 
     async def initialize_sentry_exchanges(self):
         print("🛡️ [TradeManager] Syncing state with R2...")
@@ -60,8 +60,8 @@ class TradeManager:
             if symbol in self.open_positions or symbol in self.watchlist:
                 continue
 
-            # جلب البيانات (Parallel Fetch)
-            ohlcv_task = self.data_manager.get_latest_ohlcv(symbol, '1m', 600)
+            # ✅ [FIX] زيادة البيانات هنا أيضاً للقناص
+            ohlcv_task = self.data_manager.get_latest_ohlcv(symbol, '1m', 1000) 
             ob_task = self.data_manager.get_order_book_snapshot(symbol)
             ohlcv_1m, order_book = await asyncio.gather(ohlcv_task, ob_task)
             
@@ -69,7 +69,6 @@ class TradeManager:
                 print(f"   -> [L4 Skip] {symbol} (Not enough data).")
                 continue
             
-            # استشارة القناص
             sniper_result = await self.processor.check_sniper_entry(ohlcv_1m, order_book)
             
             reason_str = sniper_result.get('reason', 'N/A')
@@ -87,7 +86,6 @@ class TradeManager:
             print("   -> [L4 Result] No candidates passed the Sniper check.")
             return
 
-        # ✅ [FIXED HERE] استخدام الاسم الصحيح 'enhanced_final_score' واستخدام .get للحماية
         sniper_candidates.sort(
             key=lambda x: (x.get('sniper_confidence', 0), x.get('enhanced_final_score', 0)), 
             reverse=True
@@ -129,10 +127,7 @@ class TradeManager:
                 'sl_price': sl_price,
                 'last_update': datetime.now().isoformat(),
                 'strategy': 'Hybrid_Titan_V1', 
-                
-                # ✅ [FIXED HERE] استخدام الاسم الصحيح للحفظ في السجل
                 'l1_score': float(signal_data.get('enhanced_final_score', 0.0)), 
-                
                 'l2_sniper_confidence': float(l2_result.get('confidence_prob', 0.0)),
                 'decision_data': {
                     'components': signal_data.get('components', {}),
@@ -161,7 +156,7 @@ class TradeManager:
             traceback.print_exc()
 
     # ==============================================================================
-    # 🛡️ Hybrid Sentry
+    # 🛡️ Hybrid Sentry (FIXED SECTION)
     # ==============================================================================
     async def _guardian_loop(self, symbol: str):
         print(f"🛡️ [Sentry] Guarding {symbol}...")
@@ -176,6 +171,7 @@ class TradeManager:
                 current_price = await self.data_manager.get_latest_price_async(symbol)
                 if current_price == 0.0: continue 
 
+                # Hard TP/SL Check
                 if current_price >= trade['tp_price']:
                     async with self.execution_lock:
                         await self._execute_exit(symbol, current_price, "TP_HIT_HARD")
@@ -185,17 +181,25 @@ class TradeManager:
                         await self._execute_exit(symbol, current_price, "SL_HIT_HARD")
                     break 
 
+                # AI Guardian Check
                 if time.time() - last_ai_check_time > 60:
-                    t1 = self.data_manager.get_latest_ohlcv(symbol, '1m', 300)
-                    t5 = self.data_manager.get_latest_ohlcv(symbol, '5m', 200)
-                    t15 = self.data_manager.get_latest_ohlcv(symbol, '15m', 100)
+                    # ✅ [CRITICAL FIX] زيادة عدد الشموع لتجاوز EMA200 Warm-up
+                    t1 = self.data_manager.get_latest_ohlcv(symbol, '1m', 1000) # كان 300
+                    t5 = self.data_manager.get_latest_ohlcv(symbol, '5m', 500)  # كان 200
+                    t15 = self.data_manager.get_latest_ohlcv(symbol, '15m', 500) # كان 100
                     d1, d5, d15 = await asyncio.gather(t1, t5, t15)
                     
-                    if d1 and d5 and d15 and len(d1) >= 200:
+                    # التحقق من أن البيانات كافية بعد الحسابات
+                    if d1 and d5 and d15 and len(d1) >= 500:
                         decision = self.processor.consult_guardian(d1, d5, d15, trade['entry_price'])
                         action = decision.get('action', 'HOLD')
                         scores = decision.get('scores', {})
                         
+                        # طباعة التشخيص (اختياري لملف التداول)
+                        # v2_val = int(scores.get('v2', 0.0) * 100)
+                        # v3_val = int(scores.get('v3', 0.0) * 100)
+                        # print(f"   🕵️ [Sentry check] {symbol} | V2:{v2_val} V3:{v3_val} | {action}")
+
                         if action in ['EXIT_HARD', 'EXIT_SOFT']:
                             print(f"🤖 [Guardian] {action}: {decision.get('reason')}")
                             async with self.execution_lock: