Update app.py

app.py

@@ -88,55 +88,72 @@ DB_NAME = "alphatrade_v9.db"
 HF_TOKEN = os.environ.get("HF_TOKEN")
 
 def init_db():
-    # --- 🛡️ DÉTECTION DE STRUCTURE ---
+    reset_needed = False
+    
+    # 1. Vérification (On ouvre et on ferme proprement)
     if os.path.exists(DB_NAME):
-        with sqlite3.connect(DB_NAME) as conn:
+        try:
+            conn = sqlite3.connect(DB_NAME)
             cursor = conn.execute("PRAGMA table_info(signals)")
             columns = [col[1] for col in cursor.fetchall()]
-            # Si 'date' ou 'timeframe' manquent, on reset tout
+            conn.close() # On ferme avant de tester la condition
+            
             if 'date' not in columns or 'timeframe' not in columns:
-                print("⚠️ Structure obsolète détectée. Reset de la base de données...")
-                conn.close()
+                reset_needed = True
+        except Exception as e:
+            print(f"⚠️ Erreur check DB: {e}")
+            reset_needed = True
+
+    # 2. Reset si nécessaire
+    if reset_needed:
+        print("⚠️ Structure obsolète détectée. Reset de la base de données...")
+        try:
+            if os.path.exists(DB_NAME):
                 os.remove(DB_NAME)
-    
-    # --- 🏗️ CRÉATION PROPRE ---
-    with sqlite3.connect(DB_NAME) as conn:
-        # Table des Signaux (Version V21 Complète)
-        conn.execute('''CREATE TABLE IF NOT EXISTS signals (
-            id INTEGER PRIMARY KEY AUTOINCREMENT, 
-            date TEXT, 
-            symbol TEXT, 
-            timeframe TEXT, 
-            direction TEXT, 
-            prob REAL, 
-            price REAL, 
-            tp REAL, 
-            sl REAL, 
-            status TEXT, 
-            regime INTEGER, 
-            prob_time REAL, 
-            prob_ml REAL, 
-            prob_lstm REAL, 
-            prob_sent REAL)''')
-        
-        # Table de Renforcement
-        conn.execute('''CREATE TABLE IF NOT EXISTS agent_logic (
-            timeframe TEXT PRIMARY KEY,
-            tp_mult REAL,
-            sl_mult REAL,
-            score REAL,
-            last_pnl REAL)''')
-        
-        # Init agent_logic si vide
-        cursor = conn.cursor()
-        cursor.execute("SELECT COUNT(*) FROM agent_logic")
-        if cursor.fetchone()[0] == 0:
-            defaults = [('5m', 1.5, 1.0, 0, 0), ('15m', 2.0, 1.2, 0, 0), 
-                        ('1h', 3.0, 1.5, 0, 0), ('4h', 4.5, 2.0, 0, 0), ('1d', 6.0, 2.5, 0, 0)]
-            conn.executemany("INSERT INTO agent_logic VALUES (?, ?, ?, ?, ?)", defaults)
-            print("✅ Mémoire RL initialisée.")
-
-    print("✅ Base de données V21 Synchronisée.")
+            print("✅ Ancienne base supprimée.")
+        except Exception as e:
+            print(f"❌ Impossible de supprimer la DB: {e}")
+
+    # 3. Création de la nouvelle structure
+    try:
+        with sqlite3.connect(DB_NAME) as conn:
+            # Table des Signaux V21
+            conn.execute('''CREATE TABLE IF NOT EXISTS signals (
+                id INTEGER PRIMARY KEY AUTOINCREMENT, 
+                date TEXT, 
+                symbol TEXT, 
+                timeframe TEXT, 
+                direction TEXT, 
+                prob REAL, 
+                price REAL, 
+                tp REAL, 
+                sl REAL, 
+                status TEXT, 
+                regime INTEGER, 
+                prob_time REAL, 
+                prob_ml REAL, 
+                prob_lstm REAL, 
+                prob_sent REAL)''')
+            
+            # Table de Renforcement
+            conn.execute('''CREATE TABLE IF NOT EXISTS agent_logic (
+                timeframe TEXT PRIMARY KEY,
+                tp_mult REAL,
+                sl_mult REAL,
+                score REAL,
+                last_pnl REAL)''')
+            
+            # Initialisation des multiplicateurs
+            cursor = conn.cursor()
+            cursor.execute("SELECT COUNT(*) FROM agent_logic")
+            if cursor.fetchone()[0] == 0:
+                defaults = [('5m', 1.5, 1.0, 0, 0), ('15m', 2.0, 1.2, 0, 0), 
+                            ('1h', 3.0, 1.5, 0, 0), ('4h', 4.5, 2.0, 0, 0), ('1d', 6.0, 2.5, 0, 0)]
+                conn.executemany("INSERT INTO agent_logic VALUES (?, ?, ?, ?, ?)", defaults)
+                print("✅ Mémoire RL initialisée.")
+        print("✅ Base de données V21 Synchronisée.")
+    except Exception as e:
+        print(f"❌ Erreur critique création DB: {e}")
     
 async def save_to_db(data):
     try: