import asyncio
import asyncpg
import os

async def test_connection():
    try:
        # Test with the actual credentials
        conn = await asyncpg.connect(
            host='127.0.0.1',
            port=5432,
            user='auth_service_user',
            password='temp-db-password-change-me',
            database='auth_db',
            timeout=10
        )
        print("✓ Database connection successful!")
        
        # Test a simple query
        version = await conn.fetchval('SELECT version()')
        print(f"✓ PostgreSQL version: {version[:50]}...")
        
        await conn.close()
        print("✓ Connection closed successfully")
        
    except Exception as e:
        print(f"✗ Connection failed: {e}")
        import traceback
        traceback.print_exc()

if __name__ == "__main__":
    asyncio.run(test_connection())