Refactor prepare_tables function to use raw SQL for creating users and images tables

app.py

@@ -51,32 +51,26 @@ app = FastAPI()
 def prepare_tables():
     """
     Ensure 'users' and 'images' tables exist. Creates them if they don't.
+    Uses postgrest.raw() to execute raw SQL.
     """
-    # Create users table
-    supabase.postgrest.client.rpc(
-        "sql",
-        {"query": """
-            CREATE TABLE IF NOT EXISTS users (
-              id SERIAL PRIMARY KEY,
-              chat_id TEXT UNIQUE NOT NULL,
-              created_at BIGINT NOT NULL
-            );
-        """}
-    ).execute()
-
-    # Create images table
-    supabase.postgrest.client.rpc(
-        "sql",
-        {"query": """
-            CREATE TABLE IF NOT EXISTS images (
-              id SERIAL PRIMARY KEY,
-              chat_id TEXT NOT NULL,
-              prompt TEXT NOT NULL,
-              url TEXT NOT NULL,
-              created_at BIGINT NOT NULL
-            );
-        """}
-    ).execute()
+    users_sql = """
+      CREATE TABLE IF NOT EXISTS users (
+        id SERIAL PRIMARY KEY,
+        chat_id TEXT UNIQUE NOT NULL,
+        created_at BIGINT NOT NULL
+      );
+    """
+    images_sql = """
+      CREATE TABLE IF NOT EXISTS images (
+        id SERIAL PRIMARY KEY,
+        chat_id TEXT NOT NULL,
+        prompt TEXT NOT NULL,
+        url TEXT NOT NULL,
+        created_at BIGINT NOT NULL
+      );
+    """
+    supabase.postgrest.raw(users_sql).execute()
+    supabase.postgrest.raw(images_sql).execute()
 
 # ————— Inactivity Monitor —————
 def inactivity_monitor():
@@ -346,10 +340,14 @@ def index():
     return "Eve is running! 💖"
 
 if __name__ == "__main__":
-    # prepare Supabase schema, then start threads and server
+    # 1) prepare Supabase schema
     prepare_tables()
+
+    # 2) start background threads
     threading.Thread(target=inactivity_monitor, daemon=True).start()
     threading.Thread(target=worker, daemon=True).start()
+
+    # 3) send startup message & run server
     send_startup_message()
     import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+    uvicorn.run(app, host="0.0.0.0", port=7860)