Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (V22.3 - GEM-Architect: Single Wallet / Multi-Stats View)
+# trade_manager.py (V22.4 - GEM-Architect: Full Logic + Multi-Stats + 300 Candle Fix)
 import asyncio
 import json
 import uuid
@@ -41,7 +41,7 @@ class TradeManager:
         
         self.execution_lock = asyncio.Lock()
         
-        print(f"🛡️ [TradeManager V22.3] Initialized. Single Wallet. Multi-View Stats.")
+        print(f"🛡️ [TradeManager V22.4] Initialized. Hybrid Guardian Active (Limit: 300).")
 
     async def initialize_sentry_exchanges(self):
         print("🛡️ [TradeManager] Initializing and syncing state with R2...")
@@ -296,17 +296,16 @@ class TradeManager:
                     break 
 
                 # 🚀 3. [ 🧠 ] Hybrid DeepSteward (V2 + V3 Dual Brain)
-                
                 if self.deep_steward and self.deep_steward.initialized:
-                    # جلب البيانات بشكل متوازي
-                    task1 = self.data_manager.get_latest_ohlcv(symbol, '1m', 120)
-                    task5 = self.data_manager.get_latest_ohlcv(symbol, '5m', 100)
-                    task15 = self.data_manager.get_latest_ohlcv(symbol, '15m', 50)
+                    # --- [تعديل جوهري] زيادة الحد إلى 300 شمعة لتجنب أخطاء النموذج ---
+                    task1 = self.data_manager.get_latest_ohlcv(symbol, '1m', 300)
+                    task5 = self.data_manager.get_latest_ohlcv(symbol, '5m', 200)
+                    task15 = self.data_manager.get_latest_ohlcv(symbol, '15m', 100)
                     
                     d1, d5, d15 = await asyncio.gather(task1, task5, task15)
                     
-                    # التأكد من وجود بيانات كافية
-                    if d1 and d5 and d15 and len(d1) >= 64: # V2 needs 64
+                    # التأكد من وجود بيانات كافية (V2 يحتاج 64 شمعة، المؤشرات تحتاج 200)
+                    if d1 and d5 and d15 and len(d1) >= 200:
                         # استشارة الحارس الهجين
                         decision = self.deep_steward.analyze_position(d1, d5, d15, trade['entry_price'])
                         action = decision.get('action', 'HOLD')
@@ -320,12 +319,13 @@ class TradeManager:
                         
                         elif action == 'EXIT_SOFT':
                             print(f"🤖 [Hybrid Guardian] ⚠️ تحذير خروج! {decision['reason']}")
+                            # هنا يمكن إضافة منطق لتشديد الستوب بدلاً من الخروج المباشر
                             async with self.execution_lock:
                                 await self._execute_exit(symbol, current_price, "AI_SOFT_EXIT", ai_scores=scores)
                             break
 
                     else:
-                        print(f"⚠️ [Sentry] بيانات الحارس الهجين غير مكتملة لـ {symbol}. تخطي الدورة.")
+                        print(f"⚠️ [Sentry] بيانات الحارس الهجين غير مكتملة لـ {symbol} (Rows: {len(d1) if d1 else 0}). تخطي الدورة.")
                 else:
                     pass # لا يوجد نموذج فعال
 
@@ -356,7 +356,7 @@ class TradeManager:
             self.ai_stats[key]["missed"] += abs(usd_impact)
 
     async def _analyze_after_exit_task(self, symbol, exit_price, exit_time, position_size_usd, ai_scores):
-        # ⏳ ننتظر 15 دقيقة
+        # ⏳ ننتظر 15 دقيقة (900 ثانية)
         await asyncio.sleep(900) 
         
         try:
@@ -398,10 +398,10 @@ class TradeManager:
             }
             
             await self.r2.append_deep_steward_audit(audit_record)
-            print(f"👻 [Ghost Monitor] {symbol}: {audit_record['verdict']} | Hybrid: Updated, V2/V3 Updated based on contribution.")
+            print(f"👻 [Ghost Monitor] {symbol}: {audit_record['verdict']} | Impact: ${usd_impact:.2f}")
 
         except Exception as e:
-            print(f"⚠️ [Ghost Error] {symbol}: {e}")
+            print(f"⚠️ [Ghost Error] فشل تحليل ما بعد الخروج لـ {symbol}: {e}")
 
     # ==============================================================================
     # 🔴 دالة الخروج المحاسبية (Accounting Exit Logic)
@@ -464,7 +464,6 @@ class TradeManager:
             print(f"✅ [EXIT EXECUTED] {symbol} | Reason: {reason} | PnL: {profit_pct_display:.2f}% (${pnl_usd:.2f}) | New Cap: ${new_capital:.2f}")
 
             # 6. [ 🧠 ] إطلاق المراقب الشبحي إذا كان الخروج بسبب الذكاء الاصطناعي
-            # نمرر حجم الصفقة (current_capital) لحساب الأثر الحقيقي بالدولار
             if "AI_" in reason:
                 self._launch_post_exit_analysis(symbol, exit_price, trade['exit_time'], current_capital, ai_scores)