refactor message flow on purposes

app/constants.py

@@ -165,9 +165,16 @@ PROCESSING_STATUS_MESSAGES = [
     "Ok, mình đang xem lại để đảm bảo chính xác.",
     "Mình xem lại thông tin rồi cập nhật bạn ngay.",
     "Để mình xử lý phần này trước đã nhé!",
-    "Mình đang kiểm tra lại, sẽ báo liền khi xong.",
-    "Ok bạn, để mình coi lại rồi chốt luôn.",
-    "Mình đang coi lại nội dung này, có gì mình nói liền."
+    "Mình đang coi lại nội dung này, có gì mình nói liền.",
+    "Cảm ơn bạn đã nhắn, mình đang đọc kỹ lại đây.",
+    "Mình vừa thấy, để mình xem kỹ rồi phản hồi nha.",
+    "Chào bạn, mình đang xem qua nội dung.",
+    "Cảm ơn bạn, mình đang thu xếp để trả lời đầy đủ.",
+    "Mình có nhận được rồi, để mình chuẩn bị lời hồi đáp chu đáo.",
+    "Mình đang tiếp nhận từng ý một để trả lời cho trọn vẹn.",
+    "Rất vui khi nhận được tin nhắn của bạn, để mình xem lại một chút.",
+    "Mình thấy rồi, đang chuẩn bị phản hồi sao cho đầy đủ và rõ ràng nhất.",
+    "Tin nhắn đã đến, mình đang cân nhắc cách trả lời cho tinh tế hơn."
 ]
 
 # Found regulations status messages for Facebook notifications when regulations are found

app/message_processor.py

@@ -125,19 +125,18 @@ class MessageProcessor:
             logger.error(f"No access token found for page {message_data['page_id']}")
             return
         # Gửi message Facebook, nếu lỗi token expired thì invalidate và thử lại một lần
-        # Tạm comment vào để test đã
-        # try:
-        #     await self.facebook.send_message(message=get_random_message(PROCESSING_STATUS_MESSAGES))
-        # except Exception as e:
-        #     if "expired" in str(e).lower():
-        #         logger.warning("[FACEBOOK] Token expired, invalidate and refresh")
-        #         self.channel.invalidate_page_token()
-        #         page_token = self.channel.get_page_token(force_refresh=True)
-        #         # Có thể update lại page_token cho self.facebook nếu cần
-        #         self.facebook.page_token = page_token
-        #         # await self.facebook.send_message(message="Ok, để mình check. Bạn chờ mình chút xíu nhé!")
-        #     else:
-        #         raise
+        try:
+            await self.facebook.send_message(message=get_random_message(PROCESSING_STATUS_MESSAGES))
+        except Exception as e:
+            if "expired" in str(e).lower():
+                logger.warning("[FACEBOOK] Token expired, invalidate and refresh")
+                self.channel.invalidate_page_token()
+                page_token = self.channel.get_page_token(force_refresh=True)
+                # Có thể update lại page_token cho self.facebook nếu cần
+                self.facebook.page_token = page_token
+                # await self.facebook.send_message(message="Ok, để mình check. Bạn chờ mình chút xíu nhé!")
+            else:
+                raise
 
         # Extract command and keywords
         from app.utils import extract_command, extract_keywords