admin.py 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835
  1. """
  2. MIT License
  3. Copyright (c) 2021 TheHamkerCat
  4. Permission is hereby granted, free of charge, to any person obtaining a copy
  5. of this software and associated documentation files (the "Software"), to deal
  6. in the Software without restriction, including without limitation the rights
  7. to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  8. copies of the Software, and to permit persons to whom the Software is
  9. furnished to do so, subject to the following conditions:
  10. The above copyright notice and this permission notice shall be included in all
  11. copies or substantial portions of the Software.
  12. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  13. IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  14. FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  15. AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  16. LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  17. OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  18. SOFTWARE.
  19. """
  20. import asyncio
  21. import re
  22. from contextlib import suppress
  23. from time import time
  24. from pyrogram.errors import FloodWait
  25. from pyrogram import filters
  26. from pyrogram.types import (
  27. CallbackQuery,
  28. ChatMemberUpdated,
  29. ChatPermissions,
  30. Message,
  31. )
  32. from wbb import BOT_ID, SUDOERS, app, log
  33. from wbb.core.decorators.errors import capture_err
  34. from wbb.core.keyboard import ikb
  35. from wbb.utils.dbfunctions import (
  36. add_warn,
  37. get_warn,
  38. int_to_alpha,
  39. remove_warns,
  40. save_filter,
  41. )
  42. from wbb.utils.functions import (
  43. extract_user,
  44. extract_user_and_reason,
  45. time_converter,
  46. )
  47. __MODULE__ = "Admin"
  48. __HELP__ = """/ban - Ban A User
  49. /dban - Delete the replied message banning its sender
  50. /tban - Ban A User For Specific Time
  51. /unban - Unban A User
  52. /listban - Ban a user from groups listed in a message
  53. /listunban - Unban a user from groups listed in a message
  54. /warn - Warn A User
  55. /dwarn - Delete the replied message warning its sender
  56. /rmwarns - Remove All Warning of A User
  57. /warns - Show Warning Of A User
  58. /kick - Kick A User
  59. /dkick - Delete the replied message kicking its sender
  60. /purge - Purge Messages
  61. /purge [n] - Purge "n" number of messages from replied message
  62. /del - Delete Replied Message
  63. /promote - Promote A Member
  64. /fullpromote - Promote A Member With All Rights
  65. /demote - Demote A Member
  66. /pin - Pin A Message
  67. /mute - Mute A User
  68. /tmute - Mute A User For Specific Time
  69. /unmute - Unmute A User
  70. /ban_ghosts - Ban Deleted Accounts
  71. /report | @admins | @admin - Report A Message To Admins.
  72. /invite - Send Group/SuperGroup Invite Link."""
  73. async def member_permissions(chat_id: int, user_id: int):
  74. perms = []
  75. try:
  76. member = await app.get_chat_member(chat_id, user_id)
  77. except Exception:
  78. return []
  79. if member.can_post_messages:
  80. perms.append("can_post_messages")
  81. if member.can_edit_messages:
  82. perms.append("can_edit_messages")
  83. if member.can_delete_messages:
  84. perms.append("can_delete_messages")
  85. if member.can_restrict_members:
  86. perms.append("can_restrict_members")
  87. if member.can_promote_members:
  88. perms.append("can_promote_members")
  89. if member.can_change_info:
  90. perms.append("can_change_info")
  91. if member.can_invite_users:
  92. perms.append("can_invite_users")
  93. if member.can_pin_messages:
  94. perms.append("can_pin_messages")
  95. if member.can_manage_voice_chats:
  96. perms.append("can_manage_voice_chats")
  97. return perms
  98. from wbb.core.decorators.permissions import adminsOnly
  99. admins_in_chat = {}
  100. async def list_admins(chat_id: int):
  101. global admins_in_chat
  102. if chat_id in admins_in_chat:
  103. interval = time() - admins_in_chat[chat_id]["last_updated_at"]
  104. if interval < 3600:
  105. return admins_in_chat[chat_id]["data"]
  106. admins_in_chat[chat_id] = {
  107. "last_updated_at": time(),
  108. "data": [
  109. member.user.id
  110. async for member in app.iter_chat_members(
  111. chat_id, filter="administrators"
  112. )
  113. ],
  114. }
  115. return admins_in_chat[chat_id]["data"]
  116. # Admin cache reload
  117. @app.on_chat_member_updated()
  118. async def admin_cache_func(_, cmu: ChatMemberUpdated):
  119. if cmu.old_chat_member and cmu.old_chat_member.promoted_by:
  120. admins_in_chat[cmu.chat.id] = {
  121. "last_updated_at": time(),
  122. "data": [
  123. member.user.id
  124. async for member in app.iter_chat_members(
  125. cmu.chat.id, filter="administrators"
  126. )
  127. ],
  128. }
  129. log.info(f"Updated admin cache for {cmu.chat.id} [{cmu.chat.title}]")
  130. # Purge Messages
  131. @app.on_message(filters.command("purge") & ~filters.edited & ~filters.private)
  132. @adminsOnly("can_delete_messages")
  133. async def purgeFunc(_, message: Message):
  134. repliedmsg = message.reply_to_message
  135. await message.delete()
  136. if not repliedmsg:
  137. return await message.reply_text("Reply to a message to purge from.")
  138. cmd = message.command
  139. if len(cmd) > 1 and cmd[1].isdigit():
  140. purge_to = repliedmsg.message_id + int(cmd[1])
  141. if purge_to > message.message_id:
  142. purge_to = message.message_id
  143. else:
  144. purge_to = message.message_id
  145. chat_id = message.chat.id
  146. message_ids = []
  147. for message_id in range(
  148. repliedmsg.message_id,
  149. purge_to,
  150. ):
  151. message_ids.append(message_id)
  152. # Max message deletion limit is 100
  153. if len(message_ids) == 100:
  154. await app.delete_messages(
  155. chat_id=chat_id,
  156. message_ids=message_ids,
  157. revoke=True, # For both sides
  158. )
  159. # To delete more than 100 messages, start again
  160. message_ids = []
  161. # Delete if any messages left
  162. if len(message_ids) > 0:
  163. await app.delete_messages(
  164. chat_id=chat_id,
  165. message_ids=message_ids,
  166. revoke=True,
  167. )
  168. # Kick members
  169. @app.on_message(
  170. filters.command(["kick", "dkick"]) & ~filters.edited & ~filters.private
  171. )
  172. @adminsOnly("can_restrict_members")
  173. async def kickFunc(_, message: Message):
  174. user_id, reason = await extract_user_and_reason(message)
  175. if not user_id:
  176. return await message.reply_text("I can't find that user.")
  177. if user_id == BOT_ID:
  178. return await message.reply_text(
  179. "I can't kick myself, i can leave if you want."
  180. )
  181. if user_id in SUDOERS:
  182. return await message.reply_text("You Wanna Kick The Elevated One?")
  183. if user_id in (await list_admins(message.chat.id)):
  184. return await message.reply_text(
  185. "I can't kick an admin, You know the rules, so do i."
  186. )
  187. mention = (await app.get_users(user_id)).mention
  188. msg = f"""
  189. **Kicked User:** {mention}
  190. **Kicked By:** {message.from_user.mention if message.from_user else 'Anon'}
  191. **Reason:** {reason or 'No Reason Provided.'}"""
  192. if message.command[0][0] == "d":
  193. await message.reply_to_message.delete()
  194. await message.chat.ban_member(user_id)
  195. await message.reply_text(msg)
  196. await asyncio.sleep(1)
  197. await message.chat.unban_member(user_id)
  198. # Ban members
  199. @app.on_message(
  200. filters.command(["ban", "dban", "tban"])
  201. & ~filters.edited
  202. & ~filters.private
  203. )
  204. @adminsOnly("can_restrict_members")
  205. async def banFunc(_, message: Message):
  206. user_id, reason = await extract_user_and_reason(message, sender_chat=True)
  207. if not user_id:
  208. return await message.reply_text("I can't find that user.")
  209. if user_id == BOT_ID:
  210. return await message.reply_text(
  211. "I can't ban myself, i can leave if you want."
  212. )
  213. if user_id in SUDOERS:
  214. return await message.reply_text(
  215. "You Wanna Ban The Elevated One?, RECONSIDER!"
  216. )
  217. if user_id in (await list_admins(message.chat.id)):
  218. return await message.reply_text(
  219. "I can't ban an admin, You know the rules, so do i."
  220. )
  221. try:
  222. mention = (await app.get_users(user_id)).mention
  223. except IndexError:
  224. mention = (
  225. message.reply_to_message.sender_chat.title
  226. if message.reply_to_message
  227. else "Anon"
  228. )
  229. msg = (
  230. f"**Banned User:** {mention}\n"
  231. f"**Banned By:** {message.from_user.mention if message.from_user else 'Anon'}\n"
  232. )
  233. if message.command[0][0] == "d":
  234. await message.reply_to_message.delete()
  235. if message.command[0] == "tban":
  236. split = reason.split(None, 1)
  237. time_value = split[0]
  238. temp_reason = split[1] if len(split) > 1 else ""
  239. temp_ban = await time_converter(message, time_value)
  240. msg += f"**Banned For:** {time_value}\n"
  241. if temp_reason:
  242. msg += f"**Reason:** {temp_reason}"
  243. with suppress(AttributeError):
  244. if len(time_value[:-1]) < 3:
  245. await message.chat.ban_member(user_id, until_date=temp_ban)
  246. await message.reply_text(msg)
  247. else:
  248. await message.reply_text("You can't use more than 99")
  249. return
  250. if reason:
  251. msg += f"**Reason:** {reason}"
  252. await message.chat.ban_member(user_id)
  253. await message.reply_text(msg)
  254. # Unban members
  255. @app.on_message(filters.command("unban") & ~filters.edited & ~filters.private)
  256. @adminsOnly("can_restrict_members")
  257. async def unban_func(_, message: Message):
  258. # we don't need reasons for unban, also, we
  259. # don't need to get "text_mention" entity, because
  260. # normal users won't get text_mention if the user
  261. # they want to unban is not in the group.
  262. reply = message.reply_to_message
  263. if reply and reply.sender_chat and reply.sender_chat != message.chat.id:
  264. return await message.reply_text("You cannot unban a channel")
  265. if len(message.command) == 2:
  266. user = message.text.split(None, 1)[1]
  267. elif len(message.command) == 1 and reply:
  268. user = message.reply_to_message.from_user.id
  269. else:
  270. return await message.reply_text(
  271. "Provide a username or reply to a user's message to unban."
  272. )
  273. await message.chat.unban_member(user)
  274. umention = (await app.get_users(user)).mention
  275. await message.reply_text(f"Unbanned! {umention}")
  276. # Ban users listed in a message
  277. @app.on_message(
  278. SUDOERS & filters.command("listban") & ~filters.edited & ~filters.private
  279. )
  280. async def list_ban_(c, message: Message):
  281. userid, msglink_reason = await extract_user_and_reason(message)
  282. if not userid or not msglink_reason:
  283. return await message.reply_text(
  284. "Provide a userid/username along with message link and reason to list-ban"
  285. )
  286. if (
  287. len(msglink_reason.split(" ")) == 1
  288. ): # message link included with the reason
  289. return await message.reply_text(
  290. "You must provide a reason to list-ban"
  291. )
  292. # seperate messge link from reason
  293. lreason = msglink_reason.split()
  294. messagelink, reason = lreason[0], " ".join(lreason[1:])
  295. if not re.search(
  296. r"(https?://)?t(elegram)?\.me/\w+/\d+", messagelink
  297. ): # validate link
  298. return await message.reply_text("Invalid message link provided")
  299. if userid == BOT_ID:
  300. return await message.reply_text("I can't ban myself.")
  301. if userid in SUDOERS:
  302. return await message.reply_text(
  303. "You Wanna Ban The Elevated One?, RECONSIDER!"
  304. )
  305. splitted = messagelink.split("/")
  306. uname, mid = splitted[-2], int(splitted[-1])
  307. m = await message.reply_text(
  308. "`Banning User from multiple groups. \
  309. This may take some time`"
  310. )
  311. try:
  312. msgtext = (await app.get_messages(uname, mid)).text
  313. gusernames = re.findall("@\w+", msgtext)
  314. except:
  315. return await m.edit_text("Could not get group usernames")
  316. count = 0
  317. for username in gusernames:
  318. try:
  319. await app.ban_chat_member(username.strip("@"), userid)
  320. await asyncio.sleep(1)
  321. except FloodWait as e:
  322. await asyncio.sleep(e.x)
  323. except:
  324. continue
  325. count += 1
  326. mention = (await app.get_users(userid)).mention
  327. msg = f"""
  328. **List-Banned User:** {mention}
  329. **Banned User ID:** `{userid}`
  330. **Admin:** {message.from_user.mention}
  331. **Affected chats:** `{count}`
  332. **Reason:** {reason}
  333. """
  334. await m.edit_text(msg)
  335. # Unban users listed in a message
  336. @app.on_message(
  337. SUDOERS & filters.command("listunban") & ~filters.edited & ~filters.private
  338. )
  339. async def list_unban_(c, message: Message):
  340. userid, msglink = await extract_user_and_reason(message)
  341. if not userid or not msglink:
  342. return await message.reply_text(
  343. "Provide a userid/username along with message link to list-unban"
  344. )
  345. if not re.search(
  346. r"(https?://)?t(elegram)?\.me/\w+/\d+", msglink
  347. ): # validate link
  348. return await message.reply_text("Invalid message link provided")
  349. splitted = msglink.split("/")
  350. uname, mid = splitted[-2], int(splitted[-1])
  351. m = await message.reply_text(
  352. "`Unbanning User from multiple groups. \
  353. This may take some time`"
  354. )
  355. try:
  356. msgtext = (await app.get_messages(uname, mid)).text
  357. gusernames = re.findall("@\w+", msgtext)
  358. except:
  359. return await m.edit_text("Could not get the group usernames")
  360. count = 0
  361. for username in gusernames:
  362. try:
  363. await app.unban_chat_member(username.strip("@"), userid)
  364. await asyncio.sleep(1)
  365. except FloodWait as e:
  366. await asyncio.sleep(e.x)
  367. except:
  368. continue
  369. count += 1
  370. mention = (await app.get_users(userid)).mention
  371. msg = f"""
  372. **List-Unbanned User:** {mention}
  373. **Unbanned User ID:** `{userid}`
  374. **Admin:** {message.from_user.mention}
  375. **Affected chats:** `{count}`
  376. """
  377. await m.edit_text(msg)
  378. # Delete messages
  379. @app.on_message(filters.command("del") & ~filters.edited & ~filters.private)
  380. @adminsOnly("can_delete_messages")
  381. async def deleteFunc(_, message: Message):
  382. if not message.reply_to_message:
  383. return await message.reply_text("Reply To A Message To Delete It")
  384. await message.reply_to_message.delete()
  385. await message.delete()
  386. # Promote Members
  387. @app.on_message(
  388. filters.command(["promote", "fullpromote"])
  389. & ~filters.edited
  390. & ~filters.private
  391. )
  392. @adminsOnly("can_promote_members")
  393. async def promoteFunc(_, message: Message):
  394. user_id = await extract_user(message)
  395. umention = (await app.get_users(user_id)).mention
  396. if not user_id:
  397. return await message.reply_text("I can't find that user.")
  398. bot = await app.get_chat_member(message.chat.id, BOT_ID)
  399. if user_id == BOT_ID:
  400. return await message.reply_text("I can't promote myself.")
  401. if not bot.can_promote_members:
  402. return await message.reply_text("I don't have enough permissions")
  403. if message.command[0][0] == "f":
  404. await message.chat.promote_member(
  405. user_id=user_id,
  406. can_change_info=bot.can_change_info,
  407. can_invite_users=bot.can_invite_users,
  408. can_delete_messages=bot.can_delete_messages,
  409. can_restrict_members=bot.can_restrict_members,
  410. can_pin_messages=bot.can_pin_messages,
  411. can_promote_members=bot.can_promote_members,
  412. can_manage_chat=bot.can_manage_chat,
  413. can_manage_voice_chats=bot.can_manage_voice_chats,
  414. )
  415. return await message.reply_text(f"Fully Promoted! {umention}")
  416. await message.chat.promote_member(
  417. user_id=user_id,
  418. can_change_info=False,
  419. can_invite_users=bot.can_invite_users,
  420. can_delete_messages=bot.can_delete_messages,
  421. can_restrict_members=False,
  422. can_pin_messages=False,
  423. can_promote_members=False,
  424. can_manage_chat=bot.can_manage_chat,
  425. can_manage_voice_chats=bot.can_manage_voice_chats,
  426. )
  427. await message.reply_text(f"Promoted! {umention}")
  428. # Demote Member
  429. @app.on_message(filters.command("demote") & ~filters.edited & ~filters.private)
  430. @adminsOnly("can_promote_members")
  431. async def demote(_, message: Message):
  432. user_id = await extract_user(message)
  433. if not user_id:
  434. return await message.reply_text("I can't find that user.")
  435. if user_id == BOT_ID:
  436. return await message.reply_text("I can't demote myself.")
  437. if user_id in SUDOERS:
  438. return await message.reply_text(
  439. "You wanna demote the elevated one?, RECONSIDER!"
  440. )
  441. await message.chat.promote_member(
  442. user_id=user_id,
  443. can_change_info=False,
  444. can_invite_users=False,
  445. can_delete_messages=False,
  446. can_restrict_members=False,
  447. can_pin_messages=False,
  448. can_promote_members=False,
  449. can_manage_chat=False,
  450. can_manage_voice_chats=False,
  451. )
  452. umention = (await app.get_users(user_id)).mention
  453. await message.reply_text(f"Demoted! {umention}")
  454. # Pin Messages
  455. @app.on_message(
  456. filters.command(["pin", "unpin"]) & ~filters.edited & ~filters.private
  457. )
  458. @adminsOnly("can_pin_messages")
  459. async def pin(_, message: Message):
  460. if not message.reply_to_message:
  461. return await message.reply_text("Reply to a message to pin/unpin it.")
  462. r = message.reply_to_message
  463. if message.command[0][0] == "u":
  464. await r.unpin()
  465. return await message.reply_text(
  466. f"**Unpinned [this]({r.link}) message.**",
  467. disable_web_page_preview=True,
  468. )
  469. await r.pin(disable_notification=True)
  470. await message.reply(
  471. f"**Pinned [this]({r.link}) message.**",
  472. disable_web_page_preview=True,
  473. )
  474. msg = "Please check the pinned message: ~ " + f"[Check, {r.link}]"
  475. filter_ = dict(type="text", data=msg)
  476. await save_filter(message.chat.id, "~pinned", filter_)
  477. # Mute members
  478. @app.on_message(
  479. filters.command(["mute", "tmute"]) & ~filters.edited & ~filters.private
  480. )
  481. @adminsOnly("can_restrict_members")
  482. async def mute(_, message: Message):
  483. user_id, reason = await extract_user_and_reason(message)
  484. if not user_id:
  485. return await message.reply_text("I can't find that user.")
  486. if user_id == BOT_ID:
  487. return await message.reply_text("I can't mute myself.")
  488. if user_id in SUDOERS:
  489. return await message.reply_text(
  490. "You wanna mute the elevated one?, RECONSIDER!"
  491. )
  492. if user_id in (await list_admins(message.chat.id)):
  493. return await message.reply_text(
  494. "I can't mute an admin, You know the rules, so do i."
  495. )
  496. mention = (await app.get_users(user_id)).mention
  497. keyboard = ikb({"🚨 Unmute 🚨": f"unmute_{user_id}"})
  498. msg = (
  499. f"**Muted User:** {mention}\n"
  500. f"**Muted By:** {message.from_user.mention if message.from_user else 'Anon'}\n"
  501. )
  502. if message.command[0] == "tmute":
  503. split = reason.split(None, 1)
  504. time_value = split[0]
  505. temp_reason = split[1] if len(split) > 1 else ""
  506. temp_mute = await time_converter(message, time_value)
  507. msg += f"**Muted For:** {time_value}\n"
  508. if temp_reason:
  509. msg += f"**Reason:** {temp_reason}"
  510. try:
  511. if len(time_value[:-1]) < 3:
  512. await message.chat.restrict_member(
  513. user_id,
  514. permissions=ChatPermissions(),
  515. until_date=temp_mute,
  516. )
  517. await message.reply_text(msg, reply_markup=keyboard)
  518. else:
  519. await message.reply_text("You can't use more than 99")
  520. except AttributeError:
  521. pass
  522. return
  523. if reason:
  524. msg += f"**Reason:** {reason}"
  525. await message.chat.restrict_member(user_id, permissions=ChatPermissions())
  526. await message.reply_text(msg, reply_markup=keyboard)
  527. # Unmute members
  528. @app.on_message(filters.command("unmute") & ~filters.edited & ~filters.private)
  529. @adminsOnly("can_restrict_members")
  530. async def unmute(_, message: Message):
  531. user_id = await extract_user(message)
  532. if not user_id:
  533. return await message.reply_text("I can't find that user.")
  534. await message.chat.unban_member(user_id)
  535. umention = (await app.get_users(user_id)).mention
  536. await message.reply_text(f"Unmuted! {umention}")
  537. # Ban deleted accounts
  538. @app.on_message(
  539. filters.command("ban_ghosts")
  540. & ~filters.private
  541. & ~filters.edited
  542. )
  543. @adminsOnly("can_restrict_members")
  544. async def ban_deleted_accounts(_, message: Message):
  545. chat_id = message.chat.id
  546. deleted_users = []
  547. banned_users = 0
  548. m = await message.reply("Finding ghosts...")
  549. async for i in app.iter_chat_members(chat_id):
  550. if i.user.is_deleted:
  551. deleted_users.append(i.user.id)
  552. if len(deleted_users) > 0:
  553. for deleted_user in deleted_users:
  554. try:
  555. await message.chat.ban_member(deleted_user)
  556. except Exception:
  557. pass
  558. banned_users += 1
  559. await m.edit(f"Banned {banned_users} Deleted Accounts")
  560. else:
  561. await m.edit("There are no deleted accounts in this chat")
  562. @app.on_message(
  563. filters.command(["warn", "dwarn"]) & ~filters.edited & ~filters.private
  564. )
  565. @adminsOnly("can_restrict_members")
  566. async def warn_user(_, message: Message):
  567. user_id, reason = await extract_user_and_reason(message)
  568. chat_id = message.chat.id
  569. if not user_id:
  570. return await message.reply_text("I can't find that user.")
  571. if user_id == BOT_ID:
  572. return await message.reply_text(
  573. "I can't warn myself, i can leave if you want."
  574. )
  575. if user_id in SUDOERS:
  576. return await message.reply_text(
  577. "You Wanna Warn The Elevated One?, RECONSIDER!"
  578. )
  579. if user_id in (await list_admins(chat_id)):
  580. return await message.reply_text(
  581. "I can't warn an admin, You know the rules, so do i."
  582. )
  583. user, warns = await asyncio.gather(
  584. app.get_users(user_id),
  585. get_warn(chat_id, await int_to_alpha(user_id)),
  586. )
  587. mention = user.mention
  588. keyboard = ikb({"🚨 Remove Warn 🚨": f"unwarn_{user_id}"})
  589. if warns:
  590. warns = warns["warns"]
  591. else:
  592. warns = 0
  593. if message.command[0][0] == "d":
  594. await message.reply_to_message.delete()
  595. if warns >= 2:
  596. await message.chat.ban_member(user_id)
  597. await message.reply_text(
  598. f"Number of warns of {mention} exceeded, BANNED!"
  599. )
  600. await remove_warns(chat_id, await int_to_alpha(user_id))
  601. else:
  602. warn = {"warns": warns + 1}
  603. msg = f"""
  604. **Warned User:** {mention}
  605. **Warned By:** {message.from_user.mention if message.from_user else 'Anon'}
  606. **Reason:** {reason or 'No Reason Provided.'}
  607. **Warns:** {warns + 1}/3"""
  608. await message.reply_text(msg, reply_markup=keyboard)
  609. await add_warn(chat_id, await int_to_alpha(user_id), warn)
  610. @app.on_callback_query(filters.regex("unwarn_"))
  611. async def remove_warning(_, cq: CallbackQuery):
  612. from_user = cq.from_user
  613. chat_id = cq.message.chat.id
  614. permissions = await member_permissions(chat_id, from_user.id)
  615. permission = "can_restrict_members"
  616. if permission not in permissions:
  617. return await cq.answer(
  618. "You don't have enough permissions to perform this action.\n"
  619. + f"Permission needed: {permission}",
  620. show_alert=True,
  621. )
  622. user_id = cq.data.split("_")[1]
  623. warns = await get_warn(chat_id, await int_to_alpha(user_id))
  624. if warns:
  625. warns = warns["warns"]
  626. if not warns or warns == 0:
  627. return await cq.answer("User has no warnings.")
  628. warn = {"warns": warns - 1}
  629. await add_warn(chat_id, await int_to_alpha(user_id), warn)
  630. text = cq.message.text.markdown
  631. text = f"~~{text}~~\n\n"
  632. text += f"__Warn removed by {from_user.mention}__"
  633. await cq.message.edit(text)
  634. # Rmwarns
  635. @app.on_message(
  636. filters.command("rmwarns") & ~filters.edited & ~filters.private
  637. )
  638. @adminsOnly("can_restrict_members")
  639. async def remove_warnings(_, message: Message):
  640. if not message.reply_to_message:
  641. return await message.reply_text(
  642. "Reply to a message to remove a user's warnings."
  643. )
  644. user_id = message.reply_to_message.from_user.id
  645. mention = message.reply_to_message.from_user.mention
  646. chat_id = message.chat.id
  647. warns = await get_warn(chat_id, await int_to_alpha(user_id))
  648. if warns:
  649. warns = warns["warns"]
  650. if warns == 0 or not warns:
  651. await message.reply_text(f"{mention} have no warnings.")
  652. else:
  653. await remove_warns(chat_id, await int_to_alpha(user_id))
  654. await message.reply_text(f"Removed warnings of {mention}.")
  655. # Warns
  656. @app.on_message(filters.command("warns") & ~filters.edited & ~filters.private)
  657. @capture_err
  658. async def check_warns(_, message: Message):
  659. user_id = await extract_user(message)
  660. if not user_id:
  661. return await message.reply_text("I can't find that user.")
  662. warns = await get_warn(message.chat.id, await int_to_alpha(user_id))
  663. mention = (await app.get_users(user_id)).mention
  664. if warns:
  665. warns = warns["warns"]
  666. else:
  667. return await message.reply_text(f"{mention} has no warnings.")
  668. return await message.reply_text(f"{mention} has {warns}/3 warnings.")
  669. # Report
  670. @app.on_message(
  671. (
  672. filters.command("report")
  673. | filters.command(["admins", "admin"], prefixes="@")
  674. )
  675. & ~filters.edited
  676. & ~filters.private
  677. )
  678. @capture_err
  679. async def report_user(_, message):
  680. if not message.reply_to_message:
  681. return await message.reply_text(
  682. "Reply to a message to report that user."
  683. )
  684. reply = message.reply_to_message
  685. reply_id = reply.from_user.id if reply.from_user else reply.sender_chat.id
  686. user_id = message.from_user.id if message.from_user else message.sender_chat.id
  687. if reply_id == user_id:
  688. return await message.reply_text("Why are you reporting yourself ?")
  689. list_of_admins = await list_admins(message.chat.id)
  690. linked_chat = (await app.get_chat(message.chat.id)).linked_chat
  691. if linked_chat is not None:
  692. if reply_id in list_of_admins or reply_id == message.chat.id or reply_id == linked_chat.id:
  693. return await message.reply_text(
  694. "Do you know that the user you are replying is an admin ?"
  695. )
  696. else:
  697. if reply_id in list_of_admins or reply_id == message.chat.id:
  698. return await message.reply_text(
  699. "Do you know that the user you are replying is an admin ?"
  700. )
  701. user_mention = reply.from_user.mention if reply.from_user else reply.sender_chat.title
  702. text = f"Reported {user_mention} to admins!"
  703. admin_data = await app.get_chat_members(
  704. chat_id=message.chat.id, filter="administrators"
  705. ) # will it giv floods ?
  706. for admin in admin_data:
  707. if admin.user.is_bot or admin.user.is_deleted:
  708. # return bots or deleted admins
  709. continue
  710. text += f"[\u2063](tg://user?id={admin.user.id})"
  711. await message.reply_to_message.reply_text(text)
  712. @app.on_message(filters.command("invite") & ~filters.edited)
  713. @adminsOnly("can_invite_users")
  714. async def invite(_, message):
  715. if message.chat.type in ["group", "supergroup"]:
  716. link = (await app.get_chat(message.chat.id)).invite_link
  717. if not link:
  718. link = await app.export_chat_invite_link(message.chat.id)
  719. text = f"Here's This Group Invite Link.\n\n{link}"
  720. if message.reply_to_message:
  721. await message.reply_to_message.reply_text(text, disable_web_page_preview=True)
  722. else:
  723. await message.reply_text(text, disable_web_page_preview=True)