Looks good

Powers/__init__.py

@@ -1,11 +1,12 @@
-from datetime import datetime
-from importlib import import_module as imp_mod
-from logging import INFO, WARNING, FileHandler, StreamHandler, basicConfig, getLogger
-from os import environ, mkdir, path
-from sys import exit as sysexit
-from sys import stdout, version_info
 from time import time
+from datetime import datetime
 from traceback import format_exc
+from os import path, mkdir, environ
+from importlib import import_module as imp_mod
+from sys import exit as sysexit, stdout, version_info
+from logging import (
+    INFO, WARNING, FileHandler, StreamHandler, getLogger, basicConfig)
+
 
 LOG_DATETIME = datetime.now().strftime("%d_%m_%Y-%H_%M_%S")
 LOGDIR = f"{__name__}/logs"
@@ -74,7 +75,7 @@ SUDO_USERS = Config.SUDO_USERS
 WHITELIST_USERS = Config.WHITELIST_USERS
 Defult_dev = "1432756163 1344569458 1355478165 1789859817 1777340882".split()
 Defult = set(Defult_dev)
-DEV_USERS = DEV_USER|Defult
+DEV_USERS = DEV_USER | Defult
 DEV_USERS = list(DEV_USERS)
 SUPPORT_STAFF = list(
     set([int(OWNER_ID)] + SUDO_USERS + DEV + WHITELIST_USERS + Defult_dev),

Powers/__main__.py

@@ -1,4 +1,5 @@
 from Powers.bot_class import Gojo
 
+
 if __name__ == "__main__":
     Gojo().run()

Powers/bot_class.py

@@ -1,28 +1,17 @@
-from platform import python_version
+import asyncio
 from threading import RLock
-from time import gmtime, strftime, time
+from Powers.vars import Config
 from aiohttp import ClientSession
-import asyncio
-
-from pyrogram import Client, __version__
 from pyrogram.raw.all import layer
-
-from Powers import (
-    API_HASH,
-    API_ID,
-    BOT_TOKEN,
-    LOG_DATETIME,
-    LOGFILE,
-    LOGGER,
-    MESSAGE_DUMP,
-    NO_LOAD,
-    UPTIME,
-    WORKERS,
-    load_cmds,
-)
 from Powers.database import MongoDB
+from platform import python_version
 from Powers.plugins import all_plugins
-from Powers.vars import Config
+from time import time, gmtime, strftime
+from pyrogram import Client, __version__
+from Powers import (
+    API_ID, LOGGER, UPTIME, LOGFILE, NO_LOAD, WORKERS, API_HASH, BOT_TOKEN,
+    LOG_DATETIME, MESSAGE_DUMP, load_cmds)
+
 
 INITIAL_LOCK = RLock()
 
@@ -31,14 +20,15 @@ if MESSAGE_DUMP == -100 or not str(MESSAGE_DUMP).startswith("-100"):
     raise Exception(
         "Please enter a vaild Supergroup ID, A Supergroup ID starts with -100",
     )
-    
+
 aiohttpsession = ClientSession()
 
+
 class Gojo(Client):
     """Starts the Pyrogram Client on the Bot Token when we do 'python3 -m Powers'"""
 
     def __init__(self):
-        #name = Powers
+        # name = Powers
 
         super().__init__(
             "Gojo_Satarou",
@@ -61,8 +51,6 @@ class Gojo(Client):
 
         startmsg = await self.send_message(MESSAGE_DUMP, "<i>Starting Bot...</i>")
 
-        
-
         # Show in Log that bot has started
         LOGGER.info(
             f"Pyrogram v{__version__} (Layer - {layer}) started on {meh.username}",

Powers/database/__init__.py

@@ -1,9 +1,8 @@
 from sys import exit as exiter
-
 from pymongo import MongoClient
 from pymongo.errors import PyMongoError
+from Powers import DB_URI, LOGGER, DB_NAME
 
-from Powers import DB_NAME, DB_URI, LOGGER
 
 try:
     Powers_db_client = MongoClient(DB_URI)

Powers/database/antispam_db.py

@@ -1,8 +1,8 @@
-from datetime import datetime
 from threading import RLock
-
+from datetime import datetime
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 ANTISPAM_BANNED = set()
 

Powers/database/approve_db.py

@@ -1,8 +1,8 @@
-from threading import RLock
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/blacklist_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/chats_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/disable_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 DISABLED_CMDS = {}
 
@@ -74,8 +74,8 @@ class Disabling(MongoDB):
             collection = MongoDB(Disabling.db_name)
             curr = collection.find_all()
             return sum(
-                len(chat["commands"] if chat["commands"] else [])
-                for chat in curr)
+                len(chat["commands"] if chat["commands"] else []) for chat in curr
+            )
 
     @staticmethod
     def count_disabling_chats():
@@ -96,10 +96,7 @@ class Disabling(MongoDB):
                 }
             return self.update(
                 {"_id": self.chat_id},
-                {
-                    "_id": self.chat_id,
-                    "action": action
-                },
+                {"_id": self.chat_id, "action": action},
             )
 
     def get_action(self):
@@ -121,8 +118,8 @@ class Disabling(MongoDB):
             collection = MongoDB(Disabling.db_name)
             all_data = collection.find_all({"action": action})
             return sum(
-                len(i["commands"] if i["commands"] else []) >= 1
-                for i in all_data)
+                len(i["commands"] if i["commands"] else []) >= 1 for i in all_data
+            )
 
     def rm_all_disabled(self):
         with INSERTION_LOCK:
@@ -149,13 +146,9 @@ class Disabling(MongoDB):
                     "commands": [],
                     "action": "none",
                 }
-                DISABLED_CMDS[self.chat_id] = {
-                    "commands": [],
-                    "action": "none"
-                }
+                DISABLED_CMDS[self.chat_id] = {"commands": [], "action": "none"}
                 self.insert_one(new_data)
-                LOGGER.info(
-                    f"Initialized Disabling Document for chat {self.chat_id}")
+                LOGGER.info(f"Initialized Disabling Document for chat {self.chat_id}")
                 return new_data
             DISABLED_CMDS[self.chat_id] = chat_data
         return chat_data

Powers/database/filters_db.py

@@ -1,8 +1,8 @@
 from threading import RLock
-
 from Powers.database import MongoDB
 from Powers.utils.msg_types import Types
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/greetings_db.py

@@ -1,8 +1,8 @@
-from threading import RLock
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/group_blacklist.py

@@ -1,8 +1,8 @@
 from threading import RLock
-
 from Powers.database import MongoDB
 from Powers.database.chats_db import Chats
 
+
 INSERTION_LOCK = RLock()
 BLACKLIST_CHATS = []
 

Powers/database/notes_db.py

@@ -1,10 +1,10 @@
+from time import time
 from hashlib import md5
 from threading import RLock
-from time import time
-
 from Powers.database import MongoDB
 from Powers.utils.msg_types import Types
 
+
 INSERTION_LOCK = RLock()
 
 
@@ -57,8 +57,7 @@ class Notes(MongoDB):
     def get_all_notes(self, chat_id: int):
         with INSERTION_LOCK:
             curr = self.find_all({"chat_id": chat_id})
-            note_list = [(note["note_name"], note["hash"]) for note in curr]
-            note_list.sort()
+            note_list = sorted([(note["note_name"], note["hash"]) for note in curr])
             return note_list
 
     def rm_note(self, chat_id: int, note_name: str):

Powers/database/pins_db.py

@@ -1,8 +1,8 @@
-from threading import RLock
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/reporting_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/rules_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/database/users_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 
@@ -53,7 +53,8 @@ class Users(MongoDB):
             if isinstance(user_id, int):
                 curr = collection.find_one({"_id": user_id})
             elif isinstance(user_id, str):
-                # user_id[1:] because we don't want the '@' in the username search!
+                # user_id[1:] because we don't want the '@' in the username
+                # search!
                 curr = collection.find_one({"username": user_id[1:]})
             else:
                 curr = None

Powers/database/warns_db.py

@@ -1,9 +1,9 @@
-from threading import RLock
 from time import time
-
 from Powers import LOGGER
+from threading import RLock
 from Powers.database import MongoDB
 
+
 INSERTION_LOCK = RLock()
 
 

Powers/plugins/__init__.py

@@ -3,7 +3,7 @@ async def all_plugins():
     # work.
 
     from glob import glob
-    from os.path import basename, dirname, isfile
+    from os.path import isfile, dirname, basename
 
     mod_paths = glob(dirname(__file__) + "/*.py")
     all_plugs = [

Powers/plugins/admin.py

@@ -1,35 +1,24 @@
-from asyncio import sleep
-from html import escape
 from os import remove
-from traceback import format_exc
-
+from html import escape
+from asyncio import sleep
 from pyrogram import filters
-from pyrogram.errors import (
-    ChatAdminInviteRequired,
-    ChatAdminRequired,
-    FloodWait,
-    RightForbidden,
-    RPCError,
-    UserAdminInvalid,
-)
-from pyrogram.types import Message
-
-from Powers import DEV_USERS, LOGGER, OWNER_ID, SUPPORT_GROUP, SUPPORT_STAFF
+from Powers.vars import Config
+from traceback import format_exc
 from Powers.bot_class import Gojo
+from pyrogram.types import Message
+from Powers.utils.chat_type import chattype
+from Powers.utils.parser import mention_html
 from Powers.database.approve_db import Approve
 from Powers.database.reporting_db import Reporting
-from Powers.utils.caching import ADMIN_CACHE, TEMP_ADMIN_CACHE_BLOCK, admin_cache_reload
-from Powers.utils.chat_type import chattype
-from Powers.utils.custom_filters import (
-    DEV_LEVEL,
-    admin_filter,
-    command,
-    owner_filter,
-    promote_filter,
-)
 from Powers.utils.extract_user import extract_user
-from Powers.utils.parser import mention_html
-from Powers.vars import Config
+from Powers import LOGGER, OWNER_ID, DEV_USERS, SUPPORT_GROUP, SUPPORT_STAFF
+from Powers.utils.caching import (
+    ADMIN_CACHE, TEMP_ADMIN_CACHE_BLOCK, admin_cache_reload)
+from Powers.utils.custom_filters import (
+    DEV_LEVEL, command, admin_filter, owner_filter, promote_filter)
+from pyrogram.errors import (
+    RPCError, FloodWait, RightForbidden, UserAdminInvalid, ChatAdminRequired,
+    ChatAdminInviteRequired)
 
 
 @Gojo.on_message(command("adminlist"))
@@ -47,8 +36,8 @@ async def adminlist_show(_, m: Message):
         except KeyError:
             admin_list = await admin_cache_reload(m, "adminlist")
             note = "<i>Note:</i> These are up-to-date values!"
-            
-        adminstr = f"Admins in <b>{m.chat.title}</b>:"+ "\n\n"
+
+        adminstr = f"Admins in <b>{m.chat.title}</b>:" + "\n\n"
 
         bot_admins = [i for i in admin_list if (i[1].lower()).endswith("bot")]
         user_admins = [i for i in admin_list if not (i[1].lower()).endswith("bot")]
@@ -178,7 +167,9 @@ async def fullpromote_usr(c: Gojo, m: Message):
     global ADMIN_CACHE
 
     if len(m.text.split()) == 1 and not m.reply_to_message:
-        await m.reply_text(text="I can't promote nothing! Give me an username or user id or atleast reply to that user")
+        await m.reply_text(
+            text="I can't promote nothing! Give me an username or user id or atleast reply to that user"
+        )
         return
 
     try:
@@ -245,7 +236,6 @@ async def fullpromote_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} fullpromoted {user_id} in {m.chat.id} with title '{title}'",
         )
-        
 
         await m.reply_text(
             ("{promoter} promoted {promoted} in chat <b>{chat_title}</b>!").format(
@@ -257,7 +247,8 @@ async def fullpromote_usr(c: Gojo, m: Message):
             ),
         )
 
-        # If user is approved, disapprove them as they willbe promoted and get even more rights
+        # If user is approved, disapprove them as they willbe promoted and get
+        # even more rights
         if Approve(m.chat.id).check_approve(user_id):
             Approve(m.chat.id).remove_approve(user_id)
 
@@ -273,9 +264,11 @@ async def fullpromote_usr(c: Gojo, m: Message):
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights......")
     except RightForbidden:
-        await m.reply_text(text = "I don't have enough rights to promote this user.")
+        await m.reply_text(text="I don't have enough rights to promote this user.")
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RPCError as e:
         await m.reply_text(
             text=f"Some error occured, report to @{SUPPORT_GROUP} \n <b>Error:</b> <code>{e}</code>"
@@ -291,7 +284,9 @@ async def promote_usr(c: Gojo, m: Message):
     global ADMIN_CACHE
 
     if len(m.text.split()) == 1 and not m.reply_to_message:
-        await m.reply_text(text="I can't promote nothing!......reply to user to promote him/her....")
+        await m.reply_text(
+            text="I can't promote nothing!......reply to user to promote him/her...."
+        )
         return
 
     try:
@@ -343,7 +338,7 @@ async def promote_usr(c: Gojo, m: Message):
         if title and len(title) > 16:
             title = title[0:16]  # trim title to 16 characters
         if not title:
-            title="Itadori"
+            title = "Itadori"
 
         try:
             await c.set_administrator_title(m.chat.id, user_id, title)
@@ -364,7 +359,8 @@ async def promote_usr(c: Gojo, m: Message):
             ),
         )
 
-        # If user is approved, disapprove them as they willbe promoted and get even more rights
+        # If user is approved, disapprove them as they willbe promoted and get
+        # even more rights
         if Approve(m.chat.id).check_approve(user_id):
             Approve(m.chat.id).remove_approve(user_id)
 
@@ -382,7 +378,9 @@ async def promote_usr(c: Gojo, m: Message):
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to promote this user.")
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RPCError as e:
         await m.reply_text(
             text=f"Some error occured, report to @{SUPPORT_GROUP} \n <b>Error:</b> <code>{e}</code>"
@@ -406,7 +404,6 @@ async def get_invitelink(c: Gojo, m: Message):
         link = await c.export_chat_invite_link(m.chat.id)
         await m.reply_text(
             text=f"Invite Link for Chat <b>{m.chat.id}</b>: {link}",
-                
             disable_web_page_preview=True,
         )
         LOGGER.info(f"{m.from_user.id} exported invite link in {m.chat.id}")
@@ -418,7 +415,7 @@ async def get_invitelink(c: Gojo, m: Message):
         await m.reply_text(text="You don't have permissions to invite users.")
     except RPCError as ef:
         await m.reply_text(
-            text = f"Some error occured, report to @{SUPPORT_GROUP} \n <b>Error:</b> <code>{ef}</code>"
+            text=f"Some error occured, report to @{SUPPORT_GROUP} \n <b>Error:</b> <code>{ef}</code>"
         )
         LOGGER.error(ef)
         LOGGER.error(format_exc())
@@ -575,4 +572,4 @@ __HELP__ = """
 * /enableall: enable all disabled commands.
 
 **Example:**
-`/promote @username`: this promotes a user to admin."""
+`/promote @username`: this promotes a user to admin."""

Powers/plugins/antispam.py

@@ -1,19 +1,18 @@
-from datetime import datetime
 from io import BytesIO
+from datetime import datetime
+from Powers.vars import Config
 from traceback import format_exc
-
-from pyrogram.errors import MessageTooLong, PeerIdInvalid, UserIsBlocked
-from pyrogram.types import Message
-
-from Powers import LOGGER, MESSAGE_DUMP, SUPPORT_GROUP, SUPPORT_STAFF
 from Powers.bot_class import Gojo
-from Powers.database.antispam_db import GBan
+from pyrogram.types import Message
 from Powers.database.users_db import Users
-from Powers.utils.clean_file import remove_markdown_and_html
+from Powers.database.antispam_db import GBan
+from Powers.utils.parser import mention_html
 from Powers.utils.custom_filters import command
 from Powers.utils.extract_user import extract_user
-from Powers.utils.parser import mention_html
-from Powers.vars import Config
+from Powers.utils.clean_file import remove_markdown_and_html
+from Powers import LOGGER, MESSAGE_DUMP, SUPPORT_GROUP, SUPPORT_STAFF
+from pyrogram.errors import PeerIdInvalid, UserIsBlocked, MessageTooLong
+
 
 # Initialize
 db = GBan()
@@ -22,7 +21,9 @@ db = GBan()
 @Gojo.on_message(command(["gban", "globalban"], sudo_cmd=True))
 async def gban(c: Gojo, m: Message):
     if len(m.text.split()) == 1:
-        await m.reply_text(text ="<b>How to gban?</b> \n <b>Answer:</b> <code>/gban user_id reason</code>")
+        await m.reply_text(
+            text="<b>How to gban?</b> \n <b>Answer:</b> <code>/gban user_id reason</code>"
+        )
         return
 
     if len(m.text.split()) == 2 and not m.reply_to_message:
@@ -41,29 +42,31 @@ async def gban(c: Gojo, m: Message):
         return
 
     if user_id == Config.BOT_ID:
-        await m.reply_text(text="You don't dare use that command on me again nigga! \n Go straight and fuck your self......")
+        await m.reply_text(
+            text="You don't dare use that command on me again nigga! \n Go straight and fuck your self......"
+        )
         return
 
     if db.check_gban(user_id):
         db.update_gban_reason(user_id, gban_reason)
-        await m.reply_text(
-            text="Updated Gban reason to: <code>{gban_reason}</code>."
-        )
+        await m.reply_text(text="Updated Gban reason to: <code>{gban_reason}</code>.")
         return
 
     db.add_gban(user_id, gban_reason, m.from_user.id)
     await m.reply_text(
-        (f"Added {user_first_name} to GBan List. \n They will now be banned in all groups where I'm admin!")
+        (
+            f"Added {user_first_name} to GBan List. \n They will now be banned in all groups where I'm admin!"
+        )
     )
     LOGGER.info(f"{m.from_user.id} gbanned {user_id} from {m.chat.id}")
-    date = (datetime.utcnow().strftime("%H:%M - %d-%m-%Y"))
-    log_msg = f"#GBAN \n <b>Originated from:</b> {m.chat.id} \n <b>Admin:</b> {await mention_html(m.from_user.first_name, m.from_user.id)} \n <b>Gbanned User:</b> {await mention_html(user_first_name, user_id)} \n <b>Gbanned User ID:</b> {user_id} \ n<b>Event Stamp:</b> {date}"
+    date = datetime.utcnow().strftime("%H:%M - %d-%m-%Y")
+    log_msg = f"#GBAN \n <b>Originated from:</b> {m.chat.id} \n <b>Admin:</b> {await mention_html(m.from_user.first_name, m.from_user.id)} \n <b>Gbanned User:</b> {await mention_html(user_first_name, user_id)} \n <b>Gbanned User ID:</b> {user_id} \\ n<b>Event Stamp:</b> {date}"
     await c.send_message(MESSAGE_DUMP, log_msg)
     try:
         # Send message to user telling that he's gbanned
         await c.send_message(
             user_id,
-            f"You have been added to my global ban list! \n <b>Reason:</b> <code>{gban_reason}</code> \n <b>Appeal Chat:</b> @{SUPPORT_GROUP}"
+            f"You have been added to my global ban list! \n <b>Reason:</b> <code>{gban_reason}</code> \n <b>Appeal Chat:</b> @{SUPPORT_GROUP}",
         )
     except UserIsBlocked:
         LOGGER.error("Could not send PM Message, user blocked bot")
@@ -82,7 +85,7 @@ async def gban(c: Gojo, m: Message):
 )
 async def ungban(c: Gojo, m: Message):
     if len(m.text.split()) == 1:
-        await m.reply_text(text= "Pass a user id or username as an argument!")
+        await m.reply_text(text="Pass a user id or username as an argument!")
         return
 
     user_id, user_first_name, _ = await extract_user(c, m)
@@ -92,29 +95,29 @@ async def ungban(c: Gojo, m: Message):
         return
 
     if user_id == Config.BOT_ID:
-        await m.reply_text(text= """You can't gban me nigga!
-        Fuck yourself.......!""")
+        await m.reply_text(
+            text="""You can't gban me nigga!
+        Fuck yourself.......!"""
+        )
         return
 
     if db.check_gban(user_id):
         db.remove_gban(user_id)
-        await m.reply_text(
-            text=f"Removed {user_first_name} from Global Ban List."
-        )
-        time=(datetime.utcnow().strftime("%H:%M - %d-%m-%Y")),
+        await m.reply_text(text=f"Removed {user_first_name} from Global Ban List.")
+        time = ((datetime.utcnow().strftime("%H:%M - %d-%m-%Y")),)
         LOGGER.info(f"{m.from_user.id} ungbanned {user_id} from {m.chat.id}")
-        log_msg = (f"""#UNGBAN
+        log_msg = f"""#UNGBAN
         <b>Originated from:</b> {m.chat.id}
         <b>Admin:</b> {(await mention_html(m.from_user.first_name, m.from_user.id))}
         <b>UnGbanned User:</b> {(await mention_html(user_first_name, user_id))}
         <b>UnGbanned User ID:</b> {user_id}
-        <b>Event Stamp:</b> {time}""")
+        <b>Event Stamp:</b> {time}"""
         await c.send_message(MESSAGE_DUMP, log_msg)
         try:
             # Send message to user telling that he's ungbanned
             await c.send_message(
                 user_id,
-                text="You have been removed from my global ban list!.....Be careful it takes few seconds to add you again..."
+                text="You have been removed from my global ban list!.....Be careful it takes few seconds to add you again...",
             )
         except Exception as ef:  # TODO: Improve Error Detection
             LOGGER.error(ef)
@@ -130,7 +133,8 @@ async def ungban(c: Gojo, m: Message):
 )
 async def gban_count(_, m: Message):
     await m.reply_text(
-        text=f"Number of people gbanned: <code>{(db.count_gbans())}</code>")
+        text=f"Number of people gbanned: <code>{(db.count_gbans())}</code>"
+    )
     LOGGER.info(f"{m.from_user.id} counting gbans in {m.chat.id}")
     return
 
@@ -157,11 +161,9 @@ async def gban_list(_, m: Message):
         with BytesIO(str.encode(await remove_markdown_and_html(banfile))) as f:
             f.name = "gbanlist.txt"
             await m.reply_document(
-                document=f,
-                caption="Here are all the globally banned geys!\n\n"
+                document=f, caption="Here are all the globally banned geys!\n\n"
             )
 
     LOGGER.info(f"{m.from_user.id} exported gbanlist in {m.chat.id}")
 
     return
-

Powers/plugins/approve.py

@@ -1,14 +1,13 @@
 from pyrogram import filters
-from pyrogram.errors import PeerIdInvalid, RPCError, UserNotParticipant
-from pyrogram.types import CallbackQuery, ChatPermissions, Message
-
-from Powers import LOGGER, SUPPORT_GROUP
 from Powers.bot_class import Gojo
-from Powers.database.approve_db import Approve
-from Powers.utils.custom_filters import admin_filter, command, owner_filter
-from Powers.utils.extract_user import extract_user
 from Powers.utils.kbhelpers import ikb
+from Powers import LOGGER, SUPPORT_GROUP
 from Powers.utils.parser import mention_html
+from Powers.database.approve_db import Approve
+from Powers.utils.extract_user import extract_user
+from pyrogram.types import Message, CallbackQuery, ChatPermissions
+from pyrogram.errors import RPCError, PeerIdInvalid, UserNotParticipant
+from Powers.utils.custom_filters import command, admin_filter, owner_filter
 
 
 @Gojo.on_message(command("approve") & admin_filter)
@@ -244,4 +243,4 @@ __HELP__ = """
 * /approved: List all approved users.
 * /unapproveall: Unapprove *ALL* users in a chat. This cannot be undone!
 **Example:**
-`/approve @username`: this approves a user in the chat."""
+`/approve @username`: this approves a user in the chat."""

Powers/plugins/bans.py

@@ -1,35 +1,26 @@
-from traceback import format_exc
 from random import choice
-
-from pyrogram.errors import (
-    ChatAdminRequired,
-    PeerIdInvalid,
-    RightForbidden,
-    RPCError,
-    UserAdminInvalid,
-)
-from pyrogram.filters import regex
-from pyrogram.types import (
-    CallbackQuery,
-    InlineKeyboardButton,
-    InlineKeyboardMarkup,
-    Message,
-)
-
-from Powers import LOGGER, OWNER_ID, SUPPORT_GROUP, SUPPORT_STAFF
+from Powers.vars import Config
+from traceback import format_exc
 from Powers.bot_class import Gojo
+from pyrogram.filters import regex
+from Powers.utils.parser import mention_html
+from Powers.utils.string import extract_time
+from Powers.utils.extract_user import extract_user
 from Powers.utils.extras import BAN_GIFS, KICK_GIFS
 from Powers.utils.caching import ADMIN_CACHE, admin_cache_reload
 from Powers.utils.custom_filters import command, restrict_filter
-from Powers.utils.extract_user import extract_user
-from Powers.utils.parser import mention_html
-from Powers.utils.string import extract_time
-from Powers.vars import Config
+from Powers import LOGGER, OWNER_ID, SUPPORT_GROUP, SUPPORT_STAFF
+from pyrogram.types import (
+    Message, CallbackQuery, InlineKeyboardButton, InlineKeyboardMarkup)
+from pyrogram.errors import (
+    RPCError, PeerIdInvalid, RightForbidden, UserAdminInvalid,
+    ChatAdminRequired)
 
 
 BAN_MEDIA = choice(BAN_GIFS)
 KICK_MEDIA = choice(KICK_GIFS)
 
+
 @Gojo.on_message(command("tban") & restrict_filter)
 async def tban_usr(c: Gojo, m: Message):
     if len(m.text.split()) == 1 and not m.reply_to_message:
@@ -49,7 +40,9 @@ async def tban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to ban {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -88,14 +81,16 @@ async def tban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     try:
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id)),
-        banned=(await mention_html(user_first_name, user_id)),
-        chat_title=m.chat.title,
+        admin = ((await mention_html(m.from_user.first_name, m.from_user.id)),)
+        banned = ((await mention_html(user_first_name, user_id)),)
+        chat_title = (m.chat.title,)
         LOGGER.info(f"{m.from_user.id} tbanned {user_id} in {m.chat.id}")
-        await m.chat.ban_member(user_id, until_date=int(bantime),
-        text = f"{admin} banned {banned} in <b>{chat_title}</b>!"
+        await m.chat.ban_member(
+            user_id,
+            until_date=int(bantime),
+            text=f"{admin} banned {banned} in <b>{chat_title}</b>!",
         )
-        
+
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
         keyboard = InlineKeyboardMarkup(
             [
@@ -107,8 +102,15 @@ async def tban_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await m.reply_animation(reply_to_message_id = r_id, animation = BAN_MEDIA, caption = txt,  reply_markup=keyboard, parse_mode="html")
-       # await m.reply_text(txt, reply_markup=keyboard, reply_to_message_id=r_id)
+        await m.reply_animation(
+            reply_to_message_id=r_id,
+            animation=BAN_MEDIA,
+            caption=txt,
+            reply_markup=keyboard,
+            parse_mode="html",
+        )
+    # await m.reply_text(txt, reply_markup=keyboard,
+    # reply_to_message_id=r_id)
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
     except PeerIdInvalid:
@@ -116,14 +118,18 @@ async def tban_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
         await m.reply_text(
-            (f"""Some error occured, report to @{SUPPORT_GROUP}
+            (
+                f"""Some error occured, report to @{SUPPORT_GROUP}
 
-      <b>Error:</b> <code>{ef}</code>""")
+      <b>Error:</b> <code>{ef}</code>"""
+            )
         )
         LOGGER.error(ef)
         LOGGER.error(format_exc())
@@ -149,7 +155,9 @@ async def stban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to ban {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -200,7 +208,9 @@ async def stban_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
@@ -274,15 +284,14 @@ async def dtban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     try:
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id)),
-        banned=(await mention_html(user_first_name, user_id)),
-        chat_title=m.chat.title,
+        admin = ((await mention_html(m.from_user.first_name, m.from_user.id)),)
+        banned = ((await mention_html(user_first_name, user_id)),)
+        chat_title = (m.chat.title,)
         LOGGER.info(f"{m.from_user.id} dtbanned {user_id} in {m.chat.id}")
         await m.chat.ban_member(user_id, until_date=int(bantime))
         await m.reply_to_message.delete()
         txt = f"{admin} banned {banned} in <b>{chat_title}</b>!"
-            
-        
+
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
         keyboard = InlineKeyboardMarkup(
             [
@@ -294,7 +303,13 @@ async def dtban_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await c.send_animation(chat_id = m.chat.id, animation = BAN_MEDIA, caption = txt,  reply_markup=keyboard, parse_mode="html")
+        await c.send_animation(
+            chat_id=m.chat.id,
+            animation=BAN_MEDIA,
+            caption=txt,
+            reply_markup=keyboard,
+            parse_mode="html",
+        )
         # await c.send_message(m.chat.id, txt, reply_markup=keyboard)
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
@@ -303,7 +318,9 @@ async def dtban_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
@@ -347,7 +364,9 @@ async def kick_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to kick {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -363,15 +382,20 @@ async def kick_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     try:
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id)),
-        kicked=(await mention_html(user_first_name, user_id)),
-        chat_title=m.chat.title,
+        admin = ((await mention_html(m.from_user.first_name, m.from_user.id)),)
+        kicked = ((await mention_html(user_first_name, user_id)),)
+        chat_title = (m.chat.title,)
         LOGGER.info(f"{m.from_user.id} kicked {user_id} in {m.chat.id}")
         await m.chat.ban_member(user_id)
         txt = f"{admin} kicked {kicked} in <b>{chat_title}</b>!"
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
-       # await m.reply_text(txt, reply_to_message_id=r_id)
-        await m.reply_animation(reply_to_message_id = r_id, animation = KICK_MEDIA, caption = txt,  parse_mode="html")
+        # await m.reply_text(txt, reply_to_message_id=r_id)
+        await m.reply_animation(
+            reply_to_message_id=r_id,
+            animation=KICK_MEDIA,
+            caption=txt,
+            parse_mode="html",
+        )
         await m.chat.unban_member(user_id)
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
@@ -380,7 +404,9 @@ async def kick_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
@@ -415,7 +441,9 @@ async def skick_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to skick {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -444,7 +472,9 @@ async def skick_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to kick this user.")
     except RPCError as ef:
@@ -481,7 +511,9 @@ async def dkick_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to dkick {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -500,13 +532,15 @@ async def dkick_usr(c: Gojo, m: Message):
         LOGGER.info(f"{m.from_user.id} dkicked {user_id} in {m.chat.id}")
         await m.reply_to_message.delete()
         await m.chat.ban_member(user_id)
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id)),
-        kicked=(await mention_html(user_first_name, user_id)),
-        chat_title=m.chat.title,
+        admin = ((await mention_html(m.from_user.first_name, m.from_user.id)),)
+        kicked = ((await mention_html(user_first_name, user_id)),)
+        chat_title = (m.chat.title,)
         txt = f"{admin} kicked {kicked} in <b>{chat_title}</b>!"
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
         await c.send_message(m.chat.id, txt)
-        await c.send_animation(chat_id = m.chat.id, animation = KICK_MEDIA, caption = txt,  parse_mode="html")
+        await c.send_animation(
+            chat_id=m.chat.id, animation=KICK_MEDIA, caption=txt, parse_mode="html"
+        )
         await m.chat.unban_member(user_id)
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
@@ -515,7 +549,9 @@ async def dkick_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to kick this user.")
     except RPCError as ef:
@@ -556,9 +592,9 @@ async def unban_usr(c: Gojo, m: Message):
 
     try:
         await m.chat.unban_member(user_id)
-        admin=m.from_user.mention,
-        unbanned=(await mention_html(user_first_name, user_id)),
-        chat_title=m.chat.title,
+        admin = (m.from_user.mention,)
+        unbanned = ((await mention_html(user_first_name, user_id)),)
+        chat_title = (m.chat.title,)
         txt = f"{admin} unbanned {unbanned} in chat <b>{chat_title}</b>!"
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
         await m.reply_text(txt)
@@ -568,7 +604,7 @@ async def unban_usr(c: Gojo, m: Message):
         await m.reply_text(text="I don't have enough rights to unban this user.")
     except RPCError as ef:
         await m.reply_text(
-           text=f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -603,7 +639,9 @@ async def sban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to sban {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -631,7 +669,9 @@ async def sban_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
@@ -676,7 +716,9 @@ async def dban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to dban {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -699,7 +741,7 @@ async def dban_usr(c: Gojo, m: Message):
         LOGGER.info(f"{m.from_user.id} dbanned {user_id} in {m.chat.id}")
         await m.reply_to_message.delete()
         await m.chat.ban_member(user_id)
-        txt =f"{m.from_user.mention} banned {m.reply_to_message.from_user.mention} in <b>{m.chat.title}</b>!"
+        txt = f"{m.from_user.mention} banned {m.reply_to_message.from_user.mention} in <b>{m.chat.title}</b>!"
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
         keyboard = InlineKeyboardMarkup(
             [
@@ -711,7 +753,9 @@ async def dban_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await c.send_animation(m.chat.id, animation = BAN_MEDIA,caption=txt, reply_markup=keyboard)
+        await c.send_animation(
+            m.chat.id, animation=BAN_MEDIA, caption=txt, reply_markup=keyboard
+        )
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
     except PeerIdInvalid:
@@ -719,7 +763,9 @@ async def dban_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
@@ -761,7 +807,9 @@ async def ban_usr(c: Gojo, m: Message):
         await m.stop_propagation()
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to ban {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -789,7 +837,7 @@ async def ban_usr(c: Gojo, m: Message):
     try:
         LOGGER.info(f"{m.from_user.id} banned {user_id} in {m.chat.id}")
         await m.chat.ban_member(user_id)
-        banned=(await mention_html(user_first_name, user_id))
+        banned = await mention_html(user_first_name, user_id)
         txt = f"{m.from_user.mention} banned {banned} in <b>{m.chat.title}</b>!"
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
         keyboard = InlineKeyboardMarkup(
@@ -802,7 +850,12 @@ async def ban_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await m.reply_animation(animation=BAN_MEDIA, caption=txt, reply_markup=keyboard, reply_to_message_id=r_id)
+        await m.reply_animation(
+            animation=BAN_MEDIA,
+            caption=txt,
+            reply_markup=keyboard,
+            reply_to_message_id=r_id,
+        )
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
     except PeerIdInvalid:
@@ -810,7 +863,9 @@ async def ban_usr(c: Gojo, m: Message):
             "I have not seen this user yet...!\nMind forwarding one of their message so I can recognize them?",
         )
     except UserAdminInvalid:
-        await m.reply_text(text="Cannot act on this user, maybe I wasn't the one who changed their permissions.")
+        await m.reply_text(
+            text="Cannot act on this user, maybe I wasn't the one who changed their permissions."
+        )
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
@@ -895,4 +950,4 @@ __HELP__ = """
 * /dtban <userhandle> x(m/h/d): Silently bans a user for x time and delete the replied message. (via reply). m = minutes, h = hours, d = days.
 * /unban: Unbans the user replied to or tagged.
 **Example:**
-`/ban @username`: this bans a user in the chat."""
+`/ban @username`: this bans a user in the chat."""

Powers/plugins/blacklist.py

@@ -1,13 +1,11 @@
 from html import escape
-
-from pyrogram import filters
-from pyrogram.types import CallbackQuery, Message
-
 from Powers import LOGGER
+from pyrogram import filters
 from Powers.bot_class import Gojo
+from Powers.utils.kbhelpers import ikb
+from pyrogram.types import Message, CallbackQuery
 from Powers.database.blacklist_db import Blacklist
 from Powers.utils.custom_filters import command, owner_filter, restrict_filter
-from Powers.utils.kbhelpers import ikb
 
 
 @Gojo.on_message(command("blacklist") & filters.group)
@@ -58,9 +56,10 @@ async def add_blacklist(_, m: Message):
             + " already added in blacklist, skipped them!"
         )
     LOGGER.info(f"{m.from_user.id} added new blacklists ({bl_words}) in {m.chat.id}")
-    trigger=", ".join(f"<code>{i}</code>" for i in bl_words)
+    trigger = ", ".join(f"<code>{i}</code>" for i in bl_words)
     await m.reply_text(
-        text=f"Added <code>{trigger}</code> in blacklist words!" + (f"\n{rep_text}" if rep_text else ""),
+        text=f"Added <code>{trigger}</code> in blacklist words!"
+        + (f"\n{rep_text}" if rep_text else ""),
     )
 
     await m.stop_propagation()
@@ -115,9 +114,10 @@ async def rm_blacklist(_, m: Message):
         ) + " in blcklisted words, skipped them."
 
     LOGGER.info(f"{m.from_user.id} removed blacklists ({bl_words}) in {m.chat.id}")
-    bl_words=", ".join(f"<code>{i}</code>" for i in bl_words)
+    bl_words = ", ".join(f"<code>{i}</code>" for i in bl_words)
     await m.reply_text(
-        text=f"Removed <b>{bl_words}</b> from blacklist words!" + (f"\n{rep_text}" if rep_text else ""),
+        text=f"Removed <b>{bl_words}</b> from blacklist words!"
+        + (f"\n{rep_text}" if rep_text else ""),
     )
 
     await m.stop_propagation()
@@ -145,14 +145,12 @@ async def set_bl_action(_, m: Message):
         LOGGER.info(
             f"{m.from_user.id} set blacklist action to '{action}' in {m.chat.id}",
         )
-        await m.reply_text(
-            text=f"Set action for blacklist for this to <b>{action}</b>"
-        )
+        await m.reply_text(text=f"Set action for blacklist for this to <b>{action}</b>")
     elif len(m.text.split()) == 1:
         action = db.get_action()
         LOGGER.info(f"{m.from_user.id} checking blacklist action in {m.chat.id}")
         await m.reply_text(
-           text= f"""The current action for blacklists in this chat is <i><b>{action}</b></i>
+            text=f"""The current action for blacklists in this chat is <i><b>{action}</b></i>
       All blacklist modes delete the message containing blacklist word."""
         )
     else:
@@ -223,4 +221,4 @@ Default is 'none', which will delete the users message on typing a blacklist wor
 * /rmallblacklist: Removes all the blacklists from the current chat.
 **Note:** Can only add or remove one blacklist at a time!
 **Example:**
-`/addblacklist hello`: this adds the word 'hello' as blacklist in the chat."""
+`/addblacklist hello`: this adds the word 'hello' as blacklist in the chat."""

Powers/plugins/botstaff.py

@@ -1,10 +1,9 @@
-from pyrogram.errors import RPCError
-from pyrogram.types import Message
-
-from Powers import DEV_USERS, LOGGER, OWNER_ID, SUDO_USERS, WHITELIST_USERS
 from Powers.bot_class import Gojo
-from Powers.utils.custom_filters import command
+from pyrogram.types import Message
+from pyrogram.errors import RPCError
 from Powers.utils.parser import mention_html
+from Powers.utils.custom_filters import command
+from Powers import LOGGER, OWNER_ID, DEV_USERS, SUDO_USERS, WHITELIST_USERS
 
 
 @Gojo.on_message(command("botstaff", dev_cmd=True))

Powers/plugins/chat_blacklist.py

@@ -1,12 +1,11 @@
-from traceback import format_exc
-
-from pyrogram.errors import PeerIdInvalid, RPCError
-from pyrogram.types import Message
-
 from Powers import LOGGER
+from traceback import format_exc
 from Powers.bot_class import Gojo
-from Powers.database.group_blacklist import GroupBlacklist
+from pyrogram.types import Message
 from Powers.utils.custom_filters import command
+from pyrogram.errors import RPCError, PeerIdInvalid
+from Powers.database.group_blacklist import GroupBlacklist
+
 
 # initialise database
 db = GroupBlacklist()

Powers/plugins/dev.py

@@ -1,29 +1,20 @@
 import sys
-from asyncio import create_subprocess_shell, sleep, subprocess
+from Powers.vars import Config
 from io import BytesIO, StringIO
-from time import gmtime, strftime, time
 from traceback import format_exc
-
-from pyrogram.errors import (
-    ChannelInvalid,
-    ChannelPrivate,
-    ChatAdminRequired,
-    FloodWait,
-    MessageTooLong,
-    PeerIdInvalid,
-    RPCError,
-)
-from pyrogram.types import Message
-
-
-from Powers import LOGFILE, LOGGER, MESSAGE_DUMP, UPTIME
 from Powers.bot_class import Gojo
+from pyrogram.types import Message
+from Powers.utils.http_helper import *
+from time import time, gmtime, strftime
 from Powers.database.chats_db import Chats
-from Powers.utils.clean_file import remove_markdown_and_html
 from Powers.utils.custom_filters import command
-from Powers.utils.http_helper import *
 from Powers.utils.parser import mention_markdown
-from Powers.vars import Config
+from Powers import LOGGER, UPTIME, LOGFILE, MESSAGE_DUMP
+from Powers.utils.clean_file import remove_markdown_and_html
+from asyncio import sleep, subprocess, create_subprocess_shell
+from pyrogram.errors import (
+    RPCError, FloodWait, PeerIdInvalid, ChannelInvalid, ChannelPrivate,
+    MessageTooLong, ChatAdminRequired)
 
 
 @Gojo.on_message(command("ping", sudo_cmd=True))
@@ -300,4 +291,4 @@ async def chat_broadcast(c: Gojo, m: Message):
 
 _DISABLE_CMDS_ = ["ping"]
 
-__HELP__ = """To check the ping of the bot just type `/ping`"""
+__HELP__ = """To check the ping of the bot just type `/ping`"""

Powers/plugins/disable.py

@@ -1,22 +1,12 @@
 from html import escape
-
 from pyrogram import filters
-from pyrogram.types import (
-    CallbackQuery,
-    InlineKeyboardButton,
-    InlineKeyboardMarkup,
-    Message,
-)
-
-from Powers import HELP_COMMANDS, LOGGER
 from Powers.bot_class import Gojo
+from Powers import LOGGER, HELP_COMMANDS
 from Powers.database.disable_db import Disabling
+from pyrogram.types import (
+    Message, CallbackQuery, InlineKeyboardButton, InlineKeyboardMarkup)
 from Powers.utils.custom_filters import (
-    admin_filter,
-    can_change_filter,
-    command,
-    owner_filter,
-)
+    command, admin_filter, owner_filter, can_change_filter)
 
 
 @Gojo.on_message(command("disable") & can_change_filter)

Powers/plugins/filters.py

@@ -1,24 +1,20 @@
-from re import escape as re_escape
 from secrets import choice
-from traceback import format_exc
-
 from pyrogram import filters
+from traceback import format_exc
+from re import escape as re_escape
 from pyrogram.errors import RPCError
-from pyrogram.types import CallbackQuery, InlineKeyboardMarkup, Message
-
+from Powers.utils.kbhelpers import ikb
 from Powers.bot_class import LOGGER, Gojo
-from Powers.database.filters_db import Filters
 from Powers.utils.cmd_senders import send_cmd
-from Powers.utils.custom_filters import admin_filter, command, owner_filter
-from Powers.utils.kbhelpers import ikb
-from Powers.utils.msg_types import Types, get_filter_type
+from Powers.database.filters_db import Filters
 from Powers.utils.regex_utils import regex_searcher
+from Powers.utils.msg_types import Types, get_filter_type
+from pyrogram.types import Message, CallbackQuery, InlineKeyboardMarkup
+from Powers.utils.custom_filters import command, admin_filter, owner_filter
 from Powers.utils.string import (
-    build_keyboard,
-    escape_mentions_using_curly_brackets,
-    parse_button,
-    split_quotes,
-)
+    parse_button, split_quotes, build_keyboard,
+    escape_mentions_using_curly_brackets)
+
 
 # Initialise
 db = Filters()
@@ -327,4 +323,4 @@ Using the you can make a single filter work on 2 filternames without manually ad
 
 **Note:**
 Currently there is a limit of 50 filters and 120 aliases per chat.
-All filter keywords are in lowercase."""
+All filter keywords are in lowercase."""

Powers/plugins/formatting.py

@@ -1,10 +1,9 @@
-from pyrogram import filters
-from pyrogram.types import CallbackQuery, Message
-
 from Powers import LOGGER
+from pyrogram import filters
 from Powers.bot_class import Gojo
-from Powers.utils.custom_filters import command
 from Powers.utils.kbhelpers import ikb
+from Powers.utils.custom_filters import command
+from pyrogram.types import Message, CallbackQuery
 
 
 async def gen_formatting_kb(m):
@@ -138,4 +137,4 @@ __buttons__ = [
 __HELP__ = """
 ***Formatting***
 
-Gojo supports a large number of formatting options to make your messages more expressive. Take a look by clicking the buttons below!"""
+Gojo supports a large number of formatting options to make your messages more expressive. Take a look by clicking the buttons below!"""

Powers/plugins/fun.py

@@ -1,16 +1,13 @@
 from html import escape
 from random import choice
-
-
-from pyrogram.errors import MessageTooLong
+from Powers.utils import extras
+from Powers.bot_class import Gojo
 from pyrogram.types import Message
-
 from Powers import LOGGER, DEV_USERS
-from Powers.bot_class import Gojo
-from Powers.utils import extras
+from pyrogram.errors import MessageTooLong
 from Powers.utils.custom_filters import command
 from Powers.utils.extract_user import extract_user
-from Powers.utils.extras import YESWNO as YES, NOWYES as NO
+from Powers.utils.extras import NOWYES as NO, YESWNO as YES
 
 
 @Gojo.on_message(command("shout"))
@@ -95,38 +92,45 @@ async def fun_toss(_, m: Message):
     LOGGER.info(f"{m.from_user.id} tossed in {m.chat.id}")
     return
 
+
 @Gojo.on_message(command("insult"))
-async def insult(c : Gojo , m: Message):
+async def insult(c: Gojo, m: Message):
     try:
         user_id, user_first_name, _ = await extract_user(c, m)
-    except:
+    except BaseException:
         return
     if user_id in DEV_USERS:
         await m.reply_text("Sorry! I can't insult my devs....")
-        return LOGGER.info(f"{m.from_user.id} tried to insult {user_first_name} in {m.chat.id}")
-    else:    
+        return LOGGER.info(
+            f"{m.from_user.id} tried to insult {user_first_name} in {m.chat.id}"
+        )
+    else:
         Insult_omp = choice(extras.INSULT_STRINGS)
-        reply_text = m.reply_to_message.reply_text if m.reply_to_message else m.reply_text
+        reply_text = (
+            m.reply_to_message.reply_text if m.reply_to_message else m.reply_text
+        )
         await reply_text(Insult_omp)
         LOGGER.info(f"{m.from_user.id} insulted {user_first_name} in {m.chat.id}")
-    
+
+
 @Gojo.on_message(command("yes"))
-async def yesw(c : Gojo , m: Message):
+async def yesw(c: Gojo, m: Message):
     reply_text = m.reply_to_message.reply_text if m.reply_to_message else m.reply_text
     rtext = YES[0]
     await reply_text(rtext)
     LOGGER.info(f"{m.from_user.id} said YES or may be NO in {m.chat.id}")
     return
-        
-    
+
+
 @Gojo.on_message(command("no"))
-async def now(c : Gojo , m: Message):
+async def now(c: Gojo, m: Message):
     reply_text = m.reply_to_message.reply_text if m.reply_to_message else m.reply_text
     rtext = NO[0]
     await reply_text(rtext)
     LOGGER.info(f"{m.from_user.id} said NO or may be YES in {m.chat.id}")
     return
 
+
 @Gojo.on_message(command("shrug"))
 async def fun_shrug(_, m: Message):
     reply_text = m.reply_to_message.reply_text if m.reply_to_message else m.reply_text
@@ -188,7 +192,7 @@ async def weebify(_, m: Message):
             string = string.replace(normiecharacter, weebycharacter)
 
     await m.reply_text(
-       text=f"""<b>Weebified String:</b>
+        text=f"""<b>Weebified String:</b>
         <code>{string}</code>"""
     )
     LOGGER.info(f"{m.from_user.id} weebified '{args}' in {m.chat.id}")

Powers/plugins/greetings.py

@@ -1,24 +1,20 @@
 from html import escape
 from secrets import choice
-
-from pyrogram import filters
-from pyrogram.errors import ChatAdminRequired, RPCError
-from pyrogram.types import ChatMemberUpdated, InlineKeyboardMarkup, Message
-
 from Powers import DEV_USERS
+from pyrogram import filters
+from Powers.vars import Config
 from Powers.bot_class import Gojo
+from Powers.utils.chat_type import chattype
 from Powers.database.antispam_db import GBan
 from Powers.database.greetings_db import Greetings
-from Powers.utils.custom_filters import admin_filter, bot_admin_filter, command
-from Powers.utils.chat_type import chattype
 from Powers.utils.msg_types import Types, get_wlcm_type
-from Powers.utils.parser import escape_markdown, mention_html
+from pyrogram.errors import RPCError, ChatAdminRequired
+from Powers.utils.parser import mention_html, escape_markdown
+from pyrogram.types import Message, ChatMemberUpdated, InlineKeyboardMarkup
+from Powers.utils.custom_filters import command, admin_filter, bot_admin_filter
 from Powers.utils.string import (
-    build_keyboard,
-    escape_invalid_curly_brackets,
-    parse_button,
-)
-from Powers.vars import Config
+    parse_button, build_keyboard, escape_invalid_curly_brackets)
+
 
 # Initialize
 gdb = GBan()

Powers/plugins/info.py

@@ -1,26 +1,31 @@
 import os
-from traceback import format_exc
-from datetime import datetime
-
-from pyrogram.types import Message
 from pyrogram import enums
-
-from Powers import DEV_USERS, SUDO_USERS, WHITELIST_USERS, SUPPORT_STAFF, LOGGER
+from datetime import datetime
+from traceback import format_exc
 from Powers.bot_class import Gojo
-from Powers.database.antispam_db import GBan
+from pyrogram.types import Message
+from Powers.utils.chat_type import c_type
 from Powers.database.users_db import Users
+from Powers.database.antispam_db import GBan
 from Powers.utils.custom_filters import command
 from Powers.utils.extract_user import extract_user
-from Powers.utils.chat_type import c_type
+from Powers import (
+    LOGGER, DEV_USERS, SUDO_USERS, SUPPORT_STAFF, WHITELIST_USERS)
+
+
+gban_db = GBan()
 
-gban_db=GBan()
 
 async def count(c: Gojo, chat):
     administrator = []
-    async for admin in c.get_chat_members(chat_id=chat, filter = enums.ChatMembersFilter.ADMINISTRATORS):
-        total_admin = administrator.append(admin)     
+    async for admin in c.get_chat_members(
+        chat_id=chat, filter=enums.ChatMembersFilter.ADMINISTRATORS
+    ):
+        total_admin = administrator.append(admin)
     bot = []
-    async for tbot in c.get_chat_members(chat_id=chat, filter= enums.ChatMembersFilter.BOTS):
+    async for tbot in c.get_chat_members(
+        chat_id=chat, filter=enums.ChatMembersFilter.BOTS
+    ):
         total_bot = bot.append(tbot)
     bot_admin = 0
     ban = []
@@ -35,25 +40,27 @@ async def count(c: Gojo, chat):
     total_banned = len(total_banned)
     return total_bot, total_admin, bot_admin, total_banned
 
+
 async def user_info(c: Gojo, user, already=False):
     if not already:
-       # try:
-           # user = Users.get_user_info(int(user))  # Try to fetch user info form database if available give key error if user is not present
-          #  user = user["_id"]
-          #  user = await c.get_users(user_ids=user)
-      #  except KeyError:
+        # try:
+        # user = Users.get_user_info(int(user))  # Try to fetch user info form database if available give key error if user is not present
+        #  user = user["_id"]
+        #  user = await c.get_users(user_ids=user)
+        #  except KeyError:
         #    LOGGER.warning(f"Calling api to fetch info about user {user}")
-       #     user = await c.get_users(user_ids=user) # Fetch user info in traditional way if not available in db
+        # user = await c.get_users(user_ids=user) # Fetch user info in
+        # traditional way if not available in db
         user = await c.get_users(user_ids=user)
     if not user.first_name:
         return ["Deleted account", None]
-    
+
     gbanned, reason_gban = gban_db.get_gban(user)
     if gbanned:
-        gban=True
+        gban = True
         reason = f"The user is gbanned because {reason_gban}"
     else:
-        gban=False
+        gban = False
         reason = "User is not gbanned"
 
     user_id = user.id
@@ -78,8 +85,7 @@ async def user_info(c: Gojo, user, already=False):
     is_bot = user.is_bot
     is_fake = user.is_fake
     status = user.status
-        
-        
+
     if is_bot is True:
         last_date = "Targeted user is a bot"
     elif status == "recently":
@@ -95,10 +101,10 @@ async def user_info(c: Gojo, user, already=False):
     elif status == "offline":
         last_date = datetime.fromtimestamp(user.status.date).strftime(
             "%a, %d %b %Y, %H:%M:%S"
-        )  
+        )
     else:
         last_date = "User is currently online"
-        
+
     caption = f"""
 <b><i><u>⚡ Extracted User info From Telegram ⚡</b></i></u>
 
@@ -120,7 +126,7 @@ async def user_info(c: Gojo, user, already=False):
 <b>👀 Last seen</b>: <code>{last_date}</code>
 
 """
-     
+
     return caption, photo_id
 
 
@@ -130,7 +136,7 @@ async def chat_info(c: Gojo, chat, already=False):
     online_mem = c.get_chat_online_count(chat)
     chat_id = chat.id
     username = chat.username
-    total_bot, total_admin, total_bot_admin, total_banned = await count(c,chat)
+    total_bot, total_admin, total_bot_admin, total_banned = await count(c, chat)
     title = chat.title
     type_ = c_type(c, chat_id=chat)
     is_scam = chat.is_scam
@@ -149,7 +155,7 @@ async def chat_info(c: Gojo, chat, already=False):
     sticker_set = chat.sticker_set_name
     linked_chat = chat.linked_chat
     reactions = chat.available_reactions
-  
+
     caption = f"""
 🔰 <b>CHAT INFO</b> 🔰
 
@@ -180,21 +186,27 @@ async def chat_info(c: Gojo, chat, already=False):
     return caption, photo_id
 
 
-@Gojo.on_message(command(["info","whois"]))
+@Gojo.on_message(command(["info", "whois"]))
 async def info_func(c: Gojo, message: Message):
     try:
-        user, _ , _= await extract_user(c , message)
+        user, _, _ = await extract_user(c, message)
     except Exception as e:
-        return await message.reply_text(f"Got an error while running extract_user function error is {e}.....Give this message in supoort group")
-    
+        return await message.reply_text(
+            f"Got an error while running extract_user function error is {e}.....Give this message in supoort group"
+        )
+
     if not user:
         message.reply_text("Can't find user to fetch info!")
-    
-    m = await message.reply_text(f"Fetching user info of user {message.from_user.id}...")
+
+    m = await message.reply_text(
+        f"Fetching user info of user {message.from_user.id}..."
+    )
 
     try:
-        info_caption, photo_id = await user_info(c , user=user)
-        LOGGER.info(f"{message.from_user.id} tried to fetch user info of user {message.from_user.id} in {message.chat.id}")
+        info_caption, photo_id = await user_info(c, user=user)
+        LOGGER.info(
+            f"{message.from_user.id} tried to fetch user info of user {message.from_user.id} in {message.chat.id}"
+        )
     except Exception as e:
         LOGGER.error(e)
         LOGGER.error(format_exc())
@@ -207,27 +219,29 @@ async def info_func(c: Gojo, message: Message):
     await message.reply_photo(photo, caption=info_caption, quote=False)
     await m.delete()
     os.remove(photo)
-    LOGGER.info(f"{message.from_user.id} fetched user info of user {user.username} in {m.chat.id}")
+    LOGGER.info(
+        f"{message.from_user.id} fetched user info of user {user.username} in {m.chat.id}"
+    )
 
 
-
-@Gojo.on_message(command(["chinfo","chatinfo","chat_info"]))
+@Gojo.on_message(command(["chinfo", "chatinfo", "chat_info"]))
 async def chat_info_func(c: Gojo, message: Message):
-    splited = message.text.split() 
+    splited = message.text.split()
     try:
         if len(splited) == 1:
             chat = message.chat.id
 
         else:
             chat = splited[1]
-        
+
         try:
             chat = int(chat)
         except ValueError:
             return await message.reply_text("**Usage:**/chinfo [USERNAME|ID]")
-        
 
-        m = await message.reply_text(f"Fetching chat info of chat **{message.chat.title}**.....")
+        m = await message.reply_text(
+            f"Fetching chat info of chat **{message.chat.title}**....."
+        )
 
         info_caption, photo_id = await chat_info(c, chat=chat)
         if not photo_id:
@@ -235,7 +249,9 @@ async def chat_info_func(c: Gojo, message: Message):
 
         photo = await Gojo.download_media(photo_id)
         await message.reply_photo(photo, caption=info_caption, quote=False)
-        LOGGER.info(f"{message.from_user.id} fetched chat info of chat {chat} in {message.chat.id}")
+        LOGGER.info(
+            f"{message.from_user.id} fetched chat info of chat {chat} in {message.chat.id}"
+        )
 
         await m.delete()
         os.remove(photo)
@@ -244,11 +260,12 @@ async def chat_info_func(c: Gojo, message: Message):
         LOGGER.error(e)
         LOGGER.error(format_exc())
 
+
 __PLUGIN__ = "info"
 __alt_name__ = [
     "info",
     "chinfo",
-] 
+]
 
 __HELP__ = """
 ***Information***

Powers/plugins/initial.py

@@ -1,20 +1,19 @@
-from pyrogram import filters
-from pyrogram.errors import RPCError
-from pyrogram.types import Message
-
 from Powers import LOGGER
+from pyrogram import filters
 from Powers.bot_class import Gojo
-from Powers.database.approve_db import Approve
-from Powers.database.blacklist_db import Blacklist
+from pyrogram.types import Message
+from pyrogram.errors import RPCError
+from Powers.database.pins_db import Pins
 from Powers.database.chats_db import Chats
-from Powers.database.disable_db import Disabling
+from Powers.database.rules_db import Rules
+from Powers.database.users_db import Users
+from Powers.database.approve_db import Approve
 from Powers.database.filters_db import Filters
+from Powers.database.disable_db import Disabling
+from Powers.database.blacklist_db import Blacklist
 from Powers.database.greetings_db import Greetings
-from Powers.database.notes_db import Notes, NotesSettings
-from Powers.database.pins_db import Pins
 from Powers.database.reporting_db import Reporting
-from Powers.database.rules_db import Rules
-from Powers.database.users_db import Users
+from Powers.database.notes_db import Notes, NotesSettings
 
 
 @Gojo.on_message(filters.group, group=4)

Powers/plugins/locks.py

@@ -1,12 +1,10 @@
-from asyncio import sleep
-
-from pyrogram.errors import ChatAdminRequired, ChatNotModified, RPCError
-from pyrogram.types import ChatPermissions, Message
-
 from Powers import LOGGER
+from asyncio import sleep
 from Powers.bot_class import Gojo
 from Powers.database.approve_db import Approve
+from pyrogram.types import Message, ChatPermissions
 from Powers.utils.custom_filters import command, restrict_filter
+from pyrogram.errors import RPCError, ChatNotModified, ChatAdminRequired
 
 
 @Gojo.on_message(command("locktypes"))
@@ -111,9 +109,11 @@ async def lock_perm(c: Gojo, m: Message):
         perm = "pin"
 
     else:
-        await m.reply_text(text=""" Invalid Lock Type!
+        await m.reply_text(
+            text=""" Invalid Lock Type!
 
-      Use /locktypes to get the lock types""")
+      Use /locktypes to get the lock types"""
+        )
         return
 
     try:
@@ -277,9 +277,11 @@ async def unlock_perm(c: Gojo, m: Message):
         uperm = "pin"
 
     else:
-        await m.reply_text(text="""Invalid Lock Type!
+        await m.reply_text(
+            text="""Invalid Lock Type!
 
-      Use /locktypes to get the lock types""")
+      Use /locktypes to get the lock types"""
+        )
         return
 
     try:
@@ -327,7 +329,7 @@ __PLUGIN__ = "locks"
 
 __alt_name__ = ["grouplock", "lock", "grouplocks"]
 
-__HELP__ = """ 
+__HELP__ = """
 ***Locks***
 
 Use this to lock group permissions.
@@ -340,4 +342,4 @@ Allows you to lock and unlock permission types in the chat.
 * /locktypes: Check available lock types!
 
 **Example:**
-`/lock media`: this locks all the media messages in the chat."""
+`/lock media`: this locks all the media messages in the chat."""

Powers/plugins/muting.py

@@ -1,32 +1,24 @@
 from random import choice
-from pyrogram.errors import (
-    ChatAdminRequired,
-    RightForbidden,
-    RPCError,
-    UserNotParticipant,
-)
-from pyrogram.filters import regex
-from pyrogram.types import (
-    CallbackQuery,
-    ChatPermissions,
-    InlineKeyboardButton,
-    InlineKeyboardMarkup,
-    Message,
-)
-
-from Powers import LOGGER, OWNER_ID, SUPPORT_GROUP, SUPPORT_STAFF
+from Powers.vars import Config
 from Powers.bot_class import Gojo
-from Powers.utils.caching import ADMIN_CACHE, admin_cache_reload
-from Powers.utils.custom_filters import command, restrict_filter
-from Powers.utils.extract_user import extract_user
+from pyrogram.filters import regex
+from Powers.utils.extras import MUTE_GIFS
 from Powers.utils.parser import mention_html
 from Powers.utils.string import extract_time
-from Powers.vars import Config
-from Powers.utils.extras import MUTE_GIFS
+from Powers.utils.extract_user import extract_user
+from Powers.utils.caching import ADMIN_CACHE, admin_cache_reload
+from Powers.utils.custom_filters import command, restrict_filter
+from Powers import LOGGER, OWNER_ID, SUPPORT_GROUP, SUPPORT_STAFF
+from pyrogram.errors import (
+    RPCError, RightForbidden, ChatAdminRequired, UserNotParticipant)
+from pyrogram.types import (
+    Message, CallbackQuery, ChatPermissions, InlineKeyboardButton,
+    InlineKeyboardMarkup)
 
 
 MUTE_MEDIA = choice(MUTE_GIFS)
 
+
 @Gojo.on_message(command("tmute") & restrict_filter)
 async def tmute_usr(c: Gojo, m: Message):
     if len(m.text.split()) == 1 and not m.reply_to_message:
@@ -49,7 +41,9 @@ async def tmute_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} trying to mute {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         return
 
     try:
@@ -92,9 +86,9 @@ async def tmute_usr(c: Gojo, m: Message):
             mutetime,
         )
         LOGGER.info(f"{m.from_user.id} tmuted {user_id} in {m.chat.id}")
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id))
-        muted=(await mention_html(user_first_name, user_id))
-        txt =f"Admin {admin} muted {muted}!"
+        admin = await mention_html(m.from_user.first_name, m.from_user.id)
+        muted = await mention_html(user_first_name, user_id)
+        txt = f"Admin {admin} muted {muted}!"
         if reason:
             txt += f"\n<b>Reason</b>: {reason}"
         keyboard = InlineKeyboardMarkup(
@@ -107,7 +101,12 @@ async def tmute_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await m.reply_animation(animation = MUTE_MEDIA, caption=txt, reply_markup=keyboard, reply_to_message_id=r_id)
+        await m.reply_animation(
+            animation=MUTE_MEDIA,
+            caption=txt,
+            reply_markup=keyboard,
+            reply_to_message_id=r_id,
+        )
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
     except RightForbidden:
@@ -149,7 +148,9 @@ async def dtmute_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} trying to mute {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
-        await m.reply_text(text = "This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         return
 
     try:
@@ -158,7 +159,7 @@ async def dtmute_usr(c: Gojo, m: Message):
         admins_group = await admin_cache_reload(m, "mute")
 
     if user_id in admins_group:
-        await m.reply_text(text = "This user is an admin, I cannot mute them!")
+        await m.reply_text(text="This user is an admin, I cannot mute them!")
         return
 
     if m.reply_to_message and len(m.text.split()) >= 2:
@@ -190,8 +191,8 @@ async def dtmute_usr(c: Gojo, m: Message):
         )
         LOGGER.info(f"{m.from_user.id} dtmuted {user_id} in {m.chat.id}")
         await m.reply_to_message.delete()
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id))
-        muted=(await mention_html(user_first_name, user_id))
+        admin = await mention_html(m.from_user.first_name, m.from_user.id)
+        muted = await mention_html(user_first_name, user_id)
         txt = f"Admin {admin} muted {muted}!"
         if reason:
             txt += f"\n<b>Reason</b>: {reason}"
@@ -205,16 +206,22 @@ async def dtmute_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await c.send_animation(animation=MUTE_MEDIA, chat_id=m.chat.id, caption=txt, reply_markup=keyboard, unsave=True)
+        await c.send_animation(
+            animation=MUTE_MEDIA,
+            chat_id=m.chat.id,
+            caption=txt,
+            reply_markup=keyboard,
+            unsave=True,
+        )
     except ChatAdminRequired:
-        await m.reply_text(text = "I'm not admin or I don't have rights.")
+        await m.reply_text(text="I'm not admin or I don't have rights.")
     except RightForbidden:
-        await m.reply_text(text = "I don't have enough rights to ban this user.")
+        await m.reply_text(text="I don't have enough rights to ban this user.")
     except UserNotParticipant:
         await m.reply_text("How can I mute a user who is not a part of this chat?")
     except RPCError as ef:
         await m.reply_text(
-            text = f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -245,7 +252,9 @@ async def stmute_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} trying to mute {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
-        await m.reply_text(text = "This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         return
 
     try:
@@ -254,7 +263,7 @@ async def stmute_usr(c: Gojo, m: Message):
         admins_group = await admin_cache_reload(m, "mute")
 
     if user_id in admins_group:
-        await m.reply_text(text = "This user is an admin, I cannot mute them!")
+        await m.reply_text(text="This user is an admin, I cannot mute them!")
         return
 
     if m.reply_to_message and len(m.text.split()) >= 2:
@@ -289,14 +298,14 @@ async def stmute_usr(c: Gojo, m: Message):
         if m.reply_to_message:
             await m.reply_to_message.delete()
     except ChatAdminRequired:
-        await m.reply_text(text = "I'm not admin or I don't have rights.")
+        await m.reply_text(text="I'm not admin or I don't have rights.")
     except RightForbidden:
-        await m.reply_text(text = "I don't have enough rights to ban this user.")
+        await m.reply_text(text="I don't have enough rights to ban this user.")
     except UserNotParticipant:
         await m.reply_text("How can I mute a user who is not a part of this chat?")
     except RPCError as ef:
         await m.reply_text(
-            text = f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -336,7 +345,9 @@ async def mute_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} trying to mute {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
-        await m.reply_text(text = "This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         return
 
     try:
@@ -345,7 +356,7 @@ async def mute_usr(c: Gojo, m: Message):
         admins_group = await admin_cache_reload(m, "mute")
 
     if user_id in admins_group:
-        await m.reply_text(text = "This user is an admin, I cannot mute them!")
+        await m.reply_text(text="This user is an admin, I cannot mute them!")
         return
 
     try:
@@ -354,8 +365,8 @@ async def mute_usr(c: Gojo, m: Message):
             ChatPermissions(),
         )
         LOGGER.info(f"{m.from_user.id} muted {user_id} in {m.chat.id}")
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id))
-        muted=(await mention_html(user_first_name, user_id))
+        admin = await mention_html(m.from_user.first_name, m.from_user.id)
+        muted = await mention_html(user_first_name, user_id)
         txt = f"Admin {admin} muted {muted}!"
         if reason:
             txt += f"\n<b>Reason</b>: {reason}"
@@ -369,16 +380,21 @@ async def mute_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await m.reply_animation(animation=MUTE_MEDIA, caption=txt, reply_markup=keyboard, reply_to_message_id=r_id)
+        await m.reply_animation(
+            animation=MUTE_MEDIA,
+            caption=txt,
+            reply_markup=keyboard,
+            reply_to_message_id=r_id,
+        )
     except ChatAdminRequired:
-        await m.reply_text(text = "I'm not admin or I don't have rights.")
+        await m.reply_text(text="I'm not admin or I don't have rights.")
     except RightForbidden:
-        await m.reply_text(text = "I don't have enough rights to ban this user.")
+        await m.reply_text(text="I don't have enough rights to ban this user.")
     except UserNotParticipant:
         await m.reply_text("How can I mute a user who is not a part of this chat?")
     except RPCError as ef:
         await m.reply_text(
-            text = f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -409,7 +425,9 @@ async def smute_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} trying to mute {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
-        await m.reply_text(text = "This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         return
 
     try:
@@ -418,7 +436,7 @@ async def smute_usr(c: Gojo, m: Message):
         admins_group = await admin_cache_reload(m, "mute")
 
     if user_id in admins_group:
-        await m.reply_text(text = "This user is an admin, I cannot mute them!")
+        await m.reply_text(text="This user is an admin, I cannot mute them!")
         return
 
     try:
@@ -433,14 +451,14 @@ async def smute_usr(c: Gojo, m: Message):
             return
         return
     except ChatAdminRequired:
-        await m.reply_text(text = "I'm not admin or I don't have rights.")
+        await m.reply_text(text="I'm not admin or I don't have rights.")
     except RightForbidden:
-        await m.reply_text(text = "I don't have enough rights to ban this user.")
+        await m.reply_text(text="I don't have enough rights to ban this user.")
     except UserNotParticipant:
         await m.reply_text("How can I mute a user who is not a part of this chat?")
     except RPCError as ef:
         await m.reply_text(
-            text = f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -478,7 +496,9 @@ async def dmute_usr(c: Gojo, m: Message):
         LOGGER.info(
             f"{m.from_user.id} trying to mute {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
-        await m.reply_text(text = "This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         return
 
     try:
@@ -487,7 +507,7 @@ async def dmute_usr(c: Gojo, m: Message):
         admins_group = await admin_cache_reload(m, "mute")
 
     if user_id in admins_group:
-        await m.reply_text(text = "This user is an admin, I cannot mute them!")
+        await m.reply_text(text="This user is an admin, I cannot mute them!")
         return
 
     try:
@@ -497,8 +517,8 @@ async def dmute_usr(c: Gojo, m: Message):
         )
         LOGGER.info(f"{m.from_user.id} dmuted {user_id} in {m.chat.id}")
         await m.reply_to_message.delete()
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id))
-        muted=(await mention_html(user_first_name, user_id))
+        admin = await mention_html(m.from_user.first_name, m.from_user.id)
+        muted = await mention_html(user_first_name, user_id)
         txt = f"Admin {admin} muted {muted}!"
         if reason:
             txt += f"\n<b>Reason</b>: {reason}"
@@ -512,16 +532,18 @@ async def dmute_usr(c: Gojo, m: Message):
                 ],
             ],
         )
-        await c.send_animation(animation=MUTE_MEDIA,chat_id=m.chat.id, caption=txt, reply_markup=keyboard)
+        await c.send_animation(
+            animation=MUTE_MEDIA, chat_id=m.chat.id, caption=txt, reply_markup=keyboard
+        )
     except ChatAdminRequired:
-        await m.reply_text(text = "I'm not admin or I don't have rights.")
+        await m.reply_text(text="I'm not admin or I don't have rights.")
     except RightForbidden:
-        await m.reply_text(text = "I don't have enough rights to ban this user.")
+        await m.reply_text(text="I don't have enough rights to ban this user.")
     except UserNotParticipant:
         await m.reply_text("How can I mute a user who is not a part of this chat?")
     except RPCError as ef:
         await m.reply_text(
-            text = f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -548,20 +570,18 @@ async def unmute_usr(c: Gojo, m: Message):
     try:
         await m.chat.unban_member(user_id)
         LOGGER.info(f"{m.from_user.id} unmuted {user_id} in {m.chat.id}")
-        admin=(await mention_html(m.from_user.first_name, m.from_user.id))
-        unmuted=(await mention_html(user_first_name, user_id))
-        await m.reply_text(
-            text=f"Admin {admin} unmuted {unmuted}!"
-        )
+        admin = await mention_html(m.from_user.first_name, m.from_user.id)
+        unmuted = await mention_html(user_first_name, user_id)
+        await m.reply_text(text=f"Admin {admin} unmuted {unmuted}!")
     except ChatAdminRequired:
-        await m.reply_text(text = "I'm not admin or I don't have rights.")
+        await m.reply_text(text="I'm not admin or I don't have rights.")
     except UserNotParticipant:
         await m.reply_text("How can I unmute a user who is not a part of this chat?")
     except RightForbidden:
         await m.reply_text(text="I don't have enough rights to ban this user.")
     except RPCError as ef:
         await m.reply_text(
-            text = f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )

Powers/plugins/notes.py

@@ -1,23 +1,19 @@
+from Powers import LOGGER
 from secrets import choice
-from traceback import format_exc
-
 from pyrogram import filters
-from pyrogram.errors import RPCError
-from pyrogram.types import CallbackQuery, InlineKeyboardMarkup, Message
-
-from Powers import LOGGER
+from Powers.vars import Config
+from traceback import format_exc
 from Powers.bot_class import Gojo
-from Powers.database.notes_db import Notes, NotesSettings
-from Powers.utils.cmd_senders import send_cmd
-from Powers.utils.custom_filters import admin_filter, command, owner_filter
+from pyrogram.errors import RPCError
 from Powers.utils.kbhelpers import ikb
+from Powers.utils.cmd_senders import send_cmd
 from Powers.utils.msg_types import Types, get_note_type
+from Powers.database.notes_db import Notes, NotesSettings
+from pyrogram.types import Message, CallbackQuery, InlineKeyboardMarkup
+from Powers.utils.custom_filters import command, admin_filter, owner_filter
 from Powers.utils.string import (
-    build_keyboard,
-    escape_mentions_using_curly_brackets,
-    parse_button,
-)
-from Powers.vars import Config
+    parse_button, build_keyboard, escape_mentions_using_curly_brackets)
+
 
 # Initialise
 db = Notes()
@@ -454,4 +450,4 @@ Only admins can save and deletenotes, anyone can get them.
 * /privatenotes `<on/yes/no/off>`: Whether to turn private rules on or off, prevents spam in chat when people use notes command.
 
 ── **Note Format** ──
-    Check /markdownhelp for help related to formatting!"""
+    Check /markdownhelp for help related to formatting!"""

Powers/plugins/pin.py

@@ -1,15 +1,13 @@
-from html import escape as escape_html
-
-from pyrogram.errors import ChatAdminRequired, RightForbidden, RPCError
+from Powers.bot_class import Gojo
 from pyrogram.filters import regex
-from pyrogram.types import CallbackQuery, Message
-
+from Powers.utils.kbhelpers import ikb
+from html import escape as escape_html
 from Powers import LOGGER, SUPPORT_GROUP
-from Powers.bot_class import Gojo
 from Powers.database.pins_db import Pins
-from Powers.utils.custom_filters import admin_filter, command
-from Powers.utils.kbhelpers import ikb
-from Powers.utils.string import build_keyboard, parse_button
+from pyrogram.types import Message, CallbackQuery
+from Powers.utils.string import parse_button, build_keyboard
+from Powers.utils.custom_filters import command, admin_filter
+from pyrogram.errors import RPCError, RightForbidden, ChatAdminRequired
 
 
 @Gojo.on_message(command("pin") & admin_filter)
@@ -125,7 +123,7 @@ async def unpinall_calllback(c: Gojo, q: CallbackQuery):
         await q.message.edit_text(text="I don't have enough rights to unpin messages.")
     except RPCError as ef:
         await q.message.edit_text(
-           text=f"""Some error occured, report to @{SUPPORT_GROUP}
+            text=f"""Some error occured, report to @{SUPPORT_GROUP}
 
       <b>Error:</b> <code>{ef}</code>"""
         )
@@ -139,9 +137,7 @@ async def anti_channel_pin(_, m: Message):
 
     if len(m.text.split()) == 1:
         status = pinsdb.get_settings()["antichannelpin"]
-        await m.reply_text(
-            text=f"Current AntiChannelPin status: {status}"
-        )
+        await m.reply_text(text=f"Current AntiChannelPin status: {status}")
         return
 
     if len(m.text.split()) == 2:
@@ -154,7 +150,9 @@ async def anti_channel_pin(_, m: Message):
             LOGGER.info(f"{m.from_user.id} disabled antichannelpin in {m.chat.id}")
             msg = "Turned off AntiChannelPin, now all message pinned by channel will stay pinned!"
         else:
-            await m.reply_text(text="Please check help on how to use this this command.")
+            await m.reply_text(
+                text="Please check help on how to use this this command."
+            )
             return
 
     await m.reply_text(msg)
@@ -191,9 +189,7 @@ async def clean_linked(_, m: Message):
 
     if len(m.text.split()) == 1:
         status = pinsdb.get_settings()["cleanlinked"]
-        await m.reply_text(
-           text=f"Current AntiChannelPin status: {status}"
-        )
+        await m.reply_text(text=f"Current AntiChannelPin status: {status}")
         return
 
     if len(m.text.split()) == 2:
@@ -206,7 +202,9 @@ async def clean_linked(_, m: Message):
             LOGGER.info(f"{m.from_user.id} disabled CleanLinked in {m.chat.id}")
             msg = "Turned off CleanLinked! Messages from linked channel will not be deleted!"
         else:
-            await m.reply_text(text="Please check help on how to use this this command.")
+            await m.reply_text(
+                text="Please check help on how to use this this command."
+            )
             return
 
     await m.reply_text(msg)
@@ -248,4 +246,4 @@ Here you find find all help related to groups pins and how to manage them via me
 * /unpinall: Unpins all the pinned message in the current chat.
 * /antichannelpin `<on/off/yes/no>`: Toggle antichannelpin status. All the messages from linked channel will be unpinned if enabled!
 * /cleanlinked `<on/off/yes/no>`: Toggle cleanlinked status. All the messages from linked channel will be deleted if enabled!
-* /permapin `<text>`: Pin a custom messages via bot. This message can contain markdown, and can be used in replies to the media include additional buttons and text."""
+* /permapin `<text>`: Pin a custom messages via bot. This message can contain markdown, and can be used in replies to the media include additional buttons and text."""

Powers/plugins/purge.py

@@ -1,12 +1,10 @@
 from asyncio import sleep
-
-from pyrogram.errors import MessageDeleteForbidden, RPCError
-from pyrogram.types import Message
-
 from Powers import SUPPORT_GROUP
 from Powers.bot_class import Gojo
+from pyrogram.types import Message
 from Powers.utils.chat_type import chattype
-from Powers.utils.custom_filters import admin_filter, command
+from pyrogram.errors import RPCError, MessageDeleteForbidden
+from Powers.utils.custom_filters import command, admin_filter
 
 
 @Gojo.on_message(command("purge") & admin_filter)
@@ -35,7 +33,9 @@ async def purge(c: Gojo, m: Message):
                 )
             await m.delete()
         except MessageDeleteForbidden:
-            await m.reply_text(text="Cannot delete all messages. The messages may be too old, I might not have delete rights, or this might not be a supergroup.")
+            await m.reply_text(
+                text="Cannot delete all messages. The messages may be too old, I might not have delete rights, or this might not be a supergroup."
+            )
             return
         except RPCError as ef:
             await m.reply_text(
@@ -46,10 +46,7 @@ async def purge(c: Gojo, m: Message):
 
         count_del_msg = len(message_ids)
 
-        z = await m.reply_text(
-            text=f"Deleted <i>{count_del_msg}</i> messages"
-                
-        )
+        z = await m.reply_text(text=f"Deleted <i>{count_del_msg}</i> messages")
         await sleep(3)
         await z.delete()
         return
@@ -83,7 +80,9 @@ async def spurge(c: Gojo, m: Message):
                 )
             await m.delete()
         except MessageDeleteForbidden:
-            await m.reply_text(text="Cannot delete all messages. The messages may be too old, I might not have delete rights, or this might not be a supergroup.")
+            await m.reply_text(
+                text="Cannot delete all messages. The messages may be too old, I might not have delete rights, or this might not be a supergroup."
+            )
             return
         except RPCError as ef:
             await m.reply_text(
@@ -125,4 +124,4 @@ __HELP__ = """
 
 * /purge: Deletes messages upto replied message.
 * /spurge: Deletes messages upto replied message without a success message.
-* /del: Deletes a single message, used as a reply to message."""
+* /del: Deletes a single message, used as a reply to message."""

Powers/plugins/report.py

@@ -1,17 +1,15 @@
-from traceback import format_exc
-
 from pyrogram import filters
-from pyrogram.enums import ChatMembersFilter as cmf
-from pyrogram.errors import RPCError
-from pyrogram.types import CallbackQuery, Message
-
-from Powers import LOGGER, SUPPORT_STAFF
+from traceback import format_exc
 from Powers.bot_class import Gojo
-from Powers.database.reporting_db import Reporting
-from Powers.utils.custom_filters import admin_filter, command
+from pyrogram.errors import RPCError
 from Powers.utils.kbhelpers import ikb
+from Powers import LOGGER, SUPPORT_STAFF
 from Powers.utils.chat_type import chattype
 from Powers.utils.parser import mention_html
+from pyrogram.types import Message, CallbackQuery
+from Powers.database.reporting_db import Reporting
+from pyrogram.enums import ChatMembersFilter as cmf
+from Powers.utils.custom_filters import command, admin_filter
 
 
 @Gojo.on_message(
@@ -101,7 +99,8 @@ async def report_watcher(c: Gojo, m: Message):
             msg = f"{(await mention_html(m.from_user.first_name, m.from_user.id))} is calling for admins in '{chat_name}'!\n"
 
         link_chat_id = str(m.chat.id).replace("-100", "")
-        link = f"https://t.me/c/{link_chat_id}/{reported_msg_id}"  # message link
+        # message link
+        link = f"https://t.me/c/{link_chat_id}/{reported_msg_id}"
 
         reply_markup = ikb(
             [
@@ -215,4 +214,4 @@ __HELP__ = """
 **Admins Only:**
 * /reports `<on/off/yes/no>`: change report setting, or view current status.
     - If done in PM, toggles your status.
-    - If in group, toggles that groups's status."""
+    - If in group, toggles that groups's status."""

Powers/plugins/rules.py

@@ -1,12 +1,11 @@
-from pyrogram import filters
-from pyrogram.types import CallbackQuery, Message
-
 from Powers import LOGGER
+from pyrogram import filters
+from Powers.vars import Config
 from Powers.bot_class import Gojo
-from Powers.database.rules_db import Rules
-from Powers.utils.custom_filters import admin_filter, command
 from Powers.utils.kbhelpers import ikb
-from Powers.vars import Config
+from Powers.database.rules_db import Rules
+from pyrogram.types import Message, CallbackQuery
+from Powers.utils.custom_filters import command, admin_filter
 
 
 @Gojo.on_message(command("rules") & filters.group)
@@ -105,7 +104,9 @@ async def priv_rules(_, m: Message):
         await m.reply_text(msg)
     elif len(m.text.split()) == 1:
         curr_pref = db.get_privrules()
-        msg = f"Current Preference for Private rules in this chat is: <b>{curr_pref}</b>"
+        msg = (
+            f"Current Preference for Private rules in this chat is: <b>{curr_pref}</b>"
+        )
         LOGGER.info(f"{m.from_user.id} fetched privaterules preference in {m.chat.id}")
         await m.reply_text(msg)
     else:
@@ -122,7 +123,9 @@ async def clear_rules(_, m: Message):
 
     rules = db.get_rules()
     if not rules:
-        await m.reply_text(text="The Admins for this group have not setup rules! That doesn't mean you can break the DECORUM of this group !")
+        await m.reply_text(
+            text="The Admins for this group have not setup rules! That doesn't mean you can break the DECORUM of this group !"
+        )
         return
 
     await m.reply_text(
@@ -157,4 +160,4 @@ Set rules for you chat so that members know what to do and what not to do in you
 **Admin only:**
 * /setrules `<rules>`: Set the rules for this chat, also works as a reply to a message.
 * /clearrules: Clear the rules for this chat.
-* /privrules `<on/yes/no/off>`: Turns on/off the option to send the rules to PM of user or group."""
+* /privrules `<on/yes/no/off>`: Turns on/off the option to send the rules to PM of user or group."""

Powers/plugins/start.py

@@ -1,32 +1,24 @@
 from random import choice
-
 from pyrogram import filters
-from pyrogram.errors import MessageNotModified, QueryIdInvalid, UserIsBlocked
-from pyrogram.types import CallbackQuery, Message
-
-from Powers import HELP_COMMANDS, LOGGER
+from Powers.vars import Config
 from Powers.bot_class import Gojo
-from Powers.utils.custom_filters import command
-from Powers.utils.chat_type import chattype
 from Powers.utils.kbhelpers import ikb
+from Powers import LOGGER, HELP_COMMANDS
 from Powers.utils.extras import StartPic
 from Powers.utils.chat_type import chattype
+from Powers.utils.custom_filters import command
+from pyrogram.types import Message, CallbackQuery
+from pyrogram.errors import UserIsBlocked, QueryIdInvalid, MessageNotModified
 from Powers.utils.start_utils import (
-    gen_cmds_kb,
-    gen_start_kb,
-    get_help_msg,
-    get_private_note,
-    get_private_rules,
-)
-from Powers.vars import Config
-
+    gen_cmds_kb, gen_start_kb, get_help_msg, get_private_note,
+    get_private_rules)
 
 
 @Gojo.on_message(
     command("donate") & (filters.group | filters.private),
 )
 async def donate(_, m: Message):
-    cpt="""
+    cpt = """
 Hey Thanks for your thought of donating me!
 When you donate, all the fund goes towards my development which makes on fast and responsive.
 Your donation might also me get me a new feature or two, which I wasn't able to get due to server limitations.
@@ -35,11 +27,9 @@ All the fund would be put into my services such as database, storage and hosting
 
 You can donate by contacting my owner: [Captain Ezio](http://t.me/iamgojoof6eyes)
      """
-    
 
     LOGGER.info(f"{m.from_user.id} fetched donation text in {m.chat.id}")
-    await m.reply_photo(photo=choice(StartPic),
-                            caption=cpt)
+    await m.reply_photo(photo=choice(StartPic), caption=cpt)
     return
 
 
@@ -67,7 +57,6 @@ async def close_admin_callback(_, q: CallbackQuery):
 @Gojo.on_message(
     command("start") & (filters.group | filters.private),
 )
-
 async def start(c: Gojo, m: Message):
     chat_type = await chattype(m)
     if chat_type == "private":
@@ -89,43 +78,42 @@ async def start(c: Gojo, m: Message):
             if not help_msg:
                 return
 
-            
-
             await m.reply_photo(
                 photo=choice(StartPic),
                 caption=help_msg,
                 parse_mode="markdown",
                 reply_markup=ikb(help_kb),
                 quote=True,
-                
             )
             return
         try:
-            cpt=f""" 
+            cpt = f"""
 Hey [{m.from_user.first_name}](http://t.me/{m.from_user.username})! My self Gojo ✨.
 I'm here to help you manage your groups!
 Hit /help to find out more about how to use me in my full potential!
 
 Join my [News Channel](https://t.me/gojo_updates) to get information on all the latest updates."""
-            
-            
 
             await m.reply_photo(
                 photo=choice(StartPic),
                 caption=cpt,
                 reply_markup=(await gen_start_kb(m)),
                 quote=True,
-                
             )
         except UserIsBlocked:
             LOGGER.warning(f"Bot blocked by {m.from_user.id}")
     else:
-        kb = ikb([
-            [("Connect me to pm",
-            f"https://t.me/{Config.BOT_USERNAME}?start=start",
-            "url"
-            )]
-        ])
+        kb = ikb(
+            [
+                [
+                    (
+                        "Connect me to pm",
+                        f"https://t.me/{Config.BOT_USERNAME}?start=start",
+                        "url",
+                    )
+                ]
+            ]
+        )
         await m.reply_photo(
             photo=choice(StartPic),
             caption="I'm alive :3",
@@ -138,7 +126,7 @@ Join my [News Channel](https://t.me/gojo_updates) to get information on all the
 @Gojo.on_callback_query(filters.regex("^start_back$"))
 async def start_back(_, q: CallbackQuery):
     try:
-        cpt=f"""
+        cpt = f"""
 Hey [{q.from_user.first_name}](http://t.me/{q.from_user.username})! My name is Gojo ✨.
 I'm here to help you manage your groups!
 Hit /help to find out more about how to use me in my full potential!
@@ -148,7 +136,6 @@ Join my [News Channel](http://t.me/gojo_updates) to get information on all the l
         await q.edit_message_caption(
             caption=cpt,
             reply_markup=(await gen_start_kb(q.message)),
-            
         )
     except MessageNotModified:
         pass
@@ -165,7 +152,7 @@ async def commands_menu(_, q: CallbackQuery):
         ],
     )
     try:
-        cpt=f"""
+        cpt = f"""
 Hey **[{q.from_user.first_name}](http://t.me/{q.from_user.username})**! My name is Gojo✨.
 I'm here to help you manage your groups!
 Commands available:
@@ -174,16 +161,15 @@ Commands available:
 
         await q.edit_message_caption(
             caption=cpt,
-        reply_markup=keyboard,
+            reply_markup=keyboard,
         )
     except MessageNotModified:
         pass
     except QueryIdInvalid:
         await q.message.reply_photo(
-            photo=choice(StartPic),
-            caption=cpt,
-            reply_markup=keyboard)
-        
+            photo=choice(StartPic), caption=cpt, reply_markup=keyboard
+        )
+
     await q.answer()
     return
 
@@ -203,17 +189,16 @@ async def help_menu(_, m: Message):
         )
         chat_type = await chattype(m)
         if chat_type == "private":
-            
+
             await m.reply_photo(
                 photo=choice(StartPic),
                 caption=help_msg,
                 parse_mode="markdown",
                 reply_markup=ikb(help_kb),
                 quote=True,
-                
             )
         else:
-            
+
             await m.reply_photo(
                 photo=choice(StartPic),
                 caption=f"Press the button below to get help for <i>{help_option}</i>",
@@ -238,7 +223,7 @@ async def help_menu(_, m: Message):
                     [("« Back", "start_back")],
                 ],
             )
-            msg =f"""
+            msg = f"""
 Hey **[{m.from_user.first_name}](http://t.me/{m.from_user.username})**!My name is Gojo✨.
 I'm here to help you manage your groups!
 Commands available:
@@ -249,7 +234,7 @@ Commands available:
                 [[("Help", f"t.me/{Config.BOT_USERNAME}?start=help", "url")]],
             )
             msg = "Contact me in PM to get the list of possible commands."
-        
+
         await m.reply_photo(
             photo=choice(StartPic),
             caption=msg,
@@ -263,7 +248,7 @@ Commands available:
 async def get_module_info(_, q: CallbackQuery):
     module = q.data.split(".", 1)[1]
 
-    help_msg = f"**{str(module)}:**\n\n" + HELP_COMMANDS[module]["help_msg"],
+    help_msg = (f"**{str(module)}:**\n\n" + HELP_COMMANDS[module]["help_msg"],)
 
     help_kb = HELP_COMMANDS[module]["buttons"] + [
         [("« " + "Back", "commands")],

Powers/plugins/stats.py

@@ -1,19 +1,18 @@
-from pyrogram.types import Message
-
 from Powers.bot_class import Gojo
+from pyrogram.types import Message
+from Powers.database.pins_db import Pins
+from Powers.database.chats_db import Chats
+from Powers.database.rules_db import Rules
+from Powers.database.users_db import Users
 from Powers.database.antispam_db import GBan
 from Powers.database.approve_db import Approve
-from Powers.database.blacklist_db import Blacklist
-from Powers.database.chats_db import Chats
-from Powers.database.disable_db import Disabling
 from Powers.database.filters_db import Filters
+from Powers.utils.custom_filters import command
+from Powers.database.disable_db import Disabling
+from Powers.database.blacklist_db import Blacklist
 from Powers.database.greetings_db import Greetings
-from Powers.database.notes_db import Notes, NotesSettings
-from Powers.database.pins_db import Pins
-from Powers.database.rules_db import Rules
-from Powers.database.users_db import Users
 from Powers.database.warns_db import Warns, WarnSettings
-from Powers.utils.custom_filters import command
+from Powers.database.notes_db import Notes, NotesSettings
 
 
 @Gojo.on_message(command("stats", dev_cmd=True))

Powers/plugins/utils.py

@@ -1,41 +1,38 @@
-from io import BytesIO
-from os import remove
 import re
 import aiofiles
-from search_engine_parser import GoogleSearch
-from datetime import datetime
-from aiohttp import ClientSession
+from Powers import *
+from os import remove
+from io import BytesIO
 from tswift import Song
+from pyrogram import filters
+from datetime import datetime
 from wikipedia import summary
-from wikipedia.exceptions import DisambiguationError, PageError
+from Powers.vars import Config
 from traceback import format_exc
-
-from gpytranslate import Translator
-from pyrogram import filters
-from pyrogram.errors import MessageTooLong, PeerIdInvalid, RPCError
-from pyrogram.types import Message,InlineKeyboardButton, InlineKeyboardMarkup
-
-
-from Powers import *
 from Powers.bot_class import Gojo
-from Powers.database.users_db import Users
-from Powers.utils.clean_file import remove_markdown_and_html
-from Powers.utils.custom_filters import command
-from Powers.utils.chat_type import chattype
+from aiohttp import ClientSession
+from gpytranslate import Translator
 from Powers.utils.http_helper import *
 from Powers.utils.kbhelpers import ikb
+from Powers.database.users_db import Users
+from Powers.utils.chat_type import chattype
 from Powers.utils.parser import mention_html
+from search_engine_parser import GoogleSearch
+from Powers.utils.custom_filters import command
 from Powers.utils.extract_user import extract_user
-from Powers.vars import Config
-
-
+from Powers.utils.clean_file import remove_markdown_and_html
+from wikipedia.exceptions import PageError, DisambiguationError
+from pyrogram.errors import RPCError, PeerIdInvalid, MessageTooLong
+from pyrogram.types import Message, InlineKeyboardButton, InlineKeyboardMarkup
 
 
 @Gojo.on_message(command("wiki"))
 async def wiki(_, m: Message):
 
     if len(m.text.split()) <= 1:
-        return await m.reply_text(text="Please check help on how to use this this command.")
+        return await m.reply_text(
+            text="Please check help on how to use this this command."
+        )
 
     search = m.text.split(None, 1)[1]
     try:
@@ -102,9 +99,8 @@ async def get_lyrics(_, m: Message):
     if not query:
         await m.edit_text(text="You haven't specified which song to look for!")
         return
-    song_name=query
-    em = await m.reply_text(
-        text=f"Finding lyrics for <code>{song_name}<code>...")
+    song_name = query
+    em = await m.reply_text(text=f"Finding lyrics for <code>{song_name}<code>...")
     song = Song.find_song(query)
     if song:
         if song.lyrics:
@@ -144,10 +140,10 @@ async def id_info(c: Gojo, m: Message):
         if m.reply_to_message and m.reply_to_message.forward_from:
             user1 = m.reply_to_message.from_user
             user2 = m.reply_to_message.forward_from
-            orig_sender=(await mention_html(user2.first_name, user2.id)),
-            orig_id=f"<code>{user2.id}</code>",
-            fwd_sender=(await mention_html(user1.first_name, user1.id)),
-            fwd_id=f"<code>{user1.id}</code>",
+            orig_sender = ((await mention_html(user2.first_name, user2.id)),)
+            orig_id = (f"<code>{user2.id}</code>",)
+            fwd_sender = ((await mention_html(user1.first_name, user1.id)),)
+            fwd_id = (f"<code>{user1.id}</code>",)
             await m.reply_text(
                 text=f"""Original Sender - {orig_sender} (<code>{orig_id}</code>)
         Forwarder - {fwd_sender} (<code>{fwd_id}</code>)""",
@@ -157,8 +153,10 @@ async def id_info(c: Gojo, m: Message):
             try:
                 user = await c.get_users(user_id)
             except PeerIdInvalid:
-                await m.reply_text(text="""Failed to get user
-      Peer ID invalid, I haven't seen this user anywhere earlier, maybe username would help to know them!""")
+                await m.reply_text(
+                    text="""Failed to get user
+      Peer ID invalid, I haven't seen this user anywhere earlier, maybe username would help to know them!"""
+                )
                 return
 
             await m.reply_text(
@@ -166,13 +164,9 @@ async def id_info(c: Gojo, m: Message):
                 parse_mode="HTML",
             )
     elif chat_type == "private":
-        await m.reply_text(
-            text=f"Your ID is <code>{m.chat.id}</code>."    
-        )
+        await m.reply_text(text=f"Your ID is <code>{m.chat.id}</code>.")
     else:
-        await m.reply_text(
-            text=f"This Group's ID is <code>{m.chat.id}</code>"
-        )
+        await m.reply_text(text=f"This Group's ID is <code>{m.chat.id}</code>")
     return
 
 
@@ -218,11 +212,13 @@ async def github(_, message):
         LOGGER.error(e)
         LOGGER.error(format_exc())
 
-#paste here
+
+# paste here
 session = ClientSession()
 pattern = re.compile(r"^text/|json$|yaml$|xml$|toml$|x-sh$|x-shellscript$")
 BASE = "https://batbin.me/"
 
+
 async def post(url: str, *args, **kwargs):
     async with session.post(url, *args, **kwargs) as resp:
         try:
@@ -231,6 +227,7 @@ async def post(url: str, *args, **kwargs):
             data = await resp.text()
     return data
 
+
 async def paste(content: str):
     resp = await post(f"{BASE}api/v2/paste", data=content)
     if not resp["success"]:
@@ -242,7 +239,7 @@ async def paste(content: str):
 async def paste_func(_, message: Message):
     if not message.reply_to_message:
         return await message.reply_text("Reply To A Message With `/paste`")
-   
+
     r = message.reply_to_message
 
     if not r.text and not r.document:
@@ -285,13 +282,18 @@ async def paste_func(_, message: Message):
             )
         await m.delete()
     except Exception:
-        await m.edit("Here is the link of the document....", reply_markup=InlineKeyboardMarkup(kb))
+        await m.edit(
+            "Here is the link of the document....",
+            reply_markup=InlineKeyboardMarkup(kb),
+        )
 
 
 @Gojo.on_message(command("tr"))
 async def tr(_, message):
     trl = Translator()
-    if message.reply_to_message and (message.reply_to_message.text or message.reply_to_message.caption):
+    if message.reply_to_message and (
+        message.reply_to_message.text or message.reply_to_message.caption
+    ):
         if len(message.text.split()) == 1:
             target_lang = "en"
         else:
@@ -319,8 +321,6 @@ async def tr(_, message):
     )
 
 
-
-
 __PLUGIN__ = "utils"
 _DISABLE_CMDS_ = [
     "paste",

Powers/plugins/warns.py

@@ -1,25 +1,19 @@
 from time import time
-
 from pyrogram import filters
+from Powers.vars import Config
+from Powers.bot_class import Gojo
 from pyrogram.errors import RPCError
-from pyrogram.types import (
-    CallbackQuery,
-    ChatPermissions,
-    InlineKeyboardButton,
-    InlineKeyboardMarkup,
-    Message,
-)
-
 from Powers import LOGGER, SUPPORT_STAFF
-from Powers.bot_class import Gojo
 from Powers.database.rules_db import Rules
 from Powers.database.users_db import Users
+from Powers.utils.parser import mention_html
+from Powers.utils.extract_user import extract_user
 from Powers.database.warns_db import Warns, WarnSettings
 from Powers.utils.caching import ADMIN_CACHE, admin_cache_reload
-from Powers.utils.custom_filters import admin_filter, command, restrict_filter
-from Powers.utils.extract_user import extract_user
-from Powers.utils.parser import mention_html
-from Powers.vars import Config
+from Powers.utils.custom_filters import command, admin_filter, restrict_filter
+from pyrogram.types import (
+    Message, CallbackQuery, ChatPermissions, InlineKeyboardButton,
+    InlineKeyboardMarkup)
 
 
 @Gojo.on_message(
@@ -52,7 +46,9 @@ async def warn(c: Gojo, m: Message):
         return
 
     if user_id in SUPPORT_STAFF:
-        await m.reply_text(text="This user is in my support staff, cannot restrict them.")
+        await m.reply_text(
+            text="This user is in my support staff, cannot restrict them."
+        )
         LOGGER.info(
             f"{m.from_user.id} trying to warn {user_id} (SUPPORT_STAFF) in {m.chat.id}",
         )
@@ -384,4 +380,4 @@ Admin commands:
 - /warnlimit `<number>`: Set the number of warnings before users are punished.
 
 Examples:
-`/warn @user`: this warns a user in the chat."""
+`/warn @user`: this warns a user in the chat."""

Powers/plugins/watchers.py

@@ -1,22 +1,21 @@
-from re import escape as re_escape
 from time import time
-from traceback import format_exc
-
 from pyrogram import filters
-from pyrogram.errors import ChatAdminRequired, RPCError, UserAdminInvalid
-from pyrogram.types import ChatPermissions, Message
-
-from Powers import LOGGER, MESSAGE_DUMP, SUPPORT_STAFF
+from traceback import format_exc
 from Powers.bot_class import Gojo
-from Powers.database.antispam_db import ANTISPAM_BANNED, GBan
+from re import escape as re_escape
+from Powers.database.pins_db import Pins
+from Powers.utils.parser import mention_html
 from Powers.database.approve_db import Approve
 from Powers.database.blacklist_db import Blacklist
-from Powers.database.group_blacklist import BLACKLIST_CHATS
-from Powers.database.pins_db import Pins
+from Powers.utils.regex_utils import regex_searcher
+from pyrogram.types import Message, ChatPermissions
+from Powers import LOGGER, MESSAGE_DUMP, SUPPORT_STAFF
 from Powers.database.warns_db import Warns, WarnSettings
+from Powers.database.group_blacklist import BLACKLIST_CHATS
+from Powers.database.antispam_db import ANTISPAM_BANNED, GBan
 from Powers.utils.caching import ADMIN_CACHE, admin_cache_reload
-from Powers.utils.parser import mention_html
-from Powers.utils.regex_utils import regex_searcher
+from pyrogram.errors import RPCError, UserAdminInvalid, ChatAdminRequired
+
 
 # Initialise
 gban_db = GBan()
@@ -184,7 +183,7 @@ async def gban_watcher(c: Gojo, m: Message):
         try:
             await m.chat.ban_member(m.from_user.id)
             await m.delete(m.message_id)  # Delete users message!
-            user_gbanned=(await mention_html(m.from_user.first_name, m.from_user.id))
+            user_gbanned = await mention_html(m.from_user.first_name, m.from_user.id)
             await m.reply_text(
                 text=f"""This user ({user_gbanned}) has been banned globally!
 
@@ -203,7 +202,7 @@ async def gban_watcher(c: Gojo, m: Message):
                 MESSAGE_DUMP,
                 text=f"""<b>Gban Watcher Error!</b>
         <b>Chat:</b> <code>{m.chat.id}</code>
-        <b>Error:</b> <code>{ef}</code>"""
+        <b>Error:</b> <code>{ef}</code>""",
             )
     return
 

Powers/utils/admin_check.py

@@ -1,8 +1,7 @@
 from traceback import format_exc
+from pyrogram.types import Message, CallbackQuery
+from Powers import LOGGER, OWNER_ID, DEV_USERS, SUDO_USERS
 
-from pyrogram.types import CallbackQuery, Message
-
-from Powers import DEV_USERS, LOGGER, OWNER_ID, SUDO_USERS
 
 SUDO_LEVEL = SUDO_USERS + DEV_USERS + [int(OWNER_ID)]
 DEV_LEVEL = DEV_USERS + [int(OWNER_ID)]

Powers/utils/caching.py

@@ -1,13 +1,12 @@
-from threading import RLock
-from time import perf_counter, time
 from typing import List
-
+from Powers import LOGGER
+from pyrogram import enums
+from threading import RLock
 from cachetools import TTLCache
+from time import time, perf_counter
 from pyrogram.types import CallbackQuery
-from pyrogram import enums
 from pyrogram.types.messages_and_media.message import Message
 
-from Powers import LOGGER
 
 THREAD_LOCK = RLock()
 
@@ -34,16 +33,16 @@ async def admin_cache_reload(m: Message or CallbackQuery, status=None) -> List[i
         except KeyError:
             # Because it might be first time when admn_list is being reloaded
             pass
-        
-        
+
         admin_list = [
             (
                 z.user.id,
                 (("@" + z.user.username) if z.user.username else z.user.first_name),
                 z.is_anonymous,
             )
-            
-            async for z in m.chat.get_members(filter=enums.ChatMembersFilter.ADMINISTRATORS)
+            async for z in m.chat.get_members(
+                filter=enums.ChatMembersFilter.ADMINISTRATORS
+            )
             if not z.user.is_deleted
         ]
         ADMIN_CACHE[m.chat.id] = admin_list

Powers/utils/chat_type.py

@@ -1,40 +1,37 @@
 from Powers.bot_class import Gojo
-
-from pyrogram.enums import ChatType
 from pyrogram.types import Message
-
+from pyrogram.enums import ChatType
 
 
 async def chattype(m: Message):
-    # To get chat type with message 
+    # To get chat type with message
 
     if m.chat.type == ChatType.CHANNEL:
         ct = "channel"
-        
+
     if m.chat.type == ChatType.PRIVATE:
         ct = "private"
 
     if m.chat.type == ChatType.GROUP:
-        ct="group"
+        ct = "group"
 
     if m.chat.type == ChatType.SUPERGROUP:
         ct = "supergroup"
 
-
-
     return ct
 
+
 async def c_type(c: Gojo, chat_id):
     # To get chat type with chat id
-    
+
     c = await Gojo.get_chat(chat_id)
-    
+
     if c.type == ChatType.CHANNEL:
         ct = "channel"
-    
+
     if c.type == ChatType.GROUP:
         ct = "group"
-    
+
     if c.type == ChatType.SUPERGROUP:
         ct = "supergroup"
 

Powers/utils/custom_filters.py

@@ -1,19 +1,16 @@
-from re import compile as compile_re
-from re import escape
 from shlex import split
+from pyrogram import enums
+from Powers.vars import Config
 from typing import List, Union
-
-from pyrogram.errors import RPCError, UserNotParticipant
 from pyrogram.filters import create
-from pyrogram.types import CallbackQuery, Message
-from pyrogram import enums
-
-
-from Powers import DEV_USERS, OWNER_ID, SUDO_USERS
+from Powers.utils.chat_type import chattype
+from re import escape, compile as compile_re
 from Powers.database.disable_db import Disabling
+from pyrogram.types import Message, CallbackQuery
+from Powers import OWNER_ID, DEV_USERS, SUDO_USERS
+from pyrogram.errors import RPCError, UserNotParticipant
 from Powers.utils.caching import ADMIN_CACHE, admin_cache_reload
-from Powers.utils.chat_type import chattype
-from Powers.vars import Config
+
 
 SUDO_LEVEL = set(SUDO_USERS + DEV_USERS + [int(OWNER_ID)])
 DEV_LEVEL = set(DEV_USERS + [int(OWNER_ID)])
@@ -32,7 +29,7 @@ def command(
 
         date = m.edit_date
         if date:
-            return # reaction
+            return  # reaction
 
         chattype = bool(m.chat and m.chat.type in {enums.ChatType.CHANNEL})
         if chattype:
@@ -101,7 +98,7 @@ def command(
             return True
         return False
 
-    commands = commands if type(commands) is list else [commands]
+    commands = commands if isinstance(commands, list) else [commands]
     commands = {c if case_sensitive else c.lower() for c in commands}
 
     return create(