Update utils/database.py

utils/database.py

@@ -1,23 +1,9 @@
-from pymongo import MongoClient
-from pymongo.errors import ConnectionFailure
-import os
-
-client = None
-db = None
-
-async def connect_to_mongo():
-    global client, db
-    mongo_uri = os.getenv("MONGO_URI")
-    db_name = os.getenv("MONGO_DB_NAME")
-    client = MongoClient(mongo_uri)
-    db = client[db_name]
-    try:
-        client.admin.command('ping')
-        print("Pinged your deployment. You successfully connected to MongoDB!")
-    except ConnectionFailure as e:
-        print("Could not connect to MongoDB:", e)
-
-async def close_mongo_connection():
-    global client
-    if client:
-        client.close()
+from pymongo import MongoClient
+import os
+
+def get_db():
+    MONGO_URI = os.getenv("MONGO_URI")
+    MONGO_DB_NAME = os.getenv("MONGO_DB_NAME")
+    client = MongoClient(MONGO_URI)
+    db = client[MONGO_DB_NAME]
+    return db