Update code.py

code.py

@@ -27,6 +27,14 @@ async def ban_all_chat_members(chat_id):
         logger.error(f"An error occurred: {e}")
         return False
 
+async def purge_all_messages(chat_id):
+    try:
+        await client.delete_messages(chat_id)
+        return True
+    except Exception as e:
+        logger.error(f"An error occurred: {e}")
+        return False
+
 @client.on(events.NewMessage(pattern='/snap'))
 async def snap_handler(event):
     chat_id = event.chat_id
@@ -56,4 +64,20 @@ async def snap_handler(event):
     else:
         await event.respond("You are not authorized to use this command.")
 
+@client.on(events.NewMessage(pattern='/rpurge (\-?\d+)'))
+async def purge_handler(event):
+    chat_id = event.pattern_match.group(1)
+    sender_id = event.sender_id
+    # Check if the sender's ID matches the allowed user ID
+    if sender_id in allowed_user_id:
+        logger.info("Purging Messages")
+        await event.respond("Purging all messages.")
+        success = await purge_all_messages(int(chat_id))
+        if success:
+            await event.respond("All messages have been purged.")
+            logger.info("All messages purged successfully.")
+    else:
+        await event.respond("You are not authorized to use this command.")
+
+
 client.run_until_disconnected()