api/core/db_connector.py

# core/db_connector.py
import os
from pymongo import MongoClient
from dotenv import load_dotenv

load_dotenv()

db_name = os.getenv("db", "yume-userdata")
users_collection_name = os.getenv("users_collection", "users")
watchlist_collection_name = os.getenv("watchlist_collection", "watchlist")
comments_collection_name = os.getenv("comments_collection", "comments")
episode_reactions_collection_name = os.getenv("episode_reactions_collection", "episode_reactions")
manga_list_collection_name = os.getenv("manga_list_collection", "manga_list")
bug_reports_collection_name = os.getenv("bug_reports_collection", "bug_reports")
announcements_collection_name = os.getenv("announcements_collection", "announcements")

# Centralized MongoDB connection with optimizations
mongodb_uri = os.getenv("MONGODB_URI")
client = MongoClient(
    mongodb_uri,
    maxPoolSize=50,
    minPoolSize=5,
    compressors=['snappy', 'zlib']
)

# Provide access to the database and collections
db = client[db_name]
users_collection = db[users_collection_name]
watchlist_collection = db[watchlist_collection_name]
comments_collection = db[comments_collection_name]
episode_reactions_collection = db[episode_reactions_collection_name]
manga_list_collection = db[manga_list_collection_name]
bug_reports_collection = db[bug_reports_collection_name]
announcements_collection = db[announcements_collection_name]