fix racing issues when sending message
Browse files- app/message_processor.py +4 -3
app/message_processor.py
CHANGED
|
@@ -121,7 +121,7 @@ class MessageProcessor:
|
|
| 121 |
|
| 122 |
# Get page access token (cache)
|
| 123 |
page_token = self.channel.get_page_token()
|
| 124 |
-
|
| 125 |
if page_token:
|
| 126 |
logger.info(f"[DEBUG] page_token: {page_token[:10]} ... {page_token[-10:]}")
|
| 127 |
else:
|
|
@@ -136,8 +136,9 @@ class MessageProcessor:
|
|
| 136 |
logger.warning("[FACEBOOK] Token expired, invalidate and refresh")
|
| 137 |
self.channel.invalidate_page_token()
|
| 138 |
page_token = self.channel.get_page_token(force_refresh=True)
|
| 139 |
-
self.
|
| 140 |
-
|
|
|
|
| 141 |
else:
|
| 142 |
raise
|
| 143 |
|
|
|
|
| 121 |
|
| 122 |
# Get page access token (cache)
|
| 123 |
page_token = self.channel.get_page_token()
|
| 124 |
+
# Không cần update context FacebookClient nữa
|
| 125 |
if page_token:
|
| 126 |
logger.info(f"[DEBUG] page_token: {page_token[:10]} ... {page_token[-10:]}")
|
| 127 |
else:
|
|
|
|
| 136 |
logger.warning("[FACEBOOK] Token expired, invalidate and refresh")
|
| 137 |
self.channel.invalidate_page_token()
|
| 138 |
page_token = self.channel.get_page_token(force_refresh=True)
|
| 139 |
+
# Có thể update lại page_token cho self.facebook nếu cần
|
| 140 |
+
self.facebook.page_token = page_token
|
| 141 |
+
# await self.facebook.send_message(message="Ok, để mình check. Bạn chờ mình chút xíu nhé!")
|
| 142 |
else:
|
| 143 |
raise
|
| 144 |
|