new update

routers/user.py

@@ -336,7 +336,7 @@ async def auth_google_callback(request: Request):
     # Set thời gian hết hạn ngắn, ví dụ 1 phút (60 giây)
     app_state = get_app_state(request=request)
     redis_client = app_state.redis
-    redis_client.set(f"google_auth_code:{auth_code}", user_email, ex=60)
+    await redis_client.set(f"google_auth_code:{auth_code}", user_email, ex=60)
 
     # 3. Chuyển hướng về trang callback của frontend, đính kèm code này
     frontend_callback_url = f"{config.FRONTEND_URL}/auth/callback?code={auth_code}"
@@ -355,11 +355,11 @@ async def exchange_google_code_for_token(request: Request,response: Response, co
     redis_client = app_state.redis
     # 1. Lấy email từ Redis bằng code và xóa code ngay lập tức
     redis_key = f"google_auth_code:{code}"
-    user_email_bytes =  redis_client.get(redis_key)
+    user_email_bytes = await redis_client.get(redis_key)
     if not user_email_bytes:
         raise HTTPException(status_code=400, detail="Invalid or expired authorization code.")
 
-    redis_client.delete(redis_key) # Dùng một lần
+    await redis_client.delete(redis_key) # Dùng một lần
     user_email = user_email_bytes.decode()
 
     mongo_db.users.update_one({

services/chat_service.py

@@ -174,13 +174,13 @@ async def stream_chat_generator(
     try:
         # --- 1. Xác thực và kiểm tra metadata từ Redis (Tương tự ask_question_service) ---
         meta_key = f"conversation_meta:{chat_id}"
-        if not  app_state.redis.exists(meta_key):
+        if not await app_state.redis.exists(meta_key):
             logger.warning(f"Stream: Metadata cho chat_id {chat_id} không tìm thấy.")
             error_payload = {"error": "Chat ID not found or session expired. Please reload."}
             yield f"event: error\ndata: {json.dumps(error_payload)}\n\n"
             return
 
-        user_in_redis_bytes =  app_state.redis.hget(meta_key, "user_id")
+        user_in_redis_bytes =await  app_state.redis.hget(meta_key, "user_id")
         if not user_in_redis_bytes:
             logger.error(f"Stream: user_id không có trong metadata của chat {chat_id}.")
             error_payload = {"error": "Chat metadata corrupted."}