fix duplicate message
Browse files- app/facebook.py +1 -0
- app/main.py +2 -1
app/facebook.py
CHANGED
|
@@ -62,6 +62,7 @@ class FacebookClient:
|
|
| 62 |
}
|
| 63 |
|
| 64 |
try:
|
|
|
|
| 65 |
response = await self._client.post(url, json=payload)
|
| 66 |
response.raise_for_status()
|
| 67 |
return response.json()
|
|
|
|
| 62 |
}
|
| 63 |
|
| 64 |
try:
|
| 65 |
+
logger.debug(f"Đang gửi tin nhắn đến Facebook Messenger....\n\t{message}")
|
| 66 |
response = await self._client.post(url, json=payload)
|
| 67 |
response.raise_for_status()
|
| 68 |
return response.json()
|
app/main.py
CHANGED
|
@@ -309,7 +309,8 @@ async def process_message(message_data: Dict[str, Any]):
|
|
| 309 |
logger.info(f"[DEBUG] Message history update cuối cùng: {conv}")
|
| 310 |
# 5. Xử lý logic nghiệp vụ
|
| 311 |
response = await process_business_logic(conv, page_token)
|
| 312 |
-
|
|
|
|
| 313 |
# 6. Gửi response và cập nhật final state
|
| 314 |
await facebook_client.send_message(page_token, sender_id, response)
|
| 315 |
await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**update_kwargs))
|
|
|
|
| 309 |
logger.info(f"[DEBUG] Message history update cuối cùng: {conv}")
|
| 310 |
# 5. Xử lý logic nghiệp vụ
|
| 311 |
response = await process_business_logic(conv, page_token)
|
| 312 |
+
logger.info(f"[DEBUG] Message history sau khi process: {conv}")
|
| 313 |
+
|
| 314 |
# 6. Gửi response và cập nhật final state
|
| 315 |
await facebook_client.send_message(page_token, sender_id, response)
|
| 316 |
await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**update_kwargs))
|