Update app.py

app.py

@@ -455,9 +455,38 @@ def run_judge_api():
     try:
         with sqlite3.connect(DB_NAME, timeout=10) as conn: 
             conn.row_factory, cursor = sqlite3.Row, conn.cursor()
+            
+            # ==============================================================
+            # 🧹 1. PURGE DES SIGNAUX ORPHELINS (Le Bras était éteint)
+            # ==============================================================
+            cursor.execute("SELECT id, date, timeframe FROM signals WHERE status = 'EN_COURS' AND confirmed = 0")
+            orphelins = cursor.fetchall()
+            current_time = datetime.now(timezone.utc)
+            max_age_minutes = {"1m": 15, "5m": 20, "15m": 30, "1h": 60}
+            
+            for o in orphelins:
+                try:
+                    date_str = o['date'].replace('Z', '+00:00')
+                    signal_time = datetime.fromisoformat(date_str)
+                    age_minutes = (current_time - signal_time).total_seconds() / 60.0
+                    max_age = max_age_minutes.get(o['timeframe'], 60)
+                    
+                    if age_minutes > max_age:
+                        cursor.execute("UPDATE signals SET status = 'EXPIRÉ ⏰' WHERE id = ?", (o['id'],))
+                        print(f"🧹 [PURGE] Signal ID {o['id']} ({o['timeframe']}) annulé. Âge: {int(age_minutes)}m > Limite: {max_age}m.")
+                except Exception:
+                    pass
+
+            # ==============================================================
+            # ⚖️ 2. JUGEMENT DES TRADES ACTIFS (Trailing Stop Complet)
+            # ==============================================================
             cursor.execute("SELECT * FROM signals WHERE status = 'EN_COURS' AND confirmed = 1")
             trades = cursor.fetchall()
-            if not trades: return {"status": "waiting"}
+            
+            if not trades: 
+                conn.commit()
+                return {"status": "waiting"}
+                
             closed_trades = []
             for t in trades:
                 try:
@@ -474,17 +503,36 @@ def run_judge_api():
 
                     sl_dyn, peak = t['sl'], t['peak_price']
                     new_peak = max(peak, current_price) if t['direction'] == 'HAUSSIER' else min(peak, current_price)
-                    progression = abs(current_price - t['price']) / abs(t['tp'] - t['price']) if abs(t['tp'] - t['price']) > 0 else 0
+                    
+                    # Calcul de la progression (0 à 1)
+                    dist_totale = abs(t['tp'] - t['price'])
+                    progression = abs(current_price - t['price']) / dist_totale if dist_totale > 0 else 0
                     
                     nouveau_sl = sl_dyn
+                    dist_sl_initial = abs(t['price'] - sl_dyn)
+
+                    # 🛡️ LOGIQUE DU TRAILING STOP À 4 PALIERS
                     if t['direction'] == 'HAUSSIER':
-                        if progression >= 0.75: nouveau_sl = max(sl_dyn, t['price'] + (abs(t['tp'] - t['price']) * 0.60))
-                        elif progression >= 0.50: nouveau_sl = max(sl_dyn, t['price'] + (abs(t['tp'] - t['price']) * 0.25))
+                        if progression >= 0.75:
+                            nouveau_sl = max(sl_dyn, t['price'] + (dist_totale * 0.60)) # Sécurise 60% du gain
+                        elif progression >= 0.50:
+                            nouveau_sl = max(sl_dyn, t['price'] + (dist_totale * 0.25)) # Sécurise 25% du gain
+                        elif progression >= 0.30:
+                            nouveau_sl = max(sl_dyn, t['price'] + (dist_totale * 0.05)) # Breakeven + frais
+                        elif progression >= 0.10:
+                            nouveau_sl = max(sl_dyn, t['price'] - (dist_sl_initial * 0.50)) # Réduit le risque de 50%
                     else:
-                        if progression >= 0.75: nouveau_sl = min(sl_dyn, t['price'] - (abs(t['tp'] - t['price']) * 0.60))
-                        elif progression >= 0.50: nouveau_sl = min(sl_dyn, t['price'] - (abs(t['tp'] - t['price']) * 0.25))
+                        if progression >= 0.75:
+                            nouveau_sl = min(sl_dyn, t['price'] - (dist_totale * 0.60))
+                        elif progression >= 0.50:
+                            nouveau_sl = min(sl_dyn, t['price'] - (dist_totale * 0.25))
+                        elif progression >= 0.30:
+                            nouveau_sl = min(sl_dyn, t['price'] - (dist_totale * 0.05))
+                        elif progression >= 0.10:
+                            nouveau_sl = min(sl_dyn, t['price'] + (dist_sl_initial * 0.50))
 
                     cursor.execute("UPDATE signals SET peak_price = ?, sl = ? WHERE id = ?", (new_peak, nouveau_sl, t['id']))
+                    
                     outcome, reward = None, 0
                     if t['direction'] == 'HAUSSIER':
                         if current_price >= t['tp']: outcome, reward = "GAGNÉ ✅", 3
@@ -497,7 +545,9 @@ def run_judge_api():
                         mutate_agent(t['symbol'], t['timeframe'], t['regime'], success=(reward>0))
                         cursor.execute("UPDATE signals SET status=? WHERE id=?", (outcome, t['id']))
                         closed_trades.append({"symbol": t['symbol'], "id": t['id']})
-                except: pass
+                except Exception: 
+                    pass
+            
             conn.commit()
         return {"status": "updates", "data": closed_trades} if closed_trades else {"status": "waiting"}
     except Exception as e: return {"status": "error", "message": str(e)}