from api import api_id,api_hash
from telethon import TelegramClient , events
from telethon.tl.functions.messages import ImportChatInviteRequest , CheckChatInviteRequest
from telethon.tl.functions.channels import JoinChannelRequest
import aiofiles
import asyncio
from  telethon.errors.rpcerrorlist import InviteHashEmptyError , InviteHashExpiredError


client = TelegramClient('my_account',api_id,api_hash,
                        device_model="Xiaomi Redmi Note 8",
                        system_version="SDK 25",
                        app_version="0.22.8.1361",
                        lang_code="RU",
                        system_lang_code="RU",
                        flood_sleep_threshold=3000
                        )

client.start()
print(client.is_connected())


async def main():
    tasks = []
    async with aiofiles.open('spisok.txt', mode='r') as f:
        async for line in f:
            task = asyncio.create_task(joingroup(line))

            tasks.append(task)


            await asyncio.gather(*tasks)



async def joingroup(line):

    a = line.rstrip()
    a = a.split('/')


    try:
        result = await client(CheckChatInviteRequest(str(a[-1])))
        print(result)
    except InviteHashEmptyError:
        print('InviteHashEmptyError')
    except InviteHashExpiredError:
        print('InviteHashExpiredError')
    except InviteHashInvalidError:
        print('InviteHashInvalidError')



with client:

    client.loop.run_until_complete(main())