Update app/services/api_logger.py

app/services/api_logger.py

@@ -7,6 +7,8 @@ from zoneinfo import ZoneInfo
 
 from motor.motor_asyncio import AsyncIOMotorCollection
 
+from app.db.mongo import connect_to_mongo
+
 logger = logging.getLogger(__name__)
 
 
@@ -33,18 +35,19 @@ class ApiLogger:
         user_id: Optional[str],
         error_message: Optional[str] = None,
     ) -> None:
-        doc = {
-            "name": name,
-            "status": status,
-            "date": self._current_ist_timestamp(),
-            "response_time": round(response_time, 3),
-        }
-        if user_id:
-            doc["user_id"] = user_id
-        if error_message:
-            doc["error_message"] = error_message
-
         try:
+            await connect_to_mongo()
+            doc = {
+                "name": name,
+                "status": status,
+                "date": self._current_ist_timestamp(),
+                "response_time": round(response_time, 3),
+            }
+            if user_id:
+                doc["user_id"] = user_id
+            if error_message:
+                doc["error_message"] = error_message
+
             await self._collection().insert_one(doc)
         except Exception:
             logger.exception("Failed to write categorize API log")