Update app.py

app.py

@@ -1,4 +1,6 @@
-# app.py (V22.2 - GEM-Architect: Full Source Code + Hybrid UI)
+# app.py (V22.3 - GEM-Architect: Full Source Code - Hybrid Guardian Edition)
+# Based on Original V21.3 logic with V4 Dual Brain Integration
+
 import os
 import sys
 import traceback
@@ -31,7 +33,8 @@ try:
     from vaderSentiment.vaderSentiment import SentimentIntensityAnalyzer
     from ml_engine.sniper_engine import SniperEngine
     
-    # [ 🧠 الجوهرة ] استيراد الحارس الهجين
+    # [ 🧠 الجوهرة ] استيراد الحارس الهجين (V4 Dual Brain)
+    # تم استبدال الاستيراد القديم بهذا الجديد
     from ml_engine.hybrid_guardian import HybridDeepSteward
     
 except ImportError as e:
@@ -58,7 +61,8 @@ BASE_DIR = os.path.dirname(os.path.abspath(__file__))
 SHARED_GUARD_MODELS_DIR = os.path.join(BASE_DIR, "ml_models", "guard_v2")
 UNIFIED_MODELS_DIR = os.path.join(BASE_DIR, "ml_models", "Unified_Models_V1")
 
-# [ 🧠 ] مسارات النماذج
+# [ 🧠 ] مسارات النماذج للحارس الهجين
+# تأكد من وجود هذه الملفات في مجلد ml_models
 V2_MODEL_PATH = os.path.join(BASE_DIR, "ml_models", "DeepSteward_Production_V1.json")
 V3_MODEL_PATH = os.path.join(BASE_DIR, "ml_models", "DeepSteward_V3_Production.json")
 V3_FEATURES_PATH = os.path.join(BASE_DIR, "ml_models", "DeepSteward_V3_Features.json")
@@ -98,7 +102,7 @@ class SystemState:
 sys_state = SystemState()
 
 # ==============================================================================
-# 🛠️ Helper Functions
+# 🛠️ Helper Functions (تمت إضافة دالة الوقت هنا لحل مشكلة العداد)
 # ==============================================================================
 def format_crypto_price(price):
     """
@@ -115,13 +119,16 @@ def format_crypto_price(price):
 def calculate_duration_str(timestamp_str):
     """
     دالة لحساب المدة الزمنية (Uptime/Trade Duration) داخل بايثون
+    لحل مشكلة توقف العدادات في الواجهة.
     """
     if not timestamp_str:
         return "--:--:--"
     try:
+        # محاولة قراءة التوقيت بأكثر من صيغة محتملة
         try:
             start_time = datetime.fromisoformat(str(timestamp_str))
         except ValueError:
+            # تنسيق احتياطي إذا فشل ISO
             start_time = datetime.strptime(str(timestamp_str), "%Y-%m-%dT%H:%M:%S.%f")
             
         now = datetime.now()
@@ -155,13 +162,18 @@ async def auto_pilot_loop():
             if not sys_state.ready: continue
             
             # الشروط الثلاثة للتشغيل التلقائي:
+            # 1. الطيار الآلي مفعل (Checkbox Checked)
+            # 2. لا توجد دورة تعمل حالياً
+            # 3. لا توجد صفقات مفتوحة
             if sys_state.auto_pilot and not sys_state.cycle_running:
                 if trade_manager and len(trade_manager.open_positions) == 0:
-                    # تشغيل الدورة
+                    # تشغيل الدورة (دون انتظارها لتنتهي هنا، نطلقها فقط)
                     asyncio.create_task(run_unified_cycle())
-                    # ننتظر فترة أطول قليلاً بعد إطلاق الدورة
+                    
+                    # ننتظر فترة أطول قليلاً بعد إطلاق الدورة لمنع التكرار الفوري
                     await asyncio.sleep(5) 
                 else:
+                    # إذا كانت هناك صفقة، الطيار الآلي يراقب فقط ولا يتدخل في الدورة
                     pass 
 
         except Exception as e:
@@ -205,17 +217,19 @@ async def lifespan(app: FastAPI):
         await sniper_engine.initialize()
         sniper_engine.set_entry_threshold(0.35) 
         
-        # [ 🧠 ] تهيئة Hybrid Deep Steward (V4 Dual Brain)
-        print(f"   [8/8] تهيئة Hybrid Guardian (V2 + V3)...")
+        # [ 🧠 ] تهيئة الحارس الهجين (Hybrid Deep Steward)
+        # هذا هو التغيير الجوهري لدمج النظامين V2 و V3
+        print(f"   [8/8] تهيئة Hybrid Guardian (V2 + V3 Dual Brain)...")
         deep_steward = HybridDeepSteward(
             v2_model_path=V2_MODEL_PATH,
             v3_model_path=V3_MODEL_PATH,
             v3_features_map_path=V3_FEATURES_PATH
         )
+        
         if deep_steward.initialize():
-            print("   ✅ [Hybrid Guardian] جاهز للعمل: (V2 Radar + V3 Sniper).")
+            print("   ✅ [Hybrid Guardian] جاهز للعمل: V2 (Radar) + V3 (Sniper).")
         else:
-            print("   ⚠️ [Hybrid Guardian] فشل التحميل! سيعمل النظام بدون حماية AI متقدمة.")
+            print("   ⚠️ [Hybrid Guardian] فشل التحميل! تأكد من وجود ملفات النماذج.")
 
         print("   [FINAL] تهيئة TradeManager...")
         trade_manager = TradeManager(
@@ -223,7 +237,7 @@ async def lifespan(app: FastAPI):
             data_manager=data_manager, 
             titan_engine=ml_processor.titan, 
             pattern_engine=ml_processor.pattern_engine,
-            guard_engine=None,
+            guard_engine=None, # تم إلغاء الحارس القديم
             sniper_engine=sniper_engine,
             deep_steward=deep_steward # تمرير الحارس الهجين
         )
@@ -277,7 +291,7 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
         return None
 
 # ==============================================================================
-# [ 🚀 🚀 🚀 ] الدورة الموحدة (كاملة بدون حذف)
+# [ 🚀 🚀 🚀 ] الدورة الموحدة (كاملة بدون حذف - منطق المسح والبحث)
 # ==============================================================================
 async def run_unified_cycle():
     
@@ -313,15 +327,40 @@ async def run_unified_cycle():
             log_and_print(f"   -> المراقبة تتم كل 60 ثانية في الخلفية (V2 Radar + V3 Sniper).")
             log_and_print(f"   -> باقي نماذج البحث (L1/L2/L3) في وضع السكون لتوفير الموارد.")
             
-            # فحص طوارئ سريع (فقط للتأكيد)
             current_price = await data_manager.get_latest_price_async(symbol)
             log_and_print(f"   -> السعر الحالي: {format_crypto_price(current_price)}")
             
+            # --- [NEW] استشارة الحارس وعرض الطوابع في السجلات ---
+            # هذا الكود مضاف لكي ترى النتائج في الواجهة عند ضغط زر Scan
+            try:
+                log_and_print("   -> 📡 جاري طلب تقرير الحارس المباشر (Consultation Scan)...")
+                
+                # جلب البيانات اللازمة للتحليل
+                t1 = data_manager.get_latest_ohlcv(symbol, '1m', 120)
+                t5 = data_manager.get_latest_ohlcv(symbol, '5m', 100)
+                t15 = data_manager.get_latest_ohlcv(symbol, '15m', 50)
+                
+                d1, d5, d15 = await asyncio.gather(t1, t5, t15)
+                
+                # تحليل استشاري (لا ينفذ خروجاً هنا، فقط يعرض الرأي)
+                if d1 and d5 and d15 and len(d1) >= 64:
+                    decision = deep_steward.analyze_position(d1, d5, d15, float(trade['entry_price']))
+                    scores = decision.get('scores', {'v2': 0.0, 'v3': 0.0})
+                    
+                    log_and_print(f"\n   📊 [GUARDIAN LIVE REPORT]")
+                    log_and_print(f"      • Decision: {decision.get('action')} ({decision.get('reason')})")
+                    log_and_print(f"      • V2 (Radar):  {scores.get('v2', 0.0):.4f}  [Safe < {deep_steward.V2_SAFE_LIMIT} | Panic > {deep_steward.V2_PANIC_TRIGGER}]")
+                    log_and_print(f"      • V3 (Sniper): {scores.get('v3', 0.0):.4f}  [Hard > {deep_steward.V3_HARD_EXIT} | Ultra > {deep_steward.V3_ULTRA_CONF}]")
+                else:
+                    log_and_print("   ⚠️ بيانات السوق غير كافية للتحليل اللحظي الآن.")
+            except Exception as e:
+                log_and_print(f"   ⚠️ تعذر عرض تقرير الحارس: {e}")
+            
             sys_state.set_cycle_end(logs=log_buffer.getvalue())
             return 
 
         # ============================================================
-        # 🔍 وضع البحث (Scanning Mode) - Normal Flow
+        # 🔍 وضع البحث (Scanning Mode) - Normal Flow (كامل بدون حذف)
         # ============================================================
         
         # --- 1. الغربلة الأولية (L1) ---
@@ -487,7 +526,7 @@ async def run_unified_cycle():
 # ==============================================================================
 app = FastAPI(
     lifespan=lifespan, 
-    title="Titan V22.2 Pro (Hybrid Guardian + MultiStats)", 
+    title="Titan V22.3 Pro (Hybrid Guardian + MultiStats)", 
     description="نظام تداول آلي هجين (L1/L2/L3-ML) مع حارس ذكي مزدوج وواجهة Gradio مدمجة"
 )
 
@@ -607,7 +646,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. 🎨 Wallet HTML
+        # 3. 🎨 Wallet 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>
@@ -631,6 +670,7 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         """
 
         # 4. 🧠 [Dynamic Stats] جلب الإحصائيات بناءً على ال��ائمة المنسدلة
+        # Mapping selection to dict keys
         key_map = {
             "Hybrid System": "hybrid",
             "Model V2 (Radar)": "v2",
@@ -642,12 +682,13 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
         if hasattr(trade_manager, 'ai_stats'):
             stats_data = trade_manager.ai_stats.get(target_key, {"total":0, "good":0, "saved":0.0, "missed":0.0})
         else:
+            # Fallback for old versions just in case
             stats_data = {"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
         
-        # Dynamic Title
+        # Dynamic Title based on selection
         title_map = {
             "hybrid": "🧠 Hybrid Guardian IQ",
             "v2": "📡 Model V2 (Radar)",
@@ -703,7 +744,7 @@ async def check_live_pnl_and_status(selected_view="Hybrid System"):
                     paper_bgcolor="#0b0f19",
                     plot_bgcolor="#0b0f19",
                     margin=dict(l=0, r=50, t=30, b=0),
-                    height=400,
+                    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')
@@ -752,16 +793,18 @@ def create_gradio_ui():
     .html-box { min-height: 180px; }
     """
 
-    with gr.Blocks(title="Titan V22.2 Pro Dashboard", css=css, theme=gr.themes.Monochrome()) as demo:
+    with gr.Blocks(title="Titan V22.3 Pro Dashboard", css=css, theme=gr.themes.Monochrome()) as demo:
         
-        gr.Markdown("# 🚀 Titan V22.2 Pro (Hybrid Guardian Edition)")
+        gr.Markdown("# 🚀 Titan V22.3 Pro (Hybrid Guardian Edition)")
         
         # --- الصف العلوي: الشارت + الإحصائيات ---
         with gr.Row():
-            # العمود الأيسر: الشارت + تفاصيل السعر
+            # العمود الأيسر: الشارت + تفاصيل السعر (لتقليل الوميض نفصلها)
             with gr.Column(scale=3):
+                # 🌟 استخدام gr.Plot هو الحل الجذري لمشكلة الشارت
                 live_chart_plot = gr.Plot(label="Live Chart", container=True)
                 
+                # صف التفاصيل الحية (تحديث نصوص فقط = لا وميض)
                 with gr.Row():
                     t_price = gr.Textbox(label="Current Price", interactive=False, elem_classes="text-yellow")
                     t_pnl = gr.Textbox(label="PnL %", interactive=False)
@@ -822,7 +865,7 @@ def create_gradio_ui():
         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)
         
-        # المؤقت الدوري (كل 3 ثواني) - تم ربط القائمة المنسدلة كـ Input
+        # المؤقت الدوري (كل 3 ثواني) - يغذي الخانات المنفصلة
         timer = gr.Timer(3) 
         timer.tick(
             fn=check_live_pnl_and_status,
@@ -830,7 +873,7 @@ def create_gradio_ui():
             outputs=[
                 cycle_logs_output, 
                 status_markdown, 
-                live_chart_plot,
+                live_chart_plot, # التحديث هنا ذكي ولا يسبب وميض
                 t_price,
                 t_entry,
                 t_tp,