Format with black

Author: raidensakura

bot.py

@@ -662,7 +662,6 @@ async def get_or_fetch_user(self, id: int) -> discord.User:
         return self.get_user(id) or await self.fetch_user(id)
 
     async def retrieve_emoji(self) -> typing.Tuple[str, str]:
-
         sent_emoji = self.config["sent_emoji"]
         blocked_emoji = self.config["blocked_emoji"]
 
@@ -736,7 +735,6 @@ def check_manual_blocked_roles(self, author: discord.Member) -> bool:
         if isinstance(author, discord.Member):
             for r in author.roles:
                 if str(r.id) in self.blocked_roles:
-
                     blocked_reason = self.blocked_roles.get(str(r.id)) or ""
 
                     try:
@@ -795,7 +793,6 @@ async def is_blocked(
         channel: discord.TextChannel = None,
         send_message: bool = False,
     ) -> bool:
-
         member = self.guild.get_member(author.id) or await MemberConverter.convert(author)
         if member is None:
             # try to find in other guilds

cogs/plugins.py

@@ -265,7 +265,6 @@ async def load_plugin(self, plugin):
             raise InvalidPluginError("Cannot load extension, plugin invalid.") from exc
 
     async def parse_user_input(self, ctx, plugin_name, check_version=False):
-
         if not self.bot.config["enable_plugins"]:
             embed = discord.Embed(
                 description="Plugins are disabled, enable them by setting `ENABLE_PLUGINS=true`",
@@ -388,7 +387,6 @@ async def plugins_add(self, ctx, *, plugin_name: str):
         await self.bot.config.update()
 
         if self.bot.config.get("enable_plugins"):
-
             invalidate_caches()
 
             try:

cogs/utility.py

@@ -599,7 +599,6 @@ async def status(self, ctx, *, status_type: str.lower):
         return await ctx.send(embed=embed)
 
     async def set_presence(self, *, status=None, activity_type=None, activity_message=None):
-
         if status is None:
             status = self.bot.config.get("status")
 

core/clients.py

@@ -446,7 +446,7 @@ def __init__(self, bot):
                 raise RuntimeError
 
         try:
-            database = parse_uri(mongo_uri).get('database') or 'modmail_bot'
+            database = parse_uri(mongo_uri).get("database") or "modmail_bot"
             db = AsyncIOMotorClient(mongo_uri)[database]
         except ConfigurationError as e:
             logger.critical(
@@ -499,7 +499,7 @@ async def validate_database_connection(self, *, ssl_retry=True):
                     'run "Certificate.command" on MacOS, '
                     'and check certifi is up to date "pip3 install --upgrade certifi".'
                 )
-                database = parse_uri(mongo_uri).get('database') or 'modmail_bot'
+                database = parse_uri(mongo_uri).get("database") or "modmail_bot"
                 self.db = AsyncIOMotorClient(mongo_uri, tlsAllowInvalidCertificates=True)[database]
                 return await self.validate_database_connection(ssl_retry=False)
             if "ServerSelectionTimeoutError" in message:

core/config.py

@@ -21,7 +21,6 @@
 
 
 class ConfigManager:
-
     public_keys = {
         # activity
         "twitch_url": "https://www.twitch.tv/discordmodmail/",

core/models.py

@@ -202,7 +202,6 @@ async def convert(self, ctx, argument):
         try:
             return await super().convert(ctx, argument)
         except commands.ChannelNotFound:
-
             if guild:
                 categories = {c.name.casefold(): c for c in guild.categories}
             else:

core/thread.py

@@ -31,7 +31,7 @@
     get_joint_id,
     AcceptButton,
     DenyButton,
-    ConfirmThreadCreationView
+    ConfirmThreadCreationView,
 )
 
 logger = getLogger(__name__)
@@ -721,7 +721,6 @@ async def delete_message(
     async def find_linked_message_from_dm(
         self, message, either_direction=False, get_thread_channel=False
     ) -> typing.List[discord.Message]:
-
         joint_id = None
         if either_direction:
             joint_id = get_joint_id(message)
@@ -914,7 +913,6 @@ async def send(
         persistent_note: bool = False,
         thread_creation: bool = False,
     ) -> None:
-
         if not note and from_mod:
             self.bot.loop.create_task(self._restart_close_timer())  # Start or restart thread auto close
 
@@ -1428,9 +1426,9 @@ async def create(
                 embed=discord.Embed(
                     title=self.bot.config["confirm_thread_creation_title"],
                     description=self.bot.config["confirm_thread_response"],
-                    color=self.bot.main_color
+                    color=self.bot.main_color,
                 ),
-                view=view
+                view=view,
             )
             await view.wait()
             if view.value is None:

core/utils.py

@@ -41,7 +41,7 @@
     "extract_block_timestamp",
     "AcceptButton",
     "DenyButton",
-    "ConfirmThreadCreationView"
+    "ConfirmThreadCreationView",
 ]
 
 
@@ -563,30 +563,27 @@ def extract_block_timestamp(reason, id_):
 
     return end_time, after
 
+
 class AcceptButton(discord.ui.Button):
     def __init__(self, emoji):
-        super().__init__(
-            style=discord.ButtonStyle.gray,
-            emoji=emoji
-        )
-    
+        super().__init__(style=discord.ButtonStyle.gray, emoji=emoji)
+
     async def callback(self, interaction: discord.Interaction):
         self.view.value = True
         await interaction.response.edit_message(view=None)
         self.view.stop()
 
+
 class DenyButton(discord.ui.Button):
     def __init__(self, emoji):
-        super().__init__(
-            style=discord.ButtonStyle.gray,
-            emoji=emoji
-        )
-    
+        super().__init__(style=discord.ButtonStyle.gray, emoji=emoji)
+
     async def callback(self, interaction: discord.Interaction):
         self.view.value = False
         await interaction.response.edit_message(view=None)
         self.view.stop()
 
+
 class ConfirmThreadCreationView(discord.ui.View):
     def __init__(self):
         super().__init__(timeout=20)