fix

routers/chat.py

@@ -129,7 +129,7 @@ async def delete_chat(chat_id: str, request: Request, user: UserOut = Depends(ge
     if user_in_chat is None:
         raise HTTPException(status_code=404, detail="Chat not found")
 
-    if user_in_chat.decode() != user.email:
+    if user_in_chat != user.email:
         raise HTTPException(status_code=403, detail="Unauthorized")
 
     # Xóa chat

services/chat_service.py

@@ -30,7 +30,7 @@ async def ask_question_service(app_state, request: QueryRequest, user: UserOut =
         raise HTTPException(status_code=404, detail="Chat metadata corrupted.")
 
     if user_in_redis != user.email:
-        logger.warning(f"User {user.email} không được phép truy cập chat {chat_id} (thuộc về {user_in_redis.decode()}).")
+        logger.warning(f"User {user.email} không được phép truy cập chat {chat_id} (thuộc về {user_in_redis}).")
         raise HTTPException(status_code=403, detail="Unauthorized to access this chat.")
 
     start_time = time.time()
@@ -187,7 +187,7 @@ async def stream_chat_generator(
             yield f"event: error\ndata: {json.dumps(error_payload)}\n\n"
             return
 
-        user_in_redis = user_in_redis_bytes.decode()
+        user_in_redis = user_in_redis_bytes
         if user_in_redis != user_email:
             logger.warning(f"Stream: User {user_email} không được phép truy cập chat {chat_id}.")
             error_payload = {"error": "Unauthorized to access this chat."}

utils/utils.py

@@ -429,7 +429,7 @@ async def get_langchain_chat_history(app_state, chat_id: str) -> RedisChatMessag
     langchain_chat_history.clear() # Cho bản đồng bộ
 
     for msg_json_bytes in raw_messages_from_our_redis:
-        msg_data = json.loads(msg_json_bytes.decode()) # decode bytes to str
+        msg_data = json.loads(msg_json_bytes)
         message = Message(**msg_data) # Validate
 
         if message.role == "user":