Update app.py

app.py

@@ -355,6 +355,22 @@ async def predict_signal(symbol, timeframe="1h"):
         }
     except Exception as e: return {"status": "error", "message": str(e)}
 
+# --- 🛡️ STATE MANAGER : LE DICTIONNAIRE D'ÉTAT GLOBAL ---
+# Clé : (symbol, timeframe) -> Valeur : Les données du dernier signal
+active_signals_state = {}
+
+def clean_old_db_signals(symbol, timeframe):
+    """Passe les anciens signaux non résolus en statut REMPLACÉ pour laisser la place aux nouveaux."""
+    try:
+        with sqlite3.connect(DB_NAME) as conn:
+            conn.execute(
+                "UPDATE signals SET status = 'REMPLACÉ ♻️', confirmed = 0 "
+                "WHERE symbol = ? AND timeframe = ? AND status = 'EN_COURS'", 
+                (symbol, timeframe)
+            )
+            conn.commit()
+    except Exception as e:
+        print(f"⚠️ Erreur nettoyage DB : {e}")
 # --- 🧬 FONCTION D'ÉVOLUTION (MUTATION) ---
 def mutate_agent(symbol, timeframe, success=True):
     try:
@@ -448,20 +464,34 @@ def set_bot_mode(mode):
     return {"status": "success", "mode": "DREAM" if DREAM_MODE_ACTIVE else "LIVE", "message": msg}
 
 async def auto_predict_loop():
+    print("👁️ [SCANNER] Le Cerveau Global est en ligne (H24)...")
     while True:
-        if not DREAM_MODE_ACTIVE:
-            try:
-                with sqlite3.connect(DB_NAME) as conn:
-                    cursor = conn.cursor()
-                    for symbol in AUTO_SYMBOLS:
-                        for tf in AUTO_TIMEFRAMES:
-                            cursor.execute("SELECT id FROM signals WHERE symbol = ? AND timeframe = ? AND status = 'EN_COURS'", (symbol, tf))
-                            if cursor.fetchone(): continue 
-                            print(f"🎯 [LIVE] Analyse : {symbol} [{tf}]")
-                            await predict_signal(symbol, timeframe=tf)
-                            await asyncio.sleep(5) # Sécurité KuCoin
-            except Exception as e: print(f"⚠️ Erreur LIVE : {e}")
-        await asyncio.sleep(60) 
+        for symbol in AUTO_SYMBOLS:
+            for tf in AUTO_TIMEFRAMES:
+                try:
+                    # 1️⃣ L'IA RÉFLÉCHIT EN CONTINU (Aucun blocage)
+                    pred = await predict_signal(symbol, timeframe=tf)
+
+                    if pred and pred.get("status") == "success":
+                        # 2️⃣ NETTOYAGE DB : On archive l'ancien signal avant d'enregistrer le nouveau
+                        clean_old_db_signals(symbol, tf)
+                        
+                        # 3️⃣ ÉCRASEMENT MATHÉMATIQUE : Le nouveau signal tue l'ancien instantanément en RAM
+                        active_signals_state[(symbol, tf)] = pred
+
+                        # 4️⃣ ACTION : C'est ici que le mode intervient !
+                        if not DREAM_MODE_ACTIVE:
+                            print(f"🎯 [LIVE] Nouveau signal maître pris en compte : {symbol} [{tf}]")
+                            # C'est ici que tu déclencheras l'API KuCoin/MT5 pour prendre le trade
+                        else:
+                            # En mode DREAM, on log juste ou on laisse le backtest tourner
+                            pass
+
+                    await asyncio.sleep(5)  # Sécurité anti-spam API KuCoin
+                except Exception as e: 
+                    print(f"⚠️ Erreur Scanner sur {symbol} [{tf}] : {e}")
+                    
+        await asyncio.sleep(60) # Pause entre deux scans complets du marché
 
 async def dream_simulation_loop():
     """Le Spinosaurus rêve sur TOUS les terrains (Multi-Timeframe)"""
@@ -654,13 +684,15 @@ def run_auto_pilot():
     try:
         loop = asyncio.new_event_loop()
         asyncio.set_event_loop(loop)
-        # On lance les deux boucles (Live & Dream) en parallèle
-        loop.create_task(auto_predict_loop())
+        
+        # Le Cerveau (H24) + Le Rêve (Mutations) tournent en parallèle
+        loop.create_task(auto_predict_loop()) 
         loop.create_task(dream_simulation_loop())
         loop.run_forever()
     except Exception as e:
         print(f"⚠️ Erreur boucle Auto-Pilote : {e}")
         _auto_pilot_started = False
+        _auto_pilot_started = False
 
 if __name__ == "__main__":
     try: threading.Thread(target=run_auto_pilot, daemon=True).start()