refactor: Sourcery AI refactor (#898)

* refactor: sourcery AI refactor

* refactor: sourcery AI refactor

* refactor: sourcery AI refactor

Author: EepyElvyra

interactions/api/gateway/client.py

@@ -264,7 +264,7 @@ async def wait_until_ready(self) -> None:
         """Waits for the client to become ready according to the Gateway."""
         await self.ready.wait()
 
-    def _dispatch_event(self, event: str, data: dict) -> None:  # sourcery no-metrics
+    def _dispatch_event(self, event: str, data: dict) -> None:
         """
         Dispatches an event from the Gateway.
 
@@ -273,11 +273,12 @@ def _dispatch_event(self, event: str, data: dict) -> None:  # sourcery no-metric
         :param data: The data for the event.
         :type data: dict
         """
+        # sourcery no-metrics
         path: str = "interactions"
         path += ".models" if event == "INTERACTION_CREATE" else ".api.models"
         if event == "INTERACTION_CREATE":
             if data.get("type"):
-                # sourcery skip: extract-method
+                # sourcery skip: dict-assign-update-to-union, extract-method, low-code-quality
                 _context = self.__contextualize(data)
                 _name: str = ""
                 __args: list = [_context]

interactions/api/gateway/heartbeat.py

@@ -1,3 +1,4 @@
+import contextlib
 from asyncio import AbstractEventLoop, Event
 from sys import version_info
 
@@ -15,8 +16,6 @@ def __init__(self, loop: AbstractEventLoop) -> None:
         :param loop: The event loop to base the asynchronous manager.
         :type loop: AbstractEventLoop
         """
-        try:
+        with contextlib.suppress(TypeError):
             self.event = Event(loop=loop) if version_info < (3, 10) else Event()
-        except TypeError:
-            pass
         self.delay = 0.0

interactions/api/http/invite.py

@@ -33,15 +33,16 @@ async def get_invite(
         """
         params_set = {
             "with_counts=true" if with_counts else None,
-            "with_expiration=false" if not with_expiration else None,
+            None if with_expiration else "with_expiration=false",
             f"guild_scheduled_event_id={guild_scheduled_event_id}"
             if guild_scheduled_event_id
             else None,
         }
+
         final = "&".join([item for item in params_set if item is not None])
 
         return await self._req.request(
-            Route("GET", f"/invites/{invite_code}{'?' + final if final is not None else ''}")
+            Route("GET", f"/invites/{invite_code}{f'?{final}' if final is not None else ''}")
         )
 
     async def delete_invite(self, invite_code: str, reason: Optional[str] = None) -> dict:

interactions/api/http/message.py

@@ -175,7 +175,7 @@ async def edit_message(
                     file._fp,
                 )
                 part.set_content_disposition(
-                    "form-data", name="files[" + str(id) + "]", filename=file._filename
+                    "form-data", name=f"files[{str(id)}]", filename=file._filename
                 )
 
         return await self._req.request(

interactions/api/http/reaction.py

@@ -137,8 +137,10 @@ async def get_reactions_of_emoji(
         return await self._req.request(
             Route(
                 "GET",
-                "/channels/{channel_id}/messages/{message_id}/reactions/{emoji}"
-                + f"{'?' + final if final is not None else ''}",
+                (
+                    "/channels/{channel_id}/messages/{message_id}/reactions/{emoji}"
+                    + f"{f'?{final}' if final is not None else ''}"
+                ),
                 channel_id=channel_id,
                 message_id=message_id,
                 emoji=emoji,

interactions/api/http/request.py

@@ -98,14 +98,14 @@ async def request(self, route: Route, **kwargs) -> Optional[Any]:
         :return: The contents of the request if any.
         :rtype: Optional[Any]
         """
+        # sourcery skip: low-code-quality
 
         kwargs["headers"] = {**self._headers, **kwargs.get("headers", {})}
 
         if kwargs.get("json"):
             kwargs["headers"]["Content-Type"] = "application/json"
 
-        reason = kwargs.pop("reason", None)
-        if reason:
+        if reason := kwargs.pop("reason", None):
             kwargs["headers"]["X-Audit-Log-Reason"] = quote(reason, safe="/ ")
 
         # Huge credit and thanks to LordOfPolls for the lock/retry logic.
@@ -185,21 +185,21 @@ async def request(self, route: Route, **kwargs) -> Optional[Any]:
                             severity=50,
                         )
                     if response.status == 429:
-                        if not is_global:
-                            log.warning(
-                                f"The HTTP client has encountered a per-route ratelimit. Locking down future requests for {reset_after} seconds."
-                            )
-                            _limiter.reset_after = reset_after
-                            await asyncio.sleep(_limiter.reset_after)
-                            continue
-                        else:
+                        if is_global:
                             log.warning(
                                 f"The HTTP client has encountered a global ratelimit. Locking down future requests for {reset_after} seconds."
                             )
                             self._global_lock.reset_after = reset_after
                             self._loop.call_later(
                                 self._global_lock.reset_after, self._global_lock.lock.release
                             )
+                        else:
+                            log.warning(
+                                f"The HTTP client has encountered a per-route ratelimit. Locking down future requests for {reset_after} seconds."
+                            )
+                            _limiter.reset_after = reset_after
+                            await asyncio.sleep(_limiter.reset_after)
+                            continue
                     if remaining is not None and int(remaining) == 0:
                         log.warning(
                             f"The HTTP client has exhausted a per-route ratelimit. Locking route for {reset_after} seconds."

interactions/api/http/scheduledEvent.py

@@ -38,8 +38,7 @@ async def create_scheduled_event(self, guild_id: Snowflake, payload: dict) -> di
         data = {k: v for k, v in payload.items() if k in valid_keys}
 
         return await self._req.request(
-            Route("POST", "/guilds/{guild_id}/scheduled-events", guild_id=int(guild_id)),
-            json=data,
+            Route("POST", "/guilds/{guild_id}/scheduled-events", guild_id=guild_id), json=data
         )
 
     async def get_scheduled_event(

interactions/api/models/attrs_utils.py

@@ -23,6 +23,7 @@ class DictSerializerMixin:
     """Should the kwargs be deepcopied or not?"""
 
     def __init__(self, kwargs_dict: dict = None, /, **other_kwargs):
+        # sourcery skip: low-code-quality
         kwargs = kwargs_dict or other_kwargs
         client = kwargs.pop("_client", None)
 

interactions/api/models/channel.py

@@ -199,7 +199,7 @@ async def send(
                 List["SelectMenu"],
             ]
         ] = MISSING,
-    ) -> "Message":
+    ) -> "Message":  # noqa  # sourcery skip: dict-assign-update-to-union
         """
         Sends a message in the channel.
 
@@ -757,7 +757,7 @@ async def purge(
         before: Optional[int] = MISSING,
         reason: Optional[str] = None,
         bulk: Optional[bool] = True,
-    ) -> List["Message"]:
+    ) -> List["Message"]:  # noqa  # sourcery skip: low-code-quality
         """
         Purges a given amount of messages from a channel. You can specify a check function to exclude specific messages.
 

interactions/api/models/guild.py

@@ -891,7 +891,7 @@ async def modify_channel(
         auto_archive_duration: Optional[int] = MISSING,
         locked: Optional[bool] = MISSING,
         reason: Optional[str] = None,
-    ) -> Channel:
+    ) -> Channel:  # sourcery skip: low-code-quality
         """
         Edits a channel of the guild.
 
@@ -1124,7 +1124,7 @@ async def modify(
         description: Optional[str] = MISSING,
         premium_progress_bar_enabled: Optional[bool] = MISSING,
         reason: Optional[str] = None,
-    ) -> "Guild":
+    ) -> "Guild":  # sourcery skip: low-code-quality
         """
         Modifies the current guild.
 
@@ -2181,7 +2181,7 @@ async def modify_auto_moderation_rule(
         exempt_roles: Optional[List[int]] = MISSING,
         exempt_channels: Optional[List[int]] = MISSING,
         reason: Optional[str] = None,
-    ) -> "AutoModerationRule":
+    ) -> "AutoModerationRule":  # noqa  # sourcery skip: compare-via-equals
         """
         Edits an AutoMod rule