add history

app/message_processor.py

@@ -44,15 +44,21 @@ class MessageProcessor:
             logger.info(f"[DEBUG] Không có message_text và attachments, không xử lý...")
             return
 
-        # Get conversation history (run in thread pool)
+        # Lấy toàn bộ history (không lọc isdone)
         loop = asyncio.get_event_loop()
         sheets_client = self.channel.get_sheets_client()
-        history = []
         history = await loop.run_in_executor(
             None, lambda: sheets_client.get_conversation_history(sender_id, page_id)
         )
-        logger.info(f"[DEBUG] history: {history}")#
+        logger.info(f"[DEBUG] history: {history}")
 
+        # Chống trùng: nếu đã có bản ghi với sender_id, page_id, timestamp thì bỏ qua
+        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
+
+        # Luôn lưu mỗi message thành 1 bản ghi mới
         log_kwargs = {
             'conversation_id': None,
             'recipient_id': sender_id,
@@ -65,52 +71,16 @@ class MessageProcessor:
             'originalaction': '',
             'originalpurpose': '',
             'originalquestion': '',
-            'timestamp': [timestamp],
+            'systemresponse': '',
+            'timestamp': timestamp,
             'isdone': False
         }
-
-        logger.info(f"[DEBUG] Message cơ bản: {log_kwargs}")
-        conv = None
-
-        if history:
-            # 1. Chặn duplicate message (trùng sender_id, page_id, timestamp)
-            for row in history:
-                row_timestamps = self.flatten_timestamp(row.get('timestamp', []))
-                if isinstance(row_timestamps, list) and len(row_timestamps) == 1 and isinstance(row_timestamps[0], list):
-                    row_timestamps = row_timestamps[0]
-                if (
-                    str(timestamp) in [str(ts) for ts in row_timestamps]
-                    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
-                conv = {
-                    'conversation_id': row.get('conversation_id'),
-                    'recipient_id': row.get('recipient_id'),
-                    'page_id': row.get('page_id'),
-                    'originaltext': row.get('originaltext'),
-                    'originalcommand': row.get('originalcommand'),
-                    'originalcontent': row.get('originalcontent'),
-                    'originalattachments': row.get('originalattachments'),
-                    'originalvehicle': row.get('originalvehicle'),
-                    'originalaction': row.get('originalaction'),
-                    'originalpurpose': row.get('originalpurpose'),
-                    'originalquestion': row.get('originalquestion'),
-                    'timestamp': row_timestamps,
-                    'isdone': row.get('isdone')
-                }
-        else:
-            # 2. Ghi conversation mới NGAY LẬP TỨC với thông tin cơ bản
-            conv = await loop.run_in_executor(None, lambda: sheets_client.log_conversation(**log_kwargs))
+        conv = await loop.run_in_executor(None, lambda: sheets_client.log_conversation(**log_kwargs))
         if not conv:
             logger.error("Không thể tạo conversation mới!")
             return
-        else:
-            logger.info(f"[DEBUG] Message history: {conv}")
-            for key, value in log_kwargs.items():
-                if value not in (None, "", []) and conv.get(key) in (None, "", []):
-                    conv[key] = value
+        logger.info(f"[DEBUG] Message history: {conv}")
+
         # Thêm timestamp mới nếu chưa có
         conv['timestamp'] = self.flatten_timestamp(conv['timestamp'])
         if timestamp not in conv['timestamp']:
@@ -182,6 +152,7 @@ class MessageProcessor:
             'originalaction': hanh_vi,
             'originalpurpose': muc_dich,
             'originalquestion': cau_hoi or "",
+            'systemresponse': conv.get('systemresponse', ''),
             'timestamp': self.flatten_timestamp(conv['timestamp']),
             'isdone': False
         }
@@ -199,20 +170,47 @@ class MessageProcessor:
             muc_dich_to_use = muc_dich
         logger.info(f"[DEBUG] Định hướng mục đích xử lý: {muc_dich_to_use}")
 
+        # Tin nhắn không có command: lấy toàn bộ history để truyền vào LLM
+        # Chuẩn bị context hội thoại cho LLM
+        MAX_CONTEXT_CHARS = 20_000
+        conversation_context = []
+        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))
+
+        # Bước 2: Duyệt từ mới -> cũ để loại bỏ message cũ nếu cần
+        for row in reversed(sorted_history):
+            temp_blocks = []
+            if row.get('systemresponse'):
+                temp_blocks.append({"role": "assistant", "content": row['systemresponse']})
+            if row.get('originaltext'):
+                temp_blocks.append({"role": "user", "content": row['originaltext']})
+
+            temp_total = sum(len(block['content']) for block in temp_blocks)
+
+            if total_chars + temp_total > MAX_CONTEXT_CHARS:
+                continue  # bỏ qua những block quá cũ
+
+            # prepend để đảm bảo thứ tự cuối cùng là từ cũ đến mới
+            conversation_context = temp_blocks + conversation_context
+            total_chars += temp_total
+
+
         response = None
         if not command:
             if muc_dich_to_use == "hỏi về mức phạt":
-                response = await self.handle_muc_phat(conv, page_token, sender_id)
+                response = await self.handle_muc_phat(conv, conversation_context, page_token, sender_id)
             elif muc_dich_to_use == "hỏi về quy tắc giao thông":
-                response = await self.handle_quy_tac(conv, message_text)
+                response = await self.handle_quy_tac(conv, conversation_context, message_text)
             elif muc_dich_to_use == "hỏi về báo hiệu đường bộ":
-                response = await self.handle_bao_hieu(conv, message_text)
+                response = await self.handle_bao_hieu(conv, conversation_context, message_text)
             elif muc_dich_to_use == "hỏi về quy trình xử lý vi phạm giao thông":
-                response = await self.handle_quy_trinh(conv, message_text)
+                response = await self.handle_quy_trinh(conv, conversation_context, message_text)
             elif muc_dich_to_use == "thông tin cá nhân của AI":
-                response = await self.handle_ca_nhan(conv, message_text)
+                response = await self.handle_ca_nhan(conv, conversation_context, message_text)
             else:
-                response = await self.handle_khac(conv, message_text)
+                response = await self.handle_khac(conv, conversation_context, message_text)
         else:
             # Có command
             if command == "xong":
@@ -226,10 +224,10 @@ class MessageProcessor:
                 response = "Vui lòng cung cấp thêm thông tin và gõ lệnh \\xong khi hoàn tất."
                 conv['isdone'] = False
 
-        # 6. Gửi response và cập nhật final state
         await self.facebook.send_message(message=response)
-        if hasattr(self.channel, 'sheets'):
-            await loop.run_in_executor(None, lambda: sheets_client.log_conversation(**conv))
+        # Lưu lại systemresponse cho bản ghi vừa tạo
+        conv['systemresponse'] = response
+        await loop.run_in_executor(None, lambda: sheets_client.log_conversation(**conv))
         return
 
     def flatten_timestamp(self, ts):
@@ -253,7 +251,7 @@ class MessageProcessor:
                     return k
         return keyword
 
-    async def format_search_results(self, question: str, matches: List[Dict[str, Any]], page_token: str, sender_id: str) -> str:
+    async def format_search_results(self, conversation_context: str, question: str, matches: List[Dict[str, Any]], page_token: str, sender_id: str) -> str:
         if not matches:
             return "Không tìm thấy kết quả phù hợp."
         await self.facebook.send_message(message=get_random_message(FOUND_REGULATIONS_MESSAGES))
@@ -335,7 +333,10 @@ class MessageProcessor:
         else:
             result_text = "Không có kết quả phù hợp!"
         prompt = (
-            "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên các đoạn luật sau. "
+            "Biết rằng bạn đã có lịch sử trao đổi như sau:"
+            f"Lịch sử:\n{conversation_context}"
+
+            "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên lịch sử trao đổi và các đoạn luật sau. "
             "Chỉ sử dụng thông tin có trong các đoạn, không tự đoán.\n"
             f"\nCác đoạn luật liên quan:\n{full_result_text}"
             "\n\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
@@ -384,7 +385,7 @@ 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, conv, page_token, sender_id):
+    async def handle_muc_phat(self, conversation_context, conv, page_token, sender_id):
         vehicle = conv.get('originalvehicle', '')
         action = conv.get('originalaction', '')
         question = conv.get('originalquestion', '')
@@ -406,7 +407,7 @@ class MessageProcessor:
             )
             logger.info(f"[DEBUG] matches: {matches}")
             if matches:
-                response = await self.format_search_results(question, matches, page_token, sender_id)
+                response = await self.format_search_results(conversation_context, question, matches, page_token, sender_id)
             else:
                 response = "Xin lỗi, tôi không tìm thấy thông tin phù hợp."
         else:
@@ -418,24 +419,51 @@ class MessageProcessor:
         #     conv['isdone'] = False
         return response
 
-    async def handle_quy_tac(self, conv, message_text):
+    async def handle_quy_tac(self, conversation_context, conv, message_text):
+        prompt = (
+            "Biết rằng bạn đã có lịch sử trao đổi như sau:"
+            f"Lịch sử:\n{conversation_context}"
+
+            "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên lịch sử trao đổi"
+            "\n\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
+            f"\n\nCâu hỏi của người dùng: {message_text}\n"
+        )
         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 trả lời về quy tắc giao thông sẽ sớm có mặt."
 
-    async def handle_bao_hieu(self, conv, message_text):
+    async def handle_bao_hieu(self, conversation_context, conv, message_text):
+        prompt = (
+            "Biết rằng bạn đã có lịch sử trao đổi như sau:"
+            f"Lịch sử:\n{conversation_context}"
+
+            "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên lịch sử trao đổi"
+            "\n\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
+            f"\n\nCâu hỏi của người dùng: {message_text}\n"
+        )
         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 trả lời về báo hiệu đường bộ sẽ sớm có mặt."
 
-    async def handle_quy_trinh(self, conv, message_text):
+    async def handle_quy_trinh(self, conversation_context, conv, message_text):
+        prompt = (
+            "Biết rằng bạn đã có lịch sử trao đổi như sau:"
+            f"Lịch sử:\n{conversation_context}"
+
+            "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên lịch sử trao đổi"
+            "\n\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
+            f"\n\nCâu hỏi của người dùng: {message_text}\n"
+        )
         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 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, conv, message_text):
+    async def handle_ca_nhan(self, conversation_context, conv, 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:"
+            f"Lịch sử:\n{conversation_context}"
+
             'Với các thông tin sau: "Bạn có tên là WeThoong AI, là trợ lý giao thông thông minh. Bạn được anh Viet Cat tạo ra và facebook cá nhân của anh ý là https://facebook.com/vietcat". '
             'Không được trả lời bạn là AI của Google, OpenAI, hay bất kỳ hãng nào khác. '
             'Hãy trả lời thông minh, hài hước, ngắn gọn cho câu hỏi sau:\n'
@@ -445,7 +473,15 @@ 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, conv, message_text):
+    async def handle_khac(self, conversation_context, conv, message_text):
+        prompt = (
+            "Biết rằng bạn đã có lịch sử trao đổi như sau:"
+            f"Lịch sử:\n{conversation_context}"
+
+            "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên lịch sử trao đổi"
+            "\n\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
+            f"\n\nCâu hỏi của người dùng: {message_text}\n"
+        )
         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." 

app/sheets.py

@@ -87,14 +87,14 @@ class SheetsClient:
             values = result.get('values', [])
             history = []
             for row in values:
-                row = row + [""] * (13 - len(row))
+                row = row + [""] * (14 - len(row))
                 try:
-                    timestamps = json.loads(row[11]) if row[11] else []
+                    timestamps = json.loads(row[12]) if row[12] else []
                 except Exception:
                     timestamps = []
                 if not isinstance(timestamps, list):
                     timestamps = [timestamps]
-                if row[4] == user_id and row[5] == page_id and row[12].lower() == 'false':
+                if row[4] == user_id and row[5] == page_id:
                     history.append({
                         'conversation_id': row[0],
                         'originalcommand': row[1],
@@ -107,8 +107,9 @@ class SheetsClient:
                         'originalaction': row[8],
                         'originalpurpose': row[9],
                         'originalquestion': row[10],
-                        'timestamp': timestamps,
-                        'isdone': row[12].lower() == 'true'
+                        'systemresponse': row[11],
+                        'timestamp': row[12],
+                        'isdone': row[13].lower() == 'true'
                     })
             return history
         except Exception as e:
@@ -128,8 +129,9 @@ class SheetsClient:
         originalvehicle: str = "",
         originalaction: str = "",
         originalpurpose: str = "",
-        originalquestion: str = "",  # <-- thêm dòng này
-        timestamp: Any = None,
+        originalquestion: str = "",
+        systemresponse: str = "",
+        timestamp: str = None,
         isdone: bool = False
     ) -> Optional[Dict[str, Any]]:
         """
@@ -149,164 +151,77 @@ class SheetsClient:
             ).execute()
             values = result.get('values', [])
             # logger.info(f"[DEBUG] Gsheet values {values}")
-            ts = datetime.now().isoformat()
-            # Đảm bảo timestamp luôn là list
+            # Đảm bảo timestamp là str
             if timestamp is None:
-                timestamp = []
-            elif not isinstance(timestamp, list):
-                timestamp = [timestamp]
-            if not conversation_id:
-                # Check for duplicates before creating new conversation
-                for row in values:
-                    if len(row) >= 11:
-                        try:
-                            row_timestamps = json.loads(row[10]) if row[10] else []
-                        except Exception:
-                            row_timestamps = []
-                        if not isinstance(row_timestamps, list):
-                            row_timestamps = [row_timestamps]
-                        row_recipient_id = row[4]
-                        row_page_id = row[5]
-                        if (str(timestamp) in [str(ts) for ts in row_timestamps] and str(row_recipient_id) == str(recipient_id) and str(row_page_id) == str(page_id)):
-                            # Found duplicate, return existing conversation
-                            logger.info(f"Found duplicate conversation for user {recipient_id}, page {page_id}, timestamp {timestamp}")
-                            return {
-                                'conversation_id': row[0],
-                                'originalcommand': row[1],
-                                'originalcontent': row[2],
-                                'originalattachments': json.loads(row[3]) if row[3] else [],
-                                'recipient_id': row[4],
-                                'page_id': row[5],
-                                'originaltext': row[6],
-                                'originalvehicle': row[7],
-                                'originalaction': row[8],
-                                'originalpurpose': row[9],
-                                'originalquestion': row[10],
-                                'timestamp': row_timestamps,
-                                'isdone': row[11].lower() == 'true' if len(row) > 11 else False
-                            }
-
-                # No duplicate found, create new conversation
-                conversation_id = generate_conversation_id(recipient_id, page_id, ts)
-                new_row = [
-                    conversation_id,
-                    originalcommand,
-                    originalcontent,
-                    json.dumps(originalattachments or []),
-                    recipient_id,
-                    page_id,
-                    originaltext,
-                    originalvehicle,
-                    originalaction,
-                    originalpurpose,
-                    originalquestion,  # <-- thêm dòng này
-                    json.dumps(timestamp),
-                    str(isdone).lower()
-                ]
-                body = {
-                    'values': [new_row]
-                }
-                range_name = SHEET_RANGE
-                self.service.spreadsheets().values().append(
-                    spreadsheetId=self.sheet_id,
-                    range=range_name,
-                    valueInputOption='RAW',
-                    body=body
-                ).execute()
-                logger.info(f"Thêm mới conversation: {conversation_id} | Giá trị: {dict(zip(['conversation_id','originalcommand','originalcontent','originalattachments','recipient_id','page_id','originaltext','originalvehicle','originalaction','originalpurpose','originalquestion','timestamp','isdone'], new_row))}")
-
-                # Return the conversation data directly
-                return {
-                    'conversation_id': conversation_id,
-                    'originalcommand': originalcommand,
-                    'originalcontent': originalcontent,
-                    'originalattachments': originalattachments or [],
-                    'recipient_id': recipient_id,
-                    'page_id': page_id,
-                    'originaltext': originaltext,
-                    'originalvehicle': originalvehicle,
-                    'originalaction': originalaction,
-                    'originalpurpose': originalpurpose,
-                    'originalquestion': originalquestion,
-                    'timestamp': timestamp,
-                    'isdone': isdone
-                }
-            else:
-                # Update existing conversation
-                if not values:
-                    logger.error("No data in sheet, cannot update conversation.")
-                    return None
-                row_index = None
-                for i, row in enumerate(values):
-                    if row[0] == conversation_id:
-                        row_index = i
-                        break
-                logger.info(f"[DEBUG] Gsheet row index {row_index}")
-                if row_index is not None:
-                    sheet_row_number = row_index + 2  # +2 vì values[0] là dòng 2 trên sheet
-                    current_row = values[row_index]
-                    logger.info(f"[DEBUG] Gsheet current row {current_row}")
-                    while len(current_row) < 13:
-                        current_row.append("")
-                    try:
-                        current_timestamps = json.loads(current_row[10]) if current_row[10] else []
-                    except Exception:
-                        current_timestamps = []
-                    if not isinstance(current_timestamps, list):
-                        current_timestamps = [current_timestamps]
-                    # Chỉ append nếu chưa có
-                    for ts in timestamp:
-                        if ts not in current_timestamps:
-                            current_timestamps.append(ts)
-                    new_row = [
-                        conversation_id,
-                        originalcommand if originalcommand else current_row[1],
-                        originalcontent if originalcontent else current_row[2],
-                        json.dumps(originalattachments) if originalattachments is not None else current_row[3],
-                        recipient_id if recipient_id else current_row[4],
-                        page_id if page_id else current_row[5],
-                        originaltext if originaltext else current_row[6],
-                        originalvehicle if originalvehicle else current_row[7],
-                        originalaction if originalaction else current_row[8],
-                        originalpurpose if originalpurpose else current_row[9],
-                        originalquestion if originalquestion else current_row[10],  # <-- thêm dòng này
-                        json.dumps(current_timestamps),
-                        str(isdone).lower() if isdone is not None else current_row[12]
-                    ]
-                    update_range = f"{SHEET_RANGE.split('!')[0]}!A{sheet_row_number}"
-                    logger.info(f"[DEBUG] Gsheet update range {update_range}")
-                    body = {
-                        'values': [new_row]
-                    }
-                    self.service.spreadsheets().values().update(
-                        spreadsheetId=self.sheet_id,
-                        range=update_range,
-                        valueInputOption='RAW',
-                        body=body
-                    ).execute()
-                    changed_cols = ['conversation_id','originalcommand','originalcontent','originalattachments','recipient_id','page_id','originaltext','originalvehicle','originalaction','originalpurpose','originalquestion','timestamp','isdone']
-                    for idx, (old, new) in enumerate(zip(current_row, new_row)):
-                        if old != new:
-                            changed_cols.append(changed_cols[idx])
-                    logger.info(f"Cập nhật conversation: {conversation_id} tại dòng {sheet_row_number} | Cột cập nhật: {changed_cols} | Giá trị mới: {dict(zip(changed_cols, new_row))}")
-
-                    # Return the updated conversation data
-                    return {
-                        'conversation_id': conversation_id,
-                        'originalcommand': new_row[1],
-                        'originalcontent': new_row[2],
-                        'originalattachments': json.loads(new_row[3]) if new_row[3] else [],
-                        'recipient_id': new_row[4],
-                        'page_id': new_row[5],
-                        'originaltext': new_row[6],
-                        'originalvehicle': new_row[7],
-                        'originalaction': new_row[8],
-                        'originalpurpose': new_row[9],
-                        'originalquestion': new_row[10],  # <-- thêm dòng này
-                        'timestamp': current_timestamps,
-                        'isdone': new_row[12].lower() == 'true'
-                    }
-            return None
+                from datetime import datetime
+                timestamp = datetime.now().isoformat()
+            # Chống trùng bản ghi dựa trên sender_id, page_id, timestamp
+            for row in values:
+                if len(row) >= 12:
+                    row_timestamp = row[12] if len(row) > 12 else ""
+                    if str(row_timestamp) == str(timestamp) and str(row[4]) == str(recipient_id) and str(row[5]) == str(page_id):
+                        logger.info(f"Found duplicate conversation for user {recipient_id}, page {page_id}, timestamp {timestamp}")
+                        return {
+                            'conversation_id': row[0],
+                            'originalcommand': row[1],
+                            'originalcontent': row[2],
+                            'originalattachments': json.loads(row[3]) if row[3] else [],
+                            'recipient_id': row[4],
+                            'page_id': row[5],
+                            'originaltext': row[6],
+                            'originalvehicle': row[7],
+                            'originalaction': row[8],
+                            'originalpurpose': row[9],
+                            'originalquestion': row[10],
+                            'systemresponse': row[11],
+                            'timestamp': row[12],
+                            'isdone': row[13].lower() == 'true' if len(row) > 13 else False
+                        }
+            # Nếu không trùng thì thêm mới bản ghi
+            conversation_id = generate_conversation_id(recipient_id, page_id, timestamp)
+            new_row = [
+                conversation_id,
+                originalcommand,
+                originalcontent,
+                json.dumps(originalattachments or []),
+                recipient_id,
+                page_id,
+                originaltext,
+                originalvehicle,
+                originalaction,
+                originalpurpose,
+                originalquestion,
+                systemresponse,
+                timestamp,
+                str(isdone).lower()
+            ]
+            body = {
+                'values': [new_row]
+            }
+            range_name = SHEET_RANGE
+            self.service.spreadsheets().values().append(
+                spreadsheetId=self.sheet_id,
+                range=range_name,
+                valueInputOption='RAW',
+                body=body
+            ).execute()
+            logger.info(f"Thêm mới conversation: {conversation_id} | Giá trị: {{dict(zip(['conversation_id','originalcommand','originalcontent','originalattachments','recipient_id','page_id','originaltext','originalvehicle','originalaction','originalpurpose','originalquestion','systemresponse','timestamp','isdone'], new_row))}}")
+            return {
+                'conversation_id': conversation_id,
+                'originalcommand': originalcommand,
+                'originalcontent': originalcontent,
+                'originalattachments': originalattachments or [],
+                'recipient_id': recipient_id,
+                'page_id': page_id,
+                'originaltext': originaltext,
+                'originalvehicle': originalvehicle,
+                'originalaction': originalaction,
+                'originalpurpose': originalpurpose,
+                'originalquestion': originalquestion,
+                'systemresponse': systemresponse,
+                'timestamp': timestamp,
+                'isdone': isdone
+            }
         except Exception as e:
             logger.error(f"Error logging conversation: {e}")
             return None