Update ml_engine/hybrid_guardian.py

ml_engine/hybrid_guardian.py

@@ -1,5 +1,5 @@
 # ml_engine/hybrid_guardian.py
-# (V23.0 - GEM-Architect: Institutional Fuzzy Logic + Ultra-Confidence Override)
+# (V23.1 - GEM-Architect: Debug Edition)
 
 import os
 import json
@@ -14,7 +14,7 @@ class HybridDeepSteward:
     def __init__(self, v2_model_path, v3_model_path, v3_features_map_path):
         """
         The Hybrid Guardian: Combines V2 (Regime Detection) and V3 (Precision Exit).
-        Uses "Fuzzy Logic" zones instead of hard cutoffs.
+        Now includes DEBUG logging to find why models return 0.
         """
         self.v2_path = v2_model_path
         self.v3_path = v3_model_path
@@ -25,19 +25,15 @@ class HybridDeepSteward:
         self.v3_feature_names = []
         self.initialized = False
         
-        # ⚙️ إعدادات المناطق المنطقية (Institutional Logic Zones)
-        
-        # 1. حدود V2 (الرادار - يحدد السياق)
-        self.V2_SAFE_LIMIT = 0.50     # تحت هذا الرقم: أمان قوي
-        self.V2_GREY_LIMIT = 0.60     # بين 0.50 و 0.60: منطقة رمادية (قلق بسيط)
-        self.V2_PANIC_TRIGGER = 0.90  # فوق هذا الرقم: انهيار مؤكد (Panic)
+        # ⚙️ إعدادات المناطق المنطقية
+        self.V2_SAFE_LIMIT = 0.50     
+        self.V2_GREY_LIMIT = 0.60     
+        self.V2_PANIC_TRIGGER = 0.90  
 
-        # 2. حدود V3 (القناص - يحدد التنفيذ)
-        self.V3_SOFT_EXIT = 0.75      # خروج جزئي/تحذير
-        self.V3_HARD_EXIT = 0.90      # خروج كامل قياسي
-        self.V3_ULTRA_CONF = 0.97     # "كسر الفيتو": خروج حتى لو V2 آمن
+        self.V3_SOFT_EXIT = 0.75      
+        self.V3_HARD_EXIT = 0.90      
+        self.V3_ULTRA_CONF = 0.97     
         
-        # ميزات V2 (ثابتة)
         self.V2_FEATURES = [
             'log_ret', 'rel_vol', 'rsi_norm', 'macd_hist', 'roc', 
             'bb_width', 'bb_pct', 'atr_pct', 'dist_ema50', 'dist_ema200',
@@ -45,10 +41,22 @@ class HybridDeepSteward:
         ]
 
     def initialize(self):
-        """تحميل النماذج"""
+        """تحميل النماذج مع فحص الأخطاء"""
+        print(f"🛠️ [Guardian Init] Checking paths...")
+        print(f"   - V2 Path: {self.v2_path}")
+        print(f"   - V3 Path: {self.v3_path}")
+        print(f"   - V3 Map : {self.v3_features_path}")
+
         try:
-            if not os.path.exists(self.v2_path): return False
-            if not os.path.exists(self.v3_path): return False
+            if not os.path.exists(self.v2_path): 
+                print(f"❌ [Guardian Error] V2 Model file NOT FOUND at: {self.v2_path}")
+                return False
+            if not os.path.exists(self.v3_path): 
+                print(f"❌ [Guardian Error] V3 Model file NOT FOUND at: {self.v3_path}")
+                return False
+            if not os.path.exists(self.v3_features_path):
+                print(f"❌ [Guardian Error] V3 Features Map NOT FOUND at: {self.v3_features_path}")
+                return False
 
             self.model_v2 = xgb.Booster()
             self.model_v2.load_model(self.v2_path)
@@ -56,27 +64,28 @@ class HybridDeepSteward:
             self.model_v3 = xgb.Booster()
             self.model_v3.load_model(self.v3_path)
             
-            if os.path.exists(self.v3_features_path):
-                with open(self.v3_features_path, 'r') as f:
-                    self.v3_feature_names = json.load(f)
-            else:
-                return False
+            with open(self.v3_features_path, 'r') as f:
+                self.v3_feature_names = json.load(f)
 
             self.initialized = True
-            print(f"✅ [HybridGuardian V23] Logic: Safe<{self.V2_SAFE_LIMIT} | Grey<{self.V2_GREY_LIMIT} | Panic>{self.V2_PANIC_TRIGGER}")
+            print(f"✅ [Guardian Ready] Models Loaded Successfully.")
             return True
 
         except Exception as e:
-            print(f"❌ [HybridGuardian] Init Failed: {e}")
+            print(f"❌ [HybridGuardian] CRITICAL Init Failed: {e}")
+            traceback.print_exc()
             return False
 
     # ==========================================================================
-    # 🧠 V2 Feature Logic (Legacy 64-Candle Sequence)
+    # 🧠 V2 Feature Logic
     # ==========================================================================
     def _engineer_v2_features(self, df, current_price, entry_price):
         try:
             df = df.copy()
-            if len(df) < 200: return None
+            # Debug: Check data length
+            if len(df) < 200: 
+                print(f"⚠️ [V2 Warning] Insufficient Data. Need 200+, Got {len(df)}")
+                return None
             
             df['log_ret'] = np.log(df['close'] / df['close'].shift(1))
             vol_sma = df['volume'].rolling(window=50).mean()
@@ -105,11 +114,12 @@ class HybridDeepSteward:
             window = df.iloc[-64:][self.V2_FEATURES].values
             if window.shape[0] < 64: return None
             return window.reshape(1, -1)
-        except:
+        except Exception as e:
+            print(f"❌ [V2 Error] Feature Eng Failed: {e}")
             return None
 
     # ==========================================================================
-    # 🧬 V3 Feature Logic (Advanced Multi-Timeframe)
+    # 🧬 V3 Feature Logic
     # ==========================================================================
     def _add_v3_indicators(self, df, window_mc):
         try:
@@ -171,7 +181,10 @@ class HybridDeepSteward:
             df5 = pd.DataFrame(ohlcv_5m, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
             df15 = pd.DataFrame(ohlcv_15m, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
             
-            if len(df1) < 200 or len(df5) < 50 or len(df15) < 50: return None
+            # Debug: Check lengths
+            if len(df1) < 200 or len(df5) < 50 or len(df15) < 50: 
+                print(f"⚠️ [V3 Warning] Data lengths: 1m={len(df1)}, 5m={len(df5)}, 15m={len(df15)}")
+                return None
 
             df1 = self._add_v3_indicators(df1, window_mc=30)
             df5 = self._add_v3_indicators(df5, window_mc=30)
@@ -193,111 +206,124 @@ class HybridDeepSteward:
                 vector.append(val)
             
             return np.array(vector).reshape(1, -1)
-        except:
+        except Exception as e:
+            print(f"❌ [V3 Error] Feature Eng Failed: {e}")
             return None
 
     # ==========================================================================
-    # 🛡️ The Institutional Hybrid Logic (المنطق المؤسسي الجديد)
+    # 🛡️ The Institutional Hybrid Logic
     # ==========================================================================
     def analyze_position(self, ohlcv_1m, ohlcv_5m, ohlcv_15m, entry_price):
         if not self.initialized:
-            return {'action': 'HOLD', 'reason': 'Not Initialized'}
+            # هنا يكمن سبب ظهور الأصفار، سنقوم بتعديل الرسالة
+            return {
+                'action': 'HOLD', 
+                'reason': '⚠️ Models NOT Loaded (Check Logs)',
+                'scores': {'v2': 0.0, 'v3': 0.0}
+            }
 
         try:
-            # 1. الحسابات (Inference)
+            # 1. الحسابات
             df_1m_raw = pd.DataFrame(ohlcv_1m, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
             current_price = df_1m_raw['close'].iloc[-1]
             
             # V2 Score
             feat_v2 = self._engineer_v2_features(df_1m_raw, current_price, entry_price)
-            score_v2 = float(self.model_v2.predict(xgb.DMatrix(feat_v2))[0]) if feat_v2 is not None else 0.0
+            if feat_v2 is not None:
+                score_v2 = float(self.model_v2.predict(xgb.DMatrix(feat_v2))[0])
+            else:
+                print("⚠️ [Guardian] V2 Features returned None (Defaulting to 0)")
+                score_v2 = 0.0
 
             # V3 Score
             feat_v3 = self._engineer_v3_features(ohlcv_1m, ohlcv_5m, ohlcv_15m)
-            score_v3 = float(self.model_v3.predict(xgb.DMatrix(feat_v3, feature_names=self.v3_feature_names))[0]) if feat_v3 is not None else 0.0
+            if feat_v3 is not None:
+                score_v3 = float(self.model_v3.predict(xgb.DMatrix(feat_v3, feature_names=self.v3_feature_names))[0])
+            else:
+                print("⚠️ [Guardian] V3 Features returned None (Defaulting to 0)")
+                score_v3 = 0.0
 
             scores_dict = {'v2': score_v2, 'v3': score_v3}
 
             # ---------------------------------------------------------
-            # 🧠 منطق اتخاذ القرار (Decision Logic Tree)
+            # 🧠 منطق اتخاذ القرار
             # ---------------------------------------------------------
 
-            # الحالة 1: V2 Panic (انهيار كارثي واضح)
+            # الحالة 1: V2 Panic
             if score_v2 >= self.V2_PANIC_TRIGGER:
                 return {
                     'action': 'EXIT_HARD',
                     'confidence': score_v2,
-                    'reason': f'🚨 V2 PANIC (S:{score_v2:.2f}) - Market Crash Regime',
+                    'reason': f'🚨 V2 PANIC (S:{score_v2:.2f})',
                     'scores': scores_dict
                 }
 
-            # الحالة 2: V2 Safe Zone (سوق آمن)
+            # الحالة 2: V2 Safe Zone
             elif score_v2 < self.V2_SAFE_LIMIT:
-                # استثناء الثقة العمياء لـ V3
                 if score_v3 >= self.V3_ULTRA_CONF:
                     return {
                         'action': 'EXIT_HARD',
                         'confidence': score_v3,
-                        'reason': f'⚡ V3 ULTRA OVERRIDE (S:{score_v3:.2f} > {self.V3_ULTRA_CONF}) - Sniper detects acute danger in Safe Zone',
+                        'reason': f'⚡ V3 ULTRA OVERRIDE',
                         'scores': scores_dict
                     }
                 else:
                     return {
                         'action': 'HOLD',
                         'confidence': 1.0 - score_v2,
-                        'reason': f'✅ Safe Regime (V2:{score_v2:.2f} < {self.V2_SAFE_LIMIT}) - V3({score_v3:.2f}) Vetoed',
+                        'reason': f'✅ Safe Regime',
                         'scores': scores_dict
                     }
 
-            # الحالة 3: V2 Grey Zone (منطقة رمادية) - نسمح لـ V3 بالتدخل بشروط
+            # الحالة 3: V2 Grey Zone
             elif self.V2_SAFE_LIMIT <= score_v2 < self.V2_GREY_LIMIT:
-                if score_v3 >= self.V3_HARD_EXIT: # 0.90
+                if score_v3 >= self.V3_HARD_EXIT:
                     return {
                         'action': 'EXIT_HARD',
                         'confidence': score_v3,
-                        'reason': f'🎯 V3 Sniper (S:{score_v3:.2f}) inside Grey Zone',
+                        'reason': f'🎯 V3 Sniper Grey',
                         'scores': scores_dict
                     }
-                elif score_v3 >= self.V3_SOFT_EXIT: # 0.75
+                elif score_v3 >= self.V3_SOFT_EXIT:
                     return {
                         'action': 'EXIT_SOFT',
                         'confidence': score_v3,
-                        'reason': f'⚠️ V3 Warning (S:{score_v3:.2f}) inside Grey Zone',
+                        'reason': f'⚠️ V3 Warning Grey',
                         'scores': scores_dict
                     }
                 else:
                     return {
                         'action': 'HOLD',
                         'confidence': 1.0 - score_v3,
-                        'reason': f'👀 Grey Zone (V2:{score_v2:.2f}) - V3({score_v3:.2f}) Waiting for signal',
+                        'reason': f'👀 Grey Zone',
                         'scores': scores_dict
                     }
 
-            # الحالة 4: V2 Risk Zone (بوابة الخطر مفتوحة) - V3 يعمل بحرية
-            else: # 0.60 <= score_v2 < 0.90
+            # الحالة 4: V2 Risk Zone
+            else: 
                 if score_v3 >= self.V3_HARD_EXIT:
                     return {
                         'action': 'EXIT_HARD',
                         'confidence': score_v3,
-                        'reason': f'🔥 V3 Kill (S:{score_v3:.2f}) [Risk Gate Open V2:{score_v2:.2f}]',
+                        'reason': f'🔥 V3 Kill Risk',
                         'scores': scores_dict
                     }
                 elif score_v3 >= self.V3_SOFT_EXIT:
                     return {
                         'action': 'EXIT_SOFT',
                         'confidence': score_v3,
-                        'reason': f'⚠️ V3 Soft (S:{score_v3:.2f}) [Risk Gate Open V2:{score_v2:.2f}]',
+                        'reason': f'⚠️ V3 Soft Risk',
                         'scores': scores_dict
                     }
                 else:
                     return {
                         'action': 'HOLD',
                         'confidence': 1.0 - score_v3,
-                        'reason': f'🛡️ High Alert (V2:{score_v2:.2f}) but V3({score_v3:.2f}) Holds',
+                        'reason': f'🛡️ High Alert',
                         'scores': scores_dict
                     }
 
         except Exception as e:
             print(f"❌ [HybridGuardian] Inference Error: {e}")
             traceback.print_exc()
-            return {'action': 'HOLD', 'reason': f'Error: {e}'}
+            return {'action': 'HOLD', 'reason': f'Error: {e}', 'scores': {'v2':0, 'v3':0}}