Update storage.py

storage.py

@@ -4,40 +4,31 @@ import time
 import threading
 
 DB_FILE = "hunter_data.db"
-db_lock = threading.Lock()  # <--- NEW: Prevents database corruption
+db_lock = threading.Lock()
 
 def init_db():
     with db_lock:
         conn = sqlite3.connect(DB_FILE, check_same_thread=False)
         c = conn.cursor()
         c.execute('''CREATE TABLE IF NOT EXISTS results
-                     (symbol TEXT PRIMARY KEY, 
-                      score INTEGER, 
-                      decision TEXT, 
-                      trend TEXT, 
-                      metrics TEXT, 
-                      reason TEXT,
-                      timestamp REAL)''')
+                     (symbol TEXT PRIMARY KEY, score INTEGER, decision TEXT, 
+                      trend TEXT, metrics TEXT, reason TEXT, timestamp REAL)''')
         c.execute('''CREATE TABLE IF NOT EXISTS state
                      (key TEXT PRIMARY KEY, value TEXT)''')
         conn.commit()
         conn.close()
 
 def save_result(data):
-    """Thread-safe save."""
     with db_lock:
         conn = sqlite3.connect(DB_FILE, check_same_thread=False)
         c = conn.cursor()
-        c.execute('''INSERT OR REPLACE INTO results 
-                     (symbol, score, decision, trend, metrics, reason, timestamp)
-                     VALUES (?, ?, ?, ?, ?, ?, ?)''',
+        c.execute('''INSERT OR REPLACE INTO results VALUES (?, ?, ?, ?, ?, ?, ?)''',
                   (data['Ticker'], data['Score'], data['Decision'], 
                    data['Trend'], data['Key Metrics'], data['AI Reasoning'], time.time()))
         conn.commit()
         conn.close()
 
 def fetch_results():
-    """Thread-safe read."""
     with db_lock:
         conn = sqlite3.connect(DB_FILE, check_same_thread=False)
         try: