Fix pool disconnect issues: recreate Supabase client session per request

usage.py

@@ -8,24 +8,33 @@ PLAN_LIMITS = {
     "pro": float("inf"),  # unlimited
 }
 
-_supabase_client = None
-
 def get_supabase() -> Client:
-    global _supabase_client
-    if _supabase_client is None:
-        url = os.getenv("SUPABASE_URL")
-        key = os.getenv("SUPABASE_SERVICE_ROLE_KEY") or os.getenv("SUPABASE_SERVICE_KEY")
-        if not url or not key:
-            raise ValueError("Supabase credentials not set.")
-        _supabase_client = create_client(url, key)
-    return _supabase_client
+    url = os.getenv("SUPABASE_URL")
+    key = os.getenv("SUPABASE_SERVICE_ROLE_KEY") or os.getenv("SUPABASE_SERVICE_KEY")
+    if not url or not key:
+        raise ValueError("Supabase credentials not set.")
+    return create_client(url, key)
+
 
+from postgrest.exceptions import APIError
 
 def get_user_profile(user_id: str) -> dict:
-    """Fetch user profile from Supabase."""
+    """Fetch user profile from Supabase, creating a default one if it doesn't exist."""
     client = get_supabase()
-    result = client.table("profiles").select("*").eq("id", user_id).single().execute()
-    return result.data
+    try:
+        result = client.table("profiles").select("*").eq("id", user_id).single().execute()
+        return result.data
+    except APIError as e:
+        if e.code == "PGRST116":
+            new_profile = {
+                "id": user_id,
+                "plan": "free",
+                "humanization_count": 0,
+                "razorpay_subscription_id": None
+            }
+            client.table("profiles").insert(new_profile).execute()
+            return new_profile
+        raise e
 
 
 def check_usage_limit(user_id: str) -> dict: