Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py (V17.3 - FastAPI Core + Gradio UI - Timer Tick Fix)
+# app.py (V17.6 - Full Logic Restored + Interface Fixes)
 import os
 import sys
 import traceback
@@ -12,12 +12,12 @@ from io import StringIO
 from fastapi import FastAPI, HTTPException, BackgroundTasks
 from typing import List, Dict, Any
 
-# [ 💡 إضافة جديدة 💡 ] استيراد مكتبات الواجهة
+# [ استيراد مكتبات الواجهة ]
 import gradio as gr
 import pandas as pd
 import matplotlib.pyplot as plt
 import matplotlib.dates as mdates
-plt.switch_backend('Agg') # (مهم لـ Matplotlib في بيئة خادم)
+plt.switch_backend('Agg') # مهم جداً لبيئة السيرفر
 
 # ==============================================================================
 # 📥 استيراد الوحدات الأساسية (Core Modules Imports)
@@ -39,7 +39,6 @@ except ImportError as e:
 # ==============================================================================
 # 🌐 المتغيرات العامة وحالة النظام (Global State)
 # ==============================================================================
-# (كل هذا يبقى كما هو)
 r2: R2Service = None
 data_manager: DataManager = None
 ml_processor: MLProcessor = None
@@ -59,7 +58,6 @@ UNIFIED_MODELS_DIR = os.path.join(BASE_DIR, "ml_models", "Unified_Models_V1")
 # ==============================================================================
 # 🔄 حالة النظام (System State)
 # ==============================================================================
-# (تبقى كما هي)
 class SystemState:
     def __init__(self):
         self.ready = False
@@ -67,16 +65,16 @@ class SystemState:
         self.last_cycle_time: datetime = None
         self.last_cycle_error = None
         self.app_start_time = datetime.now()
-        # [ 💡 إضافة جديدة 💡 ] مخزن مؤقت لآخر سجلات الدورة
+        # مخزن مؤقت لآخر سجلات الدورة
         self.last_cycle_logs = "النظام قيد التهيئة... يرجى الانتظار."
 
     def set_ready(self): 
         self.ready = True
-        self.last_cycle_logs = "✅ النظام جاهز. يمكنك بدء الدورة."
+        self.last_cycle_logs = "✅ النظام جاهز. اضغط 'بدء' للعمل."
     
     def set_cycle_start(self): 
         self.cycle_running = True
-        self.last_cycle_logs = "🌀 [Cycle START] جاري البحث عن إشارات..."
+        self.last_cycle_logs = "🌀 [Cycle START] جاري العمل..."
 
     def set_cycle_end(self, error=None, logs=None):
         self.cycle_running = False
@@ -87,50 +85,56 @@ class SystemState:
         elif error:
             self.last_cycle_logs = f"❌ [Cycle ERROR] {error}"
         else:
-            self.last_cycle_logs = f"✅ [Cycle END] {datetime.now().strftime('%H:%M:%S')}. الدورة اكتملت."
+            self.last_cycle_logs = f"✅ [Cycle END] {datetime.now().strftime('%H:%M:%S')}. الدورة انتهت."
 
 sys_state = SystemState()
 
 # ==============================================================================
 # 🚀 تهيئة التطبيق ودورة الحياة (Lifespan)
 # ==============================================================================
-# (دالة lifespan تبقى كما هي 100%)
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     global r2, data_manager, ml_processor, trade_manager, oracle_engine
     global whale_monitor, news_fetcher, senti_analyzer, guard_engine, sniper_engine, sys_state
     
-    print("🚀 [FastAPI] بدء التشغيل (Startup Event)...")
+    print("🚀 [System] Starting Up (V17.6 Full)...")
     print("------------------------------------------------------")
     
     try:
-        # ( ... كل كود التهيئة ... )
         print("   [1/8] تهيئة R2Service...")
         r2 = R2Service()
+        
         print("   [2/8] تهيئة DataManager...")
         data_manager = DataManager(contracts_db={}, whale_monitor=None, r2_service=r2)
         await data_manager.initialize() 
         await data_manager.load_contracts_from_r2()
+
         print("   [3/8] تهيئة L2 Services (Whales, News, Sentiment)...")
         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
+
         print(f"   [4/8] تهيئة OracleEngine (L3 Brain) من {UNIFIED_MODELS_DIR}...")
         oracle_engine = OracleEngine(model_dir=UNIFIED_MODELS_DIR)
         await oracle_engine.initialize()
+
         print("   [5/8] (تم تخطي LearningHub - مدمج في Oracle)")
+
         print("   [6/8] تهيئة MLProcessor (L1 Engine)...")
         ml_processor = MLProcessor(market_context=None, data_manager=data_manager, learning_hub=None) 
         await ml_processor.initialize()
+        
         print(f"   -> [Guard Path] استخدام المسار المشترك للحارس: {SHARED_GUARD_MODELS_DIR}")
+        
         print("   [7/8] تهيئة GuardEngine (L2 Exit Protector)...")
         guard_engine = GuardEngine(models_dir=SHARED_GUARD_MODELS_DIR) 
         await guard_engine.initialize()
+
         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.35) # (العتبة الجديدة 35%)
+        sniper_engine.set_entry_threshold(0.35) # العتبة المحدثة
         
         print("   [FINAL] تهيئة TradeManager...")
         trade_manager = TradeManager(
@@ -141,6 +145,7 @@ async def lifespan(app: FastAPI):
             guard_engine=guard_engine,
             sniper_engine=sniper_engine
         )
+        # تحميل الحالة فوراً من R2
         await trade_manager.initialize_sentry_exchanges()
         await trade_manager.start_sentry_loops()
         
@@ -156,16 +161,15 @@ async def lifespan(app: FastAPI):
         traceback.print_exc()
 
     finally:
-        print("\n🛑 [FastAPI] بدء إيقاف التشغيل (Shutdown Event)...")
+        print("\n🛑 [System] بدء إيقاف التشغيل...")
         sys_state.ready = False
         if trade_manager: await trade_manager.stop_sentry_loops()
         if data_manager: await data_manager.close()
         print("✅ [System SHUTDOWN] تم إغلاق جميع الاتصالات.")
 
 # ==============================================================================
-# 🧠 دوال التحليل المساعدة (تبقى كما هي)
+# 🧠 دوال التحليل المساعدة
 # ==============================================================================
-# (دالة _analyze_symbol_task تبقى كما هي 100%)
 async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
     global data_manager, ml_processor
     try:
@@ -187,13 +191,14 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
         return None
 
 # ==============================================================================
-# [ 🚀 🚀 🚀 ] الدورة الموحدة (النسخة الكاملة V15.17 - Batch Selection)
+# [ 🚀 🚀 🚀 ] الدورة الموحدة (Logic Restored + R2 Priority)
 # ==============================================================================
-# (دالة run_unified_cycle تبقى كما هي 100%)
 async def run_unified_cycle():
     """
-    دورة التحليل الكاملة: L1 -> L2 -> L3 (Oracle) -> L4 (Sniper Batch).
-    (معدلة لتخزين السجلات في sys_state)
+    دورة التحليل الكاملة: L1 -> L2 -> L3 -> L4.
+    - تتحقق أولاً من وجود صفقات مفتوحة.
+    - إذا وجدت، تقوم بفحص صحي (Health Check) وتتوقف.
+    - إذا لم تجد، تبدأ البحث الكامل (Full Scan).
     """
     
     # (إعداد التقاط السجلات)
@@ -216,6 +221,51 @@ async def run_unified_cycle():
     log_and_print(f"\n🌀 [Cycle START] {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
     
     try:
+        # -----------------------------------------------------------
+        # 1. [ 🛑 الفحص الحاسم ] هل لدينا صفقة مفتوحة؟
+        # -----------------------------------------------------------
+        if trade_manager.open_positions:
+            symbol = list(trade_manager.open_positions.keys())[0]
+            log_and_print(f"⚠️ [System Limit] توجد صفقة مفتوحة بالفعل على {symbol}.")
+            log_and_print(f"   -> 🛑 تم إلغاء البحث عن فرص جديدة (قاعدة الصفقة الواحدة).")
+            log_and_print(f"   -> 🩺 جاري تشغيل 'إعادة التحليل' (Health Check) للصفقة الحالية...")
+            
+            # --- إعادة تحليل الصفقة المفتوحة ---
+            analysis = await _analyze_symbol_task(symbol)
+            if analysis:
+                score = analysis.get('enhanced_final_score', 0.0)
+                comps = analysis.get('components', {})
+                
+                log_and_print(f"\n📊 [Health Report] {symbol}")
+                log_and_print(f"   - Current L1 Score: {score:.2f}")
+                log_and_print(f"   - Titan: {comps.get('titan_score', 0):.2f} | Patterns: {comps.get('patterns_score', 0):.2f} | MC: {comps.get('mc_score', 0):.2f}")
+                
+                # فحص العقل
+                log_and_print("   -> 🧠 استشارة Oracle للصفقة المفتوحة...")
+                oracle_res = await oracle_engine.predict(analysis)
+                action = oracle_res.get('action', 'WAIT')
+                conf = oracle_res.get('confidence', 0.0)
+                reason = oracle_res.get('analysis_summary') or oracle_res.get('reason')
+                log_and_print(f"   -> Oracle Says: {action} (Conf: {conf:.2f})")
+                log_and_print(f"      Reason: {reason}")
+                
+                # فحص الحارس
+                log_and_print("   -> 🛡️ استشارة Guard V2 للخروج...")
+                if '5m' in analysis['ohlcv']:
+                    guard_res = await guard_engine.check_exit_signal_async(analysis['ohlcv']['5m'])
+                    log_and_print(f"   -> Guard Says: {guard_res['action']} (Conf: {guard_res['confidence']:.2f})")
+                
+            else:
+                log_and_print(f"⚠️ فشل تحليل البيانات لـ {symbol}.")
+
+            log_and_print(f"\n✅ انتهت دورة المتابعة. النظام يراقب {symbol}.")
+            sys_state.set_cycle_end(logs=log_buffer.getvalue())
+            return
+
+        # -----------------------------------------------------------
+        # 2. (اذا لم توجد صفقات) -> ابدأ البحث الكامل (Restored Logic)
+        # -----------------------------------------------------------
+        
         # --- 1. الغربلة الأولية (L1) ---
         log_and_print("   [Cycle 1/5] 🔍 بدء الغربلة السريعة (L1 Screening)...")
         candidates_to_analyze = await data_manager.layer1_rapid_screening()
@@ -249,6 +299,7 @@ async def run_unified_cycle():
             sys_state.set_cycle_end(logs=log_buffer.getvalue()); return
 
         # --- 2. التعزيز وحساب نقاط الطبقة الثانية (L2 Boosting) ---
+        # [ تم استعادة الكود الكامل هنا ]
         log_and_print(f"\n   [Cycle 2/5] 🚀 بدء تعزيز النقاط (L2 Boosting) لأفضل 10 عملات...")
         l2_enriched_candidates = []
         
@@ -267,7 +318,7 @@ async def run_unified_cycle():
                 if net_flow <= -500000: whale_score = 0.10
                 elif net_flow < 0: whale_score = 0.05
             except Exception as e: log_and_print(f"       ⚠️ [Whale Error] {symbol}: {e}")
-            candidate['whale_data'] = {} # (توفير الذاكرة)
+            candidate['whale_data'] = {} 
 
             # (ب. الأخبار)
             try:
@@ -280,7 +331,7 @@ async def run_unified_cycle():
                     if compound >= 0.5: news_score = 0.05
                     elif compound >= 0.1: news_score = 0.02
             except Exception as e: log_and_print(f"       ⚠️ [News Error] {symbol}: {e}")
-            candidate['news_text'] = "..." # (توفير الذاكرة)
+            candidate['news_text'] = "..." 
 
             # (ج. مونت كارلو المتقدمة)
             try:
@@ -333,6 +384,12 @@ async def run_unified_cycle():
                 oracle_decision = await oracle_engine.predict(signal)
                 action = oracle_decision.get('action'); confidence = oracle_decision.get('confidence', 0.0)
                 reason = oracle_decision.get('analysis_summary') or oracle_decision.get('reason', 'No summary provided')
+                
+                # [فلترة إشارات الشورت]
+                if "SHORT" in str(reason).upper() or "SHORT" in str(oracle_decision.get('strategy')).upper():
+                    log_and_print(f"       🛑 [Oracle SKIP] {symbol} تم تجاهلها (إشارة بيع SHORT).")
+                    continue
+
                 if action == 'WATCH': 
                     log_and_print(f"       🔥 [Oracle APPROVED] {symbol} (Conf: {confidence:.2f})")
                     log_and_print(f"           📝 Reason: {reason}")
@@ -353,7 +410,7 @@ async def run_unified_cycle():
         if oracle_approved_signals:
             log_and_print(f"   -> 🎯 [L4 Sniper Batch] إرسال {len(oracle_approved_signals)} إشارة للقناص للفرز النهائي واختيار الأفضل...")
             
-            # [ 💡 تعديل 💡 ] تحويل طباعة TradeManager إلى السجل
+            # التقاط سجلات TradeManager
             tm_log_buffer = StringIO()
             with redirect_stdout(tm_log_buffer), redirect_stderr(tm_log_buffer):
                 await trade_manager.select_and_execute_best_signal(oracle_approved_signals)
@@ -376,244 +433,157 @@ async def run_unified_cycle():
         sys_state.set_cycle_end(error=e, logs=log_buffer.getvalue())
 
 # ==============================================================================
-# 🚦 نقاط النهاية (FastAPI Endpoints)
+# 🔧 دوال مساعدة للواجهة (تنسيق الأرقام) - [جديد]
 # ==============================================================================
-# (هذا هو تطبيق FastAPI الرئيسي)
-app = FastAPI(
-    lifespan=lifespan, 
-    title="Titan V17 (FastAPI Core + Gradio UI)", 
-    description="نظام تداول آلي هجين (L1/L2/L3-ML) مع واجهة مراقبة Gradio مدمجة"
-)
-
-# (نقطة النهاية الجذرية الأصلية - سيتم استبدالها بـ Gradio)
-# @app.get("/")
-# async def root_status(): ... (تم التعليق)
-
-@app.get("/run-cycle")
-async def trigger_cycle_endpoint(background_tasks: BackgroundTasks):
-    """
-    (تبقى كما هي 100% - الخادم الخارجي يعتمد عليها)
-    """
-    if not sys_state.ready:
-        raise HTTPException(status_code=503, detail="System is still initializing.")
-    if sys_state.cycle_running:
-        raise HTTPException(status_code=429, detail="Cycle is already running.")
-        
-    background_tasks.add_task(run_unified_cycle)
-    return {"status": "ACCEPTED", "message": "Unified smart cycle triggered (Batch Mode)."}
-
-@app.get("/status") 
-async def get_full_status():
-    """
-    (تبقى كما هي 100% - يمكن للخادم الخارجي استخدامها لإبقاء البوت مستيقظاً)
-    """
-    return {
-        "initialized": sys_state.ready,
-        "cycle_running": sys_state.cycle_running,
-        "active_trades_count": len(trade_manager.open_positions) if trade_manager else 0,
-        "active_trades": list(trade_manager.open_positions.keys()) if trade_manager else [],
-        "sentry_watchlist_count": len(trade_manager.watchlist) if trade_manager else 0,
-        "sentry_watchlist": list(trade_manager.watchlist.keys()) if trade_manager else []
-    }
+def fmt_price(price):
+    """تنسيق ذكي للأسعار: 8 خانات للعملات الصغيرة، 2 للكبيرة"""
+    if price is None or price == 0: return "0.00"
+    if price < 1.0: return f"{price:.8f}" # للعملات مثل SHIB
+    if price < 100: return f"{price:.4f}"
+    return f"{price:.2f}"
 
 # ==============================================================================
-# 📊 [ 💡 إضافة جديدة 💡 ] دوال الواجهة (Gradio Helpers)
+# 📊 واجهة Gradio وتحديث البيانات
 # ==============================================================================
-
 async def check_live_pnl_and_status():
-    """
-    [جديد] دالة يتم استدعاؤها كل 10 ثواني لتحديث الواجهة.
-    (هذه الدالة ليست Endpoint، هي دالة Python عادية تستدعيها Gradio)
-    """
-    global trade_manager, data_manager, sys_state
-    
     if not sys_state.ready:
-        return "النظام قيد التهيئة...", "...", "...", "...", "...", None, pd.DataFrame()
-
-    # 1. تحديث حالة النظام وقائمة المراقبة
-    try:
-        status_text = sys_state.last_cycle_logs # (يعرض آخر سجلات الدورة)
-        trade_count = len(trade_manager.open_positions)
-        watch_count = len(trade_manager.watchlist)
-        status_md = f"""
-        **الحالة:** {'<span style="color:green;">جاهز</span>' if not sys_state.cycle_running else '<span style="color:orange;">تحليل...</span>'} | 
-        **الصفقات الموفتوحة:** {trade_count} | 
-        **قائمة المراقبة:** {watch_count}
-        """
-        
-        watchlist_df = pd.DataFrame(list(trade_manager.watchlist.keys()), columns=["عملات المراقبة"])
-    except Exception as e:
-        return f"خطأ في جلب الحالة: {e}", "...", "...", "...", "...", None, pd.DataFrame()
+        return "جاري التهيئة...", "...", "...", "...", "...", None, pd.DataFrame()
+
+    # 1. الحالة العامة
+    log_text = sys_state.last_cycle_logs
+    n_trades = len(trade_manager.open_positions)
+    status_md = f"""
+    **الحالة:** {'<span style="color:green;">جاهز</span>' if not sys_state.cycle_running else '<span style="color:orange;">يحلل...</span>'} | 
+    **الصفقات:** {n_trades} | 
+    **المراقبة:** {len(trade_manager.watchlist)}
+    """
+    df_watch = pd.DataFrame(list(trade_manager.watchlist.keys()), columns=["Watchlist"])
 
-    # 2. التحقق من الصفقة المفتوحة
-    if not trade_manager.open_positions:
-        return status_text, status_md, "لا توجد صفقة مفتوحة", "---", "---", None, watchlist_df
+    # 2. لا توجد صفقات
+    if n_trades == 0:
+        return log_text, status_md, "### لا توجد صفقة نشطة", "---", "---", None, df_watch
 
+    # 3. عرض تفاصيل الصفقة (مع إصلاح الأصفار والمخطط)
     try:
         symbol = list(trade_manager.open_positions.keys())[0]
         trade = trade_manager.open_positions[symbol]
         
-        # 3. جلب السعر الحي
-        current_price = await data_manager.get_latest_price_async(symbol)
-        if current_price == 0.0:
-            return status_text, status_md, f"{symbol} (جاري جلب السعر...)", "...", "...", None, watchlist_df
-
-        entry_price = trade['entry_price']
-        pnl_pct = ((current_price - entry_price) / entry_price) * 100
+        curr_price = await data_manager.get_latest_price_async(symbol)
+        entry = trade['entry_price']
         
-        # 4. تحديد اللون
-        if pnl_pct > 0:
-            color = "green"
-            pnl_text = f"ربح {pnl_pct:.2f}%"
-        elif pnl_pct < 0:
-            color = "red"
-            pnl_text = f"خسارة {pnl_pct:.2f}%"
+        if curr_price > 0 and entry > 0:
+            pnl = ((curr_price - entry) / entry) * 100
         else:
-            color = "gray"
-            pnl_text = "تعادل 0.00%"
+            pnl = 0.0
 
-        symbol_md = f"### {symbol}"
-        pnl_md = f"<h2 style='color:{color}; text-align:center;'>{pnl_text}</h2>"
-        details_md = f"""
-        **سعر الدخول:** {entry_price:.4f}
-        **السعر الحالي:** {current_price:.4f}
-        **جني الأرباح (TP):** {trade['tp_price']:.4f}
-        **وقف الخسارة (SL):** {trade['sl_price']:.4f}
+        color = "green" if pnl >= 0 else "red"
+        pnl_html = f"<h2 style='color:{color}; text-align:center;'>{pnl:.2f}%</h2>"
+        
+        # [ إصلاح التنسيق ] استخدام fmt_price
+        details = f"""
+        **Entry:** {fmt_price(entry)}
+        **Current:** {fmt_price(curr_price)}
+        **TP:** {fmt_price(trade['tp_price'])}
+        **SL:** {fmt_price(trade['sl_price'])}
         """
+        
+        symbol_md = f"### {symbol}"
 
-        # 5. رسم المخطط
-        fig = None
+        # [ إصلاح المخطط ]
+        fig = plt.figure(figsize=(10, 5))
         try:
             ohlcv = await data_manager.get_latest_ohlcv(symbol, '5m', 100)
             if ohlcv:
-                df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
-                df['datetime'] = pd.to_datetime(df['timestamp'], unit='ms')
+                df = pd.DataFrame(ohlcv, columns=['ts', 'o', 'h', 'l', 'c', 'v'])
+                df['dt'] = pd.to_datetime(df['ts'], unit='ms')
                 
                 plt.style.use('dark_background')
-                fig, ax = plt.subplots(figsize=(10, 5))
-                df.plot(x='datetime', y='close', ax=ax, label=f'سعر {symbol} (5m)', color='cyan')
-                ax.axhline(y=entry_price, color='gray', linestyle='--', label=f'الدخول ({entry_price:.4f})')
-                ax.axhline(y=trade['tp_price'], color='green', linestyle=':', label=f'TP ({trade['tp_price']:.4f})')
-                ax.axhline(y=trade['sl_price'], color='red', linestyle=':', label=f'SL ({trade['sl_price']:.4f})')
-                ax.legend()
-                ax.set_title(f"مخطط {symbol} الحي")
-                ax.set_xlabel("الوقت")
-                ax.set_ylabel("السعر (USDT)")
-                ax.xaxis.set_major_formatter(mdates.DateFormatter('%H:%M'))
+                plt.plot(df['dt'], df['c'], label='Price', color='cyan')
+                plt.axhline(entry, color='gray', linestyle='--', label='Entry')
+                plt.axhline(trade['tp_price'], color='green', linestyle=':', label='TP')
+                plt.axhline(trade['sl_price'], color='red', linestyle=':', label='SL')
+                plt.title(f"{symbol} Live Chart")
+                plt.legend()
+                plt.gca().xaxis.set_major_formatter(mdates.DateFormatter('%H:%M'))
                 plt.tight_layout()
-        except Exception as e:
-            print(f"❌ خطأ في رسم المخطط: {e}")
+            else:
+                plt.text(0.5, 0.5, "No Data", ha='center', color='white')
+        except:
+            plt.close()
             fig = None
-            
-        return status_text, status_md, symbol_md, pnl_md, details_md, fig, watchlist_df
 
-    except Exception as e:
-        print(f"❌ خطأ فادح في check_live_pnl: {e}")
-        return status_text, status_md, f"خطأ: {e}", "...", "...", None, watchlist_df
+        return log_text, status_md, symbol_md, pnl_html, details, fig, df_watch
 
-async def run_cycle_from_gradio():
-    """
-    [جديد] دالة لتشغيل الدورة من زر الواجهة.
-    تقوم بالتقاط السجلات وإعادتها.
-    """
-    if sys_state.cycle_running:
-        return "الدورة قيد التشغيل بالفعل. يرجى الانتظار."
-    
-    # (استدعاء الدالة الأصلية المعدلة)
-    await run_unified_cycle()
-    
-    # (إرجاع السجلات التي خزنتها الدالة الأصلية)
-    return sys_state.last_cycle_logs
+    except Exception as e:
+        return log_text, status_md, f"Error: {e}", "...", "...", None, df_watch
 
 # ==============================================================================
-# 🚀 5. [ 💡 إضافة جديدة 💡 ] بناء وتثبيت واجهة Gradio
+# 📟 بناء الواجهة (UI Construction)
 # ==============================================================================
-
-def create_gradio_ui():
-    """
-    [جديد] إنشاء كائن واجهة Gradio.
-    """
-    css = """
-    #pnl_md { text-align: center; }
-    """
-
-    with gr.Blocks(title="لوحة تحكم Titan", css=css, theme=gr.themes.Monochrome()) as demo:
-        gr.Markdown("# 📊 لوحة تحكم Titan (مدمجة مع FastAPI)")
+def create_ui():
+    with gr.Blocks(title="Titan Dashboard", theme=gr.themes.Monochrome()) as demo:
+        gr.Markdown("# 📊 Titan Automated Trading System")
         
-        # (الجزء العلوي: مراقبة ا��أرباح الحية)
         with gr.Row():
             with gr.Column(scale=3):
-                live_chart = gr.Plot(label="المخطط الحي للصفقة")
+                chart = gr.Plot(label="Chart")
             with gr.Column(scale=1):
-                live_symbol = gr.Markdown("### لا توجد صفقة")
-                live_pnl = gr.Markdown("---", elem_id="pnl_md")
-                live_details = gr.Markdown("---")
-                
-        gr.HTML("<hr>") # فاصل
+                sym_lbl = gr.Markdown("### ...")
+                pnl_lbl = gr.HTML("---") # HTML للألوان
+                det_lbl = gr.Markdown("Waiting...")
         
-        # (الجزء السفلي: التحكم والسجلات)
         with gr.Row():
-            with gr.Column(scale=1):
-                gr.Markdown("## ⚙️ لوحة التحكم")
-                run_cycle_btn = gr.Button("🚀 (1) بدء دورة التحليل يدوياً")
-                gr.Markdown("## 📝 حالة النظام")
-                status_markdown = gr.Markdown(f"**الحالة:** {'جاري التهيئة...' if not sys_state.ready else 'جاهز'}")
-                watchlist_output = gr.DataFrame(label="قائمة المراقبة (Watchlist)")
+            btn = gr.Button("🚀 بدء دورة التحليل / فحص الحالة")
+            stat = gr.Markdown("**Status:** Initializing...")
+        
+        with gr.Row():
+            logs = gr.Textbox(label="Logs", lines=15, max_lines=30, autoscroll=True)
+            watch = gr.DataFrame(label="Watchlist")
 
-            with gr.Column(scale=3):
-                gr.Markdown("## 📜 سجلات آخر دورة تحليل")
-                cycle_logs_output = gr.Textbox(
-                    label="السجلات", 
-                    lines=20, 
-                    autoscroll=True,
-                    max_lines=100,
-                    value="...يتم تحميل السجلات عند انتهاء التهيئة..."
-                )
-
-        # (المنطق التفاعلي)
+        # Events
+        async def manual_run():
+            if sys_state.cycle_running: return "Busy..."
+            await run_unified_cycle()
+            return sys_state.last_cycle_logs
+
+        btn.click(manual_run, outputs=logs)
         
-        # 1. عند الضغط على الزر (لتشغيل الدورة يدوياً)
-        run_cycle_btn.click(
-            fn=run_cycle_from_gradio, # (استدعاء الدالة الوسيطة)
-            inputs=None, 
-            outputs=cycle_logs_output,
-            api_name="run_cycle_manual" # (يمكن استدعاؤها كـ API أيضاً)
+        # Timer (للتحديث التلقائي)
+        timer = gr.Timer(10)
+        timer.tick(
+            check_live_pnl_and_status, 
+            outputs=[logs, stat, sym_lbl, pnl_lbl, det_lbl, chart, watch]
         )
         
-        # 2. التحديث التلقائي (كل 15 ثانية) - [ 💡💡💡 هذا هو الإصلاح 💡💡💡 ]
-        
-        # (أ) تحميل البيانات مرة واحدة عند فتح الصفحة
+        # Load on start (للتحميل الأولي)
         demo.load(
-            fn=check_live_pnl_and_status,
-            inputs=None,
-            outputs=[cycle_logs_output, status_markdown, live_symbol, live_pnl, live_details, live_chart, watchlist_output]
+            check_live_pnl_and_status, 
+            outputs=[logs, stat, sym_lbl, pnl_lbl, det_lbl, chart, watch]
         )
 
-        # (ب) إنشاء مشغل مخفي يعمل كل 15 ثانية
-        timer = gr.Timer(15) 
-
-        # (ج) ربط المشغل بالدالة
-        timer.tick(
-            fn=check_live_pnl_and_status,
-            inputs=None,
-            outputs=[cycle_logs_output, status_markdown, live_symbol, live_pnl, live_details, live_chart, watchlist_output]
-        )
-        
     return demo
 
-# --- [ 💡 الأهم: دمج التطبيقين 💡 ] ---
-# 1. إنشاء واجهة Gradio
-gradio_dashboard = create_gradio_ui()
-# 2. تثبيت واجهة Gradio على تطبيق FastAPI في الرابط الرئيسي "/"
-app = gr.mount_gradio_app(app, gradio_dashboard, path="/")
-# (الآن `app` هو تطبيق FastAPI + Gradio المدمج)
-
-
 # ==============================================================================
-# 🏁 6. تشغيل الخادم المدمج
+# 🔥 التشغيل (Application Entry Point)
 # ==============================================================================
+app = FastAPI()
+
+# نقاط النهاية للخادم الخارجي (Cron Jobs)
+@app.get("/run-cycle")
+async def api_run(bg: BackgroundTasks):
+    if sys_state.cycle_running: return {"status": "Busy"}
+    bg.add_task(run_unified_cycle)
+    return {"status": "Started"}
+
+@app.get("/status")
+async def api_status():
+    return {"trades": len(trade_manager.open_positions) if trade_manager else 0}
+
+# دمج واجهة Gradio
+ui = create_ui()
+app = gr.mount_gradio_app(app, ui, path="/")
+
 if __name__ == "__main__":
     import uvicorn
-    port = int(os.environ.get("PORT", 7860))
-    # (نقوم بتشغيل `app` المدمجة)
-    uvicorn.run(app, host="0.0.0.0", port=port)
+    # --no-access-log لإخفاء إزعاج الطلبات
+    uvicorn.run(app, host="0.0.0.0", port=7860, access_log=False)