From 40fd2b126b962b8eeedb8d4c3e754acf4e6455ce Mon Sep 17 00:00:00 2001 From: Suren Khorenyan Date: Mon, 2 Jul 2018 21:51:48 +0300 Subject: [PATCH] Fix broadcast example --- examples/broadcast_example.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/examples/broadcast_example.py b/examples/broadcast_example.py index 468da916..40ba5e0c 100644 --- a/examples/broadcast_example.py +++ b/examples/broadcast_example.py @@ -23,7 +23,7 @@ def get_users(): yield from (61043901, 78238238, 78378343, 98765431, 12345678) -async def send_message(user_id: int, text: str) -> bool: +async def send_message(user_id: int, text: str, disable_notification: bool = False) -> bool: """ Safe messages sender @@ -32,7 +32,7 @@ async def send_message(user_id: int, text: str) -> bool: :return: """ try: - await bot.send_message(user_id, 'Hello, World!') + await bot.send_message(user_id, text, disable_notification=disable_notification) except exceptions.BotBlocked: log.error(f"Target [ID:{user_id}]: blocked by user") except exceptions.ChatNotFound: @@ -41,6 +41,8 @@ async def send_message(user_id: int, text: str) -> bool: log.error(f"Target [ID:{user_id}]: Flood limit is exceeded. Sleep {e.timeout} seconds.") await asyncio.sleep(e.timeout) return await send_message(user_id, text) # Recursive call + except exceptions.UserDeactivated: + log.error(f"Target [ID:{user_id}]: user is deactivated") except exceptions.TelegramAPIError: log.exception(f"Target [ID:{user_id}]: failed") else: