Update ml_engine/hybrid_guardian.py

ml_engine/hybrid_guardian.py

@@ -1,5 +1,5 @@
 # ml_engine/hybrid_guardian.py
-# (V35.2 - GEM-Architect: Time-Weighted Wall Logic)
+# (V35.4 - GEM-Architect: Configurable Thresholds)
 
 import os
 import json
@@ -12,9 +12,8 @@ import traceback
 class HybridDeepSteward:
     def __init__(self, v2_model_path, v3_model_path, v3_features_map_path):
         """
-        The Hybrid Guardian (Time-Aware Veto)
-        - V2/V3: Muzzled logic.
-        - Veto: Checks if Order Book has enough depth to absorb 30m of Volume.
+        The Hybrid Guardian (Configurable & Time-Aware)
+        - Thresholds are now controlled by Processor/SystemLimits.
         """
         self.v2_path = v2_model_path
         self.v3_path = v3_model_path
@@ -29,8 +28,7 @@ class HybridDeepSteward:
         self.FEATS_5M = ['log_ret_5m', 'rsi_5m', 'fib_pos_5m', 'trend_slope_5m']
         self.FEATS_15M = ['log_ret_15m', 'rsi_15m', 'dist_fib618_15m', 'trend_slope_15m']
         
-        # Thresholds
-        self.V2_SAFE_LIMIT = 0.40     
+        # Default Thresholds (Will be overwritten by configure_thresholds)
         self.V2_PANIC_TRIGGER = 0.95  
         self.V3_SOFT_EXIT = 0.85      
         self.V3_HARD_EXIT = 0.95      
@@ -48,6 +46,14 @@ class HybridDeepSteward:
             return True
         except: return False
 
+    # ✅ GEM-Architect: External Control Method
+    def configure_thresholds(self, v2_panic, v3_hard, v3_soft, v3_ultra):
+        self.V2_PANIC_TRIGGER = float(v2_panic)
+        self.V3_HARD_EXIT = float(v3_hard)
+        self.V3_SOFT_EXIT = float(v3_soft)
+        self.V3_ULTRA_CONF = float(v3_ultra)
+        print(f"   🕸️ [Legacy Guard] Thresholds Updated: V2_PANIC={v2_panic}, V3_HARD={v3_hard}")
+
     def _prepare_df(self, ohlcv_data):
         if not ohlcv_data: return pd.DataFrame()
         try:
@@ -121,39 +127,18 @@ class HybridDeepSteward:
     # 🔍 GEM-Architect: The Time-Weighted Logic (30-Minute Check)
     # ==========================================================================
     def _validate_with_time_weighted_ob(self, order_book, signal_type, volume_30m_usd):
-        """
-        Validates if the Order Book 'Wall' is significant relative to the last 30 minutes of volume.
-        
-        Logic:
-        - If 'EXIT_HARD' (Panic Sell) is triggered:
-          We check if (Buy Wall Size) > (Signficant % of 30m Volume).
-          If True, it means there is massive absorption capability -> BLOCK the Exit.
-        """
         if not order_book: return True 
-        if volume_30m_usd <= 0: return True # Cannot calculate ratio, fail-open
+        if volume_30m_usd <= 0: return True 
 
         try:
             bids = order_book.get('bids', [])
-            asks = order_book.get('asks', [])
-            
             if not bids: return True
 
-            # 1. Calculate 'Buy Wall' (Liquidity close to price)
-            # We sum the top 15 levels of bids (approx immediate support)
             bid_wall_usd = sum([float(x[0]) * float(x[1]) for x in bids[:15]])
-            
-            # 2. Compare Wall vs 30m Flow
-            # If the immediate Buy Wall is larger than 10% of the ENTIRE 30m volume, 
-            # that is a HUGE static wall. It implies stability for the near future.
             absorption_ratio = bid_wall_usd / volume_30m_usd
             
-            # 3. Decision Logic
             if signal_type == 'EXIT_HARD':
-                # If Buy Wall is strong (> 5% of 30m volume sitting in top 15 ticks), 
-                # we consider this a "Safe Floor".
                 if absorption_ratio > 0.05: 
-                    # يوجد جدار شراء يمثل 5% من حجم تداول نصف ساعة كاملة في أول مستويات فقط!
-                    # هذا دعم قوي جداً زمنياً.
                     return False # VETO THE EXIT
             
             return True
@@ -185,8 +170,6 @@ class HybridDeepSteward:
             v2 = scores['v2']
             v3 = scores['v3']
             
-            # 🛑 VETO CHECK
-            # If veto returns FALSE, we BLOCK the exit.
             allow_exit = self._validate_with_time_weighted_ob(order_book, 'EXIT_HARD', volume_30m_usd)
 
             # --- V2 CHECK ---