58 lines
2.0 KiB
Python
58 lines
2.0 KiB
Python
import asyncio
|
|
import logging
|
|
import signal
|
|
import sys
|
|
from aiohttp import ClientSession
|
|
from handlers.messages_routing import messages_routing
|
|
from handlers.handle_join_request import handle_join_request, handle_reaction_on_request
|
|
from bot.config import BOT_TOKEN, FEEDBACK_CHAT_ID
|
|
from bot.api import telegram_api
|
|
|
|
logging.basicConfig(level=logging.DEBUG)
|
|
logger = logging.getLogger(__name__)
|
|
state = dict()
|
|
|
|
api_url = f'https://api.telegram.org/bot{BOT_TOKEN}/'
|
|
|
|
|
|
async def fetch(session, url):
|
|
logger.debug(f"fetching: {url}")
|
|
async with session.get(url) as response:
|
|
logger.debug(response)
|
|
return await response.json()
|
|
|
|
|
|
async def start():
|
|
logger.info("\tstarted")
|
|
async with ClientSession() as session:
|
|
offset = 0 # начальное значение offset
|
|
while True:
|
|
updates = await fetch(session, f"{api_url}getUpdates?offset={offset}&allowed_updates=['message', 'join_chat_request', 'message_reaction']")
|
|
# logger.info('.' if updates['result'] == [] else updates)
|
|
for update in updates.get("result", []):
|
|
try:
|
|
message = update.get("message")
|
|
join_chat_request = update.get("join_chat_request")
|
|
message_reaction = update.get("message_reaction")
|
|
if message:
|
|
await messages_routing(message, state)
|
|
elif join_chat_request:
|
|
await handle_join_request(join_chat_request)
|
|
elif message_reaction:
|
|
await handle_reaction_on_request(message_reaction)
|
|
|
|
except Exception as e:
|
|
logger.error(e)
|
|
import traceback
|
|
text = traceback.format_exc()
|
|
await telegram_api("sendMessage", chat_id=FEEDBACK_CHAT_ID, text=text)
|
|
|
|
offset = update["update_id"] + 1
|
|
|
|
await asyncio.sleep(1.0)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
# Запуск асинхронного цикла
|
|
asyncio.run(start())
|