Update ml_engine/processor.py

ml_engine/processor.py

@@ -1,7 +1,10 @@
 # ============================================================
-# 🧠 ml_engine/processor.py (V31.0 - GEM-Architect: Central Command)
+# 🧠 ml_engine/processor.py (V32.0 - GEM-Architect: Central Command)
 # The Single Source of Truth for ALL System Thresholds
-# Fully Integrated with Patterns, Oracle & Sniper Injection
+# Features:
+# 1. Centralized Config (SystemLimits).
+# 2. R2 Persistence Support (to_dict/update_from_dict).
+# 3. Full Injection into Sub-Engines.
 # ============================================================
 
 import asyncio
@@ -72,52 +75,95 @@ class SystemLimits:
     """
     
     # --- [ Layer 1: Data Manager Screening ] ---
-    # (مرجع للقيم التي يجب استخدامها في DataManager)
     L1_MIN_QUOTE_VOLUME = 1_000_000  # الحد الأدنى للسيولة
     L1_MAX_PUMP_4H      = 8.0        # أقصى ارتفاع مسموح به في 4 ساعات
     L1_MAX_CHANGE_24H   = 12.0       # أقصى تغير يومي
     L1_MAX_RSI          = 70.0       # أقصى RSI للدخول الأولي
-    L1_MAX_DEVIATION    = 1.8        # أقصى انحراف معياري (Bollinger/ATR Deviation)
+    L1_MAX_DEVIATION    = 1.8        # أقصى انحراف معياري
 
     # --- [ Layer 2: Deep Analysis Scoring Weights ] ---
-    # كيف يتم تجميع النتيجة الأولية (Enhanced Score)
-    L2_WEIGHT_TITAN    = 0.50  # وزن التحليل الفني
-    L2_WEIGHT_PATTERNS = 0.40  # وزن الأنماط السعرية
-    L2_WEIGHT_MC       = 0.10  # وزن المحاكاة
+    L2_WEIGHT_TITAN    = 0.50
+    L2_WEIGHT_PATTERNS = 0.40
+    L2_WEIGHT_MC       = 0.10
 
     # ✅ [Layer 2: Pattern Engine Internal Config]
-    # التحكم في حساسية الأنماط وكيفية دمج الفريمات الزمنية
     PATTERN_TF_WEIGHTS = {
-        '15m': 0.40,  # الإطار الزمني القائد
+        '15m': 0.40, 
         '1h':  0.30, 
         '5m':  0.20, 
         '4h':  0.10, 
-        '1d':  0.00   # مهمل
+        '1d':  0.00
     }
-    
-    # عتبات تصنيف النمط النصي (Text Classification)
-    PATTERN_THRESH_BULLISH = 0.60  # فوق هذا الرقم يعتبر إشارة صعودية
-    PATTERN_THRESH_BEARISH = 0.40  # تحت هذا الرقم يعتبر إشارة هبوطية
+    PATTERN_THRESH_BULLISH = 0.60
+    PATTERN_THRESH_BEARISH = 0.40
 
-    # --- [ Layer 3: Oracle Strategy (Strategic Brain) ] ---
-    L3_CONFIDENCE_THRESHOLD = 0.65  # العتبة الذهبية للموافقة
+    # --- [ Layer 3: Oracle Strategy ] ---
+    L3_CONFIDENCE_THRESHOLD = 0.65
     
-    # النقاط الديناميكية (Dynamic Impact)
-    L3_WHALE_IMPACT_MAX = 0.10  # تأثير الحيتان (+/-)
-    L3_NEWS_IMPACT_MAX  = 0.05  # تأثير الأخبار (+/-)
-    L3_MC_ADVANCED_MAX  = 0.10  # تأثير المحاكاة المتقدمة (+/-)
-
-    # --- [ Layer 4: Sniper Execution (Tactical Entry) ] ---
-    L4_ENTRY_THRESHOLD  = 0.45  # عتبة القناص النهائية للدخول
-    L4_WEIGHT_ML        = 0.60  # وزن الذكاء الاصطناعي
-    L4_WEIGHT_OB        = 0.40  # وزن دفتر الطلبات
-    L4_OB_WALL_RATIO    = 0.40  # نسبة الجدار التي تفعّل الفيتو (Veto)
-
-    # --- [ Layer 0: Hydra Guardian (Risk Management) ] ---
-    # احتمالات الخروج الطارئ (Overrides)
-    HYDRA_CRASH_THRESH      = 0.60  # احتمالية الانهيار
-    HYDRA_GIVEBACK_THRESH   = 0.70  # احتمالية إرجاع الأرباح
-    HYDRA_STAGNATION_THRESH = 0.50  # احتمالية الركود
+    # Dynamic Scoring Impacts
+    L3_WHALE_IMPACT_MAX = 0.10
+    L3_NEWS_IMPACT_MAX  = 0.05
+    L3_MC_ADVANCED_MAX  = 0.10
+
+    # --- [ Layer 4: Sniper Execution ] ---
+    L4_ENTRY_THRESHOLD  = 0.45
+    L4_WEIGHT_ML        = 0.60
+    L4_WEIGHT_OB        = 0.40
+    L4_OB_WALL_RATIO    = 0.40
+
+    # --- [ Layer 0: Hydra Guardian ] ---
+    HYDRA_CRASH_THRESH      = 0.60
+    HYDRA_GIVEBACK_THRESH   = 0.70
+    HYDRA_STAGNATION_THRESH = 0.50
+
+    # ==========================================================
+    # 💾 Persistence Methods (R2 Support)
+    # ==========================================================
+    @classmethod
+    def to_dict(cls) -> Dict[str, Any]:
+        """تصدير الحالة الحالية كقاموس للحفظ في R2"""
+        return {
+            "L1_MIN_QUOTE_VOLUME": cls.L1_MIN_QUOTE_VOLUME,
+            "L1_MAX_PUMP_4H": cls.L1_MAX_PUMP_4H,
+            "L1_MAX_CHANGE_24H": cls.L1_MAX_CHANGE_24H,
+            "L1_MAX_RSI": cls.L1_MAX_RSI,
+            "L1_MAX_DEVIATION": cls.L1_MAX_DEVIATION,
+            
+            "L3_CONFIDENCE_THRESHOLD": cls.L3_CONFIDENCE_THRESHOLD,
+            
+            "L4_ENTRY_THRESHOLD": cls.L4_ENTRY_THRESHOLD,
+            "L4_OB_WALL_RATIO": cls.L4_OB_WALL_RATIO,
+            
+            "HYDRA_CRASH_THRESH": cls.HYDRA_CRASH_THRESH,
+            "HYDRA_GIVEBACK_THRESH": cls.HYDRA_GIVEBACK_THRESH,
+            "HYDRA_STAGNATION_THRESH": cls.HYDRA_STAGNATION_THRESH
+        }
+
+    @classmethod
+    def update_from_dict(cls, config: Dict[str, Any]):
+        """تحديث القيم من قاموس (عند التحميل من R2)"""
+        if not config: return
+        
+        # Layer 1
+        if "L1_MIN_QUOTE_VOLUME" in config: cls.L1_MIN_QUOTE_VOLUME = config["L1_MIN_QUOTE_VOLUME"]
+        if "L1_MAX_PUMP_4H" in config: cls.L1_MAX_PUMP_4H = config["L1_MAX_PUMP_4H"]
+        if "L1_MAX_CHANGE_24H" in config: cls.L1_MAX_CHANGE_24H = config["L1_MAX_CHANGE_24H"]
+        if "L1_MAX_RSI" in config: cls.L1_MAX_RSI = config["L1_MAX_RSI"]
+        if "L1_MAX_DEVIATION" in config: cls.L1_MAX_DEVIATION = config["L1_MAX_DEVIATION"]
+        
+        # Layer 3
+        if "L3_CONFIDENCE_THRESHOLD" in config: cls.L3_CONFIDENCE_THRESHOLD = config["L3_CONFIDENCE_THRESHOLD"]
+        
+        # Layer 4
+        if "L4_ENTRY_THRESHOLD" in config: cls.L4_ENTRY_THRESHOLD = config["L4_ENTRY_THRESHOLD"]
+        if "L4_OB_WALL_RATIO" in config: cls.L4_OB_WALL_RATIO = config["L4_OB_WALL_RATIO"]
+        
+        # Layer 0 (Hydra)
+        if "HYDRA_CRASH_THRESH" in config: cls.HYDRA_CRASH_THRESH = config["HYDRA_CRASH_THRESH"]
+        if "HYDRA_GIVEBACK_THRESH" in config: cls.HYDRA_GIVEBACK_THRESH = config["HYDRA_GIVEBACK_THRESH"]
+        if "HYDRA_STAGNATION_THRESH" in config: cls.HYDRA_STAGNATION_THRESH = config["HYDRA_STAGNATION_THRESH"]
+        
+        print("🔄 [SystemLimits] Configuration Updated from R2 Persistence.")
 
 # ============================================================
 # 🧠 MLProcessor Class
@@ -176,7 +222,7 @@ class MLProcessor:
         else:
             self.guardian = None
 
-        print(f"🧠 [MLProcessor V31.0] Central Command Loaded. SystemLimits Active.")
+        print(f"🧠 [MLProcessor V32.0] Central Command Loaded. SystemLimits Active.")
 
     async def initialize(self):
         """تهيئة متوازية لجميع المحركات وحقن الإعدادات"""
@@ -214,7 +260,6 @@ class MLProcessor:
                         threshold=SystemLimits.L4_ENTRY_THRESHOLD,
                         wall_ratio=SystemLimits.L4_OB_WALL_RATIO
                     )
-                # دعم للتوافقية القديمة
                 elif hasattr(self.sniper, 'set_entry_threshold'):
                     self.sniper.set_entry_threshold(SystemLimits.L4_ENTRY_THRESHOLD)
                     
@@ -327,11 +372,9 @@ class MLProcessor:
             decision = await self.oracle.predict(symbol_data)
             
             # ✅ فرض السيطرة: التحقق من العتبة المركزية هنا أيضاً
-            # (حتى لو قبلها Oracle، نحن نرفضها إذا كانت أقل من المحدد هنا)
             conf = decision.get('confidence', 0.0)
             
             if decision.get('action') in ['WATCH', 'BUY'] and conf < SystemLimits.L3_CONFIDENCE_THRESHOLD:
-                # نحتفظ بالاتجاه ولكن نغير القرار إلى انتظار
                 decision['action'] = 'WAIT'
                 decision['reason'] = f"Processor Veto: Conf {conf:.2f} < Limit {SystemLimits.L3_CONFIDENCE_THRESHOLD}"
             
@@ -353,7 +396,7 @@ class MLProcessor:
             return {'signal': 'WAIT', 'reason': 'Sniper Engine Missing'}
     
     def set_sniper_threshold(self, threshold: float):
-        # تحديث القيمة في SystemLimits (للحفاظ على التزامن) وتحديث القناص
+        # تحديث القيمة في SystemLimits وتحديث القناص
         SystemLimits.L4_ENTRY_THRESHOLD = threshold
         if self.sniper:
             if hasattr(self.sniper, 'set_entry_threshold'):
@@ -380,7 +423,7 @@ class MLProcessor:
             p_giveback = probs.get('giveback', 0.0)
             p_stag = probs.get('stagnation', 0.0)
 
-            # إذا قرر الحارس الانتظار، لكن الاحتمالات تجاوزت الحدود المركزية، نفرض الخروج
+            # تطبيق سياسة الفيتو المركزي على المخاطر
             if decision['action'] == 'HOLD':
                 if p_crash >= SystemLimits.HYDRA_CRASH_THRESH:
                     decision['action'] = 'EXIT_HARD'
@@ -419,4 +462,4 @@ class MLProcessor:
                 print(f"⚠️ [Processor] Advanced MC Error: {e}")
         return 0.0
 
-print("✅ [MLProcessor V31.0] Centralized Thresholds & Config Loaded.")
+print("✅ [MLProcessor V32.0] Centralized Thresholds & R2 Persistence Loaded.")