Starboard/events/join_chat.py

16 lines
581 B
Python

from aiogram import types, Router
from aiogram.filters import ChatMemberUpdatedFilter, IS_MEMBER
from database.database import pg_con
from filters.chat_type import ChatTypeFilter
router = Router()
@router.my_chat_member(ChatMemberUpdatedFilter(IS_MEMBER), ChatTypeFilter(chat_type=["group", "supergroup"]))
async def join_chat(event: types.Message):
conn = await pg_con()
data = await conn.fetch('SELECT emoji_list FROM chat WHERE chat_id = $1', event.chat.id)
if len(data) == 0:
await conn.execute('INSERT INTO chat (chat_id) VALUES ($1)', event.chat.id)