Graceful DB connection with retries and SSL for Supabase

app/database.py

@@ -483,10 +483,40 @@ class PostgresDocumentDatabase:
 
 async def connect_db():
     global client, db
-    client = await asyncpg.create_pool(settings.postgres_uri, min_size=1, max_size=10)
-    db = PostgresDocumentDatabase(client)
-    await db.initialize()
-    print("Connected to PostgreSQL")
+    import asyncio
+    import logging
+
+    logger = logging.getLogger(__name__)
+    uri = settings.postgres_uri
+
+    # Ensure SSL for remote connections (required by Supabase)
+    if "supabase" in uri and "sslmode" not in uri:
+        separator = "&" if "?" in uri else "?"
+        uri = f"{uri}{separator}sslmode=require"
+
+    max_retries = 3
+    for attempt in range(1, max_retries + 1):
+        try:
+            client = await asyncpg.create_pool(
+                uri, min_size=1, max_size=10,
+                command_timeout=30, timeout=30,
+            )
+            db = PostgresDocumentDatabase(client)
+            await db.initialize()
+            logger.info("Connected to PostgreSQL")
+            return
+        except Exception as e:
+            logger.warning(f"DB connection attempt {attempt}/{max_retries} failed: {e}")
+            if attempt < max_retries:
+                await asyncio.sleep(2 * attempt)
+            else:
+                logger.error(
+                    "Could not connect to PostgreSQL after %d attempts. "
+                    "App will start but database features will be unavailable.",
+                    max_retries,
+                )
+                # Don't crash the app — let it start for health checks
+                return
 
 
 async def close_db():