Upload main.py

main.py

@@ -8,11 +8,15 @@ import logging
 import yaml
 import os
 import subprocess
+import re
+import html
+import socket
 from aiogram import Bot, Dispatcher, types, F
 from aiogram.types import InlineQueryResultArticle, InputTextMessageContent
 from aiogram.filters import CommandStart
+from aiogram.client.session.aiohttp import AiohttpSession
+from aiohttp import web, TCPConnector
 from config import BOT_TOKEN
-from aiohttp import web
 
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
 logger = logging.getLogger(__name__)
@@ -33,18 +37,14 @@ def load_snippets():
 
 snippets = load_snippets()
 
-bot = Bot(token=BOT_TOKEN)
+# Создаем сессию с принудительным IPv4
+session = AiohttpSession(
+    connector=TCPConnector(family=socket.AF_INET, use_dns_cache=False)
+)
+bot = Bot(token=BOT_TOKEN, session=session)
 dp = Dispatcher()
 
-@dp.message(CommandStart())
-async def cmd_start(message: types.Message):
-    bot_info = await bot.get_me()
-    await message.answer(
-        f"Hello! I am an inline bot. Type @{bot_info.username} in any chat to see my snippets."
-    )
-
-import re
-import html
+# ... (остальной код safe_format и обработчиков остается прежним) ...
 
 def safe_format(text):
     text = html.escape(text)
@@ -52,38 +52,31 @@ def safe_format(text):
     text = re.sub(r'\*(.*?)\*', r'<i>\1</i>', text)
     return text
 
+@dp.message(CommandStart())
+async def cmd_start(message: types.Message):
+    bot_info = await bot.get_me()
+    await message.answer(
+        f"Helllo! I am an inline bot. Type @{bot_info.username} in any chat to see my snippets."
+    )
+
 @dp.inline_query()
 async def inline_query_handler(query: types.InlineQuery):
     query_text = query.query.lower().strip()
     results = []
-
     for key, data in snippets.items():
         title = data.get("title", key)
         content = data.get("content", "")
-
-        if (
-            not query_text 
-            or query_text in key.lower()
-            or query_text in title.lower()
-            or query_text in content.lower()
-        ):
+        if not query_text or query_text in key.lower() or query_text in title.lower() or query_text in content.lower():
             description = content.split("\n")[0] if content else "No content"
             if len(description) > 50:
                 description = description[:47] + "..."
-
             formatted_content = safe_format(content)
-
             results.append(
                 InlineQueryResultArticle(
-                    id=key,
-                    title=title,
-                    description=description,
-                    input_message_content=InputTextMessageContent(
-                        message_text=formatted_content, parse_mode="HTML"
-                    ),
+                    id=key, title=title, description=description,
+                    input_message_content=InputTextMessageContent(message_text=formatted_content, parse_mode="HTML"),
                 )
             )
-
     await query.answer(results[:50], cache_time=1)
 
 async def main():
@@ -94,17 +87,17 @@ async def main():
     site = web.TCPSite(runner, "0.0.0.0", 7860)
     await site.start()
 
-    max_retries = 10
+    max_retries = 20  # Увеличим количество попыток
     for attempt in range(1, max_retries + 1):
         try:
             bot_info = await bot.get_me()
-            logger.info(f"Connected to Telegram! Starting bot @{bot_info.username}")
+            logger.info(f"Connected to Telegram! Bot: @{bot_info.username}")
             break
         except Exception as e:
             if attempt == max_retries:
-                logger.error(f"Failed to connect to Telegram after {max_retries} attempts. Exiting.")
+                logger.error("Failed to connect. Exiting.")
                 return
-            logger.warning(f"Network not ready (Attempt {attempt}/{max_retries}). Retrying in 5s... Error: {e}")
+            logger.warning(f"Attempt {attempt} failed, retrying... ({e})")
             await asyncio.sleep(5)
     
     await dp.start_polling(bot)