send message through forwarder

app/config.py

@@ -20,6 +20,7 @@ class Settings(BaseSettings):
     # Facebook Configuration
     facebook_verify_token: str = os.getenv("FACEBOOK_VERIFY_TOKEN") or ""
     facebook_app_secret: str = os.getenv("FACEBOOK_APP_SECRET") or ""
+    facebook_api_base_url: str = os.getenv("FACEBOOK_API_BASE_URL") or ""
     
     # Google Sheets Configuration
     google_sheets_credentials_file: str = os.getenv("GOOGLE_SHEETS_CREDENTIALS_FILE") or ""

app/facebook.py

@@ -2,11 +2,14 @@ import hmac
 import hashlib
 import json
 import asyncio
+import time
 from typing import Any, Dict, Optional
 import httpx
 from fastapi import HTTPException, Request
 from loguru import logger
 import facebook
+import requests
+from .config import Settings, get_settings
 
 from .utils import timing_decorator_async, timing_decorator_sync
 
@@ -99,43 +102,98 @@ class FacebookClient:
             messages.append(current.rstrip())
         return messages
 
+    def send_message_forwarder(
+        self,
+        access_token: str,
+        recipient_id: str,
+        message: str
+    ) -> dict:
+        """
+        Gửi tin nhắn đến Facebook Messenger qua API được triển khai.
+
+        Parameters:
+            api_base_url (str): Base URL của API, ví dụ "https://your-project.vercel.app"
+            recipient_id (str): PSID của người nhận
+            access_token (str): Facebook Page Access Token
+            message (str): Nội dung tin nhắn
+
+        Returns:
+            dict: Kết quả trả về từ API (JSON)
+        """
+
+        api_base_url = get_settings().facebook_api_base_url
+        url = f"{api_base_url.rstrip('/')}/api/send-message"
+        payload = {
+            "recipient_id": recipient_id,
+            "access_token": access_token,
+            "message": message
+        }
+
+        try:
+            response = requests.post(url, json=payload, timeout=10)
+            response.raise_for_status()
+            return response.json()
+        except requests.RequestException as e:
+            return {"error": str(e)}
+
     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 với request method trực tiếp.
         """
-        try:
-            graph = facebook.GraphAPI(access_token=page_access_token, version="3.1")
-            
-            # Sử dụng request method trực tiếp cho Messenger API
-            result = graph.request(
-                path="me/messages",
-                post_args={
-                    "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")
+        max_retries = 3
+        retry_delay = 1  # giây
+        
+        for attempt in range(max_retries):
+            try:
+                graph = facebook.GraphAPI(access_token=page_access_token, version="3.1")
+                
+                # Sử dụng request method trực tiếp cho Messenger API với timeout
+                result = graph.request(
+                    path="me/messages",
+                    post_args={
+                        "recipient": {"id": recipient_id},
+                        "message": {"text": message}
+                    },
+                    timeout=30  # Thêm timeout 30 giây
+                )
+                return result
+            except facebook.GraphAPIError as e:
+                logger.error(f"Facebook GraphAPI Error (attempt {attempt + 1}/{max_retries}): {e}")
+                if attempt == max_retries - 1:  # Lần cuối
+                    raise HTTPException(status_code=500, detail=f"Failed to send message to Facebook: {e}")
+                time.sleep(retry_delay)
+                retry_delay *= 2  # Exponential backoff
+            except Exception as e:
+                logger.error(f"Unexpected error sending message to Facebook (attempt {attempt + 1}/{max_retries}): {e}")
+                if attempt == max_retries - 1:  # Lần cuối
+                    raise HTTPException(status_code=500, detail="Failed to send message to Facebook")
+                time.sleep(retry_delay)
+                retry_delay *= 2  # Exponential backoff
 
     def _get_page_info_sync(self, page_access_token: str, page_id: str) -> dict:
         """
         Lấy thông tin page sử dụng Facebook SDK.
         """
-        try:
-            graph = facebook.GraphAPI(access_token=page_access_token, version="3.1")
-            result = graph.get_object(page_id)
-            return result
-        except facebook.GraphAPIError as e:
-            logger.error(f"Facebook GraphAPI Error getting page info: {e}")
-            raise HTTPException(status_code=500, detail=f"Failed to get page info: {e}")
-        except Exception as e:
-            logger.error(f"Unexpected error getting page info: {e}")
-            raise HTTPException(status_code=500, detail="Failed to get page info")
+        max_retries = 3
+        retry_delay = 1  # giây
+        
+        for attempt in range(max_retries):
+            try:
+                graph = facebook.GraphAPI(access_token=page_access_token, version="3.1")
+                result = graph.get_object(page_id)
+                return result
+            except facebook.GraphAPIError as e:
+                logger.error(f"Facebook GraphAPI Error getting page info (attempt {attempt + 1}/{max_retries}): {e}")
+                if attempt == max_retries - 1:  # Lần cuối
+                    raise HTTPException(status_code=500, detail=f"Failed to get page info: {e}")
+                time.sleep(retry_delay)
+                retry_delay *= 2  # Exponential backoff
+            except Exception as e:
+                logger.error(f"Unexpected error getting page info (attempt {attempt + 1}/{max_retries}): {e}")
+                if attempt == max_retries - 1:  # Lần cuối
+                    raise HTTPException(status_code=500, detail="Failed to get page info")
+                time.sleep(retry_delay)
+                retry_delay *= 2  # Exponential backoff
 
     @timing_decorator_async
     async def send_message(self, page_access_token: Optional[str] = None, recipient_id: Optional[str] = None, message: str = "") -> dict:
@@ -159,7 +217,7 @@ class FacebookClient:
             loop = asyncio.get_event_loop()
             result = await loop.run_in_executor(
                 None, 
-                self._send_message_sync, 
+                self.send_message_forwarder, 
                 page_access_token, 
                 recipient_id, 
                 msg