Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py (V14.7 - Full Production Version & Verbose Cycle Start)
+# app.py (V15.1 - Full Production - Guard V2 Integrated & Verbose Restored)
 import os
 import sys
 import traceback
@@ -23,6 +23,8 @@ try:
     from whale_monitor.core import EnhancedWhaleMonitor
     from sentiment_news import NewsFetcher
     from vaderSentiment.vaderSentiment import SentimentIntensityAnalyzer
+    # [NEW] وحدة الحارس الجديد
+    from ml_engine.guard_engine import GuardEngine 
 except ImportError as e:
     # إيقاف فوري للنظام في حال فقدان أي مكون حيوي
     sys.exit(f"❌ [FATAL ERROR] Failed to import core modules: {e}")
@@ -39,6 +41,7 @@ learning_hub: LearningHubManager = None
 whale_monitor: EnhancedWhaleMonitor = None
 news_fetcher: NewsFetcher = None
 vader: SentimentIntensityAnalyzer = None
+guard_engine: GuardEngine = None # [NEW]
 
 class SystemState:
     def __init__(self):
@@ -52,12 +55,12 @@ sys_state = SystemState()
 # ==============================================================================
 async def initialize_system():
     global r2, data_manager, ml_processor, trade_manager, llm_service, learning_hub
-    global whale_monitor, news_fetcher, vader
+    global whale_monitor, news_fetcher, vader, guard_engine
     
     if sys_state.ready:
         return
 
-    print("\n🔌 [System V14.7] Starting Full Initialization Sequence...")
+    print("\n🔌 [System V15.1] Starting Full Initialization Sequence (with Guard V2)...")
     
     try:
         # 1. البنية التحتية والبيانات (Infrastructure Layer)
@@ -89,14 +92,26 @@ async def initialize_system():
         await ml_processor.initialize()
         print("   ✅ ML Processor (Titan + Patterns) ready.")
 
-        trade_manager = TradeManager(r2, data_manager, ml_processor.titan, ml_processor.pattern_engine)
+        # [NEW] تهيئة محرك الحماية
+        guard_engine = GuardEngine()
+        await guard_engine.initialize()
+        print("   ✅ Guard Engine V2 (Exit Protector) ready.")
+
+        # [MODIFIED] تمرير الحارس لمدير التداول
+        trade_manager = TradeManager(
+            r2, 
+            data_manager, 
+            ml_processor.titan, 
+            ml_processor.pattern_engine,
+            guard_engine=guard_engine # <--- تسليم الحارس
+        )
         await trade_manager.initialize_sentry_exchanges()
         # بدء مهام المراقبة الخلفية للحارس
         asyncio.create_task(trade_manager.start_sentry_loops())
-        print("   ✅ TradeManager Sentry loops started.")
+        print("   ✅ TradeManager Sentry loops started (Guard V2 Active).")
 
         sys_state.ready = True
-        print("\n🚀 [SYSTEM READY] All core systems are online and awaiting orders.")
+        print("\n🚀 [SYSTEM READY V15.1] All core systems are online and awaiting orders.")
         
     except Exception as e:
         print(f"\n❌ [INIT FATAL ERROR] System failed to start: {e}")
@@ -325,7 +340,7 @@ async def _run_explorer_mode_full():
     
     if layer3_input_candidates:
         print("📋 [L3 Qualification] The following candidates are advancing to Omniscient Brain:")
-        # رأس الجدول المحسن
+        # رأس الجدول المحسن (تمت استعادته بالكامل)
         print(f"   {'#':<2} {'SYMBOL':<10} | {'L1':<6} | {'Whale Info':<16} | {'News Info':<16} | {'FINAL L2':<8}")
         print("-" * 70)
         for i, cand in enumerate(layer3_input_candidates, 1):
@@ -388,7 +403,7 @@ async def lifespan(app: FastAPI):
     if data_manager: await data_manager.close()
     print("👋 [System] Shutdown complete.")
 
-app = FastAPI(lifespan=lifespan, title="Titan Hybrid System V14.7 (Full Production)")
+app = FastAPI(lifespan=lifespan, title="Titan Hybrid System V15.1 (Full Production + Guard V2)")
 
 @app.get("/")
 async def root():
@@ -396,6 +411,7 @@ async def root():
     return {
         "system_status": "ONLINE",
         "initialized": sys_state.ready,
+        "guard_v2_active": guard_engine.initialized if guard_engine else False, # [NEW] حالة الحارس
         "current_mode": "RE-ANALYSIS" if trade_manager and trade_manager.open_positions else "EXPLORER"
     }