Spaces:
Running
Running
File size: 2,348 Bytes
20b04f2 f388a93 20b04f2 f388a93 20b04f2 f388a93 20b04f2 f388a93 20b04f2 f388a93 20b04f2 f388a93 20b04f2 f388a93 20b04f2 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 | # db.py (Improved)
import os
import sqlite3
import logging
import json
logging.basicConfig(
level=logging.INFO,
format='%(asctime)s - %(levelname)s - %(message)s',
handlers=[logging.FileHandler('logs/db.log', encoding='utf-8'), logging.StreamHandler()]
)
logger = logging.getLogger(__name__)
class SessionDB:
def __init__(self, db_path="db/sessions.db"):
# Ensure parent folder exists
os.makedirs(os.path.dirname(db_path), exist_ok=True)
try:
self.conn = sqlite3.connect(db_path, check_same_thread=False)
self.cursor = self.conn.cursor()
self.create_table()
logger.info(f"Database initialized at {db_path}")
except Exception as e:
logger.error(f"Failed to initialize database at {db_path}: {e}")
logger.warning("Falling back to in-memory database")
self.conn = sqlite3.connect(":memory:", check_same_thread=False)
self.cursor = self.conn.cursor()
self.create_table()
def create_table(self):
try:
self.cursor.execute('''
CREATE TABLE IF NOT EXISTS sessions (
session_id TEXT PRIMARY KEY,
history TEXT
)
''')
self.conn.commit()
except Exception as e:
logger.error(f"Error creating sessions table: {e}")
def get_history(self, session_id, max_turns=4):
try:
self.cursor.execute("SELECT history FROM sessions WHERE session_id=?", (session_id,))
result = self.cursor.fetchone()
if result:
history = json.loads(result[0]) # safe parsing
return history[-max_turns:]
return []
except Exception as e:
logger.error(f"Error retrieving history for session {session_id}: {e}")
return []
def save_history(self, session_id, history):
try:
history_str = json.dumps(history) # safe serialization
self.cursor.execute(
"INSERT OR REPLACE INTO sessions (session_id, history) VALUES (?, ?)",
(session_id, history_str)
)
self.conn.commit()
except Exception as e:
logger.error(f"Error saving history for session {session_id}: {e}")
|