fix

dependencies.py

@@ -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 = mongo_db.users.find_one({"email": email.lower()}, {"password": 0, "_id": 0})
+        user_data = await 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/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 =  mongo_db.users.find_one({"email": user_email})
+    db_user = await  mongo_db.users.find_one({"email": user_email})
 
     if not db_user:
         placeholder_password = f"google-oauth2|{uuid.uuid4()}"
@@ -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 = mongo_db.users.find_one({"email": user_email})
+        db_user = await 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.")
 
@@ -408,7 +408,7 @@ async def exchange_google_code_for_token(request: Request,response: Response, co
             path="/api/user/refresh-token",
         )
 
-    user_info =mongo_db.users.find_one({"email": user_email})
+    user_info =await 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 =mongo_db.users.find_one({"email": user.email})
+        existing_user =await 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.")
 
@@ -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 =mongo_db.users.find_one({"email": request.email})
+    user = await 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")
 
@@ -110,7 +110,7 @@ async def logout_user(req: Request, credentials: HTTPAuthorizationCredentials =
         refresh_token = req.cookies.get("refresh_token")
         if refresh_token:
             # Invalidate refresh token in database
-            user = mongo_db.users.find_one({"refresh_token": refresh_token})
+            user = await mongo_db.users.find_one({"refresh_token": refresh_token})
             if user:
                 mongo_db.users.update_one(
                     {"_id": user["_id"]},

services/user_service.py

@@ -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 =mongo_db.users.find_one({"email": email})
+        user =await 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")
 
@@ -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 = mongo_db.users.find_one({ # Sử dụng await nếu mongo_db.users là async (ví dụ Motor)
+        user = await 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
         })
@@ -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 = mongo_db.users.find_one({"email": request.email.lower()})
+    user = await 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 = mongo_db.users.find_one({"refresh_token": refresh_token})
+        user =await mongo_db.users.find_one({"refresh_token": refresh_token})
 
 
         if not user: