-
Notifications
You must be signed in to change notification settings - Fork 5
/
Copy pathadmin.py
846 lines (720 loc) · 27.8 KB
/
admin.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
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
# Copyright (C) 2019 The Raphielscape Company LLC.
#
# Licensed under the Raphielscape Public License, Version 1.c (the "License");
# you may not use this file except in compliance with the License.
"""
Userbot module to help you manage a group
"""
#credits LEGENDX22
from asyncio import sleep
from os import remove
from telethon.errors import (BadRequestError, ChatAdminRequiredError,
ImageProcessFailedError, PhotoCropSizeSmallError,
UserAdminInvalidError)
from telethon.errors.rpcerrorlist import (UserIdInvalidError,
MessageTooLongError)
from telethon.tl.functions.channels import (EditAdminRequest,
EditBannedRequest,
EditPhotoRequest)
from telethon.tl.functions.messages import UpdatePinnedMessageRequest
from telethon.tl.types import (ChannelParticipantsAdmins, ChatAdminRights,
ChatBannedRights, MessageEntityMentionName,
MessageMediaPhoto)
from ULTRA import BOTLOG, BOTLOG_CHATID, CMD_HELP, bot
from ULTRA.utils import register, errors_handler
from ULTRA.utils import admin_cmd
from LEGENDX import NAME, MASTER, BOT
# =================== CONSTANT ===================
PP_TOO_SMOL = "`The image is too small`"
PP_ERROR = "`Failure while processing the image`"
NO_ADMIN = "I am not an admin!! @admins or @admin please make me admin i am very cool boy"
NO_PERM = "`I don't have permission this grp owner is very rude😕`"
NO_SQL = "`Running on Non-SQL mode!`"
CHAT_PP_CHANGED = "`Chat Picture Changed`"
CHAT_PP_ERROR = "`Some issue with updating the pic,`" \
"`maybe coz I'm not an admin,`" \
"`or don't have enough rights.`"
INVALID_MEDIA = "`Invalid Extension`"
BANNED_RIGHTS = ChatBannedRights(
until_date=None,
view_messages=True,
send_messages=True,
send_media=True,
send_stickers=True,
send_gifs=True,
send_games=True,
send_inline=True,
embed_links=True,
)
UNBAN_RIGHTS = ChatBannedRights(
until_date=None,
send_messages=None,
send_media=None,
send_stickers=None,
send_gifs=None,
send_games=None,
send_inline=None,
embed_links=None,
)
MUTE_RIGHTS = ChatBannedRights(until_date=None, send_messages=True)
UNMUTE_RIGHTS = ChatBannedRights(until_date=None, send_messages=False)
# ================================================
#@register(outgoing=True, pattern="^.setgpic$")
@borg.on(admin_cmd(pattern=r"setgpic"))
@errors_handler
async def set_group_photo(gpic):
""" For .setgpic command, changes the picture of a group """
if not gpic.is_group:
await gpic.edit("`I don't think this is a group.`")
return
replymsg = await gpic.get_reply_message()
chat = await gpic.get_chat()
admin = chat.admin_rights
creator = chat.creator
photo = None
if not admin and not creator:
await gpic.edit(NO_ADMIN)
return
if replymsg and replymsg.media:
if isinstance(replymsg.media, MessageMediaPhoto):
photo = await gpic.client.download_media(message=replymsg.photo)
elif "image" in replymsg.media.document.mime_type.split('/'):
photo = await gpic.client.download_file(replymsg.media.document)
else:
await gpic.edit(INVALID_MEDIA)
if photo:
try:
await gpic.client(
EditPhotoRequest(gpic.chat_id, await
gpic.client.upload_file(photo)))
await gpic.edit(CHAT_PP_CHANGED)
except PhotoCropSizeSmallError:
await gpic.edit(PP_TOO_SMOL)
except ImageProcessFailedError:
await gpic.edit(PP_ERROR)
#@register(outgoing=True, pattern="^.promote(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"promote(?: |$)(.*)"))
@errors_handler
async def promote(promt):
""" For .promote command, promotes the replied/tagged person """
# Get targeted chat
chat = await promt.get_chat()
# Grab admin status or creator in a chat
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, also return
if not admin and not creator:
await promt.edit(NO_ADMIN)
return
new_rights = ChatAdminRights(add_admins=False,
invite_users=True,
change_info=False,
ban_users=True,
delete_messages=True,
pin_messages=True)
await promt.edit("`Promoting...`")
user, rank = await get_user_from_event(promt)
if not rank:
rank = "LEGEND BOY" # Just in case.
if user:
pass
else:
return
# Try to promote if current user is admin or creator
try:
await promt.client(
EditAdminRequest(promt.chat_id, user.id, new_rights, rank))
await promt.edit(f"THIS USER SUCCESSFULLY PROMOTED BY {BOT} ⚡\n MY OWNER IS {MASTER} 🔥")
# If Telethon spit BadRequestError, assume
# we don't have Promote permission
except BadRequestError:
await promt.edit(NO_PERM)
return
# Announce to the logging group if we have promoted successfully
if BOTLOG:
await promt.client.send_message(
BOTLOG_CHATID, "#PROMOTE\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {promt.chat.title}(`{promt.chat_id}`)")
#@register(outgoing=True, pattern="^.demote(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"demote(?: |$)(.*)"))
@errors_handler
async def demote(dmod):
""" For .demote command, demotes the replied/tagged person """
# Admin right check
chat = await dmod.get_chat()
admin = chat.admin_rights
creator = chat.creator
if not admin and not creator:
await dmod.edit(NO_ADMIN)
return
# If passing, declare that we're going to demote
await dmod.edit("`Demoting...`")
rank = "admeme" # dummy rank, lol.
user = await get_user_from_event(dmod)
user = user[0]
if user:
pass
else:
return
# New rights after demotion
newrights = ChatAdminRights(add_admins=None,
invite_users=None,
change_info=None,
ban_users=None,
delete_messages=None,
pin_messages=None)
# Edit Admin Permission
try:
await dmod.client(
EditAdminRequest(dmod.chat_id, user.id, newrights, rank))
# If we catch BadRequestError from Telethon
# Assume we don't have permission to demote
except BadRequestError:
await dmod.edit(NO_PERM)
return
await dmod.edit(f"THIS USER SUCCESSFULLY DEMOTED BY {BOT} ⚡⚡\n MY MASTER IS {MASTER} 🔥")
# Announce to the logging group if we have demoted successfully
if BOTLOG:
await dmod.client.send_message(
BOTLOG_CHATID, "#DEMOTE\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {dmod.chat.title}(`{dmod.chat_id}`)")
#@register(outgoing=True, pattern="^.ban(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"ban(?: |$)(.*)"))
@errors_handler
async def ban(bon):
""" For .ban command, bans the replied/tagged person """
# Here laying the sanity check
chat = await bon.get_chat()
admin = chat.admin_rights
creator = chat.creator
if not admin and not creator:
await bon.edit(NO_ADMIN)
return
user, reason = await get_user_from_event(bon)
if user:
pass
else:
return
# Announce that we're going to whack the pest
await bon.edit("`BANNING THIS MADARCHOD`")
try:
await bon.client(EditBannedRequest(bon.chat_id, user.id,
BANNED_RIGHTS))
except BadRequestError:
await bon.edit(NO_PERM)
return
# Helps ban group join spammers more easily
try:
reply = await bon.get_reply_message()
if reply:
await reply.delete()
except BadRequestError:
await bon.edit(
"`I dont have message nuking rights! But still he was banned!`")
return
# Delete message and then tell that the command
# is done gracefully
# Shout out the ID, so that fedadmins can fban later
if reason:
await bon.edit(f"BANNED 🔥`{str(user.id)}` was banned by {BOT} My Master {MASTER} !!\n\nReason: {reason}")
else:
await bon.edit(f"Bitch `{str(user.id)}` was banned !!")
# Announce to the logging group if we have banned the person
# successfully!
if BOTLOG:
await bon.client.send_message(
BOTLOG_CHATID, "#BAN\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {bon.chat.title}(`{bon.chat_id}`)")
#@register(outgoing=True, pattern="^.unban(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"unban(?: |$)(.*)"))
@errors_handler
async def nothanos(unbon):
""" For .unban command, unbans the replied/tagged person """
# Here laying the sanity check
chat = await unbon.get_chat()
admin = chat.admin_rights
creator = chat.creator
# Well
if not admin and not creator:
await unbon.edit(NO_ADMIN)
return
# If everything goes well...
await unbon.edit("`Unbanning...`")
user = await get_user_from_event(unbon)
user = user[0]
if user:
pass
else:
return
try:
await unbon.client(
EditBannedRequest(unbon.chat_id, user.id, UNBAN_RIGHTS))
await unbon.edit(f"```Unbanned Successfully.\n By {BOT} My Master {MASTER}```")
if BOTLOG:
await unbon.client.send_message(
BOTLOG_CHATID, "#UNBAN\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {unbon.chat.title}(`{unbon.chat_id}`)")
except UserIdInvalidError:
await unbon.edit("`Uh oh my unban logic broke!`")
#@register(outgoing=True, pattern="^.mute(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"mute(?: |$)(.*)"))
@errors_handler
async def spider(spdr):
"""
This function is basically muting peeps
"""
# Check if the function running under SQL mode
try:
from ULTRA.modules.sql_helper.spam_mute_sql import mute
except AttributeError:
await spdr.edit(NO_SQL)
return
# Admin or creator check
chat = await spdr.get_chat()
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, return
if not admin and not creator:
await spdr.edit(NO_ADMIN)
return
user, reason = await get_user_from_event(spdr)
if user:
pass
else:
return
self_user = await spdr.client.get_me()
if user.id == self_user.id:
await spdr.edit(
"`Hands too short, can't duct tape myself...\n(ヘ・_ï½¥)ヘ┳â”┳`")
return
# If everything goes well, do announcing and mute
await spdr.edit("`Gets a tape!`")
if mute(spdr.chat_id, user.id) is False:
return await spdr.edit('`Error! User probably already muted.`')
else:
try:
await spdr.client(
EditBannedRequest(spdr.chat_id, user.id, MUTE_RIGHTS))
# Announce that the function is done
if reason:
await spdr.edit(f"`Safely taped !!`\nReason: {reason}")
else:
await spdr.edit("`Safely taped !!`")
# Announce to logging group
if BOTLOG:
await spdr.client.send_message(
BOTLOG_CHATID, "#MUTE\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {spdr.chat.title}(`{spdr.chat_id}`)")
except UserIdInvalidError:
return await spdr.edit("`Uh oh my mute logic broke!`")
#@register(outgoing=True, pattern="^.unmute(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"unmute(?: |$)(.*)"))
@errors_handler
async def unmoot(unmot):
""" For .unmute command, unmute the replied/tagged person """
# Admin or creator check
chat = await unmot.get_chat()
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, return
if not admin and not creator:
await unmot.edit(NO_ADMIN)
return
# Check if the function running under SQL mode
try:
from ULTRA.modules.sql_helper.spam_mute_sql import unmute
except AttributeError:
await unmot.edit(NO_SQL)
return
# If admin or creator, inform the user and start unmuting
await unmot.edit('```Unmuting...```')
user = await get_user_from_event(unmot)
user = user[0]
if user:
pass
else:
return
if unmute(unmot.chat_id, user.id) is False:
return await unmot.edit("`Error! User probably already unmuted.`")
else:
try:
await unmot.client(
EditBannedRequest(unmot.chat_id, user.id, UNBAN_RIGHTS))
await unmot.edit("```Unmuted Successfully```")
except UserIdInvalidError:
await unmot.edit("`Uh oh my unmute logic broke!`")
return
if BOTLOG:
await unmot.client.send_message(
BOTLOG_CHATID, "#UNMUTE\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {unmot.chat.title}(`{unmot.chat_id}`)")
@register(incoming=True)
@errors_handler
async def muter(moot):
""" Used for deleting the messages of muted people """
try:
from ULTRA.modules.sql_helper.spam_mute_sql import is_muted
from ULTRA.modules.sql_helper.gmute_sql import is_gmuted
except AttributeError:
return
muted = is_muted(moot.chat_id)
gmuted = is_gmuted(moot.sender_id)
rights = ChatBannedRights(
until_date=None,
send_messages=True,
send_media=True,
send_stickers=True,
send_gifs=True,
send_games=True,
send_inline=True,
embed_links=True,
)
if muted:
for i in muted:
if str(i.sender) == str(moot.sender_id):
await moot.delete()
await moot.client(
EditBannedRequest(moot.chat_id, moot.sender_id, rights))
for i in gmuted:
if i.sender == str(moot.sender_id):
await moot.delete()
#@register(outgoing=True, pattern="^.ungmute(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"ungmute(?: |$)(.*)"))
@errors_handler
async def ungmoot(un_gmute):
""" For .ungmute command, ungmutes the target in the ULTRA """
# Admin or creator check
chat = await un_gmute.get_chat()
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, return
if not admin and not creator:
await un_gmute.edit(NO_ADMIN)
return
# Check if the function running under SQL mode
try:
from ULTRA.modules.sql_helper.gmute_sql import ungmute
except AttributeError:
await un_gmute.edit(NO_SQL)
return
user = await get_user_from_event(un_gmute)
user = user[0]
if user:
pass
else:
return
# If pass, inform and start ungmuting
await un_gmute.edit('```Ungmuting...```')
if ungmute(user.id) is False:
await un_gmute.edit("`Error! User probably not gmuted.`")
else:
# Inform about success
await un_gmute.edit("```Ungmuted Successfully```")
if BOTLOG:
await un_gmute.client.send_message(
BOTLOG_CHATID, "#UNGMUTE\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {un_gmute.chat.title}(`{un_gmute.chat_id}`)")
#@register(outgoing=True, pattern="^.gmute(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"gmute(?: |$)(.*)"))
@errors_handler
async def gspider(gspdr):
""" For .gmute command, globally mutes the replied/tagged person """
# Admin or creator check
chat = await gspdr.get_chat()
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, return
if not admin and not creator:
await gspdr.edit(NO_ADMIN)
return
# Check if the function running under SQL mode
try:
from ULTRA.modules.sql_helper.gmute_sql import gmute
except AttributeError:
await gspdr.edit(NO_SQL)
return
user, reason = await get_user_from_event(gspdr)
if user:
pass
else:
return
# If pass, inform and start gmuting
await gspdr.edit("`Grabs a huge, sticky duct tape!`")
if gmute(user.id) is False:
await gspdr.edit(
'`Error! User probably already gmuted.\nRe-rolls the tape.`')
else:
if reason:
await gspdr.edit(f"`Globally taped!`Reason: {reason}")
else:
await gspdr.edit("`Globally taped!`")
if BOTLOG:
await gspdr.client.send_message(
BOTLOG_CHATID, "#GMUTE\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {gspdr.chat.title}(`{gspdr.chat_id}`)")
#@register(outgoing=True, pattern="^.delusers(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"delusers(?: |$)(.*)"))
@errors_handler
async def rm_deletedacc(show):
""" For .delusers command, list all the ghost/deleted accounts in a chat. """
if not show.is_group:
await show.edit("`I don't think this is a group.`")
return
con = show.pattern_match.group(1)
del_u = 0
del_status = "`No deleted accounts found, Group is cleaned as Hell`"
if con != "clean":
await show.edit("`Searching for zombie accounts...`")
async for user in show.client.iter_participants(show.chat_id,
aggressive=True):
if user.deleted:
del_u += 1
await sleep(1)
if del_u > 0:
del_status = f"Found **{del_u}** deleted account(s) in this group,\
\nclean them by using .delusers clean"
await show.edit(del_status)
return
# Here laying the sanity check
chat = await show.get_chat()
admin = chat.admin_rights
creator = chat.creator
# Well
if not admin and not creator:
await show.edit("`I am not an admin here!`")
return
await show.edit("`Deleting deleted accounts...\nOh I can do that?!?!`")
del_u = 0
del_a = 0
async for user in show.client.iter_participants(show.chat_id):
if user.deleted:
try:
await show.client(
EditBannedRequest(show.chat_id, user.id, BANNED_RIGHTS))
except ChatAdminRequiredError:
await show.edit("`I don't have ban rights in this group`")
return
except UserAdminInvalidError:
del_u -= 1
del_a += 1
await show.client(
EditBannedRequest(show.chat_id, user.id, UNBAN_RIGHTS))
del_u += 1
if del_u > 0:
del_status = f"Cleaned **{del_u}** deleted account(s)"
if del_a > 0:
del_status = f"Cleaned **{del_u}** deleted account(s) \
\n**{del_a}** deleted admin accounts are not removed"
await show.edit(del_status)
await sleep(2)
await show.delete()
if BOTLOG:
await show.client.send_message(
BOTLOG_CHATID, "#CLEANUP\n"
f"Cleaned **{del_u}** deleted account(s) !!\
\nCHAT: {show.chat.title}(`{show.chat_id}`)")
#@register(outgoing=True, pattern="^.adminlist$")
@borg.on(admin_cmd(pattern=r"adminlist"))
@errors_handler
async def get_admin(show):
""" For .admins command, list all of the admins of the chat. """
info = await show.client.get_entity(show.chat_id)
title = info.title if info.title else "this chat"
mentions = f'<b>Admins in {title}:</b> \n'
try:
async for user in show.client.iter_participants(
show.chat_id, filter=ChannelParticipantsAdmins):
if not user.deleted:
link = f"<a href=\"tg://user?id={user.id}\">{user.first_name}</a>"
userid = f"<code>{user.id}</code>"
mentions += f"\n{link} {userid}"
else:
mentions += f"\nDeleted Account <code>{user.id}</code>"
except ChatAdminRequiredError as err:
mentions += " " + str(err) + "\n"
await show.edit(mentions, parse_mode="html")
#@register(outgoing=True, pattern="^.pin(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"pin(?: |$)(.*)"))
@errors_handler
async def pin(msg):
""" For .pin command, pins the replied/tagged message on the top the chat. """
# Admin or creator check
chat = await msg.get_chat()
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, return
if not admin and not creator:
await msg.edit(NO_ADMIN)
return
to_pin = msg.reply_to_msg_id
if not to_pin:
await msg.edit("`Reply to a message to pin it.`")
return
options = msg.pattern_match.group(1)
is_silent = True
if options.lower() == "loud":
is_silent = False
try:
await msg.client(
UpdatePinnedMessageRequest(msg.to_id, to_pin, is_silent))
except BadRequestError:
await msg.edit(NO_PERM)
return
await msg.edit("`Pinned Successfully!`")
user = await get_user_sender_id(msg.sender_id, msg)
if BOTLOG:
await msg.client.send_message(
BOTLOG_CHATID, "#PIN\n"
f"ADMIN: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {msg.chat.title}(`{msg.chat_id}`)\n"
f"LOUD: {not is_silent}")
#@register(outgoing=True, pattern="^.kick(?: |$)(.*)")
@borg.on(admin_cmd(pattern=r"kick(?: |$)(.*)"))
@errors_handler
async def kick(usr):
""" For .kick command, kicks the replied/tagged person from the group. """
# Admin or creator check
chat = await usr.get_chat()
admin = chat.admin_rights
creator = chat.creator
# If not admin and not creator, return
if not admin and not creator:
await usr.edit(NO_ADMIN)
return
user, reason = await get_user_from_event(usr)
if not user:
await usr.edit("`Couldn't fetch user.`")
return
await usr.edit("`Kicking...`")
try:
await usr.client.kick_participant(usr.chat_id, user.id)
await sleep(.5)
except Exception as e:
await usr.edit(NO_PERM + f"\n{str(e)}")
return
if reason:
await usr.edit(
f"`Kicked` [{user.first_name}](tg://user?id={user.id})`!`\nReason: {reason}"
)
else:
await usr.edit(
f"`Kicked` [{user.first_name}](tg://user?id={user.id})`!`")
if BOTLOG:
await usr.client.send_message(
BOTLOG_CHATID, "#KICK\n"
f"USER: [{user.first_name}](tg://user?id={user.id})\n"
f"CHAT: {usr.chat.title}(`{usr.chat_id}`)\n")
#@register(outgoing=True, pattern="^.users ?(.*)")
@borg.on(admin_cmd(pattern=r"users ?(.*)"))
@errors_handler
async def get_users(show):
""" For .users command, list all of the users in a chat. """
info = await show.client.get_entity(show.chat_id)
title = info.title if info.title else "this chat"
mentions = 'Users in {}: \n'.format(title)
try:
if not show.pattern_match.group(1):
async for user in show.client.iter_participants(show.chat_id):
if not user.deleted:
mentions += f"\n[{user.first_name}](tg://user?id={user.id}) `{user.id}`"
else:
mentions += f"\nDeleted Account `{user.id}`"
else:
searchq = show.pattern_match.group(1)
async for user in show.client.iter_participants(
show.chat_id, search=f'{searchq}'):
if not user.deleted:
mentions += f"\n[{user.first_name}](tg://user?id={user.id}) `{user.id}`"
else:
mentions += f"\nDeleted Account `{user.id}`"
except ChatAdminRequiredError as err:
mentions += " " + str(err) + "\n"
try:
await show.edit(mentions)
except MessageTooLongError:
await show.edit(
"Damn, this is a huge group. Uploading users lists as file.")
file = open("userslist.txt", "w+")
file.write(mentions)
file.close()
await show.client.send_file(
show.chat_id,
"userslist.txt",
caption='Users in {}'.format(title),
reply_to=show.id,
)
remove("userslist.txt")
async def get_user_from_event(event):
""" Get the user from argument or replied message. """
args = event.pattern_match.group(1).split(' ', 1)
extra = None
if event.reply_to_msg_id:
previous_message = await event.get_reply_message()
user_obj = await event.client.get_entity(previous_message.sender_id)
extra = event.pattern_match.group(1)
elif args:
user = args[0]
if len(args) == 2:
extra = args[1]
if user.isnumeric():
user = int(user)
if not user:
await event.edit("`Pass the user's username, id or reply!`")
return
if event.message.entities is not None:
probable_user_mention_entity = event.message.entities[0]
if isinstance(probable_user_mention_entity,
MessageEntityMentionName):
user_id = probable_user_mention_entity.user_id
user_obj = await event.client.get_entity(user_id)
return user_obj
try:
user_obj = await event.client.get_entity(user)
except (TypeError, ValueError) as err:
await event.edit(str(err))
return None
return user_obj, extra
async def get_user_sender_id(user, event):
if isinstance(user, str):
user = int(user)
try:
user_obj = await event.client.get_entity(user)
except (TypeError, ValueError) as err:
await event.edit(str(err))
return None
return user_obj
CMD_HELP.update({
"admin":
".promote <username/reply> <custom rank (optional)>\
\nUsage: Provides admin rights to the person in the chat.\
\n\n.demote <username/reply>\
\nUsage: Revokes the person's admin permissions in the chat.\
\n\n.ban <username/reply> <reason (optional)>\
\nUsage: Bans the person off your chat.\
\n\n.unban <username/reply>\
\nUsage: Removes the ban from the person in the chat.\
\n\n.mute <username/reply> <reason (optional)>\
\nUsage: Mutes the person in the chat, works on admins too.\
\n\n.unmute <username/reply>\
\nUsage: Removes the person from the muted list.\
\n\n.gmute <username/reply> <reason (optional)>\
\nUsage: Mutes the person in all groups you have in common with them.\
\n\n.ungmute <username/reply>\
\nUsage: Reply someone's message with .ungmute to remove them from the gmuted list.\
\n\n.delusers\
\nUsage: Searches for deleted accounts in a group. Use .delusers clean to remove deleted accounts from the group.\
\n\n.admins\
\nUsage: Retrieves a list of admins in the chat.\
\n\n.users or .users <name of member>\
\nUsage: Retrieves all (or queried) users in the chat.\
\n\n.setgppic <reply to image>\
\nUsage: Changes the group's display picture."
})