Delete test_server.py

test_server.py

@@ -1,119 +0,0 @@
-import sys
-import logging
-import asyncio
-import os
-import aiohttp
-from aiohttp import web
-
-# Включаем логирование
-logging.basicConfig(
-    level=logging.INFO,
-    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
-    handlers=[logging.StreamHandler(sys.stdout)]
-)
-
-# ============================================================
-# МАГИЯ: Подменяем Bot() ДО импорта bot.py!
-# ============================================================
-from aiogram import Bot
-from aiogram.client.session.aiohttp import AiohttpSession
-from aiogram.client.telegram import TelegramAPIServer
-
-proxy_server = os.getenv("TELEGRAM_API_SERVER")
-
-if proxy_server:
-    # Убираем слэш на конце, если он есть
-    clean_proxy = proxy_server.strip().rstrip('/')
-    
-    # СТАНДАРТНЫЙ СПОСОБ AIOGRAM: Меняем сервер API на наш Worker!
-    # Это работает ИДЕАЛЬНО, так как aiogram сам формирует правильные запросы
-    # без хаков с патчами httpx.
-    custom_server = TelegramAPIServer.from_base(clean_proxy)
-    logging.critical(f"✅ [PROXY] Установлен кастомный Telegram API Server: {custom_server.base}")
-    
-    # Перехватываем создание Bot(), чтобы всунуть наш custom_server
-    _original_bot_init = Bot.__init__
-    
-    def _patched_bot_init(self, token, **kwargs):
-        if 'session' not in kwargs:
-            # Создаем сессию с нашим прокси-сервером
-            kwargs['session'] = AiohttpSession(api=custom_server)
-        _original_bot_init(self, token, **kwargs)
-        
-    Bot.__init__ = _patched_bot_init
-
-# Импорт бота (теперь bot.bot создастся с нашим custom_server!)
-import bot as M
-dp = M.dp
-bot = M.bot
-
-# ОТЛАДОЧНЫЙ МИДЛВАРЬ
-from aiogram import BaseMiddleware
-
-class DebugRawMiddleware(BaseMiddleware):
-    async def __call__(self, handler, event, data):
-        logging.critical(f"🚨 [RAW MIDDLEWARE] ВХОДЯЩЕЕ ОБНОВЛЕНИЕ! Type: {type(event).__name__}")
-        try:
-            result = await handler(event, data)
-            logging.critical(f"🚨 [RAW MIDDLEWARE] Хендлер отработал!")
-            return result
-        except Exception as e:
-            logging.critical(f"🔥 [RAW MIDDLEWARE] ОШИБКА: {e}", exc_info=True)
-            raise
-
-dp.message.middleware(DebugRawMiddleware())
-dp.callback_query.middleware(DebugRawMiddleware())
-logging.info("✅ [DEBUG] Мидлварь внедрен!")
-
-# Polling логика
-async def run_bot():
-    await M.init_db()
-    await M.start_cleanup_scheduler()
-    
-    logging.info("🚨 Удаляем Webhook...")
-    try:
-        await bot.delete_webhook(drop_pending_updates=True)
-        logging.info("🚨 Webhook удален!")
-    except Exception as e:
-        logging.critical(f"🔥 Не удалось удалить Webhook (Прокси мертв?): {e}")
-        return
-
-    try:
-        me = await bot.get_me()
-        logging.critical(f"🚨 Бот: @{me.username} (id={me.id})")
-    except Exception as e:
-        logging.critical(f"🔥 Токен/Прокси мертв: {e}")
-        return
-
-    logging.info("🚀 POLLING ЗАПУЩЕН!")
-    from aiogram import enums
-    try:
-        allowed_updates = [
-            enums.UpdateType.MESSAGE,
-            enums.UpdateType.CALLBACK_QUERY,
-            enums.UpdateType.MY_CHAT_MEMBER,
-        ]
-        await dp.start_polling(bot, allowed_updates=allowed_updates)
-    except Exception as e:
-        logging.exception(f"🔥 POLLING УПАЛ: {e}")
-
-# Мини сервер для HF Spaces
-async def ping(r): return web.Response(text="OK")
-
-def main():
-    app = web.Application()
-    app.router.add_get('/', ping)
-    
-    async def start_bg(app):
-        app['bot'] = asyncio.create_task(run_bot())
-    async def stop_bg(app):
-        app['bot'].cancel()
-        
-    app.on_startup.append(start_bg)
-    app.on_shutdown.append(stop_bg)
-    
-    web.run_app(app, host='0.0.0.0', port=int(os.getenv("PORT", 7860)))
-
-if __name__ == "__main__":
-    main()
-