adder.py

print ("")
print ("++++++---++++++++++++---++++++++++++---++++++++++++---++++++++++++---++++++")
print ("+  ____                                    ____ _           _    _         + ")
print ("- / _|   _ _  _   _  _ _    / _| |__   _ | | _| |_   _   -  ")
print ("+ \_ \ / _ | '_  _ \ / _ \/ _ \ '__| | |   | '_ \ / _ \| |/ / | | |    + ")
print ("-  _) | (_| | | | | | |  /  / |    | |_| | | | (_) |   <| | |_| |  -  ")
print ("+ |____/ \__,_|_| |_| |_|\___|\___|_|     \____|_| |_|\___/|_|\_\_|\__, |  +  ")
print ("-                                                                  |___/   -  ")
print ("++++++---++++++++++++---++++++++++++---++++++++++++---++++++++++++---++++++")
print ("")

from telethon.sync import TelegramClient
from telethon.tl.functions.messages import GetDialogsRequest
from telethon.tl.types import InputPeerEmpty, InputPeerChannel, InputPeerUser
from telethon.errors.rpcerrorlist import PeerFloodError, UserPrivacyRestrictedError
from telethon.tl.functions.channels import InviteToChannelRequest
import sys
import csv
import traceback
import time
import random

api_id =   2547332                         #enter here api_id
api_hash = '3c5bae86e2e0bbc402559ec8b20ba0c0' #Enter here api_hash id
phone = '+917755818339'          #enter here phone number with country code
client = TelegramClient(phone, api_id, api_hash)
async def main():
    # Now you can use all client methods listed below, like for example...
    await client.send_message('me', 'Hello !!!!!')


SLEEP_TIME_1 = 100
SLEEP_TIME_2 = 200
with client: client.loop.run_until_complete(main())
client.connect()
if not client.is_user_authorized():
    client.send_code_request(phone)
    client.sign_in(phone, input('40779'))

users = []
with open(r"Scrapped.csv", encoding='UTF-8') as f:  #Enter your file name
    rows = csv.reader(f,delimiter=",",lineterminator="\n")
    next(rows, None)
    for row in rows:
        user = {}
        user['username'] = row[0]
        user['id'] = int(row[1])
        user['access_hash'] = int(row[2])
        user['name'] = row[3]
        users.append(user)

chats = []
last_date = None
chunk_size = 200
groups = []

result = client(GetDialogsRequest(
    offset_date=last_date,
    offset_id=0,
    offset_peer=InputPeerEmpty(),
    limit=chunk_size,
    hash=0
))
chats.extend(result.chats)

for chat in chats:
    try:
        if chat.megagroup == True:
            groups.append(chat)
    except:
        continue

print('Choose a group to add members:')
i = 0
for group in groups:
    print(str(i) + '- ' + group.title)
    i += 1

g_index = input("Enter a Number: ")
y_index = input("Please! Enter the number for your group")
target_group = groups[int(g_index)]
your_group = groups[int(y_index)]

your_participants = []
your_participants = client.get_participants(your_group, aggressive=True)
your_username = []
your_access_hash = []

for user in your_participants:
    your_username.append(user.username)
    your_access_hash.append(user.access_hash)


target_group_entity = InputPeerChannel(target_group.id, target_group.access_hash)

mode = int(input("Enter 1 to add by username or 2 to add by ID: "))

n = 0

for user in users:
    n += 1
    if n % 80 == 0:
        time.sleep(60)
    try:
        print("Adding {}".format(user['id']))
        if mode == 1:
            # if user['username'] == "":
            #     continue
            if(user['username']  in your_username):
                print("user already in your group")
                print(user["username"])
            elif(user['username'] not in your_username):
                print("new one", user["username"])
                user_to_add = client.get_input_entity(user['username'])
                client(InviteToChannelRequest(target_group_entity, [user_to_add]))
                print("Waiting for 60-180 Seconds...")
                time.sleep(random.randrange(120, 180))



        elif mode == 2:
            if (user['access_hash'] in your_access_hash):
                print("user already in your group")
            elif (user['access_hash'] not in your_access_hash):
                user_to_add = InputPeerUser(user['id'], user['access_hash'])
                client(InviteToChannelRequest(target_group_entity, [user_to_add]))
                print("Waiting for 60-180 Seconds...")
                time.sleep(random.randrange(120, 180))




        else:
            sys.exit("Invalid Mode Selected. Please Try Again.")

    except PeerFloodError:
        print("Getting Flood Error from telegram. Script is stopping now. Please try again after some time.")
        print("Waiting {} seconds".format(SLEEP_TIME_2))
        time.sleep(SLEEP_TIME_2)
    except UserPrivacyRestrictedError:
        print("The user's privacy settings do not allow you to do this. Skipping.")
        print("Waiting for 5 Seconds...")
        time.sleep(random.randrange(5, 10))
    except:
        traceback.print_exc()
        print("Unexpected Error")
        continue