Fix: Parse DATABASE_URL to extract individual connection parameters for asyncpg

app/core/config.py

@@ -41,13 +41,51 @@ class Settings(BaseSettings):
 
     @model_validator(mode='after')
     def assemble_db_connection(self) -> 'Settings':
-        from urllib.parse import quote_plus
+        from urllib.parse import quote_plus, urlparse
+        
         # Prefer DATABASE_URL and DATABASE_URI
         env_url = (os.getenv("DATABASE_URL") or os.getenv("DATABASE_URI") or "").strip()
         if env_url:
             self.POSTGRES_URI = env_url
-            print(f"[CONFIG] Using provided DATABASE_URL/URI {self.POSTGRES_URI}")
+            print(f"[CONFIG] Using provided DATABASE_URL/URI")
+            
+            # Parse the URL to extract individual components for asyncpg
+            try:
+                # Remove the +asyncpg suffix if present for parsing
+                parse_url = env_url.replace("postgresql+asyncpg://", "postgresql://")
+                parsed = urlparse(parse_url)
+                
+                # Override individual settings from URL
+                if parsed.hostname:
+                    self.POSTGRES_HOST = parsed.hostname
+                if parsed.port:
+                    self.POSTGRES_PORT = parsed.port
+                if parsed.username:
+                    self.POSTGRES_USER = parsed.username
+                if parsed.password:
+                    self.POSTGRES_PASSWORD = parsed.password
+                if parsed.path and len(parsed.path) > 1:
+                    self.POSTGRES_DB = parsed.path[1:]  # Remove leading /
+                
+                # Parse query parameters for SSL mode
+                if parsed.query:
+                    from urllib.parse import parse_qs
+                    params = parse_qs(parsed.query)
+                    if 'sslmode' in params:
+                        self.POSTGRES_SSL_MODE = params['sslmode'][0]
+                
+                print(f"[CONFIG] Parsed DATABASE_URL:")
+                print(f"[CONFIG]   Host: {self.POSTGRES_HOST}")
+                print(f"[CONFIG]   Port: {self.POSTGRES_PORT}")
+                print(f"[CONFIG]   Database: {self.POSTGRES_DB}")
+                print(f"[CONFIG]   User: {self.POSTGRES_USER}")
+                print(f"[CONFIG]   SSL Mode: {self.POSTGRES_SSL_MODE}")
+                
+            except Exception as e:
+                print(f"[CONFIG] Warning: Failed to parse DATABASE_URL: {e}")
+            
             return self
+            
         # Build DSN from individual parts
         if all([self.POSTGRES_USER, self.POSTGRES_PASSWORD, self.POSTGRES_HOST, self.POSTGRES_DB]):
             protocol = os.getenv("DB_PROTOCOL", "postgresql+asyncpg")