fix token error

app/main.py

@@ -104,6 +104,7 @@ async def webhook(request: Request):
     try:
         body = json.loads(body_bytes)
         message_data = facebook_client.parse_message(body)
+        logger.info(f"[DEBUG] message_data: {message_data}")
         
         if not message_data:
             return {"status": "ok"}
@@ -116,6 +117,7 @@ async def webhook(request: Request):
         logger.error(f"Error processing webhook: {e}")
         raise HTTPException(status_code=500, detail="Internal server error")
 
+@timing_decorator_async
 async def process_message(message_data: Dict[str, Any]):
     """
     Xử lý message từ người dùng Facebook, phân tích, truy vấn, gửi phản hồi và log lại.
@@ -129,8 +131,9 @@ async def process_message(message_data: Dict[str, Any]):
     if not message_text:
         return
 
-    # Get page access token
-    page_token = await supabase_client.get_page_token(page_id)
+    # Get page access token (sync)
+    page_token = supabase_client.get_page_token(page_id)
+    logger.info(f"[DEBUG] page_token: {page_token}")
     if not page_token:
         logger.error(f"No access token found for page {page_id}")
         return
@@ -140,9 +143,11 @@ async def process_message(message_data: Dict[str, Any]):
     keywords = extract_keywords(message_text, VEHICLE_KEYWORDS)
 
     # Get conversation history (run in thread pool)
-    history = await asyncio.get_event_loop().run_in_executor(
-        executor, lambda: sheets_client.get_conversation_history(sender_id, page_id).result()
+    loop = asyncio.get_event_loop()
+    history = await loop.run_in_executor(
+        executor, lambda: sheets_client.get_conversation_history(sender_id, page_id)
     )
+    logger.info(f"[DEBUG] history: {history}")
 
     response = ""
     if command == "xong":
@@ -151,9 +156,11 @@ async def process_message(message_data: Dict[str, Any]):
         else:
             # Create embedding from message
             embedding = await embedding_client.create_embedding(message_text)
+            logger.info(f"[DEBUG] embedding: {embedding[:5]} ... (total {len(embedding)})")
             
-            # Search for similar documents
-            matches = await supabase_client.match_documents(embedding)
+            # Search for similar documents (sync)
+            matches = supabase_client.match_documents(embedding)
+            logger.info(f"[DEBUG] matches: {matches}")
             
             if matches:
                 response = format_search_results(matches)
@@ -166,8 +173,8 @@ async def process_message(message_data: Dict[str, Any]):
     await facebook_client.send_message(page_token, sender_id, response)
 
     # Log conversation (run in thread pool)
-    await asyncio.get_event_loop().run_in_executor(
-        executor, lambda: sheets_client.log_conversation(sender_id, page_id, message_text, keywords, response).result()
+    await loop.run_in_executor(
+        executor, lambda: sheets_client.log_conversation(sender_id, page_id, message_text, keywords, response)
     )
 
 def format_search_results(matches: List[Dict[str, Any]]) -> str: