fix fb issue

app/facebook.py

@@ -1,10 +1,12 @@
 import hmac
 import hashlib
 import json
+import asyncio
 from typing import Any, Dict, Optional
 import httpx
 from fastapi import HTTPException, Request
 from loguru import logger
+import facebook
 
 from .utils import timing_decorator_async, timing_decorator_sync
 
@@ -97,32 +99,55 @@ class FacebookClient:
             messages.append(current.rstrip())
         return messages
 
+    def _send_message_sync(self, page_access_token: str, recipient_id: str, message: str) -> dict:
+        """
+        Gửi tin nhắn sử dụng facebook-sdk (sync).
+        """
+        try:
+            graph = facebook.GraphAPI(access_token=page_access_token, version="18.0")
+            result = graph.put_object(
+                parent_object='me',
+                connection_name='messages',
+                recipient={'id': recipient_id},
+                message={'text': message}
+            )
+            return result
+        except facebook.GraphAPIError as e:
+            logger.error(f"Facebook GraphAPI Error: {e}")
+            raise HTTPException(status_code=500, detail=f"Failed to send message to Facebook: {e}")
+        except Exception as e:
+            logger.error(f"Unexpected error sending message to Facebook: {e}")
+            raise HTTPException(status_code=500, detail="Failed to send message to Facebook")
+
     @timing_decorator_async
     async def send_message(self, page_access_token: Optional[str] = None, recipient_id: Optional[str] = None, message: str = "") -> dict:
         page_access_token = page_access_token or self.page_token
         recipient_id = recipient_id or self.sender_id
         if not page_access_token or not recipient_id:
             raise ValueError("FacebookClient: page_access_token and recipient_id must not be None when sending a message.")
+        
         # Format message
         response_to_send = self.format_message(message.replace('**', '*')) if isinstance(message, str) else message
+        
         # Chia nhỏ nếu quá dài
         messages = self.split_message(response_to_send)
         results = []
+        
         for msg in messages:
             if len(msg) > 2000:
                 msg = msg[:2000]  # fallback cắt cứng
-            url = f"https://graph.facebook.com/v18.0/me/messages?access_token={page_access_token}"
-            payload = {
-                "recipient": {"id": recipient_id},
-                "message": {"text": msg}
-            }
-            try:
-                response = await self._client.post(url, json=payload)
-                response.raise_for_status()
-                results.append(response.json())
-            except httpx.HTTPError as e:
-                logger.error(f"Error sending message to Facebook: {e}")
-                raise HTTPException(status_code=500, detail="Failed to send message to Facebook")
+            
+            # Wrap sync SDK call in thread executor để giữ async
+            loop = asyncio.get_event_loop()
+            result = await loop.run_in_executor(
+                None, 
+                self._send_message_sync, 
+                page_access_token, 
+                recipient_id, 
+                msg
+            )
+            results.append(result)
+        
         return results[0] if results else {}
 
     @timing_decorator_sync

requirements.txt

@@ -12,4 +12,5 @@ numpy==1.26.2
 python-multipart==0.0.6
 tenacity==8.2.3 
 pydantic-settings
-google-generativeai>=0.3.0
+google-generativeai>=0.3.0
+facebook-sdk>=3.1.0