2022-08-07 04:45:35 -04:00
|
|
|
from database.models import Member
|
|
|
|
from config import group_id
|
|
|
|
|
|
|
|
async def check_user_data():
|
|
|
|
"""Check user data in database and update it"""
|
|
|
|
from load import tgc,database
|
2022-08-13 08:25:52 -04:00
|
|
|
|
|
|
|
members = await tgc.members_list(group_id)
|
2022-08-07 04:45:35 -04:00
|
|
|
|
2022-08-13 08:25:52 -04:00
|
|
|
for member in members:
|
|
|
|
exists = database.check_data_exists(Member.user_id,member["id"])
|
2022-08-07 04:45:35 -04:00
|
|
|
|
|
|
|
role = "member"
|
2022-08-13 08:25:52 -04:00
|
|
|
if (member["status"] == "ChatMemberStatus.OWNER"):
|
|
|
|
role = "owner"
|
2022-08-07 04:45:35 -04:00
|
|
|
|
2022-08-13 08:25:52 -04:00
|
|
|
if (not exists):
|
2022-08-07 04:45:35 -04:00
|
|
|
database.register_user(
|
2022-08-13 08:25:52 -04:00
|
|
|
member["id"],member["first_name"],
|
|
|
|
member["username"],role
|
2022-08-07 04:45:35 -04:00
|
|
|
)
|
|
|
|
else:
|
2022-08-13 08:25:52 -04:00
|
|
|
database.update_member_data(
|
|
|
|
member["id"],
|
2022-08-07 04:45:35 -04:00
|
|
|
[Member.first_name,Member.user_name],
|
2022-08-13 08:25:52 -04:00
|
|
|
[member["first_name"],member["username"]]
|
2022-08-07 04:45:35 -04:00
|
|
|
)
|