fix message format

app/message_processor.py

@@ -6,6 +6,7 @@ from .constants import SUMMARY_STATUS_MESSAGES, PROCESSING_STATUS_MESSAGES, FOUN
 from .utils import get_random_message
 from .facebook import FacebookClient
 from app.config import get_settings
+import re
 
 class MessageProcessor:
     def __init__(self, channel, sender_id):
@@ -186,7 +187,7 @@ class MessageProcessor:
         logger.info(f"[DEBUG] Message history sau khi process: {conv}")
         # 6. Gửi response và cập nhật final state
         # Replace all occurrences of '**' with '*' before sending
-        response_to_send = response.replace('**', '*') if isinstance(response, str) else response
+        response_to_send = format_for_facebook(response.replace('**', '*')) if isinstance(response, str) else response
         await self.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))
@@ -267,12 +268,13 @@ class MessageProcessor:
             reranked = await self.channel.reranker.rerank(question, matches, top_k=5)
             if reranked:
                 # Gửi Facebook message sau khi hoàn thành
-                if self.facebook:
-                    try:
-                        message = get_random_message(BATCH_STATUS_MESSAGES)
-                        await self.facebook.send_message(message=f"... {message} ...")
-                    except Exception as e:
-                        logger.error(f"[RERANK][FACEBOOK] Error sending batch message: {e}")
+                # Tạm comment đi để test 
+                # if self.facebook:
+                #     try:
+                #         message = get_random_message(BATCH_STATUS_MESSAGES)
+                #         await self.facebook.send_message(message=f"... {message} ...")
+                #     except Exception as e:
+                #         logger.error(f"[RERANK][FACEBOOK] Error sending batch message: {e}")
                 matches = reranked
         except Exception as e:
             logger.error(f"[RERANK] Lỗi khi rerank: {e}")
@@ -380,4 +382,16 @@ class MessageProcessor:
 
     async def create_facebook_post(self, page_token: str, sender_id: str, history: List[Dict[str, Any]]) -> str:
         logger.info(f"[MOCK] Creating Facebook post for sender_id={sender_id} with history={history}")
-        return "https://facebook.com/mock_post_url" 
+        return "https://facebook.com/mock_post_url" 
+
+def format_for_facebook(text: str) -> str:
+    # 1. Thay bullet markdown bằng ký hiệu khác
+    text = text.replace('\n*   ', '\n- ')
+    text = text.replace('\n    *   ', '\n    + ')
+    text = text.replace('\n* ', '\n- ')
+    text = text.replace('\n    * ', '\n    + ')
+    # 2. Chuyển **text** hoặc __text__ thành *text*
+    text = re.sub(r'\*\*([^\*]+)\*\*', r'*\1*', text)
+    text = re.sub(r'__([^_]+)__', r'*\1*', text)
+    # 3. Loại bỏ các markdown không hỗ trợ khác nếu cần
+    return text