added a script to check db connection

Author: chetanr25

apps/backend/app/auth/service.py

@@ -53,19 +53,25 @@ async def get_or_create_user(
         self, email: str, name: str, avatar_url: str = None, google_id: str = None
     ) -> Optional[Dict[str, Any]]:
         """Get existing user or create new one"""
+        # Add basic debug print to start
+        import sys
+        print(f"DEBUG: Attempting auth for {email}", file=sys.stderr, flush=True)
+
         try:
             async with async_session_factory() as db:
                 result = await db.execute(select(User).where(User.email == email))
                 user = result.scalar_one_or_none()
 
                 if user:
+                    print(f"DEBUG: Found existing user {user.id}", file=sys.stderr, flush=True)
                     return {
                         "id": str(user.id),
                         "email": user.email,
                         "name": user.name,
                         "avatar_url": user.avatar_url,
                     }
 
+                print(f"DEBUG: Creating new user for {email}", file=sys.stderr, flush=True)
                 new_user = User(
                     email=email,
                     name=name,
@@ -75,6 +81,7 @@ async def get_or_create_user(
                 db.add(new_user)
                 await db.commit()
                 await db.refresh(new_user)
+                print(f"DEBUG: Created new user {new_user.id}", file=sys.stderr, flush=True)
 
                 return {
                     "id": str(new_user.id),

apps/backend/check_db.py

@@ -0,0 +1,66 @@
+import asyncio
+import os
+import sys
+from sqlalchemy.ext.asyncio import create_async_engine
+from sqlalchemy import text
+
+# Add current directory to path to find 'app'
+sys.path.append(os.getcwd())
+
+display_url = "UNKNOWN"
+
+try:
+    from app.config import settings
+    url = settings.POSTGRES_URL
+    # Mask password for display
+    if "@" in url:
+        display_url = url.split("@")[1]
+        user_part = url.split("@")[0]
+        if ":" in user_part:
+            display_url = f"{user_part.split(':')[0]}:****@{display_url}"
+        else:
+            display_url = f"{user_part}@{display_url}"
+    else:
+        display_url = url
+        
+    print(f"Checking connection to: {display_url}")
+except Exception as e:
+    print(f"Could not load settings: {e}")
+    url = os.environ.get("POSTGRES_URL")
+    print(f"Using URL from env: {url}")
+
+if not url:
+    print("Error: POSTGRES_URL not set!")
+    sys.exit(1)
+
+async def check():
+    print("-" * 50)
+    print("Starting connection test...")
+    try:
+        # Create engine
+        engine = create_async_engine(url, echo=False)
+        
+        # Try to connect
+        async with engine.connect() as conn:
+            result = await conn.execute(text("SELECT 1"))
+            val = result.scalar()
+            print(f"SUCCESS: Database returned {val}")
+            
+            # Check database name
+            result_db = await conn.execute(text("SELECT current_database()"))
+            db_name = result_db.scalar()
+            print(f"Connected to database: {db_name}")
+            
+        await engine.dispose()
+        print("-" * 50)
+        print("✅ DATABASE CONNECTION HEALTHY")
+        
+    except Exception as e:
+        print("-" * 50)
+        print(f"❌ CONNECTION FAILED")
+        print(f"Error type: {type(e).__name__}")
+        print(f"Error message: {e}")
+        print("-" * 50)
+
+if __name__ == "__main__":
+    asyncio.run(check())