Upload main.py

main.py

@@ -37,12 +37,8 @@ def load_snippets():
 
 snippets = load_snippets()
 
-# Создаем сессию с принудительным IPv4
-session = AiohttpSession(
-    connector=TCPConnector(family=socket.AF_INET, use_dns_cache=False)
-)
-bot = Bot(token=BOT_TOKEN, session=session)
 dp = Dispatcher()
+bot = None # Будет инициализирован в main()
 
 # ... (остальной код safe_format и обработчиков остается прежним) ...
 
@@ -80,6 +76,14 @@ async def inline_query_handler(query: types.InlineQuery):
     await query.answer(results[:50], cache_time=1)
 
 async def main():
+    global bot
+    
+    # Создаем сессию здесь, когда цикл событий уже запущен
+    session = AiohttpSession(
+        connector=TCPConnector(family=socket.AF_INET, use_dns_cache=False)
+    )
+    bot = Bot(token=BOT_TOKEN, session=session)
+
     app = web.Application()
     app.router.add_get("/", health_check)
     runner = web.AppRunner(app)
@@ -87,17 +91,17 @@ async def main():
     site = web.TCPSite(runner, "0.0.0.0", 7860)
     await site.start()
 
-    max_retries = 20  # Увеличим количество попыток
+    max_retries = 20
     for attempt in range(1, max_retries + 1):
         try:
             bot_info = await bot.get_me()
-            logger.info(f"Connected to Telegram! Bot: @{bot_info.username}")
+            logger.info(f"Connected! Bot: @{bot_info.username}")
             break
         except Exception as e:
             if attempt == max_retries:
                 logger.error("Failed to connect. Exiting.")
                 return
-            logger.warning(f"Attempt {attempt} failed, retrying... ({e})")
+            logger.warning(f"Attempt {attempt} failed... ({e})")
             await asyncio.sleep(5)
     
     await dp.start_polling(bot)