🔖 Update to v1.3.1

pagermaid/__init__.py

@@ -4,24 +4,37 @@
 
 from coloredlogs import ColoredFormatter
 from datetime import datetime, timezone
-from logging import getLogger, StreamHandler, CRITICAL, INFO, basicConfig, DEBUG, Formatter, FileHandler
+from logging import (
+    getLogger,
+    StreamHandler,
+    CRITICAL,
+    INFO,
+    basicConfig,
+    DEBUG,
+    Formatter,
+    FileHandler,
+)
 from os import getcwd
 
 from pagermaid.config import Config
 from pagermaid.scheduler import scheduler
 import pyromod.listen
 from pyrogram import Client
 
-pgm_version = "1.3.0"
-pgm_version_code = 1300
+pgm_version = "1.3.1"
+pgm_version_code = 1301
 CMD_LIST = {}
 module_dir = __path__[0]
 working_dir = getcwd()
 # solve same process
 read_context = {}
 help_messages = {}
 hook_functions: Dict[str, Set[Callable[[], Awaitable[None]]]] = {
-    "startup": set(), "shutdown": set(), "command_pre": set(), "command_post": set(), "process_error": set(),
+    "startup": set(),
+    "shutdown": set(),
+    "command_pre": set(),
+    "command_post": set(),
+    "process_error": set(),
     "load_plugins_finished": set(),
 }
 all_permissions = []
@@ -51,6 +64,7 @@
 
 with contextlib.suppress(ImportError):
     import uvloop  # noqa
+
     uvloop.install()
 
 if not scheduler.running:
@@ -68,16 +82,11 @@
 
 
 async def log(message):
-    logs.info(
-        message.replace('`', '\"')
-    )
+    logs.info(message.replace("`", '"'))
     if not Config.LOG:
         return
     try:
-        await bot.send_message(
-            Config.LOG_ID,
-            message
-        )
+        await bot.send_message(Config.LOG_ID, message)
     except Exception:
         Config.LOG = False
         Config.LOG_ID = "me"

pagermaid/__main__.py

@@ -17,7 +17,7 @@
 
 
 async def main():
-    logs.info(lang('platform') + platform + lang('platform_load'))
+    logs.info(lang("platform") + platform + lang("platform_load"))
 
     try:
         await start_client(bot)
@@ -35,7 +35,9 @@ async def main():
         try:
             import_module(f"pagermaid.modules.{module_name}")
         except BaseException as exception:
-            logs.info(f"{lang('module')} {module_name} {lang('error')}: {type(exception)}: {exception}")
+            logs.info(
+                f"{lang('module')} {module_name} {lang('error')}: {type(exception)}: {exception}"
+            )
     for plugin_name in plugin_list.copy():
         try:
             import_module(f"plugins.{plugin_name}")
@@ -45,11 +47,12 @@ async def main():
     plugin_manager.load_local_plugins()
 
     await process_exit(start=True, _client=bot)
-    logs.info(lang('start'))
+    logs.info(lang("start"))
     await Hook.load_success_exec()
     await Hook.startup()
 
     await idle()
     await bot.stop()
 
+
 bot.run(main())

pagermaid/common/alias.py

@@ -28,15 +28,12 @@ def get_all_alias_dict(self):
 
     def get_all_alias_text(self) -> str:
         texts = []
-        texts.extend(
-            f'`{i.command}` > `{i.alias}`'
-            for i in self.alias_list
-        )
-        return '\n'.join(texts)
+        texts.extend(f"`{i.command}` > `{i.alias}`" for i in self.alias_list)
+        return "\n".join(texts)
 
     @staticmethod
     def save():
-        with open(f"data{sep}alias.json", 'w', encoding="utf-8") as f:
+        with open(f"data{sep}alias.json", "w", encoding="utf-8") as f:
             json_dump(Config.alias_dict, f)
 
     @staticmethod

pagermaid/common/cache.py

@@ -20,7 +20,7 @@ async def wrapped(*args, **kw):
             nonlocal cache_data
             bound = inspect.signature(func).bind(*args, **kw)
             bound.apply_defaults()
-            ins_key = '|'.join([f'{k}_{v}' for k, v in bound.arguments.items()])
+            ins_key = "|".join([f"{k}_{v}" for k, v in bound.arguments.items()])
             data: Cache = cache_data.get(ins_key, Cache(value=None, time=None))
             now = datetime.datetime.now()
             if (not data.time) or ((now - data.time) > ttl):
@@ -31,5 +31,7 @@ async def wrapped(*args, **kw):
                 except Exception as e:
                     raise e
             return data.value
+
         return wrapped
+
     return wrap

pagermaid/common/plugin.py

@@ -10,7 +10,7 @@
 from pagermaid.common.cache import cache
 from pagermaid.utils import client
 
-plugins_path = Path('plugins')
+plugins_path = Path("plugins")
 
 
 class LocalPlugin(BaseModel):
@@ -57,11 +57,11 @@ class RemotePlugin(LocalPlugin):
     ...
 
     async def install(self) -> bool:
-        html = await client.get(f'{Config.GIT_SOURCE}{self.name}/main.py')
+        html = await client.get(f"{Config.GIT_SOURCE}{self.name}/main.py")
         if html.status_code == 200:
             self.remove()
             with open(plugins_path / f"{self.name}.py", mode="wb") as f:
-                f.write(html.text.encode('utf-8'))
+                f.write(html.text.encode("utf-8"))
             return True
         return False
 
@@ -76,11 +76,11 @@ def __init__(self):
     def load_local_version_map(self):
         if not os.path.exists(plugins_path / "version.json"):
             return
-        with open(plugins_path / "version.json", 'r', encoding="utf-8") as f:
+        with open(plugins_path / "version.json", "r", encoding="utf-8") as f:
             self.version_map = json.load(f)
 
     def save_local_version_map(self):
-        with open(plugins_path / "version.json", 'w', encoding="utf-8") as f:
+        with open(plugins_path / "version.json", "w", encoding="utf-8") as f:
             json.dump(self.version_map, f, indent=4)
 
     def get_local_version(self, name: str) -> Optional[float]:
@@ -116,15 +116,17 @@ def disable_plugin(self, name: str) -> bool:
     def load_local_plugins(self) -> List[LocalPlugin]:
         self.load_local_version_map()
         self.plugins = []
-        for plugin in os.listdir('plugins'):
-            if plugin.endswith('.py') or plugin.endswith('.py.disabled'):
-                plugin = plugin[:-12] if plugin.endswith('.py.disabled') else plugin[:-3]
+        for plugin in os.listdir("plugins"):
+            if plugin.endswith(".py") or plugin.endswith(".py.disabled"):
+                plugin = (
+                    plugin[:-12] if plugin.endswith(".py.disabled") else plugin[:-3]
+                )
                 self.plugins.append(
                     LocalPlugin(
                         name=plugin,
                         installed=self.get_plugin_install_status(plugin),
                         status=self.get_plugin_load_status(plugin),
-                        version=self.get_local_version(plugin)
+                        version=self.get_local_version(plugin),
                     )
                 )
         return self.plugins
@@ -140,7 +142,8 @@ async def _load_remote_plugins(self) -> List[RemotePlugin]:
             RemotePlugin(
                 **plugin,
                 status=False,
-            ) for plugin in plugin_list
+            )
+            for plugin in plugin_list
         ]
         self.remote_plugins = plugins
         self.remote_version_map = {}

pagermaid/common/reload.py

@@ -4,7 +4,14 @@
 
 import pagermaid.config
 import pagermaid.modules
-from pagermaid import read_context, bot, help_messages, all_permissions, hook_functions, logs
+from pagermaid import (
+    read_context,
+    bot,
+    help_messages,
+    all_permissions,
+    hook_functions,
+    logs,
+)
 from pagermaid.common.plugin import plugin_manager
 from pagermaid.hook import Hook
 from pagermaid.utils import lang
@@ -32,7 +39,9 @@ async def reload_all():
             if module_name in loaded_plugins:
                 importlib.reload(module)
         except BaseException as exception:
-            logs.info(f"{lang('module')} {module_name} {lang('error')}: {type(exception)}: {exception}")
+            logs.info(
+                f"{lang('module')} {module_name} {lang('error')}: {type(exception)}: {exception}"
+            )
     for plugin_name in pagermaid.modules.plugin_list.copy():
         try:
             plugin = importlib.import_module(f"plugins.{plugin_name}")

pagermaid/common/status.py

@@ -17,11 +17,11 @@ class Status(BaseModel):
 async def human_time_duration(seconds) -> str:
     parts = {}
     time_units = (
-        ('%m', 60 * 60 * 24 * 30),
-        ('%d', 60 * 60 * 24),
-        ('%H', 60 * 60),
-        ('%M', 60),
-        ('%S', 1)
+        ("%m", 60 * 60 * 24 * 30),
+        ("%d", 60 * 60 * 24),
+        ("%H", 60 * 60),
+        ("%M", 60),
+        ("%S", 1),
     )
     for unit, div in time_units:
         amount, seconds = divmod(int(seconds), div)
@@ -48,7 +48,7 @@ async def get_status() -> Status:
     return Status(
         version=pgm_version,
         run_time=uptime,
-        cpu_percent=f'{cpu_percent}%',
-        ram_percent=f'{ram_stat.percent}%',
-        swap_percent=f'{swap_stat.percent}%',
+        cpu_percent=f"{cpu_percent}%",
+        ram_percent=f"{ram_stat.percent}%",
+        swap_percent=f"{swap_stat.percent}%",
     )

pagermaid/common/system.py

@@ -33,11 +33,11 @@ async def run_eval(cmd: str, message=None, only_result: bool = False) -> str:
 async def aexec(code, event, client):
     exec(
         (
-                (
-                        ("async def __aexec(e, client): " + "\n msg = message = e")
-                        + "\n reply = message.reply_to_message if message else None"
-                )
-                + "\n chat = e.chat if e else None"
+            (
+                ("async def __aexec(e, client): " + "\n msg = message = e")
+                + "\n reply = message.reply_to_message if message else None"
+            )
+            + "\n chat = e.chat if e else None"
         )
         + "".join(f"\n {x}" for x in code.split("\n"))
     )

pagermaid/common/update.py

@@ -4,9 +4,9 @@
 
 
 async def update(force: bool = False):
-    await execute('git fetch --all')
+    await execute("git fetch --all")
     if force:
-        await execute('git reset --hard origin/master')
-    await execute('git pull --all')
+        await execute("git reset --hard origin/master")
+    await execute("git pull --all")
     await execute(f"{executable} -m pip install --upgrade -r requirements.txt")
     await execute(f"{executable} -m pip install -r requirements.txt")