56 lines
1.5 KiB
Python
56 lines
1.5 KiB
Python
from typing import List
|
|
|
|
import aiojobs as aiojobs
|
|
from aiogram import Bot, Dispatcher
|
|
from aiogram.contrib.fsm_storage.redis import RedisStorage2
|
|
from aiogram.types import ParseMode
|
|
from aiohttp import web
|
|
from loguru import logger
|
|
|
|
from data import config
|
|
|
|
|
|
# noinspection PyUnusedLocal
|
|
async def on_startup(app: web.Application):
|
|
import middlewares
|
|
import filters
|
|
import handlers
|
|
middlewares.setup(dp)
|
|
filters.setup(dp)
|
|
handlers.errors.setup(dp)
|
|
handlers.user.setup(dp)
|
|
logger.info('Configure Webhook URL to: {url}', url=config.WEBHOOK_URL)
|
|
await dp.bot.set_webhook(config.WEBHOOK_URL)
|
|
|
|
|
|
async def on_shutdown(app: web.Application):
|
|
app_bot: Bot = app['bot']
|
|
await app_bot.close()
|
|
|
|
|
|
async def init() -> web.Application:
|
|
from utils.misc import logging
|
|
import web_handlers
|
|
logging.setup()
|
|
scheduler = await aiojobs.create_scheduler()
|
|
app = web.Application()
|
|
subapps: List[str, web.Application] = [
|
|
('/tg/webhooks/', web_handlers.tg_updates_app),
|
|
]
|
|
for prefix, subapp in subapps:
|
|
subapp['bot'] = bot
|
|
subapp['dp'] = dp
|
|
subapp['scheduler'] = scheduler
|
|
app.add_subapp(prefix, subapp)
|
|
app.on_startup.append(on_startup)
|
|
app.on_shutdown.append(on_shutdown)
|
|
return app
|
|
|
|
|
|
if __name__ == '__main__':
|
|
bot = Bot(config.BOT_TOKEN, parse_mode=ParseMode.HTML, validate_token=True)
|
|
storage = RedisStorage2(**config.redis)
|
|
dp = Dispatcher(bot, storage=storage)
|
|
|
|
web.run_app(init())
|