Update app.py

app.py

@@ -452,8 +452,19 @@ async def dream_simulation_loop():
                     except: pass
         await asyncio.sleep(60)
 
-# --- ⚖️ JUDGE API ---
-# --- ⚖️ JUDGE API ---
+def should_send_signal(symbol, timeframe, proba):
+    key = (symbol, timeframe)
+    now = time.time()
+    
+    if key in last_signals_sent:
+        last_proba, last_time = last_signals_sent[key]
+        # 1. Filtre de similitude (LaTeX pour la précision)
+        # On ignore si la proba a bougé de moins de 2%
+        if abs(last_proba - proba) < 0.02 and (now - last_time) < 600: # 10 min de cooldown
+            return False
+            
+    last_signals_sent[key] = (proba, now)
+    return True
 # --- ⚖️ JUDGE API ---
 def run_judge_api(live_prices_json="{}"):
     try:
@@ -518,10 +529,11 @@ def run_judge_api(live_prices_json="{}"):
                         current_price = float(live_prices[epic])
                     
                     # Fallback sur KuCoin
+                    # ✅ ON REMPLACE PAR :
                     if current_price is None:
-                        f_sym = sym_db if "/USDT" in sym_db else sym_db.replace("/USD", "/USDT")
-                        if "/" not in f_sym: f_sym += "/USDT"
-                        current_price = exchange_sync.fetch_ticker(f_sym)['last']
+        
+                        print(f"⚠️ [SYNC WAIT] Prix Exness manquant pour {epic}. Juge en attente...")
+                        continue
 
                     sl_dyn, peak = t['sl'], t['peak_price']
                     new_peak = max(peak, current_price) if t['direction'] == 'HAUSSIER' else min(peak, current_price)