104 lines
3.8 KiB
Python
104 lines
3.8 KiB
Python
import asyncio
|
|
import logging
|
|
from aiohttp import web
|
|
from aiogram import Bot, Dispatcher
|
|
from aiogram.webhook.aiohttp_server import SimpleRequestHandler, setup_application
|
|
from sqlalchemy.orm import sessionmaker
|
|
|
|
from config.settings import Settings
|
|
|
|
|
|
async def build_and_start_web_app(
|
|
dp: Dispatcher,
|
|
bot: Bot,
|
|
settings: Settings,
|
|
async_session_factory: sessionmaker,
|
|
):
|
|
app = web.Application()
|
|
app["bot"] = bot
|
|
app["dp"] = dp
|
|
app["settings"] = settings
|
|
app["async_session_factory"] = async_session_factory
|
|
# Inject shared instances used by webhook handlers
|
|
app["i18n"] = dp.get("i18n_instance")
|
|
for key in (
|
|
"yookassa_service",
|
|
"subscription_service",
|
|
"referral_service",
|
|
"panel_service",
|
|
"stars_service",
|
|
"freekassa_service",
|
|
"cryptopay_service",
|
|
"tribute_service",
|
|
"panel_webhook_service",
|
|
"platega_service",
|
|
):
|
|
# Access dispatcher workflow_data directly to avoid sequence protocol issues
|
|
if hasattr(dp, "workflow_data") and key in dp.workflow_data: # type: ignore
|
|
app[key] = dp.workflow_data[key] # type: ignore
|
|
|
|
setup_application(app, dp, bot=bot)
|
|
|
|
telegram_uses_webhook_mode = bool(settings.WEBHOOK_BASE_URL)
|
|
|
|
if telegram_uses_webhook_mode:
|
|
telegram_webhook_path = f"/{settings.BOT_TOKEN}"
|
|
app.router.add_post(telegram_webhook_path, SimpleRequestHandler(dispatcher=dp, bot=bot))
|
|
logging.info(
|
|
f"Telegram webhook route configured at: [POST] {telegram_webhook_path} (relative to base URL)"
|
|
)
|
|
|
|
from bot.handlers.user.payment import yookassa_webhook_route
|
|
from bot.services.tribute_service import tribute_webhook_route
|
|
from bot.services.crypto_pay_service import cryptopay_webhook_route
|
|
from bot.services.panel_webhook_service import panel_webhook_route
|
|
from bot.services.freekassa_service import freekassa_webhook_route
|
|
from bot.services.platega_service import platega_webhook_route
|
|
|
|
tribute_path = settings.tribute_webhook_path
|
|
if tribute_path.startswith("/"):
|
|
app.router.add_post(tribute_path, tribute_webhook_route)
|
|
logging.info(f"Tribute webhook route configured at: [POST] {tribute_path}")
|
|
|
|
cp_path = settings.cryptopay_webhook_path
|
|
if cp_path.startswith("/"):
|
|
app.router.add_post(cp_path, cryptopay_webhook_route)
|
|
logging.info(f"CryptoPay webhook route configured at: [POST] {cp_path}")
|
|
|
|
fk_path = settings.freekassa_webhook_path
|
|
if fk_path.startswith("/"):
|
|
app.router.add_post(fk_path, freekassa_webhook_route)
|
|
logging.info(f"FreeKassa webhook route configured at: [POST] {fk_path}")
|
|
|
|
pg_path = settings.platega_webhook_path
|
|
if pg_path.startswith("/"):
|
|
app.router.add_post(pg_path, platega_webhook_route)
|
|
logging.info(f"Platega webhook route configured at: [POST] {pg_path}")
|
|
|
|
# YooKassa webhook (register only when base URL present and path configured)
|
|
yk_path = settings.yookassa_webhook_path
|
|
if settings.WEBHOOK_BASE_URL and yk_path and yk_path.startswith("/"):
|
|
app.router.add_post(yk_path, yookassa_webhook_route)
|
|
logging.info(f"YooKassa webhook route configured at: [POST] {yk_path}")
|
|
|
|
panel_path = settings.panel_webhook_path
|
|
if panel_path.startswith("/"):
|
|
app.router.add_post(panel_path, panel_webhook_route)
|
|
logging.info(f"Panel webhook route configured at: [POST] {panel_path}")
|
|
|
|
web_app_runner = web.AppRunner(app)
|
|
await web_app_runner.setup()
|
|
site = web.TCPSite(
|
|
web_app_runner,
|
|
host=settings.WEB_SERVER_HOST,
|
|
port=settings.WEB_SERVER_PORT,
|
|
)
|
|
|
|
await site.start()
|
|
logging.info(
|
|
f"AIOHTTP server started on http://{settings.WEB_SERVER_HOST}:{settings.WEB_SERVER_PORT}"
|
|
)
|
|
|
|
# Run until cancelled
|
|
await asyncio.Event().wait()
|