Create leaveallmute.py

Akeno/plugins/leaveallmute.py

@@ -0,0 +1,83 @@
+from asyncio import *
+import asyncio
+from pyrogram import Client, filters
+from pyrogram.types import *
+from pyrogram.enums import ChatMemberStatus, ChatType
+from pyrogram.errors import UserNotParticipant, UserIsBlocked, UserAlreadyParticipant
+from pyrogram.errors import MessageNotModified
+from Akeno.utils.handler import *
+from config import *
+
+custom_boost = "<emoji id=5812442283206775108>🗿</emoji>"
+
+@Akeno(
+    ~filters.scheduled
+    & filters.command(["leaveallmute"], CMD_HANDLER)
+    & filters.me
+    & ~filters.forwarded
+)
+async def leaveallmute(client: Client, message: Message):
+    leave = 0
+    failed = 0
+    u = ""
+    try:
+        pro = await message.reply_text("Wait prossing.....")
+        async for dialog in client.get_dialogs():
+            chat_id = dialog.chat.id if dialog.chat else 0
+            chat_title = dialog.chat.title if dialog.chat else ""
+            if dialog.chat.type in [ChatType.SUPERGROUP, ChatType.GROUP]:
+                try:
+                    member = await client.get_chat_member(chat_id, "me")
+                    if member.status == ChatMemberStatus.RESTRICTED:
+                        await client.leave_chat(chat_id)
+                        leave += 1
+                        u += f"Chat ID: `{chat_id}` | Chat Title: {chat_title}\n"
+                except (UserNotParticipant, UserAlreadyParticipant):
+                    continue
+                except Exception as e:
+                    u += str(e) + "\n"
+                    failed += 1
+        if client.me.is_premium:
+            await pro.edit_text(f"{custom_boost}Successfully leave {leave} from group")
+        else:
+            await pro.edit_text(f"Successfully leave {leave} from group")
+    except MessageNotModified:
+        pass
+    except Exception as e:
+        await pro.edit_text(str(e))
+
+@Akeno(
+    ~filters.scheduled
+    & filters.command(["listmuted"], CMD_HANDLER)
+    & filters.me
+    & ~filters.forwarded
+)
+async def listmuted(client: Client, message: Message):
+    leave = 0
+    failed = 0
+    u = "Nothing found\n"
+    try:
+        pro = await message.reply_text("Wait prossing.....")
+        async for dialog in client.get_dialogs():
+            chat_id = dialog.chat.id if dialog.chat else 0
+            chat_title = dialog.chat.title if dialog.chat else ""
+            if dialog.chat.type in [ChatType.SUPERGROUP, ChatType.GROUP]:
+                try:
+                    member = await client.get_chat_member(chat_id, "me")
+                    if member.status == ChatMemberStatus.RESTRICTED:
+                        leave += 1
+                        u += f"{leave}: {chat_title} | {chat_id}\n"
+                except (UserNotParticipant, UserAlreadyParticipant):
+                    continue
+                except Exception as e:
+                    u += str(e) + "\n"
+                    failed += 1
+        formatting = (
+            f"{u}\n"
+            f"Failed: {failed}\n"
+        )
+        await pro.edit_text(formatting)
+    except MessageNotModified:
+        pass
+    except Exception as e:
+        await pro.edit_text(str(e))