Update app.py

app.py

@@ -167,39 +167,48 @@ def calculate_duration_str(timestamp_str):
 # ==============================================================================
 async def auto_pilot_loop():
     """
-    Background task that triggers scanning cycles automatically based on logic.
+    Background task that manages scanning AND monitoring.
+    Fixes the 'Blind Spot' where Guardians were not checked if a trade was open.
     """
-    logger.info("🤖 [Auto-Pilot] Daemon started.")
+    logger.info("🤖 [Auto-Pilot] Daemon started (Monitoring Mode Enabled).")
     while True:
         try:
-            await asyncio.sleep(10) # Check every 10 seconds
+            await asyncio.sleep(5) # Check every 5 seconds (Faster response)
             
-            # Safety check: System must be ready
             if not sys_state.ready: continue
             
-            # Update training status occasionally
+            # 1. حالة التدريب
             if hub_manager and int(time.time()) % 60 == 0:
                 is_ready, msg = await hub_manager.check_training_readiness()
                 sys_state.training_status_msg = msg
 
-            # Trigger Cycle if Auto-Pilot is ON and system is IDLE
+            # 2. فحص حالة الصفقات المفتوحة (Watchdog Check)
+            # هذا هو الجزء الذي كان مفقوداً! نتأكد من أن الحراس يعملون.
+            if trade_manager and len(trade_manager.open_positions) > 0:
+                # التأكد من عمل الحلقات الخلفية
+                wd_status = await trade_manager.ensure_active_guardians()
+                
+                # تحديث واجهة المستخدم برسائل الحارس
+                # إذا كانت الرسالة "No active trades" نتجاهلها، غير ذلك نعرضها
+                if "No active" not in wd_status:
+                    sys_state.last_cycle_logs = trade_manager.latest_guardian_log
+                continue # ننتقل للدورة التالية ولا نقوم بمسح جديد
+
+            # 3. Trigger Cycle (فقط إذا لم تكن هناك صفقات)
             if sys_state.auto_pilot and not sys_state.cycle_running and not sys_state.training_running:
-                # Only scan if no active trades (Safety First Logic - Spot Mode)
-                if trade_manager and len(trade_manager.open_positions) == 0:
-                    
-                    # Check time since last cycle (Throttling)
-                    if sys_state.last_cycle_time:
-                        elapsed = (datetime.now() - sys_state.last_cycle_time).total_seconds()
-                        if elapsed < 300: # Minimum 5 minutes wait between cycles
-                            continue
-
-                    logger.info("🤖 [Auto-Pilot] Triggering scan...")
-                    asyncio.create_task(run_unified_cycle())
-                    await asyncio.sleep(5) 
+                # Check time since last cycle
+                if sys_state.last_cycle_time:
+                    elapsed = (datetime.now() - sys_state.last_cycle_time).total_seconds()
+                    if elapsed < sys_state.scan_interval: 
+                        continue
+
+                logger.info("🤖 [Auto-Pilot] Triggering scan...")
+                asyncio.create_task(run_unified_cycle())
+                await asyncio.sleep(5) 
                     
         except Exception as e:
             logger.error(f"⚠️ [Auto-Pilot Error] {e}")
-            await asyncio.sleep(30) # Backoff on error
+            await asyncio.sleep(30)
 
 # ==============================================================================
 # 🚀 Lifespan (Server Startup/Shutdown & Injection)