Update trade_manager.py

trade_manager.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🛡️ trade_manager.py (V37.1 - GEM-Architect: Governance Data Loop)
+# 🛡️ trade_manager.py (V37.2 - GEM-Architect: Context Persistence)
 # ============================================================
 
 import asyncio
@@ -45,7 +45,7 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V37.1] Full System Online (Governance Learning Loop Active).")
+        print(f"🛡️ [TradeManager V37.2] Full System Online (Context Aware).")
 
     async def initialize_sentry_exchanges(self):
         """تهيئة المحفظة واستعادة الحالة"""
@@ -112,8 +112,9 @@ class TradeManager:
                 print(f"   -> ⚠️ [Skip] {symbol}: Insufficient 1m data.")
                 continue
             
-            # فحص Sniper
-            sniper_result = await self.processor.check_sniper_entry(ohlcv_1m, order_book)
+            # ✅ FIX: تمرير سياق الإشارة بالكامل لكي يرى Sniper الحدود الديناميكية
+            sniper_result = await self.processor.check_sniper_entry(ohlcv_1m, order_book, context_data=signal)
+            
             sniper_signal = sniper_result.get('signal', 'WAIT')
             final_conf = sniper_result.get('confidence_prob', 0.0)
             
@@ -189,16 +190,19 @@ class TradeManager:
             if current_price <= 0.0: current_price = await self.data_manager.get_latest_price_async(symbol)
             entry_fee_usd = approved_size_usd * self.FEE_RATE
 
-            # حفظ تفاصيل القرار كاملة من أجل التعلم
+            # ✅ FIX: حفظ الحدود الديناميكية والريجيم لاستخدامها لاحقاً
             decision_snapshot = {
                 'components': signal_data.get('components', {}),
                 'oracle_conf': signal_data.get('confidence', 0),
-                'governance_grade': gov_decision['grade'], # تسجيل الجودة
+                'governance_grade': gov_decision['grade'],
                 'governance_score': gov_decision['governance_score'],
-                'governance_details': gov_decision['components'], # تفاصيل الـ 156 مؤشر (مختصرة في المجالات)
+                'governance_details': gov_decision['components'],
                 'system_confidence': system_conf,
                 'market_mood': market_mood,
-                'regime_at_entry': getattr(SystemLimits, 'CURRENT_REGIME', 'UNKNOWN')
+                'regime_at_entry': getattr(SystemLimits, 'CURRENT_REGIME', 'UNKNOWN'),
+                # 🔥 Persist Critical Metadata for Guardians
+                'dynamic_limits': signal_data.get('dynamic_limits', {}),
+                'asset_regime': signal_data.get('asset_regime', 'UNKNOWN')
             }
 
             new_trade = {
@@ -353,12 +357,27 @@ class TradeManager:
             if '1h' not in ohlcv_data: return
             
             curr_p = await self.data_manager.get_latest_price_async(symbol)
-            l2 = await self.processor.process_compound_signal({'symbol': symbol, 'ohlcv': ohlcv_data, 'current_price': curr_p})
+            
+            # ✅ FIX: استرجاع السياق والحدود من بيانات الصفقة المحفوظة
+            decision_data = trade.get('decision_data', {})
+            saved_limits = decision_data.get('dynamic_limits', {})
+            saved_regime = decision_data.get('asset_regime', 'UNKNOWN')
+
+            # إعادة بناء raw_input مع السياق
+            raw_input = {
+                'symbol': symbol, 
+                'ohlcv': ohlcv_data, 
+                'current_price': curr_p,
+                'dynamic_limits': saved_limits,  # Inject Context
+                'asset_regime': saved_regime     # Inject Context
+            }
+
+            l2 = await self.processor.process_compound_signal(raw_input)
             if not l2: return
             
             oracle = await self.processor.consult_oracle(l2)
             if oracle.get('action') == 'WAIT' or oracle.get('direction') == 'SHORT':
-                print(f"🚨 [Oracle] Outlook Bearish. Exiting {symbol}...")
+                print(f"🚨 [Oracle] Outlook Bearish (Re-Check). Exiting {symbol}...")
                 await self.force_exit_by_manager(symbol, reason="Oracle_Bearish_Flip")
                 return
         except Exception: pass