update

db/mongoDB.py

@@ -47,7 +47,7 @@ async def connect_to_mongo():
         )
 
         # 2. Kiểm tra kết nối một cách rõ ràng
-        await mongo_db.client.admin.command('ping')
+        mongo_db.client.admin.command('ping')
 
         # 3. Gán các đối tượng database và collection
         mongo_db.db = mongo_db.client[config.DB_NAME]
@@ -57,10 +57,10 @@ async def connect_to_mongo():
 
         # 4. Tạo TTL index một cách an toàn
         # Lấy danh sách index hiện có
-        index_info = await mongo_db.token_blacklist.index_information()
+        index_info = mongo_db.token_blacklist.index_information()
         if "expires_at_1" not in index_info:
             # Chỉ tạo index nếu nó chưa tồn tại
-            await mongo_db.token_blacklist.create_index("expires_at", expireAfterSeconds=0)
+            mongo_db.token_blacklist.create_index("expires_at", expireAfterSeconds=0)
             logger.info("🔸 Successfully created TTL index for 'expires_at' in 'token_blacklist'.")
 
 

dependencies.py

@@ -189,7 +189,7 @@ async def get_current_user(
     # 1. Kiểm tra token trong blacklist
     try:
         logger.info("GET_CURRENT_USER: Đang kiểm tra blacklist...")
-        is_blacklisted = await mongo_db.token_blacklist.find_one({"token": token_to_verify})
+        is_blacklisted = mongo_db.token_blacklist.find_one({"token": token_to_verify})
         if is_blacklisted:
             logger.error(f"GET_CURRENT_USER: *** TOKEN TRONG BLACKLIST - RAISING 401 ***")
             raise HTTPException( # Sử dụng credentials_exception hoặc một cái cụ thể hơn
@@ -266,7 +266,7 @@ async def get_current_user(
     user_data: Optional[dict] = None # Khởi tạo để tránh UnboundLocalError
     try:
         logger.info(f"GET_CURRENT_USER: Đang tìm user trong DB: {email.lower()}") # email đã được validate là str
-        user_data =await mongo_db.users.find_one({"email": email.lower()}, {"password": 0, "_id": 0})
+        user_data = mongo_db.users.find_one({"email": email.lower()}, {"password": 0, "_id": 0})
         # print(user_data) # Bỏ print trong production
 
         if user_data is None:

routers/chat.py

@@ -66,7 +66,7 @@ async def create_chat(
     }
 
     try:
-        conversations_collection.insert_one(conversation_doc)
+        mongo_db.conversations.insert_one(conversation_doc)
         logger.info(f"Đã tạo hội thoại rỗng {chat_id} trong MongoDB cho user {current_user.email}.")
     except Exception as e:
         logger.error(f"Lỗi khi tạo hội thoại rỗng trong MongoDB cho chat {chat_id}: {e}", exc_info=True)
@@ -135,7 +135,7 @@ async def delete_chat(chat_id: str, request: Request, user: UserOut = Depends(ge
     # Xóa chat
     delete_chat_from_redis(redis, chat_id)
     # Xóa hội thoại trong MongoDB
-    result = await mongo_db.conversations.delete_one({"conversation_id": chat_id, "user_id": user.email})
+    result = mongo_db.conversations.delete_one({"conversation_id": chat_id, "user_id": user.email})
     if result.deleted_count == 0:
         raise HTTPException(status_code=404, detail="Chat not found in MongoDB")
 
@@ -147,7 +147,7 @@ async def delete_chat(chat_id: str, request: Request, user: UserOut = Depends(ge
 async def get_conversations(user: UserOut = Depends(get_current_user)):
     try:
         logger.info(f"Attempting to get conversations for user: {user.email}")
-        db_conversations_cursor = await mongo_db.conversations.find({"user_id": user.email})
+        db_conversations_cursor = mongo_db.conversations.find({"user_id": user.email})
 
         response_list = []
 
@@ -182,7 +182,7 @@ async def load_conversation_and_sync_redis(
 
     # 1. Kiểm tra hội thoại trong MongoDB
     try:
-        conversation_doc =await mongo_db.conversations.find_one(
+        conversation_doc =mongo_db.conversations.find_one(
             {"conversation_id": chat_id, "user_id": current_user.email}
         )
         if not conversation_doc:

routers/user.py

@@ -304,7 +304,7 @@ async def auth_google_callback(request: Request):
 
 
     # Kiểm tra xem user đã tồn tại trong DB chưa
-    db_user = await mongo_db.users.find_one({"email": user_email})
+    db_user =  mongo_db.users.find_one({"email": user_email})
 
     if not db_user:
         placeholder_password = f"google-oauth2|{uuid.uuid4()}"
@@ -314,7 +314,7 @@ async def auth_google_callback(request: Request):
 
 
         # Tạo user mới với thông tin từ Google
-        await mongo_db.users.insert_one({
+        mongo_db.users.insert_one({
             "email": user_email,
             "username": username,
             "password": hashed_password,  # Mật khẩu tạm thời, sẽ không dùng đến
@@ -324,7 +324,7 @@ async def auth_google_callback(request: Request):
         })
 
         # Lấy lại user vừa tạo để đảm bảo có _id và các trường khác
-        db_user =await mongo_db.users.find_one({"email": user_email})
+        db_user = mongo_db.users.find_one({"email": user_email})
         if not db_user: # Kiểm tra lại sau khi insert
              raise HTTPException(status_code=500, detail="Could not create and retrieve new user account.")
 
@@ -362,7 +362,7 @@ async def exchange_google_code_for_token(request: Request,response: Response, co
     redis_client.delete(redis_key) # Dùng một lần
     user_email = user_email_bytes.decode()
 
-    await mongo_db.users.update_one({
+    mongo_db.users.update_one({
         "email": user_email
     }, {
         "$set": {
@@ -408,7 +408,7 @@ async def exchange_google_code_for_token(request: Request,response: Response, co
             path="/api/user/refresh-token",
         )
 
-    user_info =await mongo_db.users.find_one({"email": user_email})
+    user_info =mongo_db.users.find_one({"email": user_email})
     user = {
         "email": user_info.get("email"),
         "username": user_info.get("username"),

services/auth_service.py

@@ -31,7 +31,7 @@ async def register_user(user: RegisterRequest):
 
     try:
                 # Kiểm tra username đã tồn tại chưa
-        existing_user =await mongo_db.users.find_one({"email": user.email})
+        existing_user =mongo_db.users.find_one({"email": user.email})
         if existing_user:
             raise HTTPException(status_code=400, detail="Tài khoản đã tồn tại.")
 
@@ -40,7 +40,7 @@ async def register_user(user: RegisterRequest):
 
         avatar = await get_random_unsplash_image()
         # Lưu user mới
-        await mongo_db.users.insert_one({
+        mongo_db.users.insert_one({
             "username": user.username,
             "password": hashed_password,
             "email": user.email,
@@ -54,7 +54,7 @@ async def register_user(user: RegisterRequest):
         raise HTTPException(status_code=e.status_code, detail=e.detail)
 # Hàm xác thực đăng nhập
 async def authenticate_user(request: LoginRequest):
-    user =await mongo_db.users.find_one({"email": request.email})
+    user =mongo_db.users.find_one({"email": request.email})
     if not user:
         raise HTTPException(status_code=401, detail="Sai tài khoản hoặc mật khẩu")
 
@@ -101,7 +101,7 @@ async def logout_user(req: Request, credentials: HTTPAuthorizationCredentials =
             raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Access token không hợp lệ")
 
         # Blacklist access token
-        await mongo_db.token_blacklist.insert_one({
+        mongo_db.token_blacklist.insert_one({
             "token": token,
             "expires_at": datetime.fromtimestamp(exp, tz=timezone.utc)
         })
@@ -110,9 +110,9 @@ async def logout_user(req: Request, credentials: HTTPAuthorizationCredentials =
         refresh_token = req.cookies.get("refresh_token")
         if refresh_token:
             # Invalidate refresh token in database
-            user = await mongo_db.users.find_one({"refresh_token": refresh_token})
+            user = mongo_db.users.find_one({"refresh_token": refresh_token})
             if user:
-                await mongo_db.users.update_one(
+                mongo_db.users.update_one(
                     {"_id": user["_id"]},
                     {"$set": {"refresh_token": None, "refresh_token_expiry": None, "revoked": True}}
                 )

services/user_service.py

@@ -37,7 +37,7 @@ async def get_users(skip: int = 0, limit: int = 100, query: dict = None):
         search_query = query or {}
 
         # Thực hiện truy vấn với phân trang
-        users_cursor =await mongo_db.users.find(
+        users_cursor = mongo_db.users.find(
             search_query,
             {"_id": 0, "password": 0}  # Loại bỏ các trường nhạy cảm
         ).skip(skip).limit(limit)
@@ -68,7 +68,7 @@ async def count_users(query: dict = None):
     """
     try:
         search_query = query or {}
-        return await mongo_db.users.count_documents(search_query)
+        return mongo_db.users.count_documents(search_query)
     except Exception as e:
         logger.error(f"Lỗi khi đếm người dùng: {str(e)}")
         raise HTTPException(
@@ -112,7 +112,7 @@ async def get_paginated_users(
         sort_criteria = [(sort_by, sort_order)]
 
         # Thực hiện truy vấn
-        users_cursor =await mongo_db.users.find(
+        users_cursor =mongo_db.users.find(
             query,
             {"_id": 0, "password": 0}  # Loại bỏ các trường nhạy cảm
         ).sort(sort_criteria).skip(skip).limit(limit)
@@ -121,7 +121,7 @@ async def get_paginated_users(
         user_list =  users_cursor.to_list(length=limit)
 
         # Đếm tổng số bản ghi
-        total =await mongo_db.users.count_documents(query)
+        total =mongo_db.users.count_documents(query)
 
         # Tính toán thông tin phân trang
         total_pages = math.ceil(total / limit) if limit > 0 else 0
@@ -182,7 +182,7 @@ async def delete_user(user_id: str):
         bool: True nếu xóa thành công, False nếu không tìm thấy người dùng
     """
     try:
-        result =await mongo_db.users.delete_one({"_id": user_id})
+        result =mongo_db.users.delete_one({"_id": user_id})
         return result.deleted_count > 0
     except Exception as e:
         logger.error(f"Lỗi khi xóa người dùng: {str(e)}")
@@ -204,7 +204,7 @@ async def change_password(email: str, current_password: str, new_password: str):
         bool: True nếu đổi mật khẩu thành công, False nếu không thành công
     """
     try:
-        user =await mongo_db.users.find_one({"email": email})
+        user =mongo_db.users.find_one({"email": email})
         if not user:
             raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Người dùng không tồn tại")
 
@@ -216,7 +216,7 @@ async def change_password(email: str, current_password: str, new_password: str):
         # Hash the new password
         hashed_password = pwd_context.hash(new_password)
         # Update the password in the database
-        result =await mongo_db.users.update_one({"email": email}, {"$set": {"password": hashed_password}})
+        result =mongo_db.users.update_one({"email": email}, {"$set": {"password": hashed_password}})
         return result.modified_count > 0
     except HTTPException as he:
         raise he
@@ -248,7 +248,7 @@ async def reset_password_request(email: str) -> bool:
             return True
 
         # Check for rate limiting (e.g., max 3 requests per hour)
-        reset_requests = await mongo_db.users.count_documents({
+        reset_requests = mongo_db.users.count_documents({
             "email": email.lower(),
             "reset_password_timestamp": {
                 "$gte": datetime.now(tz=timezone.utc) - timedelta(hours=1)
@@ -265,7 +265,7 @@ async def reset_password_request(email: str) -> bool:
         expiry = datetime.now() + timedelta(minutes=10)
 
         # Store reset token and timestamp in database
-        await mongo_db.users.update_one(
+        mongo_db.users.update_one(
             {"_id": ObjectId(user["_id"])},
             {
                 "$set": {
@@ -380,7 +380,7 @@ async def generate_and_store_verification_code(email: str) -> bool:
         expiry = datetime.now() + timedelta(minutes=10)
 
         # Store code and expiry in database
-        result = await mongo_db.users.update_one(
+        result = mongo_db.users.update_one(
             {"email": email.lower()},
             {
                 "$set": {
@@ -425,7 +425,7 @@ async def verify_login_code(email: str, code: str, res: Response): # Bỏ kiểu
         HTTPException: Nếu mã không hợp lệ, đã hết hạn hoặc có lỗi hệ thống.
     """
     try:
-        user = await mongo_db.users.find_one({ # Sử dụng await nếu mongo_db.users là async (ví dụ Motor)
+        user = mongo_db.users.find_one({ # Sử dụng await nếu mongo_db.users là async (ví dụ Motor)
             "email": email.lower(),
             "login_verification_code": code
         })
@@ -443,7 +443,7 @@ async def verify_login_code(email: str, code: str, res: Response): # Bỏ kiểu
         if not expiry or expiry < datetime.now(expiry.tzinfo if expiry.tzinfo else None): # So sánh aware với aware, naive với naive
             logger.warning(f"Mã xác minh đã hết hạn cho email: {email}")
             # Xóa mã đã hết hạn để tránh sử dụng lại
-            await mongo_db.users.update_one(
+            mongo_db.users.update_one(
                 {"_id": ObjectId(user["_id"])},
                 {
                     "$unset": {
@@ -509,7 +509,7 @@ async def verify_login_code(email: str, code: str, res: Response): # Bỏ kiểu
         # --------------------
 
         # Clear verification code và cập nhật last_login
-        await mongo_db.users.update_one( # Sử dụng await nếu là async
+        mongo_db.users.update_one( # Sử dụng await nếu là async
             {"_id": ObjectId(user["_id"])},
             {
                 "$unset": {
@@ -567,7 +567,7 @@ async def authenticate_user(request: LoginRequest) -> dict:
     Raises:
         HTTPException: Nếu thông tin đăng nhập không hợp lệ.
     """
-    user = await mongo_db.users.find_one({"email": request.email.lower()})
+    user = mongo_db.users.find_one({"email": request.email.lower()})
     if not user or not pwd_context.verify(request.password, user["password"]):
         logger.warning(f"Xác thực thất bại cho email: {request.email}")
         raise HTTPException(
@@ -603,7 +603,7 @@ async def refresh_access_token(req: Request  , res: Response ) -> dict:
             )
 
         # Find user by refresh token in database
-        user = await mongo_db.users.find_one({"refresh_token": refresh_token})
+        user = mongo_db.users.find_one({"refresh_token": refresh_token})
 
 
         if not user:
@@ -640,7 +640,7 @@ async def refresh_access_token(req: Request  , res: Response ) -> dict:
         new_refresh_token = await create_refresh_token(email)
 
         # Update database with new refresh token
-        await mongo_db.users.update_one(
+        mongo_db.users.update_one(
             {"_id": user["_id"]},
             {
                 "$set": {

utils/utils.py

@@ -233,7 +233,7 @@ async def create_refresh_token(email: str) -> str:
 
 
         # Store refresh token in database
-        result = await mongo_db.users.update_one(
+        result = mongo_db.users.update_one(
             {"email": email.lower()},
             {
                 "$set": {