Update ml_engine/processor.py

ml_engine/processor.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🧠 ml_engine/processor.py (V34.0 - Dual-Core Guardian Edition)
+# 🧠 ml_engine/processor.py (V34.1 - GEM-Architect: Transparent Stamps)
 # ============================================================
 
 import asyncio
@@ -31,15 +31,15 @@ try:
     from .sniper_engine import SniperEngine
 except ImportError: SniperEngine = None
 
-# ✅ استيراد الحارسين (القديم والحديث)
+# ✅ استيراد الحارسين
 try:
-    from .hybrid_guardian import HybridDeepSteward  # الحارس الهجين (القديم)
+    from .hybrid_guardian import HybridDeepSteward
 except ImportError:
     print("⚠️ [Processor] HybridDeepSteward not found.")
     HybridDeepSteward = None
 
 try:
-    from .guardian_hydra import GuardianHydra       # الحارس الهيدرا (الحديث)
+    from .guardian_hydra import GuardianHydra
 except ImportError:
     print("⚠️ [Processor] GuardianHydra not found.")
     GuardianHydra = None
@@ -54,12 +54,10 @@ MODELS_PATTERN_DIR = os.path.join(BASE_DIR, "ml_models", "xgboost_pattern2")
 MODELS_UNIFIED_DIR = os.path.join(BASE_DIR, "ml_models", "Unified_Models_V1")
 MODELS_SNIPER_DIR = os.path.join(BASE_DIR, "ml_models", "guard_v2") 
 
-# مسارات الحارسين
-MODELS_HYDRA_DIR = os.path.join(BASE_DIR, "ml_models", "guard_v1") # مسار الهيدرا
-# مسارات الحارس الهجين (القديم - يفترض وجودها)
-MODEL_V2_PATH = os.path.join(BASE_DIR, "ml_models", "DeepSteward_V2_Production.json")
-MODEL_V3_PATH = os.path.join(BASE_DIR, "ml_models", "DeepSteward_V3_Production.json")
-MODEL_V3_FEAT = os.path.join(BASE_DIR, "ml_models", "DeepSteward_V3_Features.json")
+MODELS_HYDRA_DIR = os.path.join(BASE_DIR, "ml_models", "guard_v1")
+MODEL_V2_PATH = os.path.join(BASE_DIR, "ml_models", "legacy", "v2_regime.json")
+MODEL_V3_PATH = os.path.join(BASE_DIR, "ml_models", "legacy", "v3_sniper.json")
+MODEL_V3_FEAT = os.path.join(BASE_DIR, "ml_models", "legacy", "v3_features.json")
 
 # ============================================================
 # 🎛️ SYSTEM LIMITS & THRESHOLDS
@@ -100,10 +98,6 @@ class SystemLimits:
     HYDRA_GIVEBACK_THRESH   = 0.70
     HYDRA_STAGNATION_THRESH = 0.50
 
-    # --- Layer 0: Hybrid Thresholds (Legacy) - يمكن إضافتها هنا للتحكم المركزي ---
-    LEGACY_PANIC_THRESH     = 0.90
-    LEGACY_SAFE_LIMIT       = 0.50
-
     @classmethod
     def to_dict(cls) -> Dict[str, Any]:
         return {k: v for k, v in cls.__dict__.items() if not k.startswith('__') and not callable(v)}
@@ -123,30 +117,25 @@ class MLProcessor:
         self.data_manager = data_manager
         self.initialized = False
         
-        # Engines Init (Standard)
         self.titan = TitanEngine(model_dir=MODELS_L2_DIR) if TitanEngine else None
         self.pattern_engine = ChartPatternAnalyzer(models_dir=MODELS_PATTERN_DIR) if ChartPatternAnalyzer else None
         self.mc_analyzer = MonteCarloEngine() if MonteCarloEngine else None
         self.oracle = OracleEngine(model_dir=MODELS_UNIFIED_DIR) if OracleEngine else None
         self.sniper = SniperEngine(models_dir=MODELS_SNIPER_DIR) if SniperEngine else None
         
-        # ✅ Dual Guardian Initialization
-        # 1. The Modern Hydra (X-Ray)
         self.guardian_hydra = None
         if GuardianHydra:
             self.guardian_hydra = GuardianHydra(model_dir=MODELS_HYDRA_DIR)
 
-        # 2. The Legacy Steward (Hybrid)
         self.guardian_legacy = None
         if HybridDeepSteward:
-            # نفترض وجود المجلد legacy داخل ml_models
             self.guardian_legacy = HybridDeepSteward(
                 v2_model_path=MODEL_V2_PATH,
                 v3_model_path=MODEL_V3_PATH,
                 v3_features_map_path=MODEL_V3_FEAT
             )
 
-        print(f"🧠 [MLProcessor V34.0] Dual-Core Guardians Setup. SystemLimits Active.")
+        print(f"🧠 [MLProcessor V34.1] Dual-Core Guardians + Detail Stamps Online.")
 
     async def initialize(self):
         if self.initialized: return
@@ -166,13 +155,11 @@ class MLProcessor:
             
             if tasks: await asyncio.gather(*tasks)
 
-            # ✅ Initialize Dual Guardians
             if self.guardian_hydra: 
                 self.guardian_hydra.initialize()
                 print("   🛡️ [Guard 1] Hydra X-Ray: Active")
             
             if self.guardian_legacy:
-                # Legacy guardian init is usually synchronous in provided code, but checking just in case
                 if asyncio.iscoroutinefunction(self.guardian_legacy.initialize):
                     await self.guardian_legacy.initialize()
                 else:
@@ -186,11 +173,7 @@ class MLProcessor:
             print(f"❌ [Processor FATAL] Init failed: {e}")
             traceback.print_exc()
 
-    # ... (process_compound_signal, consult_oracle, check_sniper_entry remain UNCHANGED) ...
-    # قم بنسخ الدوال process_compound_signal و consult_oracle و check_sniper_entry كما هي من الكود السابق
-    
     async def process_compound_signal(self, raw_data: Dict[str, Any]) -> Optional[Dict[str, Any]]:
-        # (نفس الكود السابق تماماً للاختصار، لا تغيير هنا)
         if not self.initialized: await self.initialize()
         symbol = raw_data.get('symbol')
         ohlcv_data = raw_data.get('ohlcv')
@@ -232,98 +215,92 @@ class MLProcessor:
         return {'signal': 'WAIT', 'reason': 'Sniper Engine Missing'}
 
     # ==========================================================================
-    # 🛡️ 4. الحارس المزدوج (Dual-Core Guardian Consultation) - NEW Logic
+    # 🛡️ 4. الحارس المزدوج مع الطوابع الدقيقة (Detailed Stamps)
     # ==========================================================================
     def consult_dual_guardians(self, symbol, ohlcv_1m, ohlcv_5m, ohlcv_15m, trade_context):
         """
-        استشارة كلا الحارسين (Hydra + Legacy) وتطبيق منطق OR للخروج.
+        استشارة الحارسين وإنشاء تقرير مفصل بالأرقام.
         """
         response = {
             'action': 'HOLD',
-            'reason': 'Dual Monitor Active',
-            'sources': {}
+            'detailed_log': '',
+            'probs': {}
         }
 
-        # ------------------------------------------
-        # 1. استشارة الحارس الحديث (Hydra X-Ray)
-        # ------------------------------------------
-        hydra_result = {'action': 'HOLD', 'reason': 'Disabled'}
+        # 1. Hydra X-Ray Scores
+        hydra_result = {'action': 'HOLD', 'reason': 'Disabled', 'probs': {}}
         if self.guardian_hydra and self.guardian_hydra.initialized:
             hydra_result = self.guardian_hydra.analyze_position(symbol, ohlcv_1m, ohlcv_5m, ohlcv_15m, trade_context)
             
-            # تطبيق سياسات SystemLimits على الهيدرا
-            probs = hydra_result.get('probs', {})
-            p_crash = probs.get('crash', 0.0)
-            p_giveback = probs.get('giveback', 0.0)
-            
             # Policy Overlay
+            h_probs = hydra_result.get('probs', {})
+            p_crash = h_probs.get('crash', 0.0)
+            p_giveback = h_probs.get('giveback', 0.0)
+            
             if hydra_result['action'] == 'HOLD':
                 if p_crash >= SystemLimits.HYDRA_CRASH_THRESH:
                     hydra_result['action'] = 'EXIT_HARD'
-                    hydra_result['reason'] = f"Hydra Policy: Crash Risk {p_crash:.2f}"
+                    hydra_result['reason'] = f"Hydra Crash Risk {p_crash:.2f}"
                 elif p_giveback >= SystemLimits.HYDRA_GIVEBACK_THRESH:
                     hydra_result['action'] = 'EXIT_SOFT'
-                    hydra_result['reason'] = f"Hydra Policy: Giveback Risk {p_giveback:.2f}"
+                    hydra_result['reason'] = f"Hydra Giveback Risk {p_giveback:.2f}"
         
-        # ------------------------------------------
-        # 2. استشارة الحارس القديم (Legacy Hybrid)
-        # ------------------------------------------
-        legacy_result = {'action': 'HOLD', 'reason': 'Disabled'}
+        # 2. Legacy Hybrid Scores
+        legacy_result = {'action': 'HOLD', 'reason': 'Disabled', 'scores': {}}
         if self.guardian_legacy and self.guardian_legacy.initialized:
-            # الحارس القديم يحتاج entry_price كرقم منفصل
             entry_price = float(trade_context.get('entry_price', 0.0))
             legacy_result = self.guardian_legacy.analyze_position(ohlcv_1m, ohlcv_5m, ohlcv_15m, entry_price)
 
-        # ------------------------------------------
-        # 3. منطق الدمج (Conflict Resolution)
-        # ------------------------------------------
-        response['sources']['hydra'] = hydra_result
-        response['sources']['legacy'] = legacy_result
-
-        # الأولوية للسلامة (Safety First - OR Logic)
+        # 3. تجميع الطوابع (Stamps Collection)
+        # Hydra Stamps
+        h_probs = hydra_result.get('probs', {})
+        h_c = h_probs.get('crash', 0.0)
+        h_g = h_probs.get('giveback', 0.0)
+        h_s = h_probs.get('stagnation', 0.0)
         
-        # أ) فحص الخروج القوي (HARD EXIT)
+        # Legacy Stamps
+        l_scores = legacy_result.get('scores', {})
+        l_v2 = l_scores.get('v2', 0.0) # Regime
+        l_v3 = l_scores.get('v3', 0.0) # Sniper
+        
+        # ✅ صياغة التقرير المفصل (The Detailed Stamp)
+        # مثال: 🐲[C:12%|G:05%|S:00%] 🕸️[V2:45%|V3:10%]
+        stamp_str = (
+            f"🐲[C:{h_c:.0%}|G:{h_g:.0%}|S:{h_s:.0%}] "
+            f"🕸️[V2:{l_v2:.0%}|V3:{l_v3:.0%}]"
+        )
+
+        # 4. Decision Logic (OR Gate)
+        final_action = 'HOLD'
+        final_reason = f"Safe. {stamp_str}"
+
+        # أ) فحص الخروج القوي
         if hydra_result['action'] == 'EXIT_HARD':
-            return {
-                'action': 'EXIT_HARD',
-                'reason': f"[Hydra Triggered] {hydra_result['reason']}",
-                'probs': hydra_result.get('probs', {})
-            }
+            final_action = 'EXIT_HARD'
+            final_reason = f"🚨 HYDRA KILL: {hydra_result['reason']} | {stamp_str}"
+        elif legacy_result['action'] == 'EXIT_HARD':
+            final_action = 'EXIT_HARD'
+            final_reason = f"🚨 LEGACY KILL: {legacy_result['reason']} | {stamp_str}"
         
-        if legacy_result['action'] == 'EXIT_HARD':
-            return {
-                'action': 'EXIT_HARD',
-                'reason': f"[Legacy Triggered] {legacy_result['reason']}",
-                'scores': legacy_result.get('scores', {})
-            }
-
-        # ب) فحص الخروج الناعم (SOFT EXIT)
-        if hydra_result['action'] == 'EXIT_SOFT':
-            return {
-                'action': 'EXIT_SOFT',
-                'reason': f"[Hydra Warning] {hydra_result['reason']}",
-                'probs': hydra_result.get('probs', {})
-            }
-            
-        if legacy_result['action'] == 'EXIT_SOFT':
-            return {
-                'action': 'EXIT_SOFT',
-                'reason': f"[Legacy Warning] {legacy_result['reason']}",
-                'scores': legacy_result.get('scores', {})
-            }
-
-        # ج) إدارة وقف الخسارة المتحرك (من الهيدرا فقط حالياً)
-        if hydra_result['action'] in ['TIGHTEN_SL', 'TRAIL_SL']:
-             return {
-                 'action': hydra_result['action'],
-                 'reason': hydra_result['reason']
-             }
-
-        # د) البقاء
+        # ب) فحص الخروج الناعم
+        elif hydra_result['action'] == 'EXIT_SOFT':
+            final_action = 'EXIT_SOFT'
+            final_reason = f"⚠️ HYDRA WARN: {hydra_result['reason']} | {stamp_str}"
+        elif legacy_result['action'] == 'EXIT_SOFT':
+            final_action = 'EXIT_SOFT'
+            final_reason = f"⚠️ LEGACY WARN: {legacy_result['reason']} | {stamp_str}"
+
+        # ج) SL Management
+        elif hydra_result['action'] in ['TIGHTEN_SL', 'TRAIL_SL']:
+             final_action = hydra_result['action']
+             final_reason = f"🛡️ {hydra_result['action']} | {stamp_str}"
+
         return {
-            'action': 'HOLD',
-            'reason': f"Hydra({hydra_result['action']}) & Legacy({legacy_result['action']}) Agree: Safe.",
-            'detailed_log': f"H:{hydra_result.get('reason')} | L:{legacy_result.get('reason')}"
+            'action': final_action,
+            'reason': final_reason,
+            'detailed_log': f"{final_action} | {stamp_str}", # هذا ما سيظهر في الواجهة
+            'probs': h_probs,
+            'scores': l_scores
         }
 
     async def run_advanced_monte_carlo(self, symbol, timeframe='1h'):
@@ -337,4 +314,4 @@ class MLProcessor:
             except Exception: pass
         return 0.0
 
-print("✅ [MLProcessor V34.0] Dual-Core Guardians Integrated.")
+print("✅ [MLProcessor V34.1] Detailed Stamps Logic Integrated.")