modelpy

src/main.py

@@ -3,7 +3,7 @@ from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
 from src.config import settings
 from src.database import init_db
-from src.routes import sessions
+from src.routes import sessions,files
 from src.web_socket import websocket_endpoint
 
 app = FastAPI(title="Real-time Audio Streaming Server")
@@ -20,6 +20,8 @@ os.makedirs(settings.AUDIO_STORAGE_DIR, exist_ok=True)
 init_db()
 
 app.include_router(sessions.router)
+app.include_router(files.router)
+
 
 # WebSocket route
 app.websocket("/ws/audio")(websocket_endpoint)

src/routes/files.py

@@ -0,0 +1,53 @@
+import os
+from fastapi import APIRouter
+from fastapi.responses import FileResponse, JSONResponse
+from src.config import settings
+import sqlite3
+
+router = APIRouter()
+
+# --- AUDIO FILES ---
+@router.get("/files")
+def list_files():
+    if not os.path.exists(settings.AUDIO_STORAGE_DIR):
+        return {"files": []}
+    return {"files": os.listdir(settings.AUDIO_STORAGE_DIR)}
+
+@router.get("/files/{filename}")
+def get_file(filename: str):
+    filepath = os.path.join(settings.AUDIO_STORAGE_DIR, filename)
+    if os.path.exists(filepath):
+        return FileResponse(filepath, media_type="audio/wav", filename=filename)
+    return JSONResponse(content={"error": "File not found"}, status_code=404)
+
+# --- DATABASE VIEW ---
+@router.get("/db/tables")
+def list_tables():
+    if not os.path.exists(settings.DB_PATH):
+        return {"tables": []}
+
+    conn = sqlite3.connect(settings.DB_PATH)
+    cursor = conn.cursor()
+    cursor.execute("SELECT name FROM sqlite_master WHERE type='table';")
+    tables = [row[0] for row in cursor.fetchall()]
+    conn.close()
+    return {"tables": tables}
+
+@router.get("/db/{table_name}")
+def get_table_data(table_name: str, limit: int = 50):
+    if not os.path.exists(settings.DB_PATH):
+        return {"error": "DB not found"}
+
+    conn = sqlite3.connect(settings.DB_PATH)
+    cursor = conn.cursor()
+
+    try:
+        cursor.execute(f"SELECT * FROM {table_name} LIMIT {limit}")
+        rows = cursor.fetchall()
+        columns = [description[0] for description in cursor.description]
+    except sqlite3.Error as e:
+        conn.close()
+        return {"error": str(e)}
+
+    conn.close()
+    return {"columns": columns, "rows": rows}