app/database.py

from motor.motor_asyncio import AsyncIOMotorClient
from app.config import env

client = None
db = None

async def connect_db():
    global client, db
    client = AsyncIOMotorClient(env.MONGO_URI)
    db = client.get_default_database()
    if db.name is None:
        db = client["vedaai"]
    print("Connected to MongoDB via Motor")

async def close_db():
    global client
    if client:
        client.close()
        print("Disconnected from MongoDB")