Update app.py

app.py

@@ -1,5 +1,6 @@
-# app.py (V23.5 - GEM-Architect: Full Enterprise Edition - No Abbreviations)
-# النسخة الكاملة: تشمل المنطق، الواجهة، التنسيقات، والربط مع مركز التعلم.
+# app.py (V23.6 - GEM-Architect: Full Stable Enterprise Edition)
+# يتضمن الحل الجذري لمشكلة التهيئة (Application Initialization Fix)
+# وكافة وظائف النظام: التداول، التعلم، الواجهة، والمراقبة.
 
 import os
 import sys
@@ -33,18 +34,15 @@ try:
     from vaderSentiment.vaderSentiment import SentimentIntensityAnalyzer
     
     # 3. ⚡ المحرك المركزي (The Brain) ⚡
-    # يدير Titan, Oracle, Sniper, Patterns, Guardian
     from ml_engine.processor import MLProcessor
     
     # 4. 🎓 مركز التعلم (The Learning Hub) 🎓
-    # يدير التدريب الذاتي، الأوزان المتكيفة، والأرشفة
     from learning_hub.hub_manager import LearningHubManager
     
     # 5. مدير التداول (The Executor)
     from trade_manager import TradeManager
     
 except ImportError as e:
-    # إيقاف النظام في حال فقدان أي ملف جوهري
     sys.exit(f"❌ [FATAL ERROR] Failed to import core modules: {e}")
 
 # ==============================================================================
@@ -53,7 +51,7 @@ except ImportError as e:
 r2: R2Service = None
 data_manager: DataManager = None
 ml_processor: MLProcessor = None
-hub_manager: LearningHubManager = None # المتغير العام لمركز التعلم
+hub_manager: LearningHubManager = None 
 trade_manager: TradeManager = None
 whale_monitor: EnhancedWhaleMonitor = None
 news_fetcher: NewsFetcher = None
@@ -64,19 +62,16 @@ sys_state: 'SystemState' = None
 # 🔄 حالة النظام (System State Tracker)
 # ==============================================================================
 class SystemState:
-    """
-    كلاس بسيط لتتبع حالة النظام العالمية (جاهزية، دورة، تدريب).
-    """
     def __init__(self):
         self.ready = False
         self.cycle_running = False
         self.training_running = False # حالة التدريب النشط
-        self.auto_pilot = True  # التشغيل التلقائي مفعل افتراضياً
+        self.auto_pilot = True  # التشغيل التلقائي مفعل
         self.last_cycle_time: datetime = None
         self.last_cycle_error = None
         self.app_start_time = datetime.now()
         self.last_cycle_logs = "النظام قيد التهيئة... يرجى الانتظار."
-        self.training_status_msg = "Waiting for data..." # رسالة حالة التدريب
+        self.training_status_msg = "Waiting for data..." 
 
     def set_ready(self): 
         self.ready = True
@@ -147,7 +142,6 @@ def calculate_duration_str(timestamp_str):
 async def auto_pilot_loop():
     """
     مراقب الخلفية: يفحص النظام كل 10 ثواني ويبدأ دورة البحث إذا كان الوضع آمناً.
-    كما يقوم بتحديث حالة التدريب.
     """
     print("🤖 [Auto-Pilot] Daemon started running in background...")
     while True:
@@ -155,43 +149,38 @@ async def auto_pilot_loop():
             # فاصل زمني لحماية الموارد
             await asyncio.sleep(10)
 
-            # التحقق من جاهزية النظام
             if not sys_state.ready: continue
             
-            # 1. تحديث حالة جاهزية التدريب (للعرض في الواجهة فقط)
+            # 1. تحديث حالة جاهزية التدريب للعرض في الواجهة
             if hub_manager:
                 is_ready, msg = await hub_manager.check_training_readiness()
                 sys_state.training_status_msg = msg
 
-            # 2. منطق تشغيل الدورة (Trading Cycle)
-            # الشروط: الطيار الآلي مفعل + لا دورة تعمل + لا تدريب يعمل
+            # 2. منطق تشغيل الدورة
             if sys_state.auto_pilot and not sys_state.cycle_running and not sys_state.training_running:
-                # إذا لم تكن هناك صفقات مفتوحة، نبدأ البحث
                 if trade_manager and len(trade_manager.open_positions) == 0:
                     asyncio.create_task(run_unified_cycle())
-                    # انتظار إضافي لمنع التداخل
                     await asyncio.sleep(5) 
                 else:
-                    # في حال وجود صفقة، النظام في وضع "الحراسة" ولا نطلق دورات بحث جديدة
+                    # وضع الحراسة (Sentry Mode) لا يحتاج لإطلاق دورات بحث
                     pass 
 
         except Exception as e:
             print(f"⚠️ [Auto-Pilot Error] {e}")
-            # في حال الخطأ ننتظر فترة أطول
             await asyncio.sleep(30)
 
 # ==============================================================================
-# 🚀 Lifespan (بدء وإيقاف النظام)
+# 🚀 Lifespan (تهيئة وإغلاق النظام)
 # ==============================================================================
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     global r2, data_manager, ml_processor, hub_manager, trade_manager, whale_monitor, news_fetcher, senti_analyzer, sys_state
     
-    print("\n🚀 [System] Startup Sequence Initiated (Titan V23.5 Enterprise)...")
+    print("\n🚀 [System] Startup Sequence Initiated (Titan V23.6 Stable)...")
     print("------------------------------------------------------")
     
     try:
-        # 1. تهيئة طبقة البيانات والاتصال
+        # 1. تهيئة طبقة البيانات
         print("   [1/7] Initializing R2 & Data Services...")
         r2 = R2Service()
         data_manager = DataManager(contracts_db={}, whale_monitor=None, r2_service=r2)
@@ -199,40 +188,38 @@ async def lifespan(app: FastAPI):
         await data_manager.load_contracts_from_r2()
         
         # 2. الخدمات المساعدة
-        print("   [2/7] Starting Auxiliary Services (Whales/News)...")
+        print("   [2/7] Starting Auxiliary Services...")
         whale_monitor = EnhancedWhaleMonitor(contracts_db=data_manager.get_contracts_db(), r2_service=r2)
         news_fetcher = NewsFetcher()
         senti_analyzer = SentimentIntensityAnalyzer()
         data_manager.whale_monitor = whale_monitor
         
-        # 3. 🎓 تهيئة مركز التعلم (Learning Hub) - يجب أن يكون قبل المعالج
-        print("   [3/7] Initializing Learning Hub (The Academy)...")
+        # 3. تهيئة مركز التعلم (Learning Hub)
+        print("   [3/7] Initializing Learning Hub...")
         hub_manager = LearningHubManager(r2_service=r2, data_manager=data_manager)
         await hub_manager.initialize()
 
-        # 4. ⚡ تهيئة المعالج المركزي (Brain) ⚡
-        print("   [4/7] Initializing Central ML Processor (Titan/Oracle/Sniper)...")
+        # 4. تهيئة المعالج المركزي (Brain)
+        print("   [4/7] Initializing Central ML Processor...")
         ml_processor = MLProcessor(data_manager=data_manager)
         await ml_processor.initialize()
         
-        # 🔗 حقن Hub في Processor (للحصول على الأوزان المتكيفة)
+        # 🔗 حقن Hub في Processor
         ml_processor.hub_manager = hub_manager 
         
         # 5. تهيئة مدير التداول
-        print("   [5/7] Initializing Trade Manager (The Executor)...")
+        print("   [5/7] Initializing Trade Manager...")
         trade_manager = TradeManager(
             r2_service=r2, 
             data_manager=data_manager, 
-            processor=ml_processor # نمرر المعالج فقط
+            processor=ml_processor 
         )
-        
-        # 🔗 حقن Hub في TradeManager (لإرسال الصفقات المغلقة للتعلم)
-        # نقوم بذلك يدوياً لأن TradeManager يتوقع processor في الـ init
+        # 🔗 حقن Hub في TradeManager
         trade_manager.learning_hub = hub_manager 
         
         await trade_manager.initialize_sentry_exchanges()
         
-        # 6. إعادة تشغيل حراسة الصفقات المفتوحة (إن وجدت)
+        # 6. إعادة تشغيل الحراس
         print("   [6/7] Restarting Active Sentries...")
         await trade_manager.start_sentry_loops()
         
@@ -255,9 +242,7 @@ async def lifespan(app: FastAPI):
         print("\n🛑 [System] Shutdown Sequence Initiated...")
         sys_state.ready = False
         
-        # حفظ حالة التعلم قبل الإغلاق
         if hub_manager: await hub_manager.shutdown()
-        
         if trade_manager: await trade_manager.stop_sentry_loops()
         if data_manager: await data_manager.close()
         print("✅ [System] Shutdown Complete.")
@@ -266,13 +251,9 @@ async def lifespan(app: FastAPI):
 # 🧠 Helper Task: Analyze Single Symbol
 # ==============================================================================
 async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
-    """
-    مهمة لجلب بيانات عملة واحدة وإرسالها للمعالج (Processor) للحصول على التقييم المركب.
-    """
     global data_manager, ml_processor
     try:
         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)
         
@@ -280,14 +261,13 @@ 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 '15m' not in ohlcv_data or '1h' not in ohlcv_data:
             return None
             
         current_price = await data_manager.get_latest_price_async(symbol)
         raw_data = {'symbol': symbol, 'ohlcv': ohlcv_data, 'current_price': current_price}
         
-        # ⚡ طلب التحليل من المعالج المركزي (L1/L2 Analysis) ⚡
+        # استدعاء المعالج للتحليل
         return await ml_processor.process_compound_signal(raw_data)
         
     except Exception:
@@ -297,48 +277,35 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
 # 🚀 Unified Smart Cycle (Logic Flow)
 # ==============================================================================
 async def run_unified_cycle():
-    """
-    دورة العمل الرئيسية:
-    1. مزامنة الحالة.
-    2. إدارة الصفقات المفتوحة.
-    3. البحث (Screening).
-    4. التحليل (Analysis).
-    5. الاستشارة (Oracle).
-    6. التنفيذ (Sniper).
-    """
     log_buffer = StringIO()
-    
     def log_and_print(message):
         print(message)
         log_buffer.write(message + '\n')
 
-    # التحقق من حالة الدورة
     if sys_state.cycle_running:
-        log_and_print("⚠️ [Cycle] الدورة قيد التشغيل بالفعل. تم تجاهل الطلب.")
+        log_and_print("⚠️ [Cycle] الدورة قيد التشغيل بالفعل.")
         return
     
     if sys_state.training_running:
-        log_and_print("⚠️ [Cycle] النظام مشغول بالتدريب (Training in progress).")
+        log_and_print("⚠️ [Cycle] النظام مشغول بالتدريب.")
         return
 
     if not sys_state.ready:
-        log_and_print("⚠️ [Cycle] النظام غير جاهز بعد.")
+        log_and_print("⚠️ [Cycle] النظام غير جاهز.")
         return
 
     sys_state.set_cycle_start()
     log_and_print(f"\n🌀 [Cycle START] {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
     
     try:
-        # 0. مزامنة الحالة مع R2
         await trade_manager.sync_internal_state_with_r2()
         
-        # 1. التحقق من الصفقات المفتوحة (Priority Management)
+        # 1. فحص الصفقات المفتوحة
         if len(trade_manager.open_positions) > 0:
             symbol = list(trade_manager.open_positions.keys())[0]
             trade = trade_manager.open_positions[symbol]
-            log_and_print(f"🔒 [Guardian Mode] صفقة نشطة: {symbol}. تخطي البحث للتركيز على الإدارة.")
+            log_and_print(f"🔒 [Guardian Mode] صفقة نشطة: {symbol}. المراقبة جارية.")
             
-            # عرض تقرير الحارس (للمعلومات فقط، التنفيذ يتم في الخلفية)
             try:
                 t1 = data_manager.get_latest_ohlcv(symbol, '1m', 300)
                 t5 = data_manager.get_latest_ohlcv(symbol, '5m', 200)
@@ -347,94 +314,79 @@ async def run_unified_cycle():
                 
                 if d1 and d5 and d15:
                     entry_p = trade['entry_price']
-                    # ⚡ استشارة الحارس ⚡
                     decision = ml_processor.consult_guardian(d1, d5, d15, entry_p)
                     scores = decision.get('scores', {})
                     log_and_print(f"   📊 [Guardian Report] Status: {decision.get('action')}")
-                    log_and_print(f"      • V2 (Radar): {scores.get('v2',0):.4f}")
-                    log_and_print(f"      • V3 (Sniper): {scores.get('v3',0):.4f}")
-                    log_and_print(f"      • Reason: {decision.get('reason')}")
+                    log_and_print(f"      • V2: {scores.get('v2',0):.4f} | V3: {scores.get('v3',0):.4f}")
+                    log_and_print(f"      • Msg: {decision.get('reason')}")
             except Exception as e:
-                log_and_print(f"   ⚠️ تعذر جلب تقرير الحارس المباشر: {e}")
+                log_and_print(f"   ⚠️ Guardian report check failed: {e}")
             
             sys_state.set_cycle_end(logs=log_buffer.getvalue())
             return 
 
-        # 2. البحث الأولي (L1 Screening)
-        log_and_print("   [1/4] 🔍 L1 Screening (Volume & Liquidity)...")
+        # 2. البحث الأولي (L1)
+        log_and_print("   [1/4] 🔍 L1 Screening (Liquidity)...")
         candidates = await data_manager.layer1_rapid_screening()
         
         if not candidates:
-            log_and_print("⚠️ [Cycle] لم يتم العثور على أي عملات تلبي شروط L1.")
+            log_and_print("⚠️ [Cycle] لا توجد عملات مرشحة.")
             sys_state.set_cycle_end(logs=log_buffer.getvalue()); return
             
-        # 3. التحليل المعمق (L2 Analysis - Titan/Patterns)
-        log_and_print(f"   [2/4] 🧠 L2 Deep Analysis for {len(candidates)} candidates...")
-        analysis_start = time.time()
-        
+        # 3. ال��حليل المعمق (L2)
+        log_and_print(f"   [2/4] 🧠 L2 Deep Analysis ({len(candidates)} items)...")
         tasks = [_analyze_symbol_task(c['symbol']) for c in candidates]
         results = await asyncio.gather(*tasks)
         valid_l2 = [res for res in results if res is not None]
         
-        # ترتيب حسب الدرجة النهائية المعززة
         top_10 = sorted(valid_l2, key=lambda x: x.get('enhanced_final_score', 0.0), reverse=True)[:10]
         
-        log_and_print(f"   -> اكتمل التحليل في {time.time() - analysis_start:.2f} ثانية.")
+        log_and_print(f"   -> تم تحليل {len(valid_l2)} عملة بنجاح.")
         
         if not top_10:
-            log_and_print("⚠️ [Cycle] لم تنجح أي عملة في تجاوز L2.")
+            log_and_print("⚠️ [Cycle] لم تنجح أي عملة في L2.")
             sys_state.set_cycle_end(logs=log_buffer.getvalue()); return
 
-        # عرض الجدول
         log_and_print("\n" + "="*80)
-        log_and_print(f"{'SYMBOL':<10} | {'FINAL SCORE':<12} | {'TITAN':<8} | {'PATT':<8} | {'MC':<8}")
+        log_and_print(f"{'SYMBOL':<10} | {'SCORE':<12} | {'TITAN':<8} | {'PATT':<8} | {'MC':<8}")
         log_and_print("-" * 80)
         for c in top_10:
             comps = c.get('components', {})
             log_and_print(f"{c['symbol']:<10} | {c['enhanced_final_score']:.4f}       | {comps.get('titan_score',0):.2f}     | {comps.get('patterns_score',0):.2f}     | {comps.get('mc_score',0):.2f}")
         log_and_print("="*80 + "\n")
 
-        # 4. العقل الاحتمالي (L3 Oracle)
-        log_and_print(f"   [3/4] 🔮 L3 Oracle Consultation (Probabilistic Check)...")
+        # 4. الاستشارة (L3 Oracle)
+        log_and_print(f"   [3/4] 🔮 L3 Oracle Check...")
         approved_signals = []
         
         for sig in top_10:
-            # تصفية أولية
             if sig['enhanced_final_score'] < 0.60: continue
             
-            # ⚡ استشارة Oracle عبر المعالج ⚡
             oracle_dec = await ml_processor.consult_oracle(sig)
             
             if oracle_dec.get('action') == 'WATCH':
-                conf = oracle_dec.get('confidence', 0.0)
-                log_and_print(f"       ✅ APPROVED: {sig['symbol']} (Conf: {conf:.2f})")
-                
-                # إضافة الأهداف المقترحة
+                log_and_print(f"       ✅ APPROVED: {sig['symbol']} (Conf: {oracle_dec.get('confidence',0):.2f})")
                 sig['tp_price'] = oracle_dec.get('tp_price')
                 sig['sl_price'] = oracle_dec.get('sl_price')
                 approved_signals.append(sig)
             else:
                 log_and_print(f"       ❌ REJECTED: {sig['symbol']} ({oracle_dec.get('reason')})")
 
-        # 5. القناص (L4 Sniper Execution)
+        # 5. التنفيذ (L4 Sniper)
         if approved_signals:
-            log_and_print(f"   [4/4] 🎯 L4 Sniper Execution Batch ({len(approved_signals)} signals)...")
-            
-            # التقاط مخرجات TradeManager لإضافتها للسجل
+            log_and_print(f"   [4/4] 🎯 L4 Sniper Execution Batch...")
             tm_log_buffer = StringIO()
             with redirect_stdout(tm_log_buffer), redirect_stderr(tm_log_buffer):
-                # TradeManager يستدعي القناص داخلياً عبر المعالج
                 await trade_manager.select_and_execute_best_signal(approved_signals)
             
             tm_logs = tm_log_buffer.getvalue()
             print(tm_logs) 
             log_buffer.write(tm_logs + '\n')
         else:
-            log_and_print("   -> 🛑 لا توجد إشارات معتمدة من Oracle لإرسالها للقناص.")
+            log_and_print("   -> 🛑 لا توجد إشارات معتمدة.")
 
-        # تنظيف الذاكرة
         gc.collect()
-        log_and_print(f"🌀 [Cycle END] {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
+        log_and_print(f"🌀 [Cycle END] {datetime.now().strftime('%H:%M:%S')}")
         sys_state.set_cycle_end(logs=log_buffer.getvalue())
 
     except Exception as e:
@@ -446,28 +398,23 @@ async def run_unified_cycle():
 # 🎓 Training Logic (منطق التدريب)
 # ==============================================================================
 async def trigger_training_cycle():
-    """
-    يتم استدعاؤه يدوياً من زر الواجهة لبدء التدريب.
-    """
+    """يتم استدعاؤه يدوياً من الزر لبدء التدريب"""
     if sys_state.cycle_running or len(trade_manager.open_positions) > 0:
-        return "⚠️ Cannot start training while trading or scanning is active."
+        return "⚠️ لا يمكن التدريب أثناء التداول أو البحث."
     
     if sys_state.training_running:
-        return "⚠️ Training is already in progress."
+        return "⚠️ التدريب يعمل بالفعل."
 
-    # ضبط الحالة
     sys_state.training_running = True
-    msg = "⏳ Training Started... Check console logs for progress."
+    msg = "⏳ Training Started... Check console logs."
     
-    # تشغيل التدريب في الخلفية
     asyncio.create_task(_run_training_bg())
     return msg
 
 async def _run_training_bg():
-    print("\n🏋️‍♂️ [System] Starting Manual Training Cycle (Background Task)...")
+    print("\n🏋️‍♂️ [System] Starting Manual Training Cycle...")
     try:
         if hub_manager:
-            # استدعاء المدير لتنفيذ الجلسة
             result_msg = await hub_manager.execute_training_session()
             print(f"🏋️‍♂️ [System] Training Result: {result_msg}")
             sys_state.last_cycle_logs = f"🎓 Training Report: {result_msg}"
@@ -477,53 +424,40 @@ async def _run_training_bg():
         print(f"❌ [System] Training Failed: {e}")
         traceback.print_exc()
     finally:
-        # إعادة الحالة للوضع الطبيعي
         sys_state.training_running = False
         print("🏋️‍♂️ [System] Training Cycle Ended.")
 
 # ==============================================================================
-# 📊 [UI Logic] منطق العرض والتفاعل (Full Stats Restored)
+# 📊 [UI Logic] منطق العرض والتفاعل (Full Stats)
 # ==============================================================================
 
 async def manual_close_current_trade():
-    """زر الإغلاق اليدوي"""
     if not trade_manager or not trade_manager.open_positions:
-        return "⚠️ لا توجد صفقة مفتوحة لإغلاقها."
-    
+        return "⚠️ لا توجد صفقة مفتوحة."
     symbol = list(trade_manager.open_positions.keys())[0]
     await trade_manager.force_exit_by_manager(symbol, reason="MANUAL_UI_BUTTON")
-    return f"✅ تم إرسال أمر إغلاق فوري لـ {symbol}."
+    return f"✅ تم إرسال أمر إغلاق لـ {symbol}."
 
 async def reset_stats_handler():
-    """زر تصفير الإحصائيات"""
     if trade_manager and len(trade_manager.open_positions) > 0:
-        return "⚠️ لا يمكن التصفير أثناء وجود صفقة مفتوحة. أغلقها أولاً."
-    
+        return "⚠️ أغلق الصفقة أولاً."
     success = await r2.reset_all_stats_async()
-    if success: return "✅ تم تصفير الحساب والسجلات بنجاح."
-    else: return "❌ فشل عملية التصفير."
+    if success: return "✅ تم التصفير بنجاح."
+    else: return "❌ فشل التصفير."
 
 async def toggle_auto_pilot(enable):
-    """زر تبديل الطيار الآلي"""
     sys_state.auto_pilot = enable
     status = "مفعل (ON)" if enable else "متوقف (OFF)"
-    return f"تم تغيير وضع الطيار الآلي إلى: {status}"
+    return f"الطيار الآلي: {status}"
 
 async def run_cycle_from_gradio():
-    """زر التشغيل اليدوي"""
     if sys_state.cycle_running: return "الدورة تعمل بالفعل."
     if sys_state.training_running: return "النظام مشغول بالتدريب."
-    
-    # تشغيل في الخلفية لعدم تجميد الواجهة
     asyncio.create_task(run_unified_cycle())
-    return "🚀 تم إطلاق الدورة يدوياً... راجع السجلات."
+    return "🚀 تم الإطلاق يدوياً..."
 
 async def check_live_pnl_and_status(selected_view="Hybrid System"):
-    """
-    تحديث دوري للواجهة.
-    يتم استدعاء هذه الدالة كل 3 ثواني لتحديث الشارت والأرقام.
-    """
-    # القيم الافتراضية في حال الخطأ أو التهيئة
+    # تهيئة المخرجات الافتراضية
     empty_chart = go.Figure()
     empty_chart.update_layout(
         template="plotly_dark", paper_bgcolor="#0b0f19", plot_bgcolor="#0b0f19",
@@ -536,12 +470,10 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         return "Initializing...", "...", empty_chart, "0.0", "0.0", "0.0", "0.0", "0.0%", wl_df_empty, "Loading...", "Loading...", "Checking..."
 
     try:
-        # 1. جلب بيانات المحفظة من R2
+        # 1. بيانات المحفظة
         portfolio = await r2.get_portfolio_state_async()
         curr_cap = portfolio.get('current_capital_usd', 100.0)
         first_ts = portfolio.get('first_trade_timestamp')
-        
-        # حساب وقت التشغيل
         uptime_str = calculate_duration_str(first_ts)
         
         total_t = portfolio.get('total_trades', 0)
@@ -554,7 +486,7 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         net_prof = tot_prof - tot_loss
         win_rate = (wins / total_t * 100) if total_t > 0 else 0.0
 
-        # 2. بيانات الصفقة النشطة (إن وجدت)
+        # 2. الصفقة النشطة
         symbol = None
         entry_p = 0.0; tp_p = 0.0; sl_p = 0.0; curr_p = 0.0
         pnl_val = 0.0; pnl_pct = 0.0
@@ -563,12 +495,10 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         if trade_manager.open_positions:
             symbol = list(trade_manager.open_positions.keys())[0]
             trade = trade_manager.open_positions[symbol]
-            
             entry_p = float(trade.get('entry_price', 0.0))
             tp_p = float(trade.get('tp_price', 0.0))
             sl_p = float(trade.get('sl_price', 0.0))
             trade_dur_str = calculate_duration_str(trade.get('entry_time'))
-            
             curr_p = await data_manager.get_latest_price_async(symbol)
             if curr_p > 0 and entry_p > 0:
                 pnl_pct = ((curr_p - entry_p) / entry_p) * 100
@@ -577,7 +507,7 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         final_bal = curr_cap + pnl_val
         wallet_color = "#00ff00" if pnl_val >= 0 else "#ff0000"
 
-        # 3. HTML المحفظة (Wallet Box) - تصميم كامل
+        # 3. HTML المحفظة
         wallet_md = f"""
         <div style='background-color: #1a1a1a; padding: 15px; border-radius: 8px; border: 1px solid #333; text-align:center;'>
             <h3 style='margin:0; color:#888; font-size:14px;'>💰 Live Wallet</h3>
@@ -600,28 +530,13 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         </div>
         """
 
-        # 4. إحصائيات الذكاء الاصطناعي (Stats Box)
-        # تحديد المفتاح بناءً على القائمة المنسدلة
-        key_map = {
-            "Hybrid System": "hybrid",
-            "Model V2 (Radar)": "v2",
-            "Model V3 (Sniper)": "v3"
-        }
+        # 4. HTML الإحصائيات
+        key_map = {"Hybrid System": "hybrid", "Model V2 (Radar)": "v2", "Model V3 (Sniper)": "v3"}
         target_key = key_map.get(selected_view, "hybrid")
-        
         stats_data = trade_manager.ai_stats.get(target_key, {"total":0, "good":0, "saved":0.0, "missed":0.0})
-        
         tot_ds = stats_data['total']
         ds_acc = (stats_data['good'] / tot_ds * 100) if tot_ds > 0 else 0.0
         
-        # العنوان الديناميكي
-        title_map = {
-            "hybrid": "🧠 Hybrid Guardian IQ",
-            "v2": "📡 Model V2 (Radar)",
-            "v3": "🎯 Model V3 (Sniper)"
-        }
-        stats_title = title_map.get(target_key, "DeepSteward IQ")
-
         history_md = f"""
         <div style='background-color: #1a1a1a; padding: 10px; border-radius: 8px; border: 1px solid #333; font-size: 12px;'>
             <h3 style='margin:0 0 5px 0; color:#888; font-size:14px;'>📊 Performance</h3>
@@ -632,10 +547,8 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
                 <tr><td style='padding:2px;'>Losses:</td><td style='text-align:right; color:#ff0000;'>{losses} (-${tot_loss:,.2f})</td></tr>
                 <tr><td style='border-top:1px solid #444; padding-top:5px;'>Net Profit:</td><td style='border-top:1px solid #444; text-align:right; padding-top:5px; color:{"#00ff00" if net_prof>=0 else "#ff0000"};'>${net_prof:,.2f}</td></tr>
             </table>
-            
             <hr style='border-color:#444; margin: 8px 0;'>
-            
-            <h3 style='margin:0 0 5px 0; color: #00e5ff; font-size:14px;'>{stats_title}</h3>
+            <h3 style='margin:0 0 5px 0; color: #00e5ff; font-size:14px;'>🧠 AI IQ ({target_key})</h3>
             <table style='width:100%; color:white;'>
                 <tr><td>Interventions:</td><td style='text-align:right;'>{tot_ds}</td></tr>
                 <tr><td>Accuracy:</td><td style='text-align:right; color:#00e5ff;'>{ds_acc:.1f}%</td></tr>
@@ -645,70 +558,45 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         </div>
         """
 
-        # 5. الرسم البياني (Chart)
+        # 5. الشارت
         fig = empty_chart
         if symbol and curr_p > 0:
             ohlcv = await data_manager.get_latest_ohlcv(symbol, '5m', 120)
-            if ohlcv and len(ohlcv) > 0:
+            if ohlcv:
                 df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
                 df['datetime'] = pd.to_datetime(df['timestamp'], unit='ms')
-
                 fig = go.Figure(data=[go.Candlestick(
-                    x=df['datetime'],
-                    open=df['open'], high=df['high'], low=df['low'], close=df['close'],
-                    increasing_line_color='#00ff00', decreasing_line_color='#ff0000',
-                    name=symbol
+                    x=df['datetime'], open=df['open'], high=df['high'], low=df['low'], close=df['close'],
+                    increasing_line_color='#00ff00', decreasing_line_color='#ff0000', name=symbol
                 )])
-                
-                # خطوط المستويات
-                fig.add_hline(y=entry_p, line_dash="dash", line_color="white", opacity=0.5, annotation_text="Entry")
+                fig.add_hline(y=entry_p, line_dash="dash", line_color="white", annotation_text="Entry")
                 fig.add_hline(y=tp_p, line_color="#00ff00", line_width=1, annotation_text="TP")
                 fig.add_hline(y=sl_p, line_color="#ff0000", line_width=1, annotation_text="SL")
+                fig.update_layout(template="plotly_dark", paper_bgcolor="#0b0f19", plot_bgcolor="#0b0f19",
+                                  margin=dict(l=0, r=50, t=30, b=0), height=400, xaxis_rangeslider_visible=False,
+                                  title=dict(text=f"{symbol} (5m)", font=dict(color="white")))
 
-                fig.update_layout(
-                    template="plotly_dark",
-                    paper_bgcolor="#0b0f19",
-                    plot_bgcolor="#0b0f19",
-                    margin=dict(l=0, r=50, t=30, b=0),
-                    height=400, 
-                    xaxis_rangeslider_visible=False,
-                    title=dict(text=f"{symbol} (5m)", x=0.05, font=dict(color="white", size=14)),
-                    yaxis=dict(side='right', gridcolor='#222')
-                )
-
-        # 6. قائمة المراقبة (Watchlist)
+        # 6. Watchlist
         wl_data = [[k, f"{v.get('final_total_score',0):.2f}"] for k, v in trade_manager.watchlist.items()]
         wl_df = pd.DataFrame(wl_data, columns=["Coin", "Score"])
 
+        # 7. الحالة
         status_txt = sys_state.last_cycle_logs
         status_line = f"Status: {'SCANNING' if sys_state.cycle_running else 'IDLE'} | Auto-Pilot: {'ON' if sys_state.auto_pilot else 'OFF'}"
         
-        # 7. حالة التدريب
         train_status = sys_state.training_status_msg
         if sys_state.training_running:
             train_status = "🏋️‍♂️ Training In Progress (Please Wait)..."
 
-        return (
-            status_txt, 
-            status_line, 
-            fig, 
-            f"{curr_p:.6f}", 
-            f"{entry_p:.6f}", 
-            f"{tp_p:.6f}", 
-            f"{sl_p:.6f}",
-            f"{pnl_pct:+.2f}%", 
-            wl_df, 
-            wallet_md, 
-            history_md,
-            train_status
-        )
+        return (status_txt, status_line, fig, f"{curr_p:.6f}", f"{entry_p:.6f}", f"{tp_p:.6f}", f"{sl_p:.6f}",
+                f"{pnl_pct:+.2f}%", wl_df, wallet_md, history_md, train_status)
 
     except Exception:
         traceback.print_exc()
         return "Error", "Error", empty_chart, "0", "0", "0", "0", "0%", wl_df_empty, "Err", "Err", "Err"
 
 # ==============================================================================
-# 🚀 Gradio UI Definition (The Dashboard)
+# 🚀 Gradio UI Definition
 # ==============================================================================
 def create_gradio_ui():
     css = """
@@ -718,118 +606,97 @@ def create_gradio_ui():
     .html-box { min-height: 180px; }
     """
 
-    with gr.Blocks(title="Titan V23.5 Pro Dashboard", css=css, theme=gr.themes.Monochrome()) as demo:
+    with gr.Blocks(title="Titan V23.6 Pro Dashboard", css=css, theme=gr.themes.Monochrome()) as demo:
         
-        gr.Markdown("# 🚀 Titan V23.5 Enterprise (Learning Core)")
+        gr.Markdown("# 🚀 Titan V23.6 Enterprise (Full Stats & Learning)")
         
-        # --- الصف العلوي: الشارت + الإحصائيات ---
         with gr.Row():
-            # العمود الأيسر: الشارت + تفاصيل السعر
             with gr.Column(scale=3):
                 live_chart_plot = gr.Plot(label="Live Chart", container=True)
-                
                 with gr.Row():
                     t_price = gr.Textbox(label="Current Price", interactive=False)
                     t_pnl = gr.Textbox(label="PnL %", interactive=False)
-                
                 with gr.Row():
                     t_entry = gr.Textbox(label="Entry", interactive=False)
                     t_tp = gr.Textbox(label="Target (TP)", interactive=False)
                     t_sl = gr.Textbox(label="Stop (SL)", interactive=False)
 
-            # العمود الأيمن: المحفظة والإحصائيات
             with gr.Column(scale=1):
                 wallet_output = gr.HTML(label="Wallet", elem_classes="html-box")
-                
                 stats_dropdown = gr.Dropdown(
                     choices=["Hybrid System", "Model V2 (Radar)", "Model V3 (Sniper)"],
-                    value="Hybrid System",
-                    label="Select AI View",
-                    interactive=True
+                    value="Hybrid System", label="Select AI View", interactive=True
                 )
-                
                 history_output = gr.HTML(label="Stats", elem_classes="html-box")
                 watchlist_output = gr.DataFrame(label="Watchlist", interactive=False)
                 
         gr.HTML("<hr style='border-color: #333;'>")
         
-        # --- الصف السفلي: التحكم والسجلات والتدريب ---
         with gr.Row():
             with gr.Column(scale=1):
-                gr.Markdown("## 🎮 Control & Learning")
-                
-                auto_pilot_checkbox = gr.Checkbox(
-                    label="✈️ Auto-Pilot", 
-                    value=True
-                )
+                gr.Markdown("## 🎮 Controls & Learning")
+                auto_pilot_checkbox = gr.Checkbox(label="✈️ Auto-Pilot", value=True)
                 
                 with gr.Row():
                     run_cycle_btn = gr.Button("🚀 Scan Now", variant="primary")
                     close_trade_btn = gr.Button("🚨 Panic Close", variant="stop")
                 
                 with gr.Row():
-                    # زر التدريب الجديد 🎓
                     train_btn = gr.Button("🎓 Train Model", variant="secondary")
                     reset_stats_btn = gr.Button("🗑️ Reset Stats")
                 
                 status_markdown = gr.Markdown("Initializing...")
-                
-                # صندوق حالة التدريب الجديد
                 train_status_box = gr.Textbox(label="Learning Status", interactive=False, value="Checking data...")
                 alert_box = gr.Textbox(label="Alerts", interactive=False, visible=True)
 
             with gr.Column(scale=3):
                 gr.Markdown("## 📜 System Logs")
-                cycle_logs_output = gr.Textbox(
-                    lines=12, 
-                    autoscroll=True,
-                    max_lines=50,
-                    value="Waiting for logs..."
-                )
+                cycle_logs_output = gr.Textbox(lines=12, autoscroll=True, max_lines=50, value="Waiting for logs...")
 
-        # --- التفاعلات (Events Wiring) ---
+        # التفاعلات
         run_cycle_btn.click(fn=run_cycle_from_gradio, inputs=None, outputs=alert_box)
         close_trade_btn.click(fn=manual_close_current_trade, inputs=None, outputs=alert_box)
         reset_stats_btn.click(fn=reset_stats_handler, inputs=None, outputs=alert_box)
         auto_pilot_checkbox.change(fn=toggle_auto_pilot, inputs=auto_pilot_checkbox, outputs=alert_box)
         train_btn.click(fn=trigger_training_cycle, inputs=None, outputs=alert_box)
         
-        # المؤقت الدوري (كل 3 ثواني) - يجب أن يطابق عدد المخرجات
+        # المؤقت
         timer = gr.Timer(3) 
         timer.tick(
             fn=check_live_pnl_and_status,
             inputs=[stats_dropdown],
             outputs=[
-                cycle_logs_output, 
-                status_markdown, 
-                live_chart_plot,
-                t_price,
-                t_entry,
-                t_tp,
-                t_sl,
-                t_pnl,
-                watchlist_output,
-                wallet_output,   
-                history_output,
-                train_status_box # المخرج الجديد
+                cycle_logs_output, status_markdown, live_chart_plot,
+                t_price, t_entry, t_tp, t_sl, t_pnl,
+                watchlist_output, wallet_output, history_output,
+                train_status_box
             ]
         )
         
     return demo
 
 # ==============================================================================
-# 🏁 تشغيل الخادم (Server Entry Point)
+# 🏁 تشغيل الخادم (The Initialization Fix)
 # ==============================================================================
-app = FastAPI(
+
+# 1. إنشاء تطبيق FastAPI الأساسي
+fast_api_server = FastAPI(
     lifespan=lifespan, 
-    title="Titan V23.5 Pro", 
+    title="Titan V23.6 Pro", 
     description="Titan Enterprise Trading System"
 )
 
+# 2. إنشاء الواجهة
 gradio_dashboard = create_gradio_ui()
-app = gr.mount_gradio_app(app, gradio_dashboard, path="/")
+
+# 3. دمج الواجهة مع الخادم
+app = gr.mount_gradio_app(
+    app=fast_api_server,
+    blocks=gradio_dashboard,
+    path="/"
+)
 
 if __name__ == "__main__":
     import uvicorn
-    # تشغيل الخادم على جميع الواجهات (0.0.0.0)
+    # تشغيل الخادم
     uvicorn.run(app, host="0.0.0.0", port=7860)