From 57e33dd2ec39d0b596ea6f96ff28483f0cd72a84 Mon Sep 17 00:00:00 2001 From: Capybara-z Date: Sat, 25 Oct 2025 18:29:12 +0300 Subject: [PATCH] fix sender banning issues --- handlers/admin/sender/sender_handler.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/handlers/admin/sender/sender_handler.py b/handlers/admin/sender/sender_handler.py index 22317026..5685954a 100644 --- a/handlers/admin/sender/sender_handler.py +++ b/handlers/admin/sender/sender_handler.py @@ -67,15 +67,15 @@ async def send_broadcast_batch(bot, messages, batch_size=15, session=None): await try_add_blocked_user(tg_id, session) results.append(False) except TelegramBadRequest as bad_request: - if "chat not found" in str(bad_request).lower(): + error_msg = str(bad_request).lower() + if "chat not found" in error_msg: logger.warning(f"🚫 Чат не найден для пользователя {tg_id}.") + await try_add_blocked_user(tg_id, session) else: logger.warning(f"📩 Не удалось отправить сообщение пользователю {tg_id}: {bad_request}") - await try_add_blocked_user(tg_id, session) results.append(False) except Exception as retry_error: logger.error(f"❌ Ошибка повторной отправки пользователю {tg_id}: {retry_error}") - await try_add_blocked_user(tg_id, session) results.append(False) except TelegramForbiddenError: @@ -83,15 +83,15 @@ async def send_broadcast_batch(bot, messages, batch_size=15, session=None): await try_add_blocked_user(tg_id, session) results.append(False) except TelegramBadRequest as bad_request: - if "chat not found" in str(bad_request).lower(): + error_msg = str(bad_request).lower() + if "chat not found" in error_msg: logger.warning(f"🚫 Чат не найден для пользователя {tg_id}.") + await try_add_blocked_user(tg_id, session) else: logger.warning(f"📩 Не удалось отправить сообщение пользователю {tg_id}: {bad_request}") - await try_add_blocked_user(tg_id, session) results.append(False) except Exception as e: logger.error(f"❌ Ошибка отправки сообщения пользователю {tg_id}: {e}") - await try_add_blocked_user(tg_id, session) results.append(False) await asyncio.sleep(min_interval)