admin.py 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850
  1. """
  2. MIT License
  3. Copyright (c) present 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 time import time
  23. from pyrogram.errors import FloodWait
  24. from pyrogram import filters, enums
  25. from pyrogram.types import (
  26. CallbackQuery,
  27. ChatMemberUpdated,
  28. ChatPermissions,
  29. Message,
  30. ChatPrivileges,
  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. /admincache - Reload admin list"""
  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)).privileges
  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_video_chats:
  96. perms.append("can_manage_video_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.get_chat_members(
  111. chat_id, filter=enums.ChatMembersFilter.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.get_chat_members(
  125. cmu.chat.id, filter=enums.ChatMembersFilter.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(
  132. filters.command("purge")
  133. & ~filters.private
  134. )
  135. @adminsOnly("can_delete_messages")
  136. async def purgeFunc(_, message: Message):
  137. repliedmsg = message.reply_to_message
  138. await message.delete()
  139. if not repliedmsg:
  140. return await message.reply_text("Reply to a message to purge from.")
  141. cmd = message.command
  142. if len(cmd) > 1 and cmd[1].isdigit():
  143. purge_to = repliedmsg.message_id + int(cmd[1])
  144. if purge_to > message.message_id:
  145. purge_to = message.message_id
  146. else:
  147. purge_to = message.message_id
  148. chat_id = message.chat.id
  149. message_ids = []
  150. for message_id in range(
  151. repliedmsg.message_id,
  152. purge_to,
  153. ):
  154. message_ids.append(message_id)
  155. # Max message deletion limit is 100
  156. if len(message_ids) == 100:
  157. await app.delete_messages(
  158. chat_id=chat_id,
  159. message_ids=message_ids,
  160. revoke=True, # For both sides
  161. )
  162. # To delete more than 100 messages, start again
  163. message_ids = []
  164. # Delete if any messages left
  165. if len(message_ids) > 0:
  166. await app.delete_messages(
  167. chat_id=chat_id,
  168. message_ids=message_ids,
  169. revoke=True,
  170. )
  171. # Kick members
  172. @app.on_message(
  173. filters.command(["kick", "dkick"])
  174. & ~filters.private
  175. )
  176. @adminsOnly("can_restrict_members")
  177. async def kickFunc(_, message: Message):
  178. user_id, reason = await extract_user_and_reason(message)
  179. if not user_id:
  180. return await message.reply_text("I can't find that user.")
  181. if user_id == BOT_ID:
  182. return await message.reply_text(
  183. "I can't kick myself, i can leave if you want."
  184. )
  185. if user_id in SUDOERS:
  186. return await message.reply_text("You Wanna Kick The Elevated One?")
  187. if user_id in (await list_admins(message.chat.id)):
  188. return await message.reply_text(
  189. "I can't kick an admin, You know the rules, so do i."
  190. )
  191. mention = (await app.get_users(user_id)).mention
  192. msg = f"""
  193. **Kicked User:** {mention}
  194. **Kicked By:** {message.from_user.mention if message.from_user else 'Anon'}
  195. **Reason:** {reason or 'No Reason Provided.'}"""
  196. if message.command[0][0] == "d":
  197. await message.reply_to_message.delete()
  198. await message.chat.ban_member(user_id)
  199. await message.reply_text(msg)
  200. await asyncio.sleep(1)
  201. await message.chat.unban_member(user_id)
  202. # Ban members
  203. @app.on_message(
  204. filters.command(["ban", "dban", "tban"])
  205. & ~filters.private
  206. )
  207. @adminsOnly("can_restrict_members")
  208. async def banFunc(_, message: Message):
  209. user_id, reason = await extract_user_and_reason(message, sender_chat=True)
  210. if not user_id:
  211. return await message.reply_text("I can't find that user.")
  212. if user_id == BOT_ID:
  213. return await message.reply_text(
  214. "I can't ban myself, i can leave if you want."
  215. )
  216. if user_id in SUDOERS:
  217. return await message.reply_text(
  218. "You Wanna Ban The Elevated One?, RECONSIDER!"
  219. )
  220. if user_id in (await list_admins(message.chat.id)):
  221. return await message.reply_text(
  222. "I can't ban an admin, You know the rules, so do i."
  223. )
  224. try:
  225. mention = (await app.get_users(user_id)).mention
  226. except IndexError:
  227. mention = (
  228. message.reply_to_message.sender_chat.title
  229. if message.reply_to_message
  230. else "Anon"
  231. )
  232. msg = (
  233. f"**Banned User:** {mention}\n"
  234. f"**Banned By:** {message.from_user.mention if message.from_user else 'Anon'}\n"
  235. )
  236. if message.command[0][0] == "d":
  237. await message.reply_to_message.delete()
  238. if message.command[0] == "tban":
  239. split = reason.split(None, 1)
  240. time_value = split[0]
  241. temp_reason = split[1] if len(split) > 1 else ""
  242. temp_ban = await time_converter(message, time_value)
  243. msg += f"**Banned For:** {time_value}\n"
  244. if temp_reason:
  245. msg += f"**Reason:** {temp_reason}"
  246. try:
  247. if len(time_value[:-1]) < 3:
  248. await message.chat.ban_member(user_id, until_date=temp_ban)
  249. await message.reply_text(msg)
  250. else:
  251. await message.reply_text("You can't use more than 99")
  252. except AttributeError:
  253. pass
  254. return
  255. if reason:
  256. msg += f"**Reason:** {reason}"
  257. await message.chat.ban_member(user_id)
  258. await message.reply_text(msg)
  259. # Unban members
  260. @app.on_message(
  261. filters.command("unban")
  262. & ~filters.private
  263. )
  264. @adminsOnly("can_restrict_members")
  265. async def unban_func(_, message: Message):
  266. # we don't need reasons for unban, also, we
  267. # don't need to get "text_mention" entity, because
  268. # normal users won't get text_mention if the user
  269. # they want to unban is not in the group.
  270. reply = message.reply_to_message
  271. if reply and reply.sender_chat and reply.sender_chat != message.chat.id:
  272. return await message.reply_text("You cannot unban a channel")
  273. if len(message.command) == 2:
  274. user = message.text.split(None, 1)[1]
  275. elif len(message.command) == 1 and reply:
  276. user = message.reply_to_message.from_user.id
  277. else:
  278. return await message.reply_text(
  279. "Provide a username or reply to a user's message to unban."
  280. )
  281. await message.chat.unban_member(user)
  282. umention = (await app.get_users(user)).mention
  283. await message.reply_text(f"Unbanned! {umention}")
  284. # Ban users listed in a message
  285. @app.on_message(
  286. SUDOERS
  287. & filters.command("listban")
  288. & ~filters.private
  289. )
  290. async def list_ban_(c, message: Message):
  291. userid, msglink_reason = await extract_user_and_reason(message)
  292. if not userid or not msglink_reason:
  293. return await message.reply_text(
  294. "Provide a userid/username along with message link and reason to list-ban"
  295. )
  296. if (
  297. len(msglink_reason.split(" ")) == 1
  298. ): # message link included with the reason
  299. return await message.reply_text(
  300. "You must provide a reason to list-ban"
  301. )
  302. # seperate messge link from reason
  303. lreason = msglink_reason.split()
  304. messagelink, reason = lreason[0], " ".join(lreason[1:])
  305. if not re.search(
  306. r"(https?://)?t(elegram)?\.me/\w+/\d+", messagelink
  307. ): # validate link
  308. return await message.reply_text("Invalid message link provided")
  309. if userid == BOT_ID:
  310. return await message.reply_text("I can't ban myself.")
  311. if userid in SUDOERS:
  312. return await message.reply_text(
  313. "You Wanna Ban The Elevated One?, RECONSIDER!"
  314. )
  315. splitted = messagelink.split("/")
  316. uname, mid = splitted[-2], int(splitted[-1])
  317. m = await message.reply_text(
  318. "`Banning User from multiple groups. \
  319. This may take some time`"
  320. )
  321. try:
  322. msgtext = (await app.get_messages(uname, mid)).text
  323. gusernames = re.findall("@\w+", msgtext)
  324. except:
  325. return await m.edit_text("Could not get group usernames")
  326. count = 0
  327. for username in gusernames:
  328. try:
  329. await app.ban_chat_member(username.strip("@"), userid)
  330. await asyncio.sleep(1)
  331. except FloodWait as e:
  332. await asyncio.sleep(e.value)
  333. except:
  334. continue
  335. count += 1
  336. mention = (await app.get_users(userid)).mention
  337. msg = f"""
  338. **List-Banned User:** {mention}
  339. **Banned User ID:** `{userid}`
  340. **Admin:** {message.from_user.mention}
  341. **Affected chats:** `{count}`
  342. **Reason:** {reason}
  343. """
  344. await m.edit_text(msg)
  345. # Unban users listed in a message
  346. @app.on_message(
  347. SUDOERS
  348. & filters.command("listunban")
  349. & ~filters.private
  350. )
  351. async def list_unban_(c, message: Message):
  352. userid, msglink = await extract_user_and_reason(message)
  353. if not userid or not msglink:
  354. return await message.reply_text(
  355. "Provide a userid/username along with message link to list-unban"
  356. )
  357. if not re.search(
  358. r"(https?://)?t(elegram)?\.me/\w+/\d+", msglink
  359. ): # validate link
  360. return await message.reply_text("Invalid message link provided")
  361. splitted = msglink.split("/")
  362. uname, mid = splitted[-2], int(splitted[-1])
  363. m = await message.reply_text(
  364. "`Unbanning User from multiple groups. \
  365. This may take some time`"
  366. )
  367. try:
  368. msgtext = (await app.get_messages(uname, mid)).text
  369. gusernames = re.findall("@\w+", msgtext)
  370. except:
  371. return await m.edit_text("Could not get the group usernames")
  372. count = 0
  373. for username in gusernames:
  374. try:
  375. await app.unban_chat_member(username.strip("@"), userid)
  376. await asyncio.sleep(1)
  377. except FloodWait as e:
  378. await asyncio.sleep(e.value)
  379. except:
  380. continue
  381. count += 1
  382. mention = (await app.get_users(userid)).mention
  383. msg = f"""
  384. **List-Unbanned User:** {mention}
  385. **Unbanned User ID:** `{userid}`
  386. **Admin:** {message.from_user.mention}
  387. **Affected chats:** `{count}`
  388. """
  389. await m.edit_text(msg)
  390. # Delete messages
  391. @app.on_message(
  392. filters.command("del")
  393. & ~filters.private
  394. )
  395. @adminsOnly("can_delete_messages")
  396. async def deleteFunc(_, message: Message):
  397. if not message.reply_to_message:
  398. return await message.reply_text("Reply To A Message To Delete It")
  399. await message.reply_to_message.delete()
  400. await message.delete()
  401. # Promote Members
  402. @app.on_message(
  403. filters.command(["promote", "fullpromote"])
  404. & ~filters.private
  405. )
  406. @adminsOnly("can_promote_members")
  407. async def promoteFunc(_, message: Message):
  408. user_id = await extract_user(message)
  409. umention = (await app.get_users(user_id)).mention
  410. if not user_id:
  411. return await message.reply_text("I can't find that user.")
  412. bot = (await app.get_chat_member(message.chat.id, BOT_ID)).privileges
  413. if user_id == BOT_ID:
  414. return await message.reply_text("I can't promote myself.")
  415. if not bot.can_promote_members:
  416. return await message.reply_text("I don't have enough permissions")
  417. if message.command[0][0] == "f":
  418. await message.chat.promote_member(
  419. user_id=user_id,
  420. can_change_info=bot.can_change_info,
  421. can_invite_users=bot.can_invite_users,
  422. can_delete_messages=bot.can_delete_messages,
  423. can_restrict_members=bot.can_restrict_members,
  424. can_pin_messages=bot.can_pin_messages,
  425. can_promote_members=bot.can_promote_members,
  426. can_manage_chat=bot.can_manage_chat,
  427. can_manage_video_chats=bot.can_manage_video_chats,
  428. )
  429. return await message.reply_text(f"Fully Promoted! {umention}")
  430. await message.chat.promote_member(
  431. user_id,
  432. ChatPrivileges(
  433. can_change_info=False,
  434. can_restrict_members=False,
  435. can_pin_messages=False,
  436. can_promote_members=False,
  437. can_invite_users=True,
  438. can_delete_messages=True,
  439. can_manage_chat=True,
  440. can_manage_video_chats=True,
  441. ),
  442. )
  443. await message.reply_text(f"Promoted! {umention}")
  444. # Demote Member
  445. @app.on_message(
  446. filters.command("demote")
  447. & ~filters.private
  448. )
  449. @adminsOnly("can_promote_members")
  450. async def demote(_, message: Message):
  451. user_id = await extract_user(message)
  452. if not user_id:
  453. return await message.reply_text("I can't find that user.")
  454. if user_id == BOT_ID:
  455. return await message.reply_text("I can't demote myself.")
  456. if user_id in SUDOERS:
  457. return await message.reply_text(
  458. "You wanna demote the elevated one?, RECONSIDER!"
  459. )
  460. await message.chat.promote_member(
  461. user_id=user_id,
  462. privileges=ChatPrivileges(
  463. can_change_info=False,
  464. can_invite_users=False,
  465. can_delete_messages=False,
  466. can_restrict_members=False,
  467. can_pin_messages=False,
  468. can_promote_members=False,
  469. can_manage_chat=False,
  470. can_manage_video_chats=False,
  471. ),
  472. )
  473. umention = (await app.get_users(user_id)).mention
  474. await message.reply_text(f"Demoted! {umention}")
  475. # Pin Messages
  476. @app.on_message(
  477. filters.command(["pin", "unpin"])
  478. & ~filters.private
  479. )
  480. @adminsOnly("can_pin_messages")
  481. async def pin(_, message: Message):
  482. if not message.reply_to_message:
  483. return await message.reply_text("Reply to a message to pin/unpin it.")
  484. r = message.reply_to_message
  485. if message.command[0][0] == "u":
  486. await r.unpin()
  487. return await message.reply_text(
  488. f"**Unpinned [this]({r.link}) message.**",
  489. disable_web_page_preview=True,
  490. )
  491. await r.pin(disable_notification=True)
  492. await message.reply(
  493. f"**Pinned [this]({r.link}) message.**",
  494. disable_web_page_preview=True,
  495. )
  496. msg = "Please check the pinned message: ~ " + f"[Check, {r.link}]"
  497. filter_ = dict(type="text", data=msg)
  498. await save_filter(message.chat.id, "~pinned", filter_)
  499. # Mute members
  500. @app.on_message(
  501. filters.command(["mute", "tmute"])
  502. & ~filters.private
  503. )
  504. @adminsOnly("can_restrict_members")
  505. async def mute(_, message: Message):
  506. user_id, reason = await extract_user_and_reason(message)
  507. if not user_id:
  508. return await message.reply_text("I can't find that user.")
  509. if user_id == BOT_ID:
  510. return await message.reply_text("I can't mute myself.")
  511. if user_id in SUDOERS:
  512. return await message.reply_text(
  513. "You wanna mute the elevated one?, RECONSIDER!"
  514. )
  515. if user_id in (await list_admins(message.chat.id)):
  516. return await message.reply_text(
  517. "I can't mute an admin, You know the rules, so do i."
  518. )
  519. mention = (await app.get_users(user_id)).mention
  520. keyboard = ikb({"🚨 Unmute 🚨": f"unmute_{user_id}"})
  521. msg = (
  522. f"**Muted User:** {mention}\n"
  523. f"**Muted By:** {message.from_user.mention if message.from_user else 'Anon'}\n"
  524. )
  525. if message.command[0] == "tmute":
  526. split = reason.split(None, 1)
  527. time_value = split[0]
  528. temp_reason = split[1] if len(split) > 1 else ""
  529. temp_mute = await time_converter(message, time_value)
  530. msg += f"**Muted For:** {time_value}\n"
  531. if temp_reason:
  532. msg += f"**Reason:** {temp_reason}"
  533. try:
  534. if len(time_value[:-1]) < 3:
  535. await message.chat.restrict_member(
  536. user_id,
  537. permissions=ChatPermissions(),
  538. until_date=temp_mute,
  539. )
  540. await message.reply_text(msg, reply_markup=keyboard)
  541. else:
  542. await message.reply_text("You can't use more than 99")
  543. except AttributeError:
  544. pass
  545. return
  546. if reason:
  547. msg += f"**Reason:** {reason}"
  548. await message.chat.restrict_member(user_id, permissions=ChatPermissions())
  549. await message.reply_text(msg, reply_markup=keyboard)
  550. # Unmute members
  551. @app.on_message(
  552. filters.command("unmute")
  553. & ~filters.private
  554. )
  555. @adminsOnly("can_restrict_members")
  556. async def unmute(_, message: Message):
  557. user_id = await extract_user(message)
  558. if not user_id:
  559. return await message.reply_text("I can't find that user.")
  560. await message.chat.unban_member(user_id)
  561. umention = (await app.get_users(user_id)).mention
  562. await message.reply_text(f"Unmuted! {umention}")
  563. # Ban deleted accounts
  564. @app.on_message(
  565. filters.command("ban_ghosts")
  566. & ~filters.private
  567. )
  568. @adminsOnly("can_restrict_members")
  569. async def ban_deleted_accounts(_, message: Message):
  570. chat_id = message.chat.id
  571. deleted_users = []
  572. banned_users = 0
  573. m = await message.reply("Finding ghosts...")
  574. async for i in app.get_chat_members(chat_id):
  575. if i.user.is_deleted:
  576. deleted_users.append(i.user.id)
  577. if len(deleted_users) > 0:
  578. for deleted_user in deleted_users:
  579. try:
  580. await message.chat.ban_member(deleted_user)
  581. except Exception:
  582. pass
  583. banned_users += 1
  584. await m.edit(f"Banned {banned_users} Deleted Accounts")
  585. else:
  586. await m.edit("There are no deleted accounts in this chat")
  587. @app.on_message(
  588. filters.command(["warn", "dwarn"])
  589. & ~filters.private
  590. )
  591. @adminsOnly("can_restrict_members")
  592. async def warn_user(_, message: Message):
  593. user_id, reason = await extract_user_and_reason(message)
  594. chat_id = message.chat.id
  595. if not user_id:
  596. return await message.reply_text("I can't find that user.")
  597. if user_id == BOT_ID:
  598. return await message.reply_text(
  599. "I can't warn myself, i can leave if you want."
  600. )
  601. if user_id in SUDOERS:
  602. return await message.reply_text(
  603. "You Wanna Warn The Elevated One?, RECONSIDER!"
  604. )
  605. if user_id in (await list_admins(chat_id)):
  606. return await message.reply_text(
  607. "I can't warn an admin, You know the rules, so do i."
  608. )
  609. user, warns = await asyncio.gather(
  610. app.get_users(user_id),
  611. get_warn(chat_id, await int_to_alpha(user_id)),
  612. )
  613. mention = user.mention
  614. keyboard = ikb({"🚨 Remove Warn 🚨": f"unwarn_{user_id}"})
  615. if warns:
  616. warns = warns["warns"]
  617. else:
  618. warns = 0
  619. if message.command[0][0] == "d":
  620. await message.reply_to_message.delete()
  621. if warns >= 2:
  622. await message.chat.ban_member(user_id)
  623. await message.reply_text(
  624. f"Number of warns of {mention} exceeded, BANNED!"
  625. )
  626. await remove_warns(chat_id, await int_to_alpha(user_id))
  627. else:
  628. warn = {"warns": warns + 1}
  629. msg = f"""
  630. **Warned User:** {mention}
  631. **Warned By:** {message.from_user.mention if message.from_user else 'Anon'}
  632. **Reason:** {reason or 'No Reason Provided.'}
  633. **Warns:** {warns + 1}/3"""
  634. await message.reply_text(msg, reply_markup=keyboard)
  635. await add_warn(chat_id, await int_to_alpha(user_id), warn)
  636. @app.on_callback_query(filters.regex("unwarn_"))
  637. async def remove_warning(_, cq: CallbackQuery):
  638. from_user = cq.from_user
  639. chat_id = cq.message.chat.id
  640. permissions = await member_permissions(chat_id, from_user.id)
  641. permission = "can_restrict_members"
  642. if permission not in permissions:
  643. return await cq.answer(
  644. "You don't have enough permissions to perform this action.\n"
  645. + f"Permission needed: {permission}",
  646. show_alert=True,
  647. )
  648. user_id = cq.data.split("_")[1]
  649. warns = await get_warn(chat_id, await int_to_alpha(user_id))
  650. if warns:
  651. warns = warns["warns"]
  652. if not warns or warns == 0:
  653. return await cq.answer("User has no warnings.")
  654. warn = {"warns": warns - 1}
  655. await add_warn(chat_id, await int_to_alpha(user_id), warn)
  656. text = cq.message.text.markdown
  657. text = f"~~{text}~~\n\n"
  658. text += f"__Warn removed by {from_user.mention}__"
  659. await cq.message.edit(text)
  660. # Rmwarns
  661. @app.on_message(
  662. filters.command("rmwarns")
  663. & ~filters.private
  664. )
  665. @adminsOnly("can_restrict_members")
  666. async def remove_warnings(_, message: Message):
  667. if not message.reply_to_message:
  668. return await message.reply_text(
  669. "Reply to a message to remove a user's warnings."
  670. )
  671. user_id = message.reply_to_message.from_user.id
  672. mention = message.reply_to_message.from_user.mention
  673. chat_id = message.chat.id
  674. warns = await get_warn(chat_id, await int_to_alpha(user_id))
  675. if warns:
  676. warns = warns["warns"]
  677. if warns == 0 or not warns:
  678. await message.reply_text(f"{mention} have no warnings.")
  679. else:
  680. await remove_warns(chat_id, await int_to_alpha(user_id))
  681. await message.reply_text(f"Removed warnings of {mention}.")
  682. # Warns
  683. @app.on_message(
  684. filters.command("warns")
  685. & ~filters.private
  686. )
  687. @capture_err
  688. async def check_warns(_, message: Message):
  689. user_id = await extract_user(message)
  690. if not user_id:
  691. return await message.reply_text("I can't find that user.")
  692. warns = await get_warn(message.chat.id, await int_to_alpha(user_id))
  693. mention = (await app.get_users(user_id)).mention
  694. if warns:
  695. warns = warns["warns"]
  696. else:
  697. return await message.reply_text(f"{mention} has no warnings.")
  698. return await message.reply_text(f"{mention} has {warns}/3 warnings.")
  699. # Report
  700. @app.on_message(
  701. (
  702. filters.command("report")
  703. | filters.command(["admins", "admin"], prefixes="@")
  704. )
  705. & ~filters.private
  706. )
  707. @capture_err
  708. async def report_user(_, message):
  709. if not message.reply_to_message:
  710. return await message.reply_text(
  711. "Reply to a message to report that user."
  712. )
  713. reply = message.reply_to_message
  714. reply_id = reply.from_user.id if reply.from_user else reply.sender_chat.id
  715. user_id = message.from_user.id if message.from_user else message.sender_chat.id
  716. if reply_id == user_id:
  717. return await message.reply_text("Why are you reporting yourself ?")
  718. list_of_admins = await list_admins(message.chat.id)
  719. linked_chat = (await app.get_chat(message.chat.id)).linked_chat
  720. if linked_chat is not None:
  721. if reply_id in list_of_admins or reply_id == message.chat.id or reply_id == linked_chat.id:
  722. return await message.reply_text(
  723. "Do you know that the user you are replying is an admin ?"
  724. )
  725. else:
  726. if reply_id in list_of_admins or reply_id == message.chat.id:
  727. return await message.reply_text(
  728. "Do you know that the user you are replying is an admin ?"
  729. )
  730. user_mention = reply.from_user.mention if reply.from_user else reply.sender_chat.title
  731. text = f"Reported {user_mention} to admins!"
  732. admin_data = await app.get_chat_members(
  733. chat_id=message.chat.id, filter=enums.ChatMembersFilter.ADMINISTRATORS
  734. ) # will it giv floods ?
  735. for admin in admin_data:
  736. if admin.user.is_bot or admin.user.is_deleted:
  737. # return bots or deleted admins
  738. continue
  739. text += f"[\u2063](tg://user?id={admin.user.id})"
  740. await message.reply_to_message.reply_text(text)