fix remove retry

app/main.py

@@ -174,12 +174,20 @@ async def process_message(message_data: Dict[str, Any]):
     )
     logger.info(f"[DEBUG] history: {history}")
 
-    if history:
-        if history["timestamp"] == timestamp and history["recipient_id"] == sender_id and history["page_id"] == page_id:
-            logger.info(f"[DEBUG] Message bị duplicate (trùng sender, page, timestamp), không xử lý...")
-            return 
+    # 1. Chặn duplicate message (trùng sender_id, page_id, timestamp)
+    for row in history:
+        if (
+            str(row.get('timestamp')) == str(timestamp)
+            and str(row.get('recipient_id')) == str(sender_id)
+            and str(row.get('page_id')) == str(page_id)
+        ):
+            logger.info("[DUPLICATE] Message duplicate, skipping log.")
+            return
+
+    # Tìm conversation chưa kết thúc (isdone = false)
+    open_conv = next((row for row in history if not row.get('isdone')), None)
 
- # Get page access token (sync)
+    # Get page access token (sync)
     page_token = supabase_client.get_page_token(page_id)
     if page_token:
         logger.info(f"[DEBUG] page_token: {page_token[:10]} ... {page_token[-10:]}")
@@ -234,6 +242,7 @@ async def process_message(message_data: Dict[str, Any]):
 
     # 1. Nếu history rỗng (conversation mới)
     if not history:
+        log_kwargs['conversation_id'] = None
         if not command:
             if keywords:
                 # Có thông tin phương tiện
@@ -278,6 +287,12 @@ async def process_message(message_data: Dict[str, Any]):
             log_kwargs[key] = history_val  # Ưu tiên giá trị từ lịch sử
     # --- END cập nhật log_kwargs ---
 
+    # Đảm bảo truyền đúng conversation_id khi update
+    if open_conv:
+        log_kwargs['conversation_id'] = open_conv['conversation_id']
+    else:
+        log_kwargs['conversation_id'] = None
+
     if not last_command:
         # Lịch sử không có command
         if keywords: