adjust parallel search and rerank

app/facebook.py

@@ -129,18 +129,32 @@ class FacebookClient:
             "message": message
         }
         
-        log_payload = payload.copy()
-        log_payload['message'] = _safe_truncate(log_payload['message'])
-        log_payload['access_token'] = f"{log_payload.get('access_token', '')[:5]}..." if log_payload.get('access_token') else "None"
-        
-        logger.info(f"[FACEBOOK_FORWARDER] Forwarding message to {url} for recipient {recipient_id}. Payload (truncated): {log_payload}")
+        # Ghi lại toàn bộ payload để gỡ lỗi.
+        # CẢNH BÁO: Việc này sẽ ghi lại cả PAGE_ACCESS_TOKEN. Chỉ nên dùng trong môi trường dev hoặc khi cần gỡ lỗi.
+        logger.info(f"[FACEBOOK_FORWARDER] Forwarding message to {url}. Full payload: {json.dumps(payload, ensure_ascii=False)}")
+
         try:
             response = requests.post(url, json=payload, timeout=10)
-            response.raise_for_status()
+            response.raise_for_status()  # Sẽ raise HTTPError cho các status 4xx/5xx
             logger.info(f"[FACEBOOK_FORWARDER] Forwarder API returned status {response.status_code}.")
             return response.json()
+        except requests.HTTPError as e:
+            # Lỗi HTTP (4xx, 5xx), log chi tiết hơn để gỡ lỗi phía forwarder
+            error_content = "No response body"
+            try:
+                # Cố gắng lấy nội dung lỗi từ server để biết nguyên nhân
+                error_content = e.response.text
+            except Exception:
+                pass
+            logger.error(
+                f"[FACEBOOK_FORWARDER] HTTP Error calling forwarder API: {e}. "
+                f"Status: {e.response.status_code}. Payload sent: {json.dumps(payload, ensure_ascii=False)}. "
+                f"Response: {error_content}"
+            )
+            return {"error": str(e), "details": error_content}
         except requests.RequestException as e:
-            logger.error(f"[FACEBOOK_FORWARDER] Error calling forwarder API: {e}")
+            # Các lỗi request khác (timeout, connection error)
+            logger.error(f"[FACEBOOK_FORWARDER] Request Error calling forwarder API: {e}")
             return {"error": str(e)}
 
     def _send_message_sync(self, page_access_token: str, recipient_id: str, message: str) -> dict: