Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py (V15.16 - OracleEngine Integration)
+# app.py (V15.16 - OracleEngine Integration - Patched)
 import os
 import sys
 import traceback
@@ -21,6 +21,7 @@ try:
     from trade_manager import TradeManager
     
     # --- [ 🔴 التعديل: استبدال LLM بـ OracleEngine ] ---
+    # (تأكد من أن الملف أعلاه موجود في: ml_engine/oracle_engine.py)
     from ml_engine.oracle_engine import OracleEngine
     # (تمت إزالة LLMService و LearningHubManager)
     # --- [ نهاية التعديل ] ---
@@ -120,6 +121,7 @@ async def lifespan(app: FastAPI):
 
         print("   [6/8] تهيئة MLProcessor (L1 Engine)...")
         # --- [ 🔴 التعديل: إزالة learning_hub من MLProcessor ] ---
+        # (استناداً إلى `processor (34).py` و `app (43).py` الأصلي)
         ml_processor = MLProcessor(market_context=None, data_manager=data_manager, learning_hub=None) 
         # --- [ نهاية التعديل ] ---
         await ml_processor.initialize()
@@ -133,7 +135,7 @@ async def lifespan(app: FastAPI):
         print("   [8/8] تهيئة SniperEngine (L2 Entry Sniper)...")
         sniper_engine = SniperEngine(models_dir=SHARED_GUARD_MODELS_DIR) 
         await sniper_engine.initialize()
-        sniper_engine.set_entry_threshold(0.60)
+        sniper_engine.set_entry_threshold(0.60) #
         
         print("   [FINAL] تهيئة TradeManager...")
         trade_manager = TradeManager(
@@ -171,9 +173,7 @@ async def lifespan(app: FastAPI):
 async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
     global data_manager, ml_processor
     try:
-        # (🔴 ملاحظة: OracleEngine يحتاج لأطر 15m, 1h, 4h)
-        # (L1/L2 يحتاج 5m, 15m, 1h, 4h, 1d)
-        # لذا، هذه القائمة صحيحة وتغطي كل الاحتياجات
+        # (هذه القائمة تغطي احتياجات L1/L2 واحتياجات Oracle L3)
         required_tfs = ["5m", "15m", "1h", "4h", "1d"]
         data_tasks = [data_manager.get_latest_ohlcv(symbol, tf, limit=250) for tf in required_tfs]
         all_data = await asyncio.gather(*data_tasks)
@@ -182,7 +182,8 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
         for tf, data in zip(required_tfs, all_data):
             if data and len(data) > 0: ohlcv_data[tf] = data
 
-        if '5m' not in ohlcv_data or '1h' not in ohlcv_data: # (التأكد من وجود بيانات كافية)
+        if '5m' not in ohlcv_data or '15m' not in ohlcv_data or '1h' not in ohlcv_data or '4h' not in ohlcv_data:
+            print(f"   -> ⚠️ [L1 Task] بيانات ناقصة لـ {symbol}، تم الإلغاء.")
             return None
             
         current_price = await data_manager.get_latest_price_async(symbol)
@@ -348,7 +349,7 @@ async def run_unified_cycle():
             
         print("="*135 + "\n")
 
-        # --- [ 🔴 🔴 🔴 التعديل: خطوة 4 - استبدال LLM بـ OracleEngine ] ---
+        # --- [ 🔴 🔴 🔴 التعديل: خطوة 4 - استبدال LLM بـ OracleEngine وتطبيق إصلاح اللوغاريتمات ] ---
         # --- 4. اختيار أفضل 5 للنموذج الضخم ---
         top_5_candidates = sorted_finalists[:5]
         print(f"   [Cycle 4/5] 🧠 إرسال أفضل {len(top_5_candidates)} عملة للعقل الاحتمالي (Oracle Engine)...")
@@ -359,6 +360,7 @@ async def run_unified_cycle():
         for signal in top_5_candidates:
             symbol = signal['symbol']
             
+            # (عتبة المرور إلى L3 لا تتغير)
             if signal['final_total_score'] < 0.60: 
                 print(f"   -> 🛑 {symbol} تم استبعاده (الدرجة النهائية {signal['final_total_score']:.2f} < 0.60)")
                 continue
@@ -371,7 +373,9 @@ async def run_unified_cycle():
 
                 action = oracle_decision.get('action')
                 confidence = oracle_decision.get('confidence', 0.0)
-                reason = oracle_decision.get('analysis_summary', 'No summary')
+                
+                # (الإصلاح: البحث عن "السبب" في مفتاحين)
+                reason = oracle_decision.get('analysis_summary') or oracle_decision.get('reason', 'No summary provided')
 
                 if action == 'WATCH': # (نحن نبحث عن 'WATCH' بناءً على كود Oracle)
                     print(f"       🔥 [Oracle APPROVED] {symbol} (Conf: {confidence:.2f})")
@@ -386,7 +390,7 @@ async def run_unified_cycle():
                     processed_count += 1
                 else:
                     print(f"       🛑 [Oracle REJECTED] {symbol} (Conf: {confidence:.2f})")
-                    print(f"           📝 Reason: {reason[:200]}...")
+                    print(f"           📝 Reason: {reason[:200]}...") # (الآن سيطبع السبب الحقيقي)
             
             except Exception as e:
                 print(f"       ⚠️ [Oracle Error] فشل تحليل Oracle لـ {symbol}: {e}")
@@ -413,8 +417,8 @@ async def run_unified_cycle():
 app = FastAPI(
     lifespan=lifespan, 
     # --- [ 🔴 التعديل: تحديث العنوان ] ---
-    title="Titan V16.0 (Oracle Engine - Probabilistic)", 
-    description="نظام تداول آلي هجين (L1/L2/L3-ML) مع قرار احتمالي"
+    title="Titan V16.1 (Oracle Engine V2.1 - Patched)", 
+    description="نظام تداول آلي هجين (L1/L2/L3-ML) مع قرار احتمالي متعدد الأطر"
     # --- [ نهاية التعديل ] ---
 )
 
@@ -423,7 +427,9 @@ async def root_status():
     return {
         "system_status": "ONLINE",
         "initialized": sys_state.ready,
-        "brain_type": "Oracle_Engine_V2", # (تحديث الحالة)
+        # --- [ 🔴 التعديل: تحديث الحالة ] ---
+        "brain_type": "Oracle_Engine_V2.1 (Multi-TF)", 
+        # --- [ نهاية التعديل ] ---
         "guard_v2_active": guard_engine.initialized if guard_engine else False,
         "sniper_v3_active": sniper_engine.initialized if sniper_engine else False, 
         "current_mode": "RE-ANALYSIS" if trade_manager and trade_manager.open_positions else "EXPLORER"
@@ -434,7 +440,9 @@ async def trigger_cycle_endpoint(background_tasks: BackgroundTasks):
     if not sys_state.ready:
         raise HTTPException(status_code=503, detail="System is still initializing.")
     background_tasks.add_task(run_unified_cycle)
-    return {"status": "ACCEPTED", "message": "Unified smart cycle triggered (Oracle Mode)."}
+    # --- [ 🔴 التعديل: تحديث الرسالة ] ---
+    return {"status": "ACCEPTED", "message": "Unified smart cycle triggered (Oracle V2.1 Mode)."}
+    # --- [ نهاية التعديل ] ---
 
 @app.get("/status") 
 async def get_full_status():