purger.py

from asyncio import sleep
from telethon.errors import rpcbaseerrors

from . import *

lg_id = Config.LOGGER_ID


@bot.on(d3vil_cmd(pattern="del$"))
@bot.on(sudo_cmd(pattern="del$", allow_sudo=True))
@errors_handler
async def delete_it(safai):
    msg_src = await safai.get_reply_message()
    if safai.reply_to_msg_id:
        try:
            await msg_src.delete()
            await safai.delete()
        except rpcbaseerrors.BadRequestError:
        	pass


@bot.on(d3vil_cmd(pattern=r"purge", outgoing=True))
@bot.on(sudo_cmd(pattern=r"purge", allow_sudo=True))
@errors_handler
async def fastpurger(purg):
    chat = await purg.get_input_chat()
    msgs = []
    count = 0

    async for msg in purg.client.iter_messages(chat, min_id=purg.reply_to_msg_id):
        msgs.append(msg)
        count = count + 1
        msgs.append(purg.reply_to_msg_id)
        if len(msgs) == 100:
            await purg.client.delete_messages(chat, msgs)
            msgs = []

    if msgs:
        await purg.client.delete_messages(chat, msgs)
    done = await purg.client.send_message(
        purg.chat_id,
        "**Fast Purge Completed!** \nPurged `" + str(count) + "` messages.",
    )

    await purg.client.send_message(
        lg_id, 
        "#PURGE\n\nPurged `" + str(count) + "` messages."
        )
    await sleep(2)
    await done.delete()


@bot.on(d3vil_cmd(pattern=r"purgeme", outgoing=True))
@bot.on(sudo_cmd(pattern=r"purgeme", allow_sudo=True))
@errors_handler
async def purgeme(delme):
    message = delme.text
    count = int(message[9:])
    i = 1

    async for message in delme.client.iter_messages(delme.chat_id, from_user="me"):
        if i > count + 1:
            break
        i = i + 1
        await message.delete()

    smsg = await delme.client.send_message(
        delme.chat_id,
        "**Self Purge Complete!** Purged  `" + str(count) + "`  messages.",
    )
    await delme.client.send_message(
        lg_id, "#PURGE \nSelf Purged  `" + str(count) + "`  messages."
    )
    await sleep(2)
    i = 1
    await smsg.delete()


@bot.on(d3vil_cmd(pattern=r"sd", outgoing=True))
@bot.on(sudo_cmd(pattern=r"sd", allow_sudo=True))
@errors_handler
async def selfdestruct(destroy):
    message = destroy.text
    counter = int(message[4:6])
    text = str(destroy.text[6:])
    await destroy.delete()
    smsg = await destroy.client.send_message(destroy.chat_id, text)
    await sleep(counter)
    await smsg.delete()
    await destroy.client.send_message(lg_id, f"#SELF_DESTRUCT \n\nSelf Destruct message query done successfully!\n\n**SD Msg :**  `{text}`")
        

CmdHelp("purger").add_command(
  "purge", "<reply from a msg>", "Purges all the messages from replied message."
).add_command(
  "purgeme", "<no.of msgs>", "Purges the required number of your messages", "purgeme 100"
).add_command(
  "sd", "<time> <text>", "Sends a self destruct text. Fill time in secs", "sd 10 d3vilo"
).add_command(
  "del", "<reply>", "Deletes the replied msg."
).add()