format message

app/constants.py

@@ -128,4 +128,32 @@ VIETNAMESE_STOP_PHRASES = [
     # ... thêm các từ khác bạn muốn loại bỏ
 ]
 
+# Batch status messages for reranker Facebook notifications
+BATCH_STATUS_MESSAGES = [
+    "Mình đang sắp xếp lại để nội dung rõ ràng hơn",
+    "Thông tin mình đang hệ thống lại cho mạch lạc hơn",
+    "Mình đang tổ chức lại các ý chính cho dễ theo dõi",
+    "Hiện tại mình đang chỉnh sửa lại cấu trúc thông tin",
+    "Mình đang rà soát và sắp xếp lại nội dung đã có",
+    "Các phần thông tin đang được mình sắp lại theo thứ tự hợp lý",
+    "Mình đang gom các ý liên quan để thống nhất nội dung",
+    "Thông tin đang được mình sắp xếp lại để tránh trùng lặp",
+    "Mình đang điều chỉnh bố cục để nội dung liền mạch hơn",
+    "Mình đang tinh gọn lại thông tin cho súc tích và dễ hiểu"
+]
+
+# Summary status messages for Facebook notifications when summarizing/answering
+SUMMARY_STATUS_MESSAGES = [
+    "Mình đang tổng hợp lại để đưa ra câu trả lời rõ ràng nhất",
+    "Hiện tại mình đang rà lại các thông tin để chốt phương án",
+    "Mình đang đối chiếu dữ liệu để đưa ra kết luận cuối cùng",
+    "Mình đang gom lại toàn bộ nội dung để trả lời dứt khoát",
+    "Mình đang hoàn thiện phần tổng hợp để có câu trả lời chính xác",
+    "Thông tin đang được mình tổng hợp lại để phản hồi đầy đủ",
+    "Mình đang chuẩn bị câu trả lời cuối cùng dựa trên các dữ liệu đã có",
+    "Mình đang xử lý thông tin đầu vào để đưa ra phương án phù hợp nhất",
+    "Mình đang hoàn tất bước tổng hợp để có phản hồi cụ thể",
+    "Mình đang chốt lại các điểm chính để trả lời một cách trọn vẹn"
+]
+
 SHEET_RANGE = 'chat!A2:L'

app/message_processor.py

@@ -2,6 +2,8 @@ from typing import Dict, Any, List
 import asyncio
 import traceback
 from loguru import logger
+import random
+from .constants import SUMMARY_STATUS_MESSAGES
 
 class MessageProcessor:
     def __init__(self, channel):
@@ -153,7 +155,7 @@ class MessageProcessor:
                 hanh_vi_vi_pham = hanh_vi_vi_pham.replace(kw, "")
             hanh_vi_vi_pham = hanh_vi_vi_pham.strip()
         logger.info(f"[DEBUG] Phương tiện: {keywords} - Hành vi: {hanh_vi_vi_pham} - Mục đích: {muc_dich}")
-        await self.channel.facebook.send_message(message=f"... đang tìm kiếm hành vi {hanh_vi_vi_pham} .....")
+        await self.channel.facebook.send_message(message=f"... đang tìm kiếm quy định liên quan đến {hanh_vi_vi_pham} .....")
         # 4. Update lại conversation với thông tin đầy đủ
         update_kwargs = {
             'conversation_id': conv['conversation_id'],
@@ -177,7 +179,9 @@ class MessageProcessor:
         response = await self.process_business_logic(conv, page_token)
         logger.info(f"[DEBUG] Message history sau khi process: {conv}")
         # 6. Gửi response và cập nhật final state
-        await self.channel.facebook.send_message(message=response)
+        # Replace all occurrences of '**' with '*' before sending
+        response_to_send = response.replace('**', '*') if isinstance(response, str) else response
+        await self.channel.facebook.send_message(message=response_to_send)
         if hasattr(self.channel, 'sheets'):
             await loop.run_in_executor(None, lambda: self.channel.sheets.log_conversation(**conv))
         return
@@ -318,11 +322,11 @@ class MessageProcessor:
             "\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: {question}\n"
         )
-        await self.channel.facebook.send_message(message=f"... Được rồi, để tôi tóm tắt lại nhé .....")
+        await self.channel.facebook.send_message(message=f"... {random.choice(SUMMARY_STATUS_MESSAGES)} ...")
         try:
             answer = await self.channel.llm.generate_text(prompt)
             if answer and answer.strip():
-                logger.error(f"LLM trả về câu trả lời: \n\tanswer: {answer}")
+                logger.info(f"LLM trả về câu trả lời: \n\tanswer: {answer}")
                 return answer.strip()
             else:
                 logger.error(f"LLM không trả về câu trả lời phù hợp: \n\tanswer: {answer}")

app/reranker.py

@@ -3,6 +3,8 @@ from .config import get_settings
 from .gemini_client import GeminiClient
 from loguru import logger
 import asyncio
+import random
+from .constants import BATCH_STATUS_MESSAGES
 
 class Reranker:
     def __init__(self, facebook_client=None):
@@ -88,7 +90,8 @@ class Reranker:
             # Send Facebook message after each batch
             if self.facebook_client:
                 try:
-                    await self.facebook_client.send_message(message=f"... tôi đang sắp xếp lại chút ...")
+                    message = random.choice(BATCH_STATUS_MESSAGES)
+                    await self.facebook_client.send_message(message=f"... {message} ...")
                 except Exception as e:
                     logger.error(f"[RERANK][FACEBOOK] Error sending batch message: {e}")