retry register webhook

2025-03-20 02:00:54 +07:00
parent ffe2c95056
commit d7671c8d26
1 changed files with 13 additions and 6 deletions
--- a/src/qbot/main.py
+++ b/src/qbot/main.py
@@ -1,3 +1,4 @@
+from asyncio import sleep
 from contextlib import asynccontextmanager
 from typing import Callable, Any
 from aiogram import Bot, Dispatcher
@@ -194,12 +195,18 @@ class QBotApp[UserType: UserBase](FastAPI):
                language_code=None if locale == "default" else locale,
            )

-        await self.bot.set_webhook(
-            url=f"{self.config.TELEGRAM_WEBHOOK_URL}/telegram/webhook",
-            drop_pending_updates=True,
-            allowed_updates=self.allowed_updates,
-            secret_token=self.bot_auth_token,
-        )
+        while True:
+            try:
+                await self.bot.set_webhook(
+                    url=f"{self.config.TELEGRAM_WEBHOOK_URL}/telegram/webhook",
+                    drop_pending_updates=True,
+                    allowed_updates=self.allowed_updates,
+                    secret_token=self.bot_auth_token,
+                )
+                break
+            except Exception:
+                logger.error("Error setting webhook", exc_info=True)
+                await sleep(5)

    async def bot_close(self):
        await self.bot.delete_webhook()