3.3.0-dev

Author: Taaku18

CHANGELOG.md

@@ -12,6 +12,19 @@ however, insignificant breaking changes does not guarantee a major version bump,
 ### Changed
 
 - `?contact` no longer send the "thread created" message to where the command is ran, instead, it's now sent to the newly created thread channel. (Thanks to DAzVise)
+- Plugins update (mostly internal).
+  - `git` is no longer used to install plugins, it now downloads through zip files.
+  - `?plugins enabled` renamed to `?plugins loaded` while `enabled` is still an alias to that command.
+  - Reorganised plugins folder structure.
+  - Logging / plugin-related messages changes.
+  - Updating one plugin will not update all other plugins (plugins are no longer separated by repos, but the plugin name itself).
+- Help command is in alphabetical order grouped by permissions.
+
+### Internal
+
+- Reworked `config.get` and `config.set`, it feeds through the converters before setting/getting.
+  - To get/set the raw value, access through `config[]`.
+- Prerelease naming scheme is now `x.x.x-dev`.
 
 # v3.2.2
 

Dockerfile

@@ -1,5 +1,4 @@
 FROM python:3.7.4-alpine
-RUN apk add --no-cache git
 WORKDIR /modmailbot
 COPY . /modmailbot
 RUN pip install --no-cache-dir -r requirements.min.txt

bot.py

@@ -1,4 +1,4 @@
-__version__ = "3.2.3-pre"
+__version__ = "3.3.0-dev"
 
 import asyncio
 import logging
@@ -19,6 +19,7 @@
 from aiohttp import ClientSession
 from emoji import UNICODE_EMOJI
 from motor.motor_asyncio import AsyncIOMotorClient
+from pkg_resources import parse_version
 from pymongo.errors import ConfigurationError
 
 try:
@@ -32,7 +33,7 @@
 from core import checks
 from core.clients import ApiClient, PluginDatabaseClient
 from core.config import ConfigManager
-from core.utils import human_join, strtobool, parse_alias
+from core.utils import human_join, parse_alias
 from core.models import PermissionLevel, ModmailLogger, SafeFormatter
 from core.thread import ThreadManager
 from core.time import human_timedelta
@@ -70,6 +71,7 @@ def __init__(self):
         self._api = None
         self.metadata_loop = None
         self.formatter = SafeFormatter()
+        self.loaded_cogs = ['cogs.modmail', 'cogs.plugins', 'cogs.utility']
 
         self._connected = asyncio.Event()
         self.start_time = datetime.utcnow()
@@ -97,17 +99,7 @@ def __init__(self):
             sys.exit(0)
 
         self.plugin_db = PluginDatabaseClient(self)
-
-        logger.line()
-        logger.info("┌┬┐┌─┐┌┬┐┌┬┐┌─┐┬┬")
-        logger.info("││││ │ │││││├─┤││")
-        logger.info("┴ ┴└─┘─┴┘┴ ┴┴ ┴┴┴─┘")
-        logger.info("v%s", __version__)
-        logger.info("Authors: kyb3r, fourjr, Taaku18")
-        logger.line()
-
-        self._load_extensions()
-        logger.line()
+        self.startup()
 
     @property
     def uptime(self) -> str:
@@ -123,6 +115,24 @@ def uptime(self) -> str:
 
         return self.formatter.format(fmt, d=days, h=hours, m=minutes, s=seconds)
 
+    def startup(self):
+        logger.line()
+        logger.info("┌┬┐┌─┐┌┬┐┌┬┐┌─┐┬┬")
+        logger.info("││││ │ │││││├─┤││")
+        logger.info("┴ ┴└─┘─┴┘┴ ┴┴ ┴┴┴─┘")
+        logger.info("v%s", __version__)
+        logger.info("Authors: kyb3r, fourjr, Taaku18")
+        logger.line()
+
+        for cog in self.loaded_cogs:
+            logger.info("Loading %s.", cog)
+            try:
+                self.load_extension(cog)
+                logger.info("Successfully loaded %s.", cog)
+            except Exception:
+                logger.exception("Failed to load %s.", cog)
+        logger.line()
+
     def _configure_logging(self):
         level_text = self.config["log_level"].upper()
         logging_levels = {
@@ -161,8 +171,8 @@ def _configure_logging(self):
         logger.debug("Successfully configured logging.")
 
     @property
-    def version(self) -> str:
-        return __version__
+    def version(self):
+        return parse_version(__version__)
 
     @property
     def session(self) -> ClientSession:
@@ -179,18 +189,6 @@ def api(self):
     async def get_prefix(self, message=None):
         return [self.prefix, f"<@{self.user.id}> ", f"<@!{self.user.id}> "]
 
-    def _load_extensions(self):
-        """Adds commands automatically"""
-        for file in os.listdir("cogs"):
-            if not file.endswith(".py"):
-                continue
-            cog = f"cogs.{file[:-3]}"
-            logger.info("Loading %s.", cog)
-            try:
-                self.load_extension(cog)
-            except Exception:
-                logger.exception("Failed to load %s.", cog)
-
     def run(self, *args, **kwargs):
         try:
             self.loop.run_until_complete(self.start(self.token))
@@ -366,25 +364,17 @@ def blocked_whitelisted_users(self) -> typing.List[str]:
     def prefix(self) -> str:
         return str(self.config["prefix"])
 
-    def _parse_color(self, conf_name):
-        color = self.config[conf_name]
-        try:
-            return int(color.lstrip("#"), base=16)
-        except ValueError:
-            logger.error("Invalid %s provided.", conf_name)
-        return int(self.config.remove(conf_name).lstrip("#"), base=16)
-
     @property
     def mod_color(self) -> int:
-        return self._parse_color("mod_color")
+        return self.config.get("mod_color")
 
     @property
     def recipient_color(self) -> int:
-        return self._parse_color("recipient_color")
+        return self.config.get("recipient_color")
 
     @property
     def main_color(self) -> int:
-        return self._parse_color("main_color")
+        return self.config.get("main_color")
 
     def command_perm(self, command_name: str) -> PermissionLevel:
         level = self.config["override_command_level"].get(command_name)
@@ -518,7 +508,6 @@ async def on_ready(self):
             loop=None,
         )
         self.metadata_loop.before_loop(self.before_post_metadata)
-        self.metadata_loop.after_loop(self.after_post_metadata)
         self.metadata_loop.start()
 
     async def convert_emoji(self, name: str) -> str:
@@ -574,38 +563,14 @@ async def _process_blocked(self, message: discord.Message) -> bool:
 
         now = datetime.utcnow()
 
-        account_age = self.config["account_age"]
-        guild_age = self.config["guild_age"]
+        account_age = self.config.get("account_age")
+        guild_age = self.config.get("guild_age")
 
         if account_age is None:
             account_age = isodate.Duration()
         if guild_age is None:
             guild_age = isodate.Duration()
 
-        if not isinstance(account_age, isodate.Duration):
-            try:
-                account_age = isodate.parse_duration(account_age)
-            except isodate.ISO8601Error:
-                logger.warning(
-                    "The account age limit needs to be a "
-                    "ISO-8601 duration formatted duration string "
-                    'greater than 0 days, not "%s".',
-                    str(account_age),
-                )
-                account_age = self.config.remove("account_age")
-
-        if not isinstance(guild_age, isodate.Duration):
-            try:
-                guild_age = isodate.parse_duration(guild_age)
-            except isodate.ISO8601Error:
-                logger.warning(
-                    "The guild join age limit needs to be a "
-                    "ISO-8601 duration formatted duration string "
-                    'greater than 0 days, not "%s".',
-                    str(guild_age),
-                )
-                guild_age = self.config.remove("guild_age")
-
         reason = self.blocked_users.get(str(message.author.id)) or ""
         min_guild_age = min_account_age = now
 
@@ -860,14 +825,7 @@ async def process_commands(self, message):
 
             thread = await self.threads.find(channel=ctx.channel)
             if thread is not None:
-                try:
-                    reply_without_command = strtobool(
-                        self.config["reply_without_command"]
-                    )
-                except ValueError:
-                    reply_without_command = self.config.remove("reply_without_command")
-
-                if reply_without_command:
+                if self.config.get('reply_without_command'):
                     await thread.reply(message)
                 else:
                     await self.api.append_log(message, type_="internal")
@@ -887,23 +845,15 @@ async def _void(*_args, **_kwargs):
             pass
 
         if isinstance(channel, discord.DMChannel):
-            try:
-                user_typing = strtobool(self.config["user_typing"])
-            except ValueError:
-                user_typing = self.config.remove("user_typing")
-            if not user_typing:
+            if not self.config.get("user_typing"):
                 return
 
             thread = await self.threads.find(recipient=user)
 
             if thread:
                 await thread.channel.trigger_typing()
         else:
-            try:
-                mod_typing = strtobool(self.config["mod_typing"])
-            except ValueError:
-                mod_typing = self.config.remove("mod_typing")
-            if not mod_typing:
+            if not self.config.get('mod_typing'):
                 return
 
             thread = await self.threads.find(channel=channel)
@@ -941,15 +891,7 @@ async def on_raw_reaction_add(self, payload):
 
         if isinstance(channel, discord.DMChannel):
             if str(reaction) == str(close_emoji):  # closing thread
-                try:
-                    recipient_thread_close = strtobool(
-                        self.config["recipient_thread_close"]
-                    )
-                except ValueError:
-                    recipient_thread_close = self.config.remove(
-                        "recipient_thread_close"
-                    )
-                if not recipient_thread_close:
+                if not self.config.get('recipient_thread_close'):
                     return
                 thread = await self.threads.find(recipient=user)
                 ts = message.embeds[0].timestamp if message.embeds else None
@@ -1146,7 +1088,7 @@ async def post_metadata(self):
             "member_count": len(self.guild.members),
             "uptime": (datetime.utcnow() - self.start_time).total_seconds(),
             "latency": f"{self.ws.latency * 1000:.4f}",
-            "version": self.version,
+            "version": str(self.version),
             "selfhosted": True,
             "last_updated": str(datetime.utcnow()),
         }
@@ -1161,10 +1103,6 @@ async def before_post_metadata(self):
         if not self.guild:
             self.metadata_loop.cancel()
 
-    @staticmethod
-    async def after_post_metadata():
-        logger.info("Metadata loop has been cancelled.")
-
 
 if __name__ == "__main__":
     try: