Update app.py

app.py

@@ -1,5 +1,5 @@
 # ==============================================================================
-# 🚀 app.py (V37.2 - GEM-Architect: Neural Dashboard + Context Pipeline Fix)
+# 🚀 app.py (V38.0 - GEM-Architect: Diagnostic Matrix Integration)
 # ==============================================================================
 
 import os
@@ -190,7 +190,7 @@ async def auto_pilot_loop():
 async def lifespan(app: FastAPI):
     global r2, data_manager, ml_processor, adaptive_hub, trade_manager, whale_monitor, news_fetcher, senti_analyzer, sys_state, scheduler
     
-    logger.info("\n🚀 [System] Startup Sequence (Titan V37.2 - Neural Dashboard)...")
+    logger.info("\n🚀 [System] Startup Sequence (Titan V38.0 - Diagnostics)...")
     try:
         # 1. الخدمات الأساسية
         r2 = R2Service()
@@ -438,7 +438,6 @@ async def run_unified_cycle():
         # LAYER 4: Sniper & Governance & Execution
         if approved_signals:
             log_and_print("-" * 110)
-            # ✅ تحديث النص ليعكس وجود الحوكمة
             log_and_print(f"   [4/5] 🎯 L4 Sniper -> 🏛️ Governance -> 💰 Portfolio ({len(approved_signals)} candidates)...")
             tm_log_buffer = StringIO()
             
@@ -529,6 +528,19 @@ async def reset_capital_handler():
          await sp._save_state_to_r2()
     return f"✅ Capital Reset to ${INITIAL_CAPITAL} (History Kept)"
 
+# 🔥 زر تصفير مصفوفة التشخيص
+async def reset_diagnostics_handler():
+    await r2.reset_diagnostic_stats_async()
+    return "✅ Diagnostic Matrix Reset."
+
+# 🔥 زر تصفير إحصائيات الحراس
+async def reset_guardians_handler():
+    await r2.reset_guardian_stats_async()
+    # تحديث الذاكرة المحلية لمدير التجارة لتنعكس التغييرات فوراً
+    if trade_manager:
+        trade_manager.ai_stats = await r2.get_guardian_stats_async()
+    return "✅ Guardian Stats Reset."
+
 async def toggle_auto_pilot(enable):
     sys_state.auto_pilot = enable
     return f"Auto-Pilot: {enable}"
@@ -539,15 +551,16 @@ async def run_cycle_from_gradio():
     return "🚀 Launched."
 
 # ------------------------------------------------------------------------------
-# UI Updates (Modified for Governance)
+# UI Updates (Updated for Diagnostics)
 # ------------------------------------------------------------------------------
 async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
     empty_chart = go.Figure()
     empty_chart.update_layout(template="plotly_dark", paper_bgcolor="#0b0f19", plot_bgcolor="#0b0f19", xaxis={'visible':False}, yaxis={'visible':False})
     wl_df_empty = pd.DataFrame(columns=["Coin", "Score"])
+    diag_df_empty = pd.DataFrame(columns=["Model", "Wins", "Losses", "PnL (USD)"])
     
     if not sys_state.ready:
-        return "Initializing...", "...", empty_chart, "0.0", "0.0", "0.0", "0.0", "0.0%", wl_df_empty, "Loading...", "Loading...", "Loading..."
+        return "Initializing...", "...", empty_chart, "0.0", "0.0", "0.0", "0.0", "0.0%", wl_df_empty, diag_df_empty, "Loading...", "Loading...", "Loading..."
 
     try:
         sp = trade_manager.smart_portfolio
@@ -591,7 +604,6 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
                 size = float(trade.get('entry_capital', 0.0))
                 pnl_val_unrealized = size * (pnl_pct / 100)
             
-            # عرض البيانات الجديدة في الواجهة
             active_trade_info = f"""
              <div style='display: flex; justify-content: space-between; font-size: 12px; color: #ccc; margin-top:5px; border-top: 1px solid #333; padding-top: 5px;'>
                 <span>⏱️ Time:</span> <span style='color: #ffff00;'>{trade_dur_str}</span>
@@ -654,6 +666,7 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
             "Hydra: Stagnation (Time)": "stagnation"
         }
         target_key = key_map.get(selected_view, "hybrid")
+        # استخدام النسخة الموجودة في TradeManager مباشرة لضمان الحداثة
         stats_data = trade_manager.ai_stats.get(target_key, {"total":0, "good":0, "saved":0.0, "missed":0.0})
         
         tot_ds = stats_data['total']
@@ -729,6 +742,22 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
             </div>
         </div>
         """
+        
+        # 🔥 جلب بيانات مصفوفة التشخيص (Diagnostic Matrix)
+        diag_data = await r2.get_diagnostic_stats_async()
+        diag_list = []
+        ordered_models = ["Titan", "Patterns", "Oracle", "Sniper", "MonteCarlo_L", "MonteCarlo_A", "Governance"]
+        
+        for m in ordered_models:
+            stats = diag_data.get(m, {"wins": 0, "losses": 0, "pnl": 0.0})
+            diag_list.append([
+                m, 
+                stats['wins'], 
+                stats['losses'], 
+                f"${stats['pnl']:.2f}"
+            ])
+        
+        diag_df = pd.DataFrame(diag_list, columns=["Model", "Wins", "Losses", "PnL (USD)"])
 
         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"])
@@ -766,12 +795,13 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
         train_status = sys_state.training_status_msg
         if sys_state.training_running: train_status = "🧪 Backtest Running..."
 
+        # إضافة diag_df إلى مخرجات الدالة
         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, neural_md)
+                f"{pnl_pct:+.2f}%", wl_df, diag_df, wallet_md, history_md, neural_md)
 
     except Exception:
         traceback.print_exc()
-        return "Error", "Error", empty_chart, "0", "0", "0", "0", "0%", wl_df_empty, "Err", "Err", "Err"
+        return "Error", "Error", empty_chart, "0", "0", "0", "0", "0%", wl_df_empty, diag_df_empty, "Err", "Err", "Err"
 
 # ------------------------------------------------------------------------------
 # Gradio UI Construction
@@ -779,10 +809,10 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
 def create_gradio_ui():
     custom_css = ".gradio-container {background:#0b0f19} .dataframe {background:#1a1a1a!important} .html-box {min-height:180px}"
     
-    with gr.Blocks(title="Titan V37.2 (Neural Dashboard)") as demo:
+    with gr.Blocks(title="Titan V38.0 (Neural Dashboard)") as demo:
         gr.HTML(f"<style>{custom_css}</style>")
         
-        gr.Markdown("# 🚀 Titan V37.2 (Cybernetic: Neural Dashboard)")
+        gr.Markdown("# 🚀 Titan V38.0 (Cybernetic: Neural Dashboard)")
         
         with gr.Row():
             with gr.Column(scale=3):
@@ -797,9 +827,23 @@ def create_gradio_ui():
 
             with gr.Column(scale=1):
                 wallet_out = gr.HTML(label="Smart Wallet", elem_classes="html-box")
-                # 🔥 إضافة المخرج الجديد
                 neural_out = gr.HTML(label="Neural Cycles", elem_classes="html-box")
                 
+                # 🔥 إضافة مصفوفة التشخيص الجديدة
+                gr.Markdown("### 🕵️ Diagnostic Matrix")
+                diagnostic_out = gr.Dataframe(
+                    headers=["Model", "Wins", "Losses", "PnL (USD)"],
+                    datatype=["str", "number", "number", "str"],
+                    interactive=False,
+                    label="Model Performance"
+                )
+                
+                with gr.Row():
+                    btn_reset_diag = gr.Button("🧹 Reset Matrix", size="sm", variant="secondary")
+                    btn_reset_guard = gr.Button("🛡️ Reset Guardians", size="sm", variant="secondary")
+                
+                gr.HTML("<hr style='border-color:#444; margin: 10px 0;'>")
+                
                 stats_dd = gr.Dropdown([
                     "Dual-Core (Hybrid)", 
                     "Hydra: Crash (Panic)", 
@@ -840,8 +884,12 @@ def create_gradio_ui():
         btn_backtest.click(fn=trigger_strategic_backtest, outputs=alert)
         auto_pilot.change(fn=toggle_auto_pilot, inputs=auto_pilot, outputs=alert)
         
+        # ربط أزرار التصفير الجديدة
+        btn_reset_diag.click(fn=reset_diagnostics_handler, outputs=alert)
+        btn_reset_guard.click(fn=reset_guardians_handler, outputs=alert)
+        
         gr.Timer(3).tick(fn=check_live_pnl_and_status, inputs=stats_dd, 
-                         outputs=[logs, status, live_chart, t_price, t_entry, t_tp, t_sl, t_pnl, watchlist_out, wallet_out, history_out, neural_out])
+                         outputs=[logs, status, live_chart, t_price, t_entry, t_tp, t_sl, t_pnl, watchlist_out, diagnostic_out, wallet_out, history_out, neural_out])
     return demo
 
 fast_api_server = FastAPI(lifespan=lifespan)