fix racing issues when sending message

app/chat_channel.py

@@ -37,6 +37,14 @@ class ChatChannel:
     def invalidate_page_token(self):
         self.page_token = None
 
+    def get_sheets_client(self):
+        settings = get_settings()
+        return SheetsClient(
+            settings.google_sheets_credentials_file,
+            settings.google_sheets_token_file,
+            settings.conversation_sheet_id
+        )
+
     def get_or_create_conversation(self, sender_id: str):
         if sender_id not in self.conversations:
             self.conversations[sender_id] = MessageProcessor(self, sender_id)

app/message_processor.py

@@ -44,12 +44,11 @@ class MessageProcessor:
 
         # Get conversation history (run in thread pool)
         loop = asyncio.get_event_loop()
-        sheets_client = self.channel.supabase  # Nếu bạn dùng Google Sheets, thay bằng self.channel.sheets nếu có
+        sheets_client = self.channel.get_sheets_client()
         history = []
-        if hasattr(self.channel, 'sheets'):
-            history = await loop.run_in_executor(
-                None, lambda: self.channel.sheets.get_conversation_history(sender_id, page_id)
-            )
+        history = await loop.run_in_executor(
+            None, lambda: sheets_client.get_conversation_history(sender_id, page_id)
+        )
         logger.info(f"[DEBUG] history: {history}")#
 
         log_kwargs = {
@@ -99,10 +98,7 @@ class MessageProcessor:
                 }
         else:
             # 2. Ghi conversation mới NGAY LẬP TỨC với thông tin cơ bản
-            if hasattr(self.channel, 'sheets'):
-                conv = await loop.run_in_executor(None, lambda: self.channel.sheets.log_conversation(**log_kwargs))
-            else:
-                conv = log_kwargs.copy()
+            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
@@ -116,8 +112,7 @@ class MessageProcessor:
         if timestamp not in conv['timestamp']:
             conv['timestamp'].append(timestamp)
         logger.info(f"[DEBUG] Message history sau update: {conv}")
-        if hasattr(self.channel, 'sheets'):
-            await loop.run_in_executor(None, lambda: self.channel.sheets.log_conversation(**conv))
+        await loop.run_in_executor(None, lambda: sheets_client.log_conversation(**conv))
 
         # Get page access token (cache)
         page_token = self.channel.get_page_token()