Update trade_manager.py

trade_manager.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🛡️ trade_manager.py (V37.2 - GEM-Architect: Context Persistence)
+# 🛡️ trade_manager.py (V38.0 - GEM-Architect: Diagnostics Logic)
 # ============================================================
 
 import asyncio
@@ -36,7 +36,7 @@ class TradeManager:
         self.FEE_RATE = 0.001 
         self.ORACLE_CHECK_INTERVAL = 900
         
-        # إحصائيات الذكاء الاصطناعي (للعرض في الواجهة)
+        # إحصائيات الذكاء الاصطناعي (سيتم تحميلها من R2)
         self.ai_stats = {
             "hybrid": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
             "crash":  {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
@@ -45,13 +45,20 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V37.2] Full System Online (Context Aware).")
+        print(f"🛡️ [TradeManager V38.0] Full System Online (Diagnostics Ready).")
 
     async def initialize_sentry_exchanges(self):
         """تهيئة المحفظة واستعادة الحالة"""
         print("🛡️ [TradeManager] Syncing state & Initializing Portfolio...")
         await self.smart_portfolio.initialize()
         await self.sync_internal_state_with_r2()
+        
+        # ✅ تحميل إحصائيات الحراس من R2
+        try:
+            saved_stats = await self.r2.get_guardian_stats_async()
+            if saved_stats: self.ai_stats = saved_stats
+            print("   -> [Stats] Guardian metrics loaded from R2.")
+        except Exception: pass
 
     async def sync_internal_state_with_r2(self):
         """استرجاع الصفقات المفتوحة من R2"""
@@ -112,7 +119,7 @@ class TradeManager:
                 print(f"   -> ⚠️ [Skip] {symbol}: Insufficient 1m data.")
                 continue
             
-            # ✅ FIX: تمرير سياق الإشارة بالكامل لكي يرى Sniper الحدود الديناميكية
+            # ✅ تمرير سياق الإشارة بالكامل لكي يرى Sniper الحدود الديناميكية
             sniper_result = await self.processor.check_sniper_entry(ohlcv_1m, order_book, context_data=signal)
             
             sniper_signal = sniper_result.get('signal', 'WAIT')
@@ -144,6 +151,103 @@ class TradeManager:
             print(f"🚀 [EXECUTING] Attempting entry for best candidate: {best_signal['symbol']}")
             await self._execute_entry_from_signal(best_signal['symbol'], best_signal)
 
+    # ==============================================================================
+    # 🕵️ محرك التشخيص (Diagnostic Engine) - تحديد من صوّت للشراء
+    # ==============================================================================
+    def _snapshot_model_votes(self, signal_data: Dict[str, Any]) -> Dict[str, bool]:
+        """
+        تحدد أي النماذج صوّتت بـ 'شراء' بناءً على القيم وقت الدخول.
+        تستخدم الحدود الديناميكية إن وجدت، أو القيم الافتراضية للنظام.
+        """
+        votes = {}
+        limits = signal_data.get('dynamic_limits', {})
+        comps = signal_data.get('components', {}) or {} # مكونات L2 (Titan, Pattern, MC-L)
+
+        # 1. نموذج تيتان (Titan)
+        # إذا تجاوزت النتيجة 0.5 (الحياد) يعتبر موافقاً
+        votes['Titan'] = comps.get('titan_score', signal_data.get('titan_score', 0)) > 0.5
+
+        # 2. نماذج الأنماط (Patterns)
+        votes['Patterns'] = comps.get('patterns_score', signal_data.get('patterns_score', 0)) > 0.5
+
+        # 3. نموذج أوراكل (Oracle)
+        # مقارنة الثقة مع الحد الأدنى المطلوب
+        oracle_thresh = limits.get('l3_oracle_thresh', SystemLimits.L3_CONFIDENCE_THRESHOLD)
+        votes['Oracle'] = signal_data.get('confidence', 0) >= oracle_thresh
+
+        # 4. نموذج القناص (Sniper)
+        sniper_thresh = limits.get('l4_sniper_thresh', SystemLimits.L4_ENTRY_THRESHOLD)
+        votes['Sniper'] = signal_data.get('sniper_score', 0) >= sniper_thresh
+
+        # 5. مونت كارلو L (Light)
+        votes['MonteCarlo_L'] = comps.get('mc_score', 0.5) > 0.5
+
+        # 6. مونت كارلو A (Advanced)
+        # عادة النطاق من -0.10 إلى +0.10. أي قيمة موجبة تعني ميلاً إيجابياً.
+        votes['MonteCarlo_A'] = signal_data.get('mc_advanced_score', 0) > 0
+
+        # 7. طبقة الحوكمة (Governance)
+        # أي شيء غير REJECT يعتبر قبولاً
+        votes['Governance'] = signal_data.get('governance_grade', 'REJECT') != 'REJECT'
+
+        return votes
+
+    async def _run_diagnostic_verification(self, symbol: str, entry_price: float, position_size_usd: float, votes: Dict[str, bool]):
+        """
+        مهمة خلفية للت��قق من أداء النماذج بالتوقيتات المحددة.
+        - القناص: بعد دقيقة واحدة.
+        - البقية: بعد ساعة واحدة.
+        """
+        try:
+            print(f"🕵️ [Diagnostics] Audit started for {symbol}...")
+            
+            # --- المؤقت 1: فحص القناص (دقيقة واحدة) ---
+            await asyncio.sleep(60) 
+            current_price_1m = await self.data_manager.get_latest_price_async(symbol)
+            
+            if current_price_1m > 0 and votes.get('Sniper'):
+                pnl_pct = (current_price_1m - entry_price) / entry_price
+                pnl_usd = pnl_pct * position_size_usd
+                
+                # تحديث إحصائيات القناص في R2
+                update = {
+                    "Sniper": {
+                        "wins": 1 if pnl_pct > 0 else 0,
+                        "losses": 1 if pnl_pct <= 0 else 0,
+                        "pnl": pnl_usd
+                    }
+                }
+                await self.r2.update_diagnostic_stats_async(update)
+                print(f"   🕵️ [Diagnostics] Sniper Result (1m): ${pnl_usd:.2f} ({'WIN' if pnl_pct>0 else 'LOSS'})")
+
+            # --- المؤقت 2: الفحص العام (ساعة واحدة) ---
+            # انتظار 59 دقيقة متبقية (المجموع 60 دقيقة = 3600 ثانية)
+            await asyncio.sleep(3540) 
+            current_price_1h = await self.data_manager.get_latest_price_async(symbol)
+
+            if current_price_1h > 0:
+                pnl_pct = (current_price_1h - entry_price) / entry_price
+                pnl_usd = pnl_pct * position_size_usd
+                
+                updates = {}
+                # النماذج التي يتم فحصها بعد ساعة
+                long_term_models = ["Titan", "Patterns", "Oracle", "MonteCarlo_L", "MonteCarlo_A", "Governance"]
+                
+                for model in long_term_models:
+                    if votes.get(model): # إذا وافق النموذج على الدخول
+                        updates[model] = {
+                            "wins": 1 if pnl_pct > 0 else 0,
+                            "losses": 1 if pnl_pct <= 0 else 0,
+                            "pnl": pnl_usd
+                        }
+                
+                if updates:
+                    await self.r2.update_diagnostic_stats_async(updates)
+                    print(f"   🕵️ [Diagnostics] 1H Audit Complete for {symbol}. PnL: ${pnl_usd:.2f}")
+
+        except Exception as e:
+            print(f"❌ [Diagnostics Error] {e}")
+
     async def _execute_entry_from_signal(self, symbol, signal_data):
         """تنفيذ الدخول الفعلي مع فحص الحوكمة وإدارة المحفظة"""
         try:
@@ -241,6 +345,15 @@ class TradeManager:
             if symbol in self.sentry_tasks: self.sentry_tasks[symbol].cancel()
             self.sentry_tasks[symbol] = asyncio.create_task(self._guardian_loop(symbol))
             
+            # 🔥 إطلاق مهمة التدقيق (Diagnostic Matrix)
+            model_votes = self._snapshot_model_votes(signal_data)
+            asyncio.create_task(self._run_diagnostic_verification(
+                symbol, 
+                current_price, 
+                approved_size_usd, 
+                model_votes
+            ))
+            
             print(f"✅ [ENTRY] {symbol} @ {current_price} | Grade: {gov_decision['grade']} | Size: ${approved_size_usd:.2f} | TP: {approved_tp} ({target_label}) | Mood: {market_mood}")
 
         except Exception as e:
@@ -407,6 +520,10 @@ class TradeManager:
             
             record = {"symbol": symbol, "exit_price": exit_price, "price_15m": curr, "usd_impact": usd_impact, "verdict": "SUCCESS" if is_good_exit else "MISS"}
             await self.r2.append_deep_steward_audit(record)
+            
+            # 🔥 حفظ إحصائيات الحراس في R2 بعد التحديث
+            await self.r2.save_guardian_stats_async(self.ai_stats)
+            
         except Exception: pass
 
     async def _execute_exit(self, symbol, price, reason, ai_scores=None):