Update app.py

app.py

@@ -84,7 +84,10 @@ except:
 try:
     from ensemble import combine_scores
 except:
-    def combine_scores(symbol, timeframe, t, m, l, sent, r): return (t+m+l+sent)/4, 0.25, 0.25, 0.25, 0.25
+    def combine_scores(symbol, timeframe, t, m, l, sent, r): 
+        # Formule PRO : 30% Time, 30% ML, 30% LightGBM, 10% Sentiment
+        score = (t * 0.30) + (m * 0.30) + (l * 0.30) + (sent * 0.10)
+        return score, 0.30, 0.30, 0.30, 0.10
 
 # --- DB, SYNC & HUGGING FACE BACKUP ---
 DB_NAME = "alphatrade_v31_dino.db"
@@ -231,6 +234,7 @@ init_db()
 
 # --- 🛡️ STATE MANAGER ---
 active_signals_state = {}
+last_signals_sent = {} # ⬅️ LA RUSTINE CRITIQUE EST LÀ
 
 def clean_old_db_signals(symbol, timeframe):
     try:
@@ -277,19 +281,31 @@ try:
 except:
     dino_brain = None
 
-# --- 📊 FEATURES ENGINE ---
+# --- 🌐 HTTP SESSION MANAGER ---
+global_aio_session = None
+
+async def get_aio_session():
+    global global_aio_session
+    if global_aio_session is None or global_aio_session.closed:
+        global_aio_session = aiohttp.ClientSession()
+    return global_aio_session
+
 async def fetch_kucoin_futures_data(symbol):
     try:
         ku_sym = symbol.replace("/", "").replace("BTC", "XBT") + "M"
-        async with aiohttp.ClientSession() as session:
-            oi_url = f"https://api-futures.kucoin.com/api/v1/open-interest?symbol={ku_sym}"
-            trade_url = f"https://api-futures.kucoin.com/api/v1/trade/history?symbol={ku_sym}"
-            async with session.get(oi_url) as r1, session.get(trade_url) as r2:
-                oi_json = await r1.json()
-                trades = (await r2.json()).get("data", [])
-                cvd = sum([float(t.get("size", 0)) if t.get("side") == "buy" else -float(t.get("size", 0)) for t in trades])
-                return {"oi": float(oi_json.get("data", {}).get("value", 0)), "cvd": cvd}
-    except: return {"oi": 0, "cvd": 0}
+        session = await get_aio_session() # On utilise la session globale ouverte
+        
+        oi_url = f"https://api-futures.kucoin.com/api/v1/open-interest?symbol={ku_sym}"
+        trade_url = f"https://api-futures.kucoin.com/api/v1/trade/history?symbol={ku_sym}"
+        
+        async with session.get(oi_url) as r1, session.get(trade_url) as r2:
+            oi_json = await r1.json()
+            trades = (await r2.json()).get("data", [])
+            cvd = sum([float(t.get("size", 0)) if t.get("side") == "buy" else -float(t.get("size", 0)) for t in trades])
+            return {"oi": float(oi_json.get("data", {}).get("value", 0)), "cvd": cvd}
+    except Exception as e: 
+        print(f"⚠️ Erreur Flux KuCoin ({symbol}) : {e}")
+        return {"oi": 0, "cvd": 0}
 
 def prepare_features_sync(symbol, timeframe='1h', limit_bars=600):
     try: