fix bugs

app/embedding.py

@@ -47,7 +47,7 @@ class EmbeddingClient:
                 json={"text": text}
             )
             response.raise_for_status()
-            data = await response.json()
+            data = response.json()
             logger.info(f"[DEBUG] Embedding API response: {data}")
             return data["embedding"]
         except Exception as e:

app/main.py

@@ -121,6 +121,15 @@ async def webhook(request: Request):
 
 @timing_decorator_async
 async def process_message(message_data: Dict[str, Any]):
+    # Kiểm tra message_data hợp lệ và đủ trường
+    if not message_data or not isinstance(message_data, dict):
+        logger.error(f"[ERROR] Invalid message_data: {message_data}")
+        return
+    required_fields = ["sender_id", "page_id", "text"]
+    for field in required_fields:
+        if field not in message_data:
+            logger.error(f"[ERROR] Missing field {field} in message_data: {message_data}")
+            return
     sender_id = message_data["sender_id"]
     page_id = message_data["page_id"]
     message_text = message_data["text"]

app/sheets.py

@@ -92,6 +92,7 @@ class SheetsClient:
             for row in values:
                 # Bổ sung cột rỗng cho đủ 9 cột
                 row = row + [""] * (9 - len(row))
+                logger.info(f"[DEBUG] row: {row[4]}:{user_id} - {row[5]}:{page_id} - {row[8].lower()}:false")
                 if row[4] == user_id and row[5] == page_id and row[8].lower() == 'false':
                     history.append({
                         'conversation_id': row[0],