forked from th3unkn0n/TeleGram-Scraper
-
Notifications
You must be signed in to change notification settings - Fork 0
/
add2group.py
145 lines (127 loc) · 4.47 KB
/
add2group.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
#!/bin/env python3
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, UserChannelsTooMuchError
from telethon.tl.functions.channels import InviteToChannelRequest
import configparser
import os
import sys
import csv
import traceback
import time
import random
re = "\033[1;31m"
gr = "\033[1;32m"
cy = "\033[1;36m"
def banner():
print(f"""
{re}╔╦╗{cy}┌─┐┬ ┌─┐{re}╔═╗ ╔═╗{cy}┌─┐┬─┐┌─┐┌─┐┌─┐┬─┐
{re} ║ {cy}├┤ │ ├┤ {re}║ ╦ ╚═╗{cy}│ ├┬┘├─┤├─┘├┤ ├┬┘
{re} ╩ {cy}└─┘┴─┘└─┘{re}╚═╝ ╚═╝{cy}└─┘┴└─┴ ┴┴ └─┘┴└─
version : 1.0
""")
cpass = configparser.RawConfigParser()
cpass.read('config.data')
try:
api_id = cpass['cred']['id']
api_hash = cpass['cred']['hash']
phone = cpass['cred']['phone']
client = TelegramClient(phone, api_id, api_hash)
except KeyError:
os.system('clear')
banner()
print(re+"[!] run python3 setup.py first !!\n")
sys.exit(1)
client.connect()
if not client.is_user_authorized():
client.send_code_request(phone)
os.system('clear')
banner()
client.sign_in(phone, input(gr+'[+] Enter the code: '+re))
os.system('clear')
banner()
input_file = sys.argv[1]
users = []
with open(input_file, encoding='UTF-8') as f:
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
i = 0
for group in groups:
print(gr+'['+cy+str(i)+gr+']'+cy+' - '+group.title)
i += 1
print(gr+'[+] Choose a group to add members')
g_index = input(gr+"[+] Enter a Number : "+re)
target_group = groups[int(g_index)]
target_group_entity = InputPeerChannel(
target_group.id, target_group.access_hash)
print(gr+"[1] add member by user ID\n[2] add member by username ")
mode = int(input(gr+"Input : "+re))
user_success = []
for user in users:
try:
print(gr+"Adding {}".format(user['id']))
if mode == 1:
if user['username'] == "":
continue
user_to_add = client.get_input_entity(user['username'])
elif mode == 2:
user_to_add = InputPeerUser(user['id'], user['access_hash'])
else:
sys.exit(re+"[!] Invalid Mode Selected. Please Try Again.")
client(InviteToChannelRequest(target_group_entity, [user_to_add]))
print(gr+"[+] Waiting for 15-30 Seconds...")
user_success.append(user)
time.sleep(random.randrange(15, 30))
except PeerFloodError:
print(
re+"[!] Getting Flood Error from telegram. \n[!] Script is stopping now. \n[!] Please try again after some time.")
print(re+"[!] Error --- Waiting for 15-30 Seconds...")
time.sleep(random.randrange(15, 30))
except UserPrivacyRestrictedError:
print(
re+"[!] The user's privacy settings do not allow you to do this. Skipping.")
print(re+"[!] Error --- Waiting for 15-30 Seconds...")
time.sleep(random.randrange(15, 30))
except UserChannelsTooMuchError:
print(
re+"[!] The user's in too many channel. Skipping.")
print(re+"[!] Error --- Waiting for 15-30 Seconds...")
time.sleep(random.randrange(15, 30))
except:
traceback.print_exc()
print(re+"[!] Unexpected Error")
print(re+"[!] Error --- Waiting for 15-30 Seconds...")
time.sleep(random.randrange(15, 30))
continue
with open("users_live.csv", "a", encoding='UTF-8') as f:
writer = csv.writer(f, delimiter=",", lineterminator="\n")
for user in user_success:
writer.writerow([user['username'], user['id'],
user['access_hash'], user['name']])
print(gr+'[+] Update users live successfully.')