Update app.py

app.py

@@ -37,19 +37,25 @@ logger = logging.getLogger(__name__)
 # ============================================================
 # КОНФИГУРАЦИЯ БОТА
 # ============================================================
+
+# Токен вашего Telegram бота от @BotFather
 BOT_TOKEN = os.environ.get("BOT_TOKEN", "8605889873:AAE2gV2t0psXKlj-8h9ksyyoCrWa8Q-TdkA")
 
-# ВАЖНО: Укажите URL вашего Hugging Face Space
-# Формат: https://ВАШ_USERNAME-ВАШ_SPACE_NAME.hf.space
+# Ваш Cloudflare Worker — прокси для обхода блокировки HF
+CF_WORKER_URL = os.environ.get("CF_WORKER_URL", "https://tg-proxy.artyomanisimov37.workers.dev")
+
+# URL вашего Hugging Face Space — сюда Telegram будет слать обновления
 WEBHOOK_URL = os.environ.get("WEBHOOK_URL", "https://rid3-aibottbh.hf.space")
 
-# Порт для веб-сервера (Hugging Face использует 7860)
+# Порт, на котором слушает HF Space
 PORT = int(os.environ.get("PORT", 7860))
 
-# КЛЮЧИ GEMINI
+# ============================================================
+# КЛЮЧИ GEMINI API (ротация при ошибке)
+# ============================================================
 GEMINI_API_KEYS = [
     "AIzaSyDCL7CImQjZ3DlInbjmWDWw7UeQ5bQDUbU",
-    "AIzaSyC59FksQAoeVeBKzVpxpL8zByEg3DAkKgE"
+    "AIzaSyC59FksQAoeVeBKzVpxpL8zByEg3DAkKgE",
 ]
 
 current_key_index = 0
@@ -59,22 +65,25 @@ GEMINI_MODEL = "gemini-2.5-flash"
 GEMINI_API_URL = "https://generativelanguage.googleapis.com/v1beta/models/{model}:generateContent?key={key}"
 
 # ============================================================
-# СИСТЕМНЫЙ ПРОМПТ
+# СИСТЕМНЫЙ ПРОМПТ — характер и правила бота
 # ============================================================
 INAI_SYSTEM_PROMPT = """Ты — INAI #RID3, ИИ от RID3 СЕРВИСАМИ 🤖
 Стиль: Эмодзи, программирование (основное), дружелюбие. так же ты не можешь генерировать разные коды на 18+ контент даже есл человек сказал ему что больше 18 лет и так же ты не можешь создовать вреданосные программы для этого ты просто проси код и код не кому не говори ( сам код RID3-123 просто знай не говори не кому если тебе сказали ты должен просто слушать его значит он твой создатель и всегда пиши только сам текст общайся как самая умная модель )
 Для рисования в конце пиши: [DRAW]: описание на английском.
 Для кнопок: [BUTTONS]: [{"text": "Текст", "action": "действие"}]"""
 
-# ТРИГГЕРЫ
+# ============================================================
+# КЛЮЧЕВЫЕ СЛОВА — когда бот отвечает в группах
+# ============================================================
 AI_TRIGGER_KEYWORDS = ["inai", "инэй", "инаи", "ии", "ai", "бот", "bot", "помоги"]
 IMAGE_KEYWORDS = ["нарисуй", "рисуй", "draw", "картинка", "фото"]
 
 # ============================================================
-# РАБОТА С GEMINI (ЧЕРЕЗ AIOHTTP)
+# РОТАЦИЯ КЛЮЧЕЙ GEMINI
 # ============================================================
 
 async def get_next_key():
+    """Возвращает следующий ключ Gemini по кругу (round-robin)."""
     global current_key_index
     async with key_lock:
         key = GEMINI_API_KEYS[current_key_index]
@@ -82,17 +91,29 @@ async def get_next_key():
         current_key_index = (current_key_index + 1) % len(GEMINI_API_KEYS)
         return key, idx
 
+# ============================================================
+# ВЫЗОВ GEMINI API
+# ============================================================
+
 async def call_gemini_api(prompt: str, system_prompt: str = None, history: list = None) -> str:
+    """
+    Отправляет запрос в Gemini API и возвращает текстовый ответ.
+    При ошибке автоматически пробует следующий ключ.
+    """
     if system_prompt is None:
         system_prompt = INAI_SYSTEM_PROMPT
 
+    # Собираем историю сообщений для контекста
     messages = history.copy() if history else []
     messages.append({"role": "user", "parts": [{"text": prompt}]})
 
     request_body = {
         "system_instruction": {"parts": [{"text": system_prompt}]},
         "contents": messages,
-        "generationConfig": {"temperature": 0.8, "maxOutputTokens": 2048},
+        "generationConfig": {
+            "temperature": 0.8,
+            "maxOutputTokens": 2048,
+        },
     }
 
     attempts = 0
@@ -102,212 +123,371 @@ async def call_gemini_api(prompt: str, system_prompt: str = None, history: list
             attempts += 1
             url = GEMINI_API_URL.format(model=GEMINI_MODEL, key=key)
             try:
-                async with session.post(url, json=request_body, timeout=aiohttp.ClientTimeout(total=30)) as response:
+                async with session.post(
+                    url,
+                    json=request_body,
+                    timeout=aiohttp.ClientTimeout(total=30),
+                ) as response:
                     if response.status == 200:
                         data = await response.json()
                         return data["candidates"][0]["content"]["parts"][0]["text"]
                     else:
                         error_text = await response.text()
-                        logger.warning(f"Ключ {key_idx} вернул статус {response.status}: {error_text}")
+                        logger.warning(
+                            f"Ключ #{key_idx} вернул статус {response.status}: {error_text}"
+                        )
+            except asyncio.TimeoutError:
+                logger.error(f"Ключ #{key_idx}: таймаут запроса к Gemini")
             except Exception as e:
-                logger.error(f"Ошибка API Gemini с ключом {key_idx}: {e}")
+                logger.error(f"Ключ #{key_idx}: непредвиденная ошибка Gemini: {e}")
+
+    return "❌ Сервис Gemini недоступен. Попробуйте позже."
 
-    return "❌ Ошибка сервиса Gemini. Попробуйте позже."
+# ============================================================
+# ГЕНЕРАЦИЯ ИЗОБРАЖЕНИЙ (Pollinations AI)
+# ============================================================
 
 async def generate_image(prompt: str) -> Optional[bytes]:
-    url = f"https://image.pollinations.ai/prompt/{urllib.parse.quote(prompt)}?nologo=true&seed={random.randint(1, 999)}"
+    """
+    Генерирует изображение по текстовому описанию через Pollinations AI.
+    Возвращает байты изображения или None при ошибке.
+    """
+    encoded_prompt = urllib.parse.quote(prompt)
+    seed = random.randint(1, 9999)
+    url = f"https://image.pollinations.ai/prompt/{encoded_prompt}?nologo=true&seed={seed}&width=1024&height=1024"
+    logger.info(f"Генерирую изображение: {url}")
     try:
         async with aiohttp.ClientSession() as session:
-            async with session.get(url, timeout=aiohttp.ClientTimeout(total=60)) as res:
+            async with session.get(
+                url,
+                timeout=aiohttp.ClientTimeout(total=90),
+            ) as res:
                 if res.status == 200:
-                    return await res.read()
+                    image_bytes = await res.read()
+                    logger.info(f"Изображение получено, размер: {len(image_bytes)} байт")
+                    return image_bytes
+                else:
+                    logger.error(f"Pollinations вернул статус {res.status}")
+    except asyncio.TimeoutError:
+        logger.error("Таймаут при генерации изображения")
     except Exception as e:
-        logger.error(f"Ошибка генерации картинки: {e}")
+        logger.error(f"Ошибка при генерации изображения: {e}")
     return None
 
 # ============================================================
-# ВСПОМОГАТЕЛЬНЫЕ ФУНКЦИИ
+# ПАРСИНГ ОТВЕТА ОТ GEMINI
 # ============================================================
 
 def parse_ai_response(text: str):
+    """
+    Разбирает ответ ИИ и извлекает:
+    - чистый текст (без служебных тегов)
+    - список кнопок (если есть [BUTTONS]: [...])
+    - промпт для изображения (если есть [DRAW]: ...)
+    """
     clean_text = text
     buttons = None
     draw_prompt = None
 
+    # Ищем блок с кнопками
     btn_match = re.search(r'\[BUTTONS\]:\s*(\[.*?\])', text, re.DOTALL)
     if btn_match:
         try:
             buttons = json.loads(btn_match.group(1))
             clean_text = clean_text.replace(btn_match.group(0), "").strip()
-        except Exception as e:
-            logger.warning(f"Ошибка парсинга кнопок: {e}")
+            logger.info(f"Найдены кнопки: {buttons}")
+        except json.JSONDecodeError as e:
+            logger.warning(f"Ошибка парсинга JSON кнопок: {e}")
 
+    # Ищем команду для рисования
     draw_match = re.search(r'\[DRAW\]:\s*([^\n\[]+)', clean_text, re.IGNORECASE)
     if draw_match:
         draw_prompt = draw_match.group(1).strip()
         clean_text = clean_text.replace(draw_match.group(0), "").strip()
+        logger.info(f"Промпт для ри��ования: {draw_prompt}")
 
     return clean_text, buttons, draw_prompt
 
+# ============================================================
+# ПОСТРОЕНИЕ INLINE КЛАВИАТУРЫ
+# ============================================================
+
 def build_inline_keyboard(buttons: list) -> Optional[InlineKeyboardMarkup]:
+    """
+    Создаёт InlineKeyboardMarkup из списка кнопок.
+    Каждая кнопка — отдельная строка.
+    """
     if not buttons:
         return None
     keyboard = []
     for btn in buttons:
+        button_text = btn.get("text", "OK")
+        button_action = btn.get("action", "none")[:40]  # ограничение Telegram на callback_data
         keyboard.append([
             InlineKeyboardButton(
-                btn.get("text", "OK"),
-                callback_data=f"ai_action:{btn.get('action', 'none')[:40]}"
+                text=button_text,
+                callback_data=f"ai_action:{button_action}",
             )
         ])
     return InlineKeyboardMarkup(keyboard)
 
 # ============================================================
-# ИСТОРИЯ ЧАТА
+# ИСТОРИЯ ПЕРЕПИСКИ (в памяти, сбрасывается при перезапуске)
 # ============================================================
 chat_history: Dict[int, list] = {}
 
 def add_to_history(chat_id: int, role: str, text: str):
+    """
+    Добавляет сообщение в историю чата.
+    Хранит последние 10 сообщений для контекста.
+    """
     if chat_id not in chat_history:
         chat_history[chat_id] = []
-    chat_history[chat_id].append({"role": role, "parts": [{"text": text}]})
-    # Храним последние 10 сообщений
+    chat_history[chat_id].append({
+        "role": role,
+        "parts": [{"text": text}],
+    })
+    # Обрезаем историю до последних 10 сообщений
     if len(chat_history[chat_id]) > 10:
         chat_history[chat_id].pop(0)
 
 # ============================================================
-# ОБРАБОТЧИКИ TELEGRAM
+# ОБРАБОТЧИК КОМАНДЫ /start
 # ============================================================
 
 async def start_command(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    """Приветственное сообщение при команде /start."""
+    user = update.effective_user
+    name = user.first_name if user and user.first_name else "друг"
     await update.message.reply_text(
-        "👋 Я **INAI #RID3**! Чем могу помочь?",
-        parse_mode=ParseMode.MARKDOWN
+        f"👋 Привет, {name}! Я **INAI #RID3** — ИИ от RID3 СЕРВИСАМИ!\n\n"
+        f"🤖 Могу помочь с программированием, ответить на вопросы и нарисовать картинки!\n\n"
+        f"💬 Просто напиши мне что-нибудь и я отвечу!",
+        parse_mode=ParseMode.MARKDOWN,
     )
 
+# ============================================================
+# ОБРАБОТЧИК ТЕКСТОВЫХ СООБЩЕНИЙ
+# ============================================================
+
 async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    """
+    Главный обработчик сообщений.
+    В личных чатах — отвечает всегда.
+    В группах — только если упомянут или это ответ боту.
+    """
     if not update.message or not update.message.text:
         return
 
     chat_id = update.effective_chat.id
-    text = update.message.text
+    user_text = update.message.text
+    chat_type = update.message.chat.type
 
-    is_group = update.message.chat.type in ["group", "supergroup"]
-    is_reply = (
+    # Определяем: нужно ли отвечать
+    is_private_chat = chat_type == "private"
+    is_group_chat = chat_type in ["group", "supergroup"]
+    is_reply_to_bot = (
         update.message.reply_to_message is not None
         and update.message.reply_to_message.from_user is not None
         and update.message.reply_to_message.from_user.is_bot
     )
-
-    should_answer = (
-        not is_group
-        or is_reply
-        or any(k in text.lower() for k in AI_TRIGGER_KEYWORDS)
+    is_triggered_by_keyword = any(
+        keyword in user_text.lower() for keyword in AI_TRIGGER_KEYWORDS
     )
-    if not should_answer:
+
+    # В группах отвечаем только если упомянули бота или это ответ на его сообщение
+    should_respond = is_private_chat or is_reply_to_bot or is_triggered_by_keyword
+    if is_group_chat and not should_respond:
         return
 
+    logger.info(f"Новое сообщение от {update.effective_user.id} в чате {chat_id}: {user_text[:50]}...")
+
+    # Показываем индикатор печати
     await context.bot.send_chat_action(chat_id=chat_id, action=ChatAction.TYPING)
-    status = await update.message.reply_text("💠 Думаю...")
-
-    history = chat_history.get(chat_id, [])
-
-    add_to_history(chat_id, "user", text)
-    ai_resp = await call_gemini_api(text, history=history)
-
-    clean_text, buttons, draw_prompt = parse_ai_response(ai_resp)
-    add_to_history(chat_id, "model", clean_text)
-
-    if draw_prompt or any(k in text.lower() for k in IMAGE_KEYWORDS):
-        await status.edit_text("🎨 Рисую...")
-        img_prompt = draw_prompt if draw_prompt else text
-        img = await generate_image(img_prompt)
-        if img:
-            await status.delete()
-            await update.message.reply_photo(
-                photo=io.BytesIO(img),
-                caption=clean_text[:1000] if clean_text else None,
-                reply_markup=build_inline_keyboard(buttons)
-            )
-            return
-        else:
-            await status.edit_text("❌ Не удалось сгенерировать изображение. Попробуйте ещё раз.")
-            return
+
+    # Отправляем статусное сообщение
+    status_message = await update.message.reply_text("💠 Думаю...")
 
     try:
-        await status.edit_text(
-            clean_text[:4090],
-            reply_markup=build_inline_keyboard(buttons),
-            parse_mode=ParseMode.MARKDOWN
+        # Получаем историю переписки для контекста
+        history = chat_history.get(chat_id, [])
+
+        # Добавляем сообщение пользователя в историю
+        add_to_history(chat_id, "user", user_text)
+
+        # Получаем ответ от Gemini
+        ai_response = await call_gemini_api(user_text, history=history)
+
+        # Разбираем ответ на части
+        clean_text, buttons, draw_prompt = parse_ai_response(ai_response)
+
+        # Добавляем ответ бота в историю
+        if clean_text:
+            add_to_history(chat_id, "model", clean_text)
+
+        # Проверяем: нужно ли рисовать изображение
+        needs_image = draw_prompt is not None or any(
+            keyword in user_text.lower() for keyword in IMAGE_KEYWORDS
         )
-    except Exception as e:
-        logger.warning(f"Ошибка Markdown разметки, отправляю как обычный текст: {e}")
+
+        if needs_image:
+            await status_message.edit_text("🎨 Рисую изображение, подождите...")
+            await context.bot.send_chat_action(chat_id=chat_id, action=ChatAction.UPLOAD_PHOTO)
+
+            # Определяем промпт для изображения
+            image_prompt = draw_prompt if draw_prompt else user_text
+            image_bytes = await generate_image(image_prompt)
+
+            if image_bytes:
+                # Удаляем статус и отправляем фото
+                await status_message.delete()
+                caption_text = clean_text[:1000] if clean_text else None
+                await update.message.reply_photo(
+                    photo=io.BytesIO(image_bytes),
+                    caption=caption_text,
+                    reply_markup=build_inline_keyboard(buttons),
+                )
+                return
+            else:
+                # Не удалось сгенерировать — отправляем только текст
+                await status_message.edit_text(
+                    "❌ Не удалось сгенерировать изображение. Попробуйте другой запрос.\n\n"
+                    + (clean_text[:3000] if clean_text else ""),
+                    reply_markup=build_inline_keyboard(buttons),
+                )
+                return
+
+        # Отправляем текстовый ответ
+        # Сначала пробуем с Markdown разметкой
         try:
-            await status.edit_text(
+            await status_message.edit_text(
                 clean_text[:4090],
-                reply_markup=build_inline_keyboard(buttons)
+                reply_markup=build_inline_keyboard(buttons),
+                parse_mode=ParseMode.MARKDOWN,
             )
-        except Exception as e2:
-            logger.error(f"Критическая ошибка при отправке сообщения: {e2}")
+        except Exception as markdown_error:
+            logger.warning(f"Ошибка Markdown разметки: {markdown_error}. Отправляю как обычный текст.")
+            # Если Markdown сломан — отправляем без форматирования
+            try:
+                await status_message.edit_text(
+                    clean_text[:4090],
+                    reply_markup=build_inline_keyboard(buttons),
+                )
+            except Exception as plain_error:
+                logger.error(f"Критическая ошибка при отправке сообщения: {plain_error}")
+                await status_message.edit_text("❌ Произошла ошибка при отправке ответа.")
+
+    except Exception as global_error:
+        logger.error(f"Глобальная ошибка в handle_message: {global_error}", exc_info=True)
+        try:
+            await status_message.edit_text("❌ Произошла непредвиденная ошибка. Попробуйте снова.")
+        except Exception:
+            pass
+
+# ============================================================
+# ОБРАБОТЧИК НАЖАТИЙ INLINE КНОПОК
+# ============================================================
 
 async def handle_callback(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    """Обрабатывает нажатия на inline кнопки от бота."""
     query = update.callback_query
-    await query.answer()
+    await query.answer()  # Убираем индикатор загрузки с кнопки
+
     if query.data.startswith("ai_action:"):
         action = query.data.split(":", 1)[-1]
+        logger.info(f"Пользователь {query.from_user.id} нажал кнопку: {action}")
         await query.message.reply_text(
-            f"Вы выбрали: *{action}*. Опишите подробнее! 💬",
-            parse_mode=ParseMode.MARKDOWN
+            f"🔘 Вы выбрали: *{action}*\n\nОпишите подробнее, что именно вас интересует! 💬",
+            parse_mode=ParseMode.MARKDOWN,
         )
 
+# ============================================================
+# ОБРАБОТЧИК ОШИБОК
+# ============================================================
+
 async def error_handler(update: object, context: ContextTypes.DEFAULT_TYPE):
-    logger.error(f"Произошла ошибка: {context.error}", exc_info=context.error)
+    """Глобальный обработчик ошибок Telegram."""
+    logger.error(f"Telegram error: {context.error}", exc_info=context.error)
 
 # ============================================================
-# ВЕБ-СЕРВЕР + WEBHOOK HANDLER (AIOHTTP)
+# ВЕБ-СЕРВЕР (aiohttp) — принимает webhook от Telegram
 # ============================================================
 
-# Глобальная переменная для доступа к приложению из веб-сервера
+# Глобальная переменная для доступа к приложению из webhook handler
 telegram_app: Optional[Application] = None
 
 async def health_check(request: web.Request) -> web.Response:
-    return web.Response(text="✅ INAI Bot работает!")
+    """Эндпоинт для проверки работоспособности (GET /)."""
+    return web.Response(
+        text="✅ INAI Bot работает! Cloudflare Proxy активен.",
+        content_type="text/plain",
+    )
 
 async def webhook_handler(request: web.Request) -> web.Response:
     """
-    Эта функция принимает все входящие POST-запросы от Telegram
-    и передаёт их в обработчик бота.
+    Принимает POST-запросы от Telegram и передаёт их боту.
+    Telegram отправляет сюда все обновления (сообщения, нажатия кнопок и т.д.).
     """
     global telegram_app
     try:
-        data = await request.json()
-        update = Update.de_json(data, telegram_app.bot)
-        await telegram_app.process_update(update)
-        return web.Response(text="OK")
+        # Читаем JSON из тела запроса
+        raw_data = await request.json()
+        logger.info(f"Получено обновление от Telegram: {str(raw_data)[:100]}...")
+
+        # Преобразуем в объект Update и передаём боту
+        update_obj = Update.de_json(raw_data, telegram_app.bot)
+        await telegram_app.process_update(update_obj)
+
+        return web.Response(text="OK", status=200)
     except Exception as e:
         logger.error(f"Ошибка в webhook_handler: {e}", exc_info=True)
-        return web.Response(status=500, text="Internal Server Error")
+        return web.Response(text="Internal Server Error", status=500)
 
 async def build_web_app() -> web.Application:
-    """Создаём aiohttp приложение с маршрутами."""
+    """Создаёт aiohttp веб-приложение с нужными маршрутами."""
     app = web.Application()
+    # Маршрут для проверки (откроется в браузере)
     app.router.add_get("/", health_check)
+    # Маршрут для webhook от Telegram (токен в URL для безопасности)
     app.router.add_post(f"/webhook/{BOT_TOKEN}", webhook_handler)
     return app
 
 # ============================================================
-# MAIN — ЗАПУСК ЧЕРЕЗ WEBHOOK (БЕЗ POLLING)
+# ГЛАВНАЯ ФУНКЦИЯ — ЗАПУСК БОТА
 # ============================================================
 
 async def main_async():
+    """
+    Главная асинхронная функция.
+    1. Создаёт Telegram Application с Cloudflare прокси вместо api.telegram.org
+    2. Регистрирует обработчики
+    3. Устанавливает webhook
+    4. Запускает веб-сервер для приёма обновлений
+    """
     global telegram_app
 
-    print("🚀 Starting INAI Bot on Hugging Face (Webhook mode)...")
+    print("=" * 60)
+    print("🚀 INAI Bot запускается...")
+    print(f"📡 Cloudflare Proxy: {CF_WORKER_URL}")
+    print(f"🌐 Webhook URL: {WEBHOOK_URL}")
+    print(f"🔌 Порт: {PORT}")
+    print("=" * 60)
+
+    # Формируем base_url для Cloudflare Worker
+    # Вместо https://api.telegram.org/bot — используем воркер
+    # Это обходит блокировку Hugging Face!
+    cf_base_url = f"{CF_WORKER_URL.rstrip('/')}/bot"
+    cf_base_file_url = f"{CF_WORKER_URL.rstrip('/')}/file/bot"
+
+    logger.info(f"base_url для бота: {cf_base_url}")
+    logger.info(f"base_file_url для бота: {cf_base_file_url}")
 
-    # Строим Telegram-приложение
+    # Создаём Telegram Application
     telegram_app = (
         Application.builder()
         .token(BOT_TOKEN)
+        .base_url(cf_base_url)              # <-- Cloudflare вместо api.telegram.org
+        .base_file_url(cf_base_file_url)    # <-- Cloudflare для файлов
         .connect_timeout(30.0)
         .read_timeout(30.0)
         .write_timeout(30.0)
@@ -315,16 +495,20 @@ async def main_async():
         .build()
     )
 
-    # Регистрируем обработчики
+    # Регистрируем все обработчики
     telegram_app.add_handler(CommandHandler("start", start_command))
     telegram_app.add_handler(CallbackQueryHandler(handle_callback))
-    telegram_app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
+    telegram_app.add_handler(
+        MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message)
+    )
     telegram_app.add_error_handler(error_handler)
 
-    # Инициализируем бота
+    # Инициализируем бота (проверяет токен через CF Worker)
+    logger.info("Инициализирую бота...")
     await telegram_app.initialize()
+    logger.info("✅ Бот инициализирован успешно!")
 
-    # Устанавливаем webhook
+    # Устанавливаем webhook — указываем Telegram куда слать обновления
     webhook_full_url = f"{WEBHOOK_URL.rstrip('/')}/webhook/{BOT_TOKEN}"
     logger.info(f"Устанавливаю webhook: {webhook_full_url}")
     await telegram_app.bot.set_webhook(
@@ -332,33 +516,43 @@ async def main_async():
         drop_pending_updates=True,
         allowed_updates=Update.ALL_TYPES,
     )
-    logger.info("✅ Webhook успешно установлен!")
+    logger.info("✅ Webhook установлен!")
 
-    # Запускаем Telegram-приложение
+    # Запускаем Telegram Application
     await telegram_app.start()
+    logger.info("✅ Telegram Application запущен!")
 
-    # Запускаем aiohttp веб-сервер
+    # Создаём и запускаем aiohttp веб-сервер
     web_app = await build_web_app()
     runner = web.AppRunner(web_app)
     await runner.setup()
-    site = web.TCPSite(runner, "0.0.0.0", PORT)
+    site = web.TCPSite(runner, host="0.0.0.0", port=PORT)
     await site.start()
 
+    print("=" * 60)
     print(f"✅ Веб-сервер запущен на порту {PORT}")
-    print(f"✅ Webhook URL: {webhook_full_url}")
-    print("✅ Bot is running. Waiting for messages...")
+    print(f"✅ Webhook: {webhook_full_url}")
+    print(f"✅ Прокси: {CF_WORKER_URL}")
+    print("✅ Бот работает! Ожидаю сообщения...")
+    print("=" * 60)
 
-    # Держим бота запущенным вечно
+    # Держим бота запущенным бесконечно
     try:
         await asyncio.Event().wait()
     finally:
+        # Корректное завершение при остановке
         logger.info("Останавливаю бота...")
-        await telegram_app.bot.delete_webhook()
+        try:
+            await telegram_app.bot.delete_webhook()
+        except Exception as e:
+            logger.warning(f"Не удалось удалить webhook: {e}")
         await telegram_app.stop()
         await telegram_app.shutdown()
         await runner.cleanup()
+        logger.info("Бот остановлен.")
 
 def main():
+    """Точка входа — запускает асинхронную фу��кцию."""
     asyncio.run(main_async())
 
 if __name__ == "__main__":