Update app.py

app.py

@@ -143,7 +143,19 @@ def init_db():
         print("✅ Base de données V12 (Multi-Brain & Trailing Stop) Synchronisée.")
     except Exception as e:
         print(f"❌ Erreur critique création DB: {e}")
-    
+
+
+conn = sqlite3.connect("alphatrade_v10.db")
+cursor = conn.cursor()
+try:
+    cursor.execute("ALTER TABLE signals ADD COLUMN confirmed INTEGER DEFAULT 0")
+    conn.commit()
+    print("✅ Colonne 'confirmed' ajoutée avec succès !")
+except Exception as e:
+    print(f"ℹ️ {e}") # Probablement déjà existante
+conn.close() 
+
+
 async def save_to_db(data):
     try:
         with sqlite3.connect(DB_NAME) as conn:
@@ -432,6 +444,16 @@ async def auto_predict_loop():
 def keep_alive_ping():
     return {"status": "awake", "time": datetime.now(timezone.utc).isoformat()}
 
+def confirm_trade_api(trade_id):
+    try:
+        with sqlite3.connect(DB_NAME) as conn:
+            cursor = conn.cursor()
+            cursor.execute("UPDATE signals SET confirmed = 1 WHERE id = ?", (trade_id,))
+            conn.commit()
+        return {"status": "success", "message": f"Signal {trade_id} confirmé et activé."}
+    except Exception as e:
+        return {"status": "error", "message": str(e)}
+        
 async def check_data_count(symbol):
     try:
         ex = ExchangeManager.get_instance()
@@ -449,7 +471,7 @@ def run_judge_api():
             conn.row_factory = sqlite3.Row
             cursor = conn.cursor()
             
-            cursor.execute("SELECT * FROM signals WHERE status = 'EN_COURS'")
+            cursor.execute("SELECT * FROM signals WHERE status = 'EN_COURS' AND confirmed = 1")
             trades = cursor.fetchall()
             
             if not trades: