Update ml_engine/processor.py

ml_engine/processor.py

@@ -1,5 +1,6 @@
-# ml_engine/processor.py
-# (V35.3 - GEM-Architect: Hydra Heads Fixed)
+# ============================================================
+# 🧠 ml_engine/processor.py (V35.4 - GEM-Architect: Centralized Limits)
+# ============================================================
 
 import asyncio
 import traceback
@@ -9,6 +10,7 @@ import sys
 import numpy as np
 from typing import Dict, Any, List, Optional
 
+# --- استيراد المحركات (كما هي) ---
 try: from .titan_engine import TitanEngine
 except ImportError: TitanEngine = None
 try: from .patterns import ChartPatternAnalyzer
@@ -24,6 +26,9 @@ except ImportError: HybridDeepSteward = None
 try: from .guardian_hydra import GuardianHydra
 except ImportError: GuardianHydra = None
 
+# ============================================================
+# 📂 مسارات النماذج
+# ============================================================
 BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
 MODELS_L2_DIR = os.path.join(BASE_DIR, "ml_models", "layer2")
 MODELS_PATTERN_DIR = os.path.join(BASE_DIR, "ml_models", "xgboost_pattern2")
@@ -34,29 +39,52 @@ MODEL_V2_PATH = os.path.join(BASE_DIR, "ml_models", "DeepSteward_V2_Production.j
 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")
 
+# ============================================================
+# 🎛️ SYSTEM LIMITS & THRESHOLDS (UPDATED)
+# ============================================================
 class SystemLimits:
+    """GEM-Architect: The Central Constitution (Updated)."""
+    
+    # --- Layer 1 (Data Manager Control) ---
     L1_MIN_AFFINITY_SCORE = 10
+    
+    # --- Layer 2 Weights ---
     L2_WEIGHT_TITAN    = 0.50
     L2_WEIGHT_PATTERNS = 0.40
     L2_WEIGHT_MC       = 0.10
+
     PATTERN_TF_WEIGHTS = {'15m': 0.40, '1h': 0.30, '5m': 0.20, '4h': 0.10, '1d': 0.00}
     PATTERN_THRESH_BULLISH = 0.60
     PATTERN_THRESH_BEARISH = 0.40
+
+    # --- Layer 3 ---
     L3_CONFIDENCE_THRESHOLD = 0.65
     L3_WHALE_IMPACT_MAX = 0.10
     L3_NEWS_IMPACT_MAX  = 0.05
     L3_MC_ADVANCED_MAX  = 0.10
+
+    # --- Layer 4 ---
     L4_ENTRY_THRESHOLD  = 0.30
     L4_WEIGHT_ML        = 0.60
     L4_WEIGHT_OB        = 0.40
     L4_OB_WALL_RATIO    = 0.40
+
+    # --- Layer 0: Hydra Thresholds ---
     HYDRA_CRASH_THRESH      = 0.60
     HYDRA_GIVEBACK_THRESH   = 0.70
     HYDRA_STAGNATION_THRESH = 0.50
 
+    # --- ✅ NEW: Legacy Guardian Config (Moved Here) ---
+    # Processor is now the MASTER of these thresholds.
+    LEGACY_V2_PANIC_THRESH = 0.95
+    LEGACY_V3_HARD_THRESH  = 0.95
+    LEGACY_V3_SOFT_THRESH  = 0.85
+    LEGACY_V3_ULTRA_THRESH = 0.98
+
     @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)}
+
     @classmethod
     def update_from_dict(cls, config: Dict[str, Any]):
         if not config: return
@@ -64,10 +92,14 @@ class SystemLimits:
             if hasattr(cls, k): setattr(cls, k, v)
         print("🔄 [SystemLimits] Config Updated.")
 
+# ============================================================
+# 🧠 MLProcessor Class
+# ============================================================
 class MLProcessor:
     def __init__(self, data_manager=None):
         self.data_manager = data_manager
         self.initialized = False
+        
         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
@@ -85,10 +117,12 @@ class MLProcessor:
                 v3_model_path=MODEL_V3_PATH,
                 v3_features_map_path=MODEL_V3_FEAT
             )
-        print(f"🧠 [MLProcessor V35.3] Hydra Heads Corrected.")
+
+        print(f"🧠 [MLProcessor V35.4] Centralized Control Active.")
 
     async def initialize(self):
         if self.initialized: return
+        print("⚙️ [Processor] Initializing Neural Grid...")
         try:
             tasks = []
             if self.titan: tasks.append(self.titan.initialize())
@@ -107,15 +141,30 @@ class MLProcessor:
                         w_ob=SystemLimits.L4_WEIGHT_OB
                     )
                 tasks.append(self.sniper.initialize())
+            
             if tasks: await asyncio.gather(*tasks)
 
             if self.guardian_hydra: 
                 self.guardian_hydra.initialize()
+                print("   🛡️ [Guard 1] Hydra X-Ray: Active")
+            
             if self.guardian_legacy:
-                if asyncio.iscoroutinefunction(self.guardian_legacy.initialize): await self.guardian_legacy.initialize()
-                else: self.guardian_legacy.initialize()
+                if asyncio.iscoroutinefunction(self.guardian_legacy.initialize):
+                    await self.guardian_legacy.initialize()
+                else:
+                    self.guardian_legacy.initialize()
+                
+                # ✅ GEM-Architect: Inject Thresholds from SystemLimits
+                self.guardian_legacy.configure_thresholds(
+                    v2_panic=SystemLimits.LEGACY_V2_PANIC_THRESH,
+                    v3_hard=SystemLimits.LEGACY_V3_HARD_THRESH,
+                    v3_soft=SystemLimits.LEGACY_V3_SOFT_THRESH,
+                    v3_ultra=SystemLimits.LEGACY_V3_ULTRA_THRESH
+                )
+                print(f"   🛡️ [Guard 2] Legacy Steward: Active (Limits Injected)")
 
             self.initialized = True
+            print("✅ [Processor] All Systems Operational.")
             
         except Exception as e:
             print(f"❌ [Processor FATAL] Init failed: {e}")
@@ -189,12 +238,9 @@ class MLProcessor:
         # 3. Final Arbitration & Display
         h_probs = hydra_result.get('probs', {}); l_scores = legacy_result.get('scores', {})
         h_c = h_probs.get('crash', 0.0); h_g = h_probs.get('giveback', 0.0)
-        # ✅ FIX: Extract Stagnation Score and Add to Log
         h_s = h_probs.get('stagnation', 0.0) 
         
         l_v2 = l_scores.get('v2', 0.0); l_v3 = l_scores.get('v3', 0.0)
-        
-        # ✅ FIX: Added |S:..%| to the string
         stamp_str = f"🐲[C:{h_c:.0%}|G:{h_g:.0%}|S:{h_s:.0%}] 🕸️[V2:{l_v2:.0%}|V3:{l_v3:.0%}]"
 
         final_action = 'HOLD'; final_reason = f"Safe. {stamp_str}"