Update ml_engine/oracle_engine.py

ml_engine/oracle_engine.py

@@ -41,7 +41,7 @@ class OracleEngine:
         self.feature_names: List[str] = []
         self.initialized = False
         # (تحديث الإصدار)
-        print("🧠 [OracleEngine V2.2] تم الإنشاء (Actionable-Only Patch). جاهز للتهيئة.")
+        print("🧠 [OracleEngine V2.3] تم الإنشاء (Spot/Long-Only Mode). جاهز للتهيئة.")
 
     async def initialize(self):
         """
@@ -50,7 +50,7 @@ class OracleEngine:
         if self.initialized:
             return True
             
-        print(f"🧠 [OracleEngine V2.2] جاري تحميل 15 نموذجاً من {self.model_dir}...")
+        print(f"🧠 [OracleEngine V2.3] جاري تحميل 15 نموذجاً من {self.model_dir}...")
         try:
             # 1. تحميل نماذج "لجنة القرار" (Strategy Ensemble)
             for i in range(N_STRATEGY_MODELS):
@@ -79,12 +79,12 @@ class OracleEngine:
             self.feature_names = self.strategy_boosters[0].feature_name()
             self.initialized = True
             
-            print(f"✅ [OracleEngine V2.2] جاهز. (Threshold: {DECISION_CONFIDENCE_THRESHOLD*100}%)")
+            print(f"✅ [OracleEngine V2.3] جاهز. (Threshold: {DECISION_CONFIDENCE_THRESHOLD*100}%)")
             print(f"   -> سيعمل على الأطر: {TIMEBYTES_TO_PROCESS}")
             return True
 
         except Exception as e:
-            print(f"❌ [OracleEngine V2.2] فشل فادح أثناء التهيئة: {e}")
+            print(f"❌ [OracleEngine V2.3] فشل فادح أثناء التهيئة: {e}")
             self.initialized = False
             return False
 
@@ -170,12 +170,10 @@ class OracleEngine:
         try:
             feature_vector = latest_features[self.feature_names]
             
-            # --- [ 🔴 🔴 🔴 إصلاح المشكلة 1: NaN Bug ] ---
-            # (إصلاح حالات مثل USDC التي ليس لها تقلب)
+            # --- [ إصلاح المشكلة: NaN Bug ] ---
             feature_vector = feature_vector.fillna(0)
             # --- [ نهاية الإصلاح ] ---
 
-            # (الفحص الأخير، رغم أن fillna(0) يجب أن تحل المشكلة)
             if feature_vector.isnull().values.any():
                 print("⚠️ [Oracle Warning] Feature vector still contains NaN after fill(0).")
                 return None
@@ -214,16 +212,12 @@ class OracleEngine:
                 ]
                 ensemble_probs = np.mean(all_probs, axis=0)[0] 
                 
-                # --- [ 🔴 🔴 🔴 إصلاح المشكلة 2: منطق WAIT ] ---
-                # (بدلاً من أخذ np.argmax، سنتجاهل الفئة 0)
-                
-                # نسخ الاحتمالات وتعيين احتمالية 'WAIT' (index 0) إلى 0
+                # --- [ إصلاح المشكلة: منطق WAIT ] ---
                 actionable_probs = ensemble_probs.copy()
                 actionable_probs[0] = 0.0 # (تجاهل WAIT)
                 
-                # إيجاد أفضل إشارة "قابلة للتنفيذ"
                 predicted_strategy_idx = np.argmax(actionable_probs)
-                confidence = actionable_probs[predicted_strategy_idx] # (الثقة في أفضل إشارة غير-WAIT)
+                confidence = actionable_probs[predicted_strategy_idx] 
                 strategy_name = STRATEGY_MAP.get(predicted_strategy_idx, 'WAIT')
                 # --- [ نهاية الإصلاح ] ---
 
@@ -244,7 +238,18 @@ class OracleEngine:
             confidence = best_decision['confidence']
             best_tf = best_decision['timeframe']
 
-            # --- [ الخطوة 3: تطبيق فلتر الثقة (لا تغيير هنا) ] ---
+            # --- [ 🛑 🛑 🛑 التعديل الجديد: فلتر Spot Only ] ---
+            # إذا كانت الاستراتيجية تحتوي على "SHORT"، يتم تجاهلها فوراً
+            if "SHORT" in strategy_name:
+                return {
+                    'action': 'IGNORE',
+                    'reason': f"Spot Mode: Ignored {strategy_name} signal (Shorts disabled)",
+                    'confidence': confidence,
+                    'strategy': strategy_name
+                }
+            # --- [ نهاية التعديل ] ---
+
+            # --- [ الخطوة 3: تطبيق فلتر الثقة ] ---
             if confidence < DECISION_CONFIDENCE_THRESHOLD:
                 return {
                     'action': 'IGNORE',
@@ -253,8 +258,6 @@ class OracleEngine:
                     'strategy': strategy_name
                 }
             
-            # (الآن نحن متأكدون أن strategy_name ليست 'WAIT' وأن الثقة عالية)
-
             # --- [ الخطوة 4: (نجحت الثقة) - تشغيل "لجنة الأهداف" ] ---
             winning_feature_vector = best_decision['feature_vector']
             preds_quantile = {}
@@ -272,13 +275,9 @@ class OracleEngine:
                 tp_price = current_price * (1 + tp_pct)
                 sl_price = current_price * (1 - sl_pct)
                 action_type = "BUY"
-            elif "SHORT" in strategy_name:
-                tp_price = current_price * (1 - tp_pct)
-                sl_price = current_price * (1 + sl_pct)
-                action_type = "SELL"
             else:
-                # (هذا مستحيل الحدوث الآن بسبب منطقنا الجديد)
-                return {'action': 'IGNORE', 'reason': 'Strategy not actionable'}
+                # (لن نصل إلى هنا لأننا قمنا بتصفية SHORT مسبقاً)
+                return {'action': 'IGNORE', 'reason': 'Strategy not actionable (Unknown type)'}
 
             # --- [ الخطوة 6: إرجاع القرار الكامل ] ---
             return {
@@ -294,7 +293,7 @@ class OracleEngine:
             }
 
         except Exception as e:
-            print(f"❌ [OracleEngine V2.2] فشل فادح أثناء التنبؤ: {e}")
+            print(f"❌ [OracleEngine V2.3] فشل فادح أثناء التنبؤ: {e}")
             import traceback
             traceback.print_exc()
             return {'action': 'WAIT', 'reason': f'Exception: {e}'}