aho/welcomecenterbot
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

debug+lang

Browse Source
This commit is contained in:
Untone 2023-10-21 12:54:27 +03:00
parent 091b7613cf
commit 5be6d0bd05
1 changed files with 51 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
bot/main.py
View File

@ -4,8 +4,8 @@ import sys
import signal # Import the signal module import signal # Import the signal module
from aiogram import Bot, Dispatcher, Router from aiogram import Bot, Dispatcher, Router
from aiogram.enums import ParseMode from aiogram.enums import ParseMode
from aiogram.filters import CommandStart, Command from aiogram.filters import CommandStart
from aiogram.types import Message, ChatJoinRequest, CallbackQuery, ChatMemberUpdated, ChatMemberLeft, ChatMemberBanned from aiogram.types import Message, ChatJoinRequest, CallbackQuery, ChatMemberUpdated
from aiogram.enums import ChatMemberStatus from aiogram.enums import ChatMemberStatus
from config import BOT_TOKEN from config import BOT_TOKEN
from handlers.routing import handle_routing from handlers.routing import handle_routing
@ -27,56 +27,75 @@ state = State()
@router.message(CommandStart()) @router.message(CommandStart())
async def command_start_handler(message: Message) -> None: async def command_start_handler(message: Message) -> None:
await message.answer("Напишите своё сообщение для администрации чата") caption = "Напишите своё сообщение для нас" if message.from_user.llanguage_code == 'ru' else "Write your message for us"
await message.answer(caption)
@router.callback_query() @router.callback_query()
async def process_callback(callback_query: CallbackQuery): async def process_callback(callback_query: CallbackQuery):
cbq = vars(callback_query) cbq = vars(callback_query)
cbq["from"] = vars(callback_query.from_user) try:
cbq["message"] = vars(callback_query.message) cbq["from"] = vars(callback_query.from_user)
data = cbq["data"] cbq["message"] = vars(callback_query.message)
if data.startswith("vouch"): data = cbq["data"]
await handle_button(cbq) if data.startswith("vouch"):
elif data.startswith("unlink"): await handle_button(cbq)
await handle_unlink(cbq, state) elif data.startswith("unlink"):
await handle_unlink(cbq, state)
except Exception as e:
logger.error(f"[main.process_callback] ERROR {e}")
logger.debug(cbq)
@router.chat_join_request() @router.chat_join_request()
async def join_request_handler(update: ChatJoinRequest) -> None: async def join_request_handler(update: ChatJoinRequest) -> None:
print("chat join request") print("chat join request")
join_request = vars(update) join_request = vars(update)
join_request["from"] = vars(update.from_user) try:
join_request["chat"] = vars(update.chat) join_request["from"] = vars(update.from_user)
await handle_join_request(join_request) join_request["chat"] = vars(update.chat)
await handle_join_request(join_request)
except Exception as e:
logger.error(f"[main.join_request_handler] ERROR {e}")
logger.debug(join_request)
@router.message() @router.message()
async def all_handler(message: Message) -> None: async def all_handler(message: Message) -> None:
msg = vars(message) msg = vars(message)
msg["from"] = vars(message.from_user) try:
msg["chat"] = vars(message.chat) msg["from"] = vars(message.from_user)
if message.reply_to_message: msg["chat"] = vars(message.chat)
msg["reply_to_message"] = vars(message.reply_to_message) if message.reply_to_message:
await handle_routing(msg, state) msg["reply_to_message"] = vars(message.reply_to_message)
await asyncio.sleep(1.0) await handle_routing(msg, state)
await asyncio.sleep(1.0)
except Exception as e:
logger.error(f"[main.all_handler] ERROR {e}")
logger.debug(msg)
@router.my_chat_member() @router.my_chat_member()
async def chat_members_change(update: ChatMemberUpdated): async def chat_members_change(update: ChatMemberUpdated):
msg = vars(update) msg = vars(update)
msg["chat"] = vars(update.chat) try:
msg["from"] = vars(update.from_user) msg["chat"] = vars(update.chat)
logger.debug(msg) msg["from"] = vars(update.from_user)
old_member = update.old_chat_member logger.debug(msg)
new_member = update.new_chat_member old_member = update.old_chat_member
if old_member: new_member = update.new_chat_member
if old_member.status == ChatMemberStatus.KICKED: if old_member:
Profile.erase(update.from_user.id) if old_member.status == ChatMemberStatus.KICKED:
await handle_left(msg) Profile.erase(update.from_user.id)
elif new_member: await handle_left(msg)
await handle_join(msg) elif new_member:
else: await handle_join(msg)
logger.info("unhandled members update") else:
logger.info("unhandled members update")
except Exception as e:
logger.error(f"[main.all_handler] ERROR {e}")
logger.debu(msg)
async def main() -> None: async def main() -> None: