Update app.py

app.py

@@ -1,6 +1,5 @@
 # ==============================================================================
-# 🚀 app.py (V35.0 - GEM-Architect: Portfolio-Aware Edition)
-# Fully synchronized with SmartPortfolio V1.2 & TradeManager V35.0
+# 🚀 app.py (V35.1 - GEM-Architect: Granular Control & UI Fix)
 # ==============================================================================
 
 import os
@@ -16,15 +15,14 @@ from contextlib import asynccontextmanager, redirect_stdout, redirect_stderr
 from io import StringIO
 from typing import List, Dict, Any, Optional
 
-# المكتبات الخارجية للواجهة والخادم
 from fastapi import FastAPI, HTTPException, BackgroundTasks
 import gradio as gr
 import pandas as pd
 import plotly.graph_objects as go 
 
-# ==============================================================================
-# 📝 إعداد نظام السجلات (Server Logging)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Logging Setup
+# ------------------------------------------------------------------------------
 logging.basicConfig(
     level=logging.INFO,
     format="[%(levelname)s] %(message)s", 
@@ -32,25 +30,17 @@ logging.basicConfig(
 )
 logger = logging.getLogger("TitanCore")
 
-# ==============================================================================
-# 📥 استيراد الوحدات الأساسية (Module Imports)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Imports
+# ------------------------------------------------------------------------------
 try:
-    # Core Data & ML Modules
-    from r2 import R2Service
+    from r2 import R2Service, INITIAL_CAPITAL # ✅ استيراد رأس المال الافتراضي
     from ml_engine.data_manager import DataManager
-    # ✅ استيراد SystemLimits للربط المركزي بالعتبات
     from ml_engine.processor import MLProcessor, SystemLimits 
-    
-    # Whale & Network Analysis Modules
     from whale_monitor.core import EnhancedWhaleMonitor
     from whale_monitor.rpc_manager import AdaptiveRpcManager
-    
-    # Sentiment & News Modules
     from sentiment_news import NewsFetcher
     from vaderSentiment.vaderSentiment import SentimentIntensityAnalyzer
-    
-    # ✅ Learning & Trading Execution Modules (تم تحديثها للنظام التكيفي)
     from learning_hub.adaptive_hub import AdaptiveHub
     from trade_manager import TradeManager
 except ImportError as e:
@@ -58,9 +48,9 @@ except ImportError as e:
     traceback.print_exc()
     sys.exit(1)
 
-# ==============================================================================
-# 🌐 المتغيرات العامة (Global Context & Singletons)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Global Context
+# ------------------------------------------------------------------------------
 r2: R2Service = None
 data_manager: DataManager = None
 ml_processor: MLProcessor = None
@@ -71,9 +61,9 @@ news_fetcher: NewsFetcher = None
 senti_analyzer: SentimentIntensityAnalyzer = None
 sys_state: 'SystemState' = None
 
-# ==============================================================================
-# 🔄 حالة النظام (State Management System)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# State Management
+# ------------------------------------------------------------------------------
 class SystemState:
     def __init__(self):
         self.ready = False
@@ -88,7 +78,7 @@ class SystemState:
         self.last_cycle_logs = "System Initializing..."
         self.training_status_msg = "Adaptive Mode: Active" 
         
-        self.scan_interval = 60 # Seconds
+        self.scan_interval = 60 
 
     def set_ready(self): 
         self.ready = True
@@ -116,9 +106,9 @@ class SystemState:
 
 sys_state = SystemState()
 
-# ==============================================================================
-# 🛠️ دوال مساعدة (Utilities & Formatting)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Utilities
+# ------------------------------------------------------------------------------
 def format_crypto_price(price):
     if price is None: return "0.0"
     try:
@@ -146,18 +136,16 @@ def calculate_duration_str(timestamp_str):
         return f"{hours:02}:{minutes:02}:{seconds:02}"
     except: return "--:--:--"
 
-# ==============================================================================
-# 🤖 Auto-Pilot Daemon (Background Service)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Auto-Pilot Daemon
+# ------------------------------------------------------------------------------
 async def auto_pilot_loop():
-    logger.info("🤖 [Auto-Pilot] Daemon started (Monitoring Mode Enabled).")
+    logger.info("🤖 [Auto-Pilot] Daemon started.")
     while True:
         try:
             await asyncio.sleep(5) 
-            
             if not sys_state.ready: continue
             
-            # ✅ تحديث حالة النظام التكيفي بشكل دوري
             if adaptive_hub and int(time.time()) % 60 == 0:
                 sys_state.training_status_msg = adaptive_hub.get_status()
 
@@ -181,22 +169,20 @@ async def auto_pilot_loop():
             logger.error(f"⚠️ [Auto-Pilot Error] {e}")
             await asyncio.sleep(30)
 
-# ==============================================================================
-# 🚀 Lifespan (Server Startup/Shutdown & Injection)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Lifespan
+# ------------------------------------------------------------------------------
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     global r2, data_manager, ml_processor, adaptive_hub, trade_manager, whale_monitor, news_fetcher, senti_analyzer, sys_state
     
-    logger.info("\n🚀 [System] Startup Sequence (Titan V35.0 - Portfolio Aware)...")
+    logger.info("\n🚀 [System] Startup Sequence (Titan V35.1)...")
     try:
-        logger.info("   [1/7] Initializing R2 & Data Services...")
         r2 = R2Service()
         data_manager = DataManager(contracts_db={}, whale_monitor=None, r2_service=r2)
         await data_manager.initialize() 
         await data_manager.load_contracts_from_r2()
         
-        logger.info("   [2/7] Starting Auxiliary Services (Whale & News)...")
         whale_monitor = EnhancedWhaleMonitor(contracts_db=data_manager.get_contracts_db(), r2_service=r2)
         rpc_mgr = AdaptiveRpcManager(data_manager.http_client)
         whale_monitor.set_rpc_manager(rpc_mgr)
@@ -205,24 +191,18 @@ async def lifespan(app: FastAPI):
         senti_analyzer = SentimentIntensityAnalyzer()
         data_manager.whale_monitor = whale_monitor
         
-        logger.info("   [3/7] Initializing Adaptive Hub (Meta-Learner)...")
         adaptive_hub = AdaptiveHub(r2_service=r2)
         await adaptive_hub.initialize()
 
-        logger.info("   [4/7] Initializing Central ML Processor...")
         ml_processor = MLProcessor(data_manager=data_manager)
         await ml_processor.initialize()
         
-        logger.info("   [5/7] Initializing Trade Manager (with SmartPortfolio)...")
         trade_manager = TradeManager(r2_service=r2, data_manager=data_manager, processor=ml_processor)
-        # ✅ ربط النظام التكيفي بمدير التداول
         trade_manager.learning_hub = adaptive_hub 
         await trade_manager.initialize_sentry_exchanges()
         
-        logger.info("   [6/7] Restarting Active Sentries...")
         await trade_manager.start_sentry_loops()
         
-        logger.info("   [7/7] Launching Auto-Pilot...")
         sys_state.set_ready()
         asyncio.create_task(auto_pilot_loop())
         logger.info("✅ [System READY] All modules operational.")
@@ -232,21 +212,16 @@ async def lifespan(app: FastAPI):
         logger.critical(f"❌ [FATAL STARTUP ERROR] {e}")
         traceback.print_exc()
     finally:
-        logger.info("\n🛑 [System] Shutdown Sequence...")
         sys_state.ready = False
         if trade_manager: await trade_manager.stop_sentry_loops()
         if data_manager: await data_manager.close()
         if whale_monitor and whale_monitor.rpc_manager: await whale_monitor.rpc_manager.close()
         logger.info("✅ [System] Shutdown Complete.")
 
-# ==============================================================================
-# 🧠 Helper Tasks (Layer 2 Calculation)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Helper Tasks
+# ------------------------------------------------------------------------------
 async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
-    """
-    Task to analyze a single symbol.
-    Uses SystemLimits for L2 Weights.
-    """
     try:
         required_tfs = ["5m", "15m", "1h", "4h"]
         data_tasks = [data_manager.get_latest_ohlcv(symbol, tf, limit=300) for tf in required_tfs]
@@ -265,14 +240,10 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
         res = await ml_processor.process_compound_signal(raw_data)
         if not res: return None
 
-        # ---------------------------------------------------------
-        # ⚖️ EXPLICIT L2 SCORING (Centralized Config)
-        # ---------------------------------------------------------
         titan_s = res.get('titan_score', 0.5)
         pattern_s = res.get('patterns_score', 0.5)
         mc_light_s = res.get('mc_score', 0.5)
 
-        # ✅ استخدام الأوزان المركزية من SystemLimits
         l2_base_score = (
             (titan_s * SystemLimits.L2_WEIGHT_TITAN) + 
             (pattern_s * SystemLimits.L2_WEIGHT_PATTERNS) + 
@@ -283,16 +254,12 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
         res['l2_base_score'] = l2_base_score
         
         return res
-        
     except Exception: return None
 
-# ==============================================================================
-# 🚀 Unified Smart Cycle (Oracle V4 Logic + Deep Dive Top 10)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Unified Cycle
+# ------------------------------------------------------------------------------
 async def run_unified_cycle():
-    """
-    Full Analysis Cycle.
-    """
     log_buffer = StringIO()
     def log_and_print(message):
         logger.info(message)
@@ -304,23 +271,18 @@ async def run_unified_cycle():
     sys_state.set_cycle_start()
     
     try:
-        # --- LAYER 0: Guardian ---
+        # LAYER 0: Guardian
         await trade_manager.sync_internal_state_with_r2()
         
-        # إذا كان هناك صفقات مفتوحة، نكتفي بالمراقبة (إلا إذا سمحت المحفظة بأكثر من صفقة)
-        # ولكن لدواعي التبسيط، إذا كان هناك صفقات، سنقوم بالمسح فقط إذا كانت المحفظة تسمح بذلك.
-        # هنا سنترك المسح يعمل دائماً، و TradeManager سيقرر القبول أو الرفض بناءً على slots.
-        
         if len(trade_manager.open_positions) > 0:
             log_and_print(f"ℹ️ [Cycle] Active Positions: {len(trade_manager.open_positions)}")
-            # يمكننا طباعة حالة الصفقات المفتوحة
             for sym, tr in trade_manager.open_positions.items():
                 curr_p = await data_manager.get_latest_price_async(sym)
                 entry_p = float(tr.get('entry_price', 0))
                 pnl = ((curr_p - entry_p)/entry_p)*100 if entry_p > 0 else 0
                 log_and_print(f"   🔒 {sym}: {pnl:+.2f}%")
 
-        # --- LAYER 1: Screening ---
+        # LAYER 1: Screening
         log_and_print("   [1/5] 🔍 L1 Screening (Liquidity & Volume)...")
         candidates = await data_manager.layer1_rapid_screening()
         if not candidates:
@@ -328,7 +290,7 @@ async def run_unified_cycle():
             sys_state.set_cycle_end(logs=log_buffer.getvalue())
             return
             
-        # --- LAYER 2: Deep Analysis ---
+        # LAYER 2: Deep Analysis
         log_and_print(f"   [2/5] 🧠 L2 Deep Analysis ({len(candidates)} items)...")
         tasks = [_analyze_symbol_task(c['symbol']) for c in candidates]
         results = await asyncio.gather(*tasks)
@@ -341,7 +303,7 @@ async def run_unified_cycle():
             sys_state.set_cycle_end(logs=log_buffer.getvalue())
             return
 
-        # --- LAYER 3: Deep Dive (Dynamic Scoring) ---
+        # LAYER 3: Deep Dive
         log_and_print(f"   [3/5] 📡 L3 Deep Dive (Dynamic Scoring) for TOP {len(semi_finalists)}...")
         
         final_candidates = []
@@ -350,7 +312,6 @@ async def run_unified_cycle():
             symbol = sig['symbol']
             l2_score = sig.get('l2_base_score', 0.0)
             
-            # A. Whale Analysis (Dynamic)
             whale_points = 0.0
             try:
                 if whale_monitor:
@@ -364,7 +325,6 @@ async def run_unified_cycle():
                         elif action == 'SELL': whale_points = -dynamic_impact
             except Exception: pass
 
-            # B. News Analysis (Dynamic)
             news_points = 0.0
             try:
                 if news_fetcher and senti_analyzer:
@@ -376,7 +336,6 @@ async def run_unified_cycle():
                         news_points = compound_score * SystemLimits.L3_NEWS_IMPACT_MAX
             except Exception: pass
 
-            # C. Advanced Monte Carlo
             mc_a_points = 0.0
             try:
                 raw_mc_a = await ml_processor.run_advanced_monte_carlo(symbol, '1h')
@@ -392,7 +351,7 @@ async def run_unified_cycle():
             
             final_candidates.append(sig)
 
-        # --- RE-RANKING ---
+        # RE-RANKING
         final_candidates.sort(key=lambda x: x['final_total_score'], reverse=True)
 
         approved_signals = []
@@ -406,7 +365,6 @@ async def run_unified_cycle():
         for sig in final_candidates:
             symbol = sig['symbol']
             
-            # E. Consult Oracle V4
             decision = await ml_processor.consult_oracle(sig)
             
             action = decision.get('action', 'WAIT')
@@ -440,7 +398,7 @@ async def run_unified_cycle():
                 f"{status_str}"
             )
 
-        # --- LAYER 4: Sniper Execution (Pass to TradeManager & Portfolio) ---
+        # LAYER 4: Sniper Execution
         if approved_signals:
             log_and_print("-" * 110)
             log_and_print(f"   [4/5] 🎯 L4 Sniper & Portfolio Check ({len(approved_signals)} candidates)...")
@@ -463,13 +421,10 @@ async def run_unified_cycle():
         traceback.print_exc()
         sys_state.set_cycle_end(error=e, logs=log_buffer.getvalue())
 
-# ==============================================================================
-# 🎓 Training & Helper Logic (ADAPTIVE MODE)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Handlers (Reset Logic & Training)
+# ------------------------------------------------------------------------------
 async def trigger_training_cycle():
-    """
-    زر التدريب اليدوي (معطل حالياً لصالح التعلم التكيفي التلقائي).
-    """
     if adaptive_hub:
         status = adaptive_hub.get_status()
         return f"🤖 Adaptive System Active. Status: {status}"
@@ -481,16 +436,43 @@ async def manual_close_current_trade():
     await trade_manager.force_exit_by_manager(symbol, reason="MANUAL_UI")
     return f"✅ Closed {symbol}."
 
-async def reset_stats_handler():
-    if trade_manager.open_positions: return "⚠️ Close trade first."
+# ✅ الدالة 1: تصفير السجل التاريخي فقط (مع الحفاظ على المال)
+async def reset_history_handler():
+    if trade_manager.open_positions: return "⚠️ Close active trades first."
+    
+    # نقرأ الحالة الحالية أولاً لنحافظ على المال
+    current_state = await r2.get_portfolio_state_async()
+    preserved_capital = current_state.get('current_capital_usd', INITIAL_CAPITAL)
+    
+    # تصفير شامل (الذي يصفر كل شيء في r2)
     await r2.reset_all_stats_async()
+    
+    # استعادة رأس المال المحفوظ
+    if trade_manager and trade_manager.smart_portfolio:
+         sp = trade_manager.smart_portfolio
+         sp.state["current_capital"] = preserved_capital # استعادة المال
+         sp.state["session_start_balance"] = preserved_capital
+         sp.state["allocated_capital_usd"] = 0.0
+         sp.state["daily_net_pnl"] = 0.0
+         sp.state["is_trading_halted"] = False
+         await sp._save_state_to_r2()
+         
+    return f"✅ History Cleared. Capital Preserved at ${preserved_capital:.2f}"
+
+# ✅ الدالة 2: تصفير رأس المال فقط (مع الحفاظ على السجل)
+async def reset_capital_handler():
+    if trade_manager.open_positions: return "⚠️ Close active trades first."
+    
     if trade_manager and trade_manager.smart_portfolio:
-         # تصفير حالة المحفظة أيضاً
-         trade_manager.smart_portfolio.state["allocated_capital_usd"] = 0.0
-         trade_manager.smart_portfolio.state["daily_net_pnl"] = 0.0
-         trade_manager.smart_portfolio.state["is_trading_halted"] = False
-         await trade_manager.smart_portfolio._save_state_to_r2()
-    return "✅ Reset Done."
+         sp = trade_manager.smart_portfolio
+         sp.state["current_capital"] = INITIAL_CAPITAL # العودة لـ 10$
+         sp.state["session_start_balance"] = INITIAL_CAPITAL
+         sp.state["allocated_capital_usd"] = 0.0
+         sp.state["daily_net_pnl"] = 0.0
+         sp.state["is_trading_halted"] = False
+         await sp._save_state_to_r2()
+    
+    return f"✅ Capital Reset to ${INITIAL_CAPITAL} (History Kept)"
 
 async def toggle_auto_pilot(enable):
     sys_state.auto_pilot = enable
@@ -501,9 +483,9 @@ async def run_cycle_from_gradio():
     asyncio.create_task(run_unified_cycle())
     return "🚀 Launched."
 
-# ==============================================================================
-# 📊 UI Updates & Charting (UPDATED FOR SMART PORTFOLIO)
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# UI Updates (Updated for PnL Fix)
+# ------------------------------------------------------------------------------
 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})
@@ -513,7 +495,6 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
         return "Initializing...", "...", empty_chart, "0.0", "0.0", "0.0", "0.0", "0.0%", wl_df_empty, "Loading...", "Loading...", "Checking..."
 
     try:
-        # ✅ جلب بيانات المحفظة الحقيقية من SmartPortfolio
         sp = trade_manager.smart_portfolio
         equity = sp.state.get('current_capital', 10.0)
         allocated = sp.state.get('allocated_capital_usd', 0.0)
@@ -523,7 +504,10 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
         market_mood = sp.market_trend
         fg_index = sp.fear_greed_index
         
-        # جلب الإحصائيات التاريخية
+        # ✅ حساب الربح/الخسارة الكلي مقارنة برأس المال الافتراضي (للعرض تحت الرصيد)
+        total_pnl_val = equity - INITIAL_CAPITAL
+        total_pnl_color = "#00ff00" if total_pnl_val >= 0 else "#ff0000"
+        
         portfolio = await r2.get_portfolio_state_async()
         first_ts = portfolio.get('first_trade_timestamp')
         uptime_str = calculate_duration_str(first_ts) 
@@ -541,7 +525,6 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
         trade_dur_str = "--:--:--" 
         active_trade_info = ""
         
-        # عرض أول صفقة نشطة كعينة (إذا وجدت)
         if trade_manager.open_positions:
             symbol = list(trade_manager.open_positions.keys())[0]
             trade = trade_manager.open_positions[symbol]
@@ -550,7 +533,6 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
             sl_p = float(trade.get('sl_price', 0.0))
             trade_dur_str = calculate_duration_str(trade.get('entry_time'))
             
-            # معلومات الثقة
             sys_conf = trade.get('decision_data', {}).get('system_confidence', 0.0)
             
             curr_p = await data_manager.get_latest_price_async(symbol)
@@ -568,15 +550,16 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
              </div>
             """
 
-        # حساب القيمة الافتراضية (equity + unrealized) للعرض فقط
         virtual_equity = equity + pnl_val_unrealized
         color = "#00ff00" if daily_pnl >= 0 else "#ff0000"
         halt_status = "<span style='color:red; font-weight:bold;'>HALTED</span>" if is_halted else "<span style='color:#00ff00;'>ACTIVE</span>"
 
+        # ✅ تحديث واجهة المحفظة لإضافة سطر PnL الكلي
         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;'>💼 Smart Portfolio</h3>
-            <div style='font-size: 24px; font-weight: bold; color: white; margin: 5px 0;'>${virtual_equity:,.2f}</div>
+            <div style='font-size: 24px; font-weight: bold; color: white; margin: 5px 0 0 0;'>${virtual_equity:,.2f}</div>
+            <div style='font-size: 14px; color: {total_pnl_color}; margin-bottom: 5px;'>({total_pnl_val:+,.2f} USD)</div>
             
             <table style='width:100%; font-size:12px; margin-top:5px; color:#ccc;'>
                 <tr><td>Allocated:</td><td style='text-align:right; color:#ffa500;'>${allocated:.2f}</td></tr>
@@ -671,19 +654,18 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
                 f"{pnl_pct:+.2f}%", wl_df, wallet_md, history_md, train_status)
 
     except Exception:
-        # Fallback in case of errors
         return "Error", "Error", empty_chart, "0", "0", "0", "0", "0%", wl_df_empty, "Err", "Err", "Err"
 
-# ==============================================================================
-# 🎨 Gradio UI
-# ==============================================================================
+# ------------------------------------------------------------------------------
+# Gradio UI Construction
+# ------------------------------------------------------------------------------
 def create_gradio_ui():
     custom_css = ".gradio-container {background:#0b0f19} .dataframe {background:#1a1a1a!important} .html-box {min-height:180px}"
     
-    with gr.Blocks(title="Titan V35.0 (Portfolio Aware)") as demo:
+    with gr.Blocks(title="Titan V35.1 (Portfolio Aware)") as demo:
         gr.HTML(f"<style>{custom_css}</style>")
         
-        gr.Markdown("# 🚀 Titan V35.0 (Portfolio-Aware & Dual-Core)")
+        gr.Markdown("# 🚀 Titan V35.1 (Portfolio-Aware & Dual-Core)")
         
         with gr.Row():
             with gr.Column(scale=3):
@@ -717,7 +699,10 @@ def create_gradio_ui():
                     btn_close = gr.Button("🚨 Close", variant="stop")
                 with gr.Row():
                     btn_train = gr.Button("🤖 Check Adaptive Status", variant="secondary")
-                    btn_reset = gr.Button("🗑️ Reset")
+                    # ✅ تقسيم الأزرار
+                    btn_history_reset = gr.Button("🗑️ Clear History", variant="secondary")
+                    btn_cap_reset = gr.Button("💰 Reset Capital", variant="secondary")
+                    
                 status = gr.Markdown("Init...")
                 train_status = gr.Textbox(label="Adaptive Mode", interactive=False, value="Active")
                 alert = gr.Textbox(label="Alerts", interactive=False)
@@ -726,9 +711,13 @@ def create_gradio_ui():
                 logs = gr.Textbox(label="Logs", lines=14, autoscroll=True, elem_classes="log-box", type="text")
                 gr.HTML("<style>.log-box textarea { font-family: 'Consolas', 'Monaco', monospace !important; font-size: 12px !important; white-space: pre !important; }</style>")
 
+        # ربط الأزرار بالدوال الجديدة
         btn_run.click(fn=run_cycle_from_gradio, outputs=alert)
         btn_close.click(fn=manual_close_current_trade, outputs=alert)
-        btn_reset.click(fn=reset_stats_handler, outputs=alert)
+        
+        btn_history_reset.click(fn=reset_history_handler, outputs=alert)
+        btn_cap_reset.click(fn=reset_capital_handler, outputs=alert)
+        
         btn_train.click(fn=trigger_training_cycle, outputs=alert)
         auto_pilot.change(fn=toggle_auto_pilot, inputs=auto_pilot, outputs=alert)