quick fix timestamp

app/message_processor.py

@@ -181,7 +181,13 @@ class MessageProcessor:
         total_chars = 0
 
         # Bước 1: Sắp xếp history theo timestamp tăng dần (cũ -> mới)
-        sorted_history = sorted(history, key=lambda x: x.get('timestamp', 0))
+        # <<< FIX LỖI 2 TẠI ĐÂY >>>
+        def get_sortable_timestamp(row):
+            ts = row.get('timestamp', 0)
+            if isinstance(ts, list):
+                return max(ts) if ts else 0
+            return ts
+        sorted_history = sorted(history, key=get_sortable_timestamp)
 
         # Bước 2: Duyệt từ mới -> cũ để loại bỏ message cũ nếu cần
         for row in reversed(sorted_history):
@@ -238,6 +244,8 @@ class MessageProcessor:
         # if isinstance(ts, int):
         #     return ts
         flat = []
+        if not isinstance(ts, list):
+             ts = [ts]
         for t in ts:
             if isinstance(t, list):
                 flat.extend(self.flatten_timestamp(t))
@@ -396,7 +404,8 @@ class MessageProcessor:
         logger.info(f"[MOCK] Creating Facebook post for sender_id={sender_id} with history={history}")
         return "https://facebook.com/mock_post_url" 
 
-    async def handle_muc_phat(self, conversation_context, conv, page_token, sender_id):
+    # <<< FIX LỖI 1 TẠI ĐÂY >>>
+    async def handle_muc_phat(self, conv, conversation_context, page_token, sender_id):
         vehicle = conv.get('originalvehicle', '')
         action = conv.get('originalaction', '')
         question = conv.get('originalquestion', '')
@@ -430,7 +439,7 @@ class MessageProcessor:
         #     conv['isdone'] = False
         return response
 
-    async def handle_quy_tac(self, conversation_context, conv, message_text):
+    async def handle_quy_tac(self, conv, conversation_context, message_text):
         prompt = (
             "Biết rằng bạn đã có lịch sử trao đổi như sau:"
             f"Lịch sử:\n{conversation_context}"
@@ -443,7 +452,7 @@ class MessageProcessor:
         conv['isdone'] = True
         return answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng trả lời về quy tắc giao thông sẽ sớm có mặt."
 
-    async def handle_bao_hieu(self, conversation_context, conv, message_text):
+    async def handle_bao_hieu(self, conv, conversation_context, message_text):
         prompt = (
             "Biết rằng bạn đã có lịch sử trao đổi như sau:"
             f"Lịch sử:\n{conversation_context}"
@@ -456,7 +465,7 @@ class MessageProcessor:
         conv['isdone'] = True
         return answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng trả lời về báo hiệu đường bộ sẽ sớm có mặt."
 
-    async def handle_quy_trinh(self, conversation_context, conv, message_text):
+    async def handle_quy_trinh(self, conv, conversation_context, message_text):
         prompt = (
             "Biết rằng bạn đã có lịch sử trao đổi như sau:"
             f"Lịch sử:\n{conversation_context}"
@@ -469,7 +478,7 @@ class MessageProcessor:
         conv['isdone'] = True
         return answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng trả lời về quy trình xử lý vi phạm giao thông sẽ sớm có mặt."
 
-    async def handle_ca_nhan(self, conversation_context, conv, message_text):
+    async def handle_ca_nhan(self, conv, conversation_context, message_text):
         # Nếu câu hỏi là về thông tin cá nhân của bot, hướng dẫn LLM trả lời đúng
         prompt = (
             "Biết rằng bạn đã có lịch sử trao đổi như sau:"
@@ -484,7 +493,7 @@ class MessageProcessor:
         conv['isdone'] = True
         return answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng này sẽ sớm có mặt."
 
-    async def handle_khac(self, conversation_context, conv, message_text):
+    async def handle_khac(self, conv, conversation_context, message_text):
         prompt = (
             "Biết rằng bạn đã có lịch sử trao đổi như sau:"
             f"Lịch sử:\n{conversation_context}"
@@ -495,4 +504,4 @@ class MessageProcessor:
         )
         answer = await self.channel.llm.generate_text(message_text)
         conv['isdone'] = True
-        return answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng này sẽ sớm có mặt." 
+        return answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng này sẽ sớm có mặt."