style(pre-commit): auto fixes from pre-commit.com hooks

Author: pre-commit-ci[bot]

discord/sinks/core.py

@@ -26,14 +26,14 @@
 from __future__ import annotations
 
 import asyncio
-from collections.abc import Callable, Coroutine
-from functools import partial
 import io
 import os
 import struct
 import sys
 import threading
 import time
+from collections.abc import Callable, Coroutine
+from functools import partial
 from typing import TYPE_CHECKING, Any, TypeVar, overload
 
 from discord.utils import MISSING
@@ -46,10 +46,11 @@
 
     from discord import abc
     from discord.types import snowflake
+
     from ..voice.client import VoiceClient
 
-    R = TypeVar('R')
-    P = ParamSpec('P')
+    R = TypeVar("R")
+    P = ParamSpec("P")
 
 __all__ = (
     "Filters",
@@ -81,12 +82,18 @@ class Filter:
     """
 
     @overload
-    async def filter(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) -> bool: ...
+    async def filter(
+        self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData
+    ) -> bool: ...
 
     @overload
-    def filter(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) -> bool: ...
+    def filter(
+        self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData
+    ) -> bool: ...
 
-    def filter(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) -> bool | Coroutine[Any, Any, bool]:
+    def filter(
+        self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData
+    ) -> bool | Coroutine[Any, Any, bool]:
         """|maybecoro|
 
         Represents the filter callback.
@@ -110,11 +117,10 @@ def filter(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) ->
         :class:`bool`
             Whether the filter was successful.
         """
-        raise NotImplementedError('subclasses must implement this')
+        raise NotImplementedError("subclasses must implement this")
 
     def cleanup(self) -> None:
         """A function called when the filter is ready for cleanup."""
-        pass
 
 
 class Handler:
@@ -126,12 +132,18 @@ class Handler:
     """
 
     @overload
-    async def handle(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) -> Any: ...
+    async def handle(
+        self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData
+    ) -> Any: ...
 
     @overload
-    def handle(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) -> Any: ...
+    def handle(
+        self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData
+    ) -> Any: ...
 
-    def handle(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) -> Any | Coroutine[Any, Any, Any]:
+    def handle(
+        self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData
+    ) -> Any | Coroutine[Any, Any, Any]:
         """|maybecoro|
 
         Represents the handler callback.
@@ -149,11 +161,10 @@ def handle(self, sink: Sink, user: abc.Snowflake, ssrc: int, packet: RawData) ->
         packet: :class:`~.RawData`
             The raw data packet.
         """
-        raise NotImplementedError('subclasses must implement this')
+        raise NotImplementedError("subclasses must implement this")
 
     def cleanup(self) -> None:
         """A function called when the handler is ready for cleanup."""
-        pass
 
 
 class Filters:
@@ -383,10 +394,12 @@ def __init_subclass__(cls) -> None:
                 elif isinstance(value, classmethod):
                     value = partial(value.__func__, cls)
 
-                if not hasattr(value, '__listener__'):
+                if not hasattr(value, "__listener__"):
                     continue
 
-                event_name = getattr(value, '__listener_name__', elem).removeprefix('on_')
+                event_name = getattr(value, "__listener_name__", elem).removeprefix(
+                    "on_"
+                )
 
                 try:
                     listeners[event_name].append(value)
@@ -408,14 +421,14 @@ def __init__(
         self.__dispatch_set: set[asyncio.Task[Any]] = set()
 
     def dispatch(self, event: str, *args: Any, **kwargs: Any) -> Any:
-        event = event.removeprefix('on_')
+        event = event.removeprefix("on_")
 
         listeners = self.__listeners__.get(event, [])
 
         for listener in listeners:
             task = asyncio.create_task(
                 listener(*args, **kwargs),
-                name=f'dispatch-{event}:{id(listener):#x}',
+                name=f"dispatch-{event}:{id(listener):#x}",
             )
             self.__dispatch_set.add(task)
             task.add_done_callback(self.__dispatch_set.remove)
@@ -455,7 +468,9 @@ def add_filter(self, filter: Filter, /) -> None:
         """
 
         if not isinstance(filter, Filter):
-            raise TypeError(f'expected a Filter object, not {filter.__class__.__name__}')
+            raise TypeError(
+                f"expected a Filter object, not {filter.__class__.__name__}"
+            )
         self._filters.append(filter)
 
     def remove_filter(self, filter: Filter, /) -> None:
@@ -487,7 +502,9 @@ def add_handler(self, handler: Handler, /) -> None:
         """
 
         if not isinstance(handler, Handler):
-            raise TypeError(f'expected a Handler object, not {handler.__class__.__name__}')
+            raise TypeError(
+                f"expected a Handler object, not {handler.__class__.__name__}"
+            )
         self._handlers.append(handler)
 
     def remove_handler(self, handler: Handler, /) -> None:
@@ -505,22 +522,16 @@ def remove_handler(self, handler: Handler, /) -> None:
             pass
 
     @staticmethod
-    def listener(event: str = MISSING) -> Callable[[Callable[P, Coroutine[Any, Any, R]]], Callable[P, Coroutine[Any, Any, R]]]:
+    def listener(
+        event: str = MISSING,
+    ) -> Callable[
+        [Callable[P, Coroutine[Any, Any, R]]], Callable[P, Coroutine[Any, Any, R]]
+    ]:
         """Registers a function to be an event listener for this sink.
 
         The events must be a :ref:`coroutine <coroutine>`, if not, :exc:`TypeError` is raised; and
         also must be inside a sink class.
 
-        Example
-        -------
-
-        .. code-block:: python3
-
-            class MySink(Sink):
-                @Sink.listener()
-                async def on_member_speaking_state_update(member, ssrc, state):
-                    pass
-
         Parameters
         ----------
         event: :class:`str`
@@ -530,22 +541,37 @@ async def on_member_speaking_state_update(member, ssrc, state):
         ------
         TypeError
             The coroutine passed is not actually a coroutine, or the listener is not in a sink class.
+
+        Example
+        -------
+
+        .. code-block:: python3
+
+            class MySink(Sink):
+                @Sink.listener()
+                async def on_member_speaking_state_update(member, ssrc, state):
+                    pass
         """
 
-        def decorator(func: Callable[P, Coroutine[Any, Any, R]]) -> Callable[P, Coroutine[Any, Any, R]]:
-            parts = func.__qualname__.split('.')
+        def decorator(
+            func: Callable[P, Coroutine[Any, Any, R]],
+        ) -> Callable[P, Coroutine[Any, Any, R]]:
+            parts = func.__qualname__.split(".")
 
             if not parts or not len(parts) > 1:
-                raise TypeError('event listeners must be declared in a Sink class')
+                raise TypeError("event listeners must be declared in a Sink class")
 
             if parts[-1] != func.__name__:
-                raise NameError('qualified name and function name mismatch, this should not happen')
+                raise NameError(
+                    "qualified name and function name mismatch, this should not happen"
+                )
 
             if not asyncio.iscoroutinefunction(func):
-                raise TypeError('event listeners must be coroutine functions')
+                raise TypeError("event listeners must be coroutine functions")
 
             func.__listener__ = True
             if event is not MISSING:
                 func.__listener_name__ = event
             return func
+
         return decorator

discord/sinks/enums.py

@@ -22,6 +22,7 @@
 FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
 DEALINGS IN THE SOFTWARE.
 """
+
 from __future__ import annotations
 
 from discord.enums import Enum

discord/voice/flags.py

@@ -22,6 +22,7 @@
 FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
 DEALINGS IN THE SOFTWARE.
 """
+
 from __future__ import annotations
 
 from discord.flags import BaseFlags, fill_with_flags, flag_value

discord/voice/state.py

@@ -39,8 +39,8 @@
 from discord.object import Object
 
 from .enums import ConnectionFlowState, OpCodes
-from .gateway import VoiceWebSocket
 from .flags import SpeakingFlags
+from .gateway import VoiceWebSocket
 
 if TYPE_CHECKING:
     from discord import abc
@@ -129,7 +129,7 @@ def run(self) -> None:
             self._do_run()
         except Exception:
             _log.exception(
-                'An error ocurred while running the socket reader %s',
+                "An error ocurred while running the socket reader %s",
                 self.name,
             )
         finally:
@@ -143,11 +143,14 @@ def _do_run(self) -> None:
 
 class SocketVoiceRecvReader(SocketReader):
     def __init__(
-        self, state: VoiceConnectionState, *, start_paused: bool = True,
+        self,
+        state: VoiceConnectionState,
+        *,
+        start_paused: bool = True,
     ) -> None:
         super().__init__(
             state,
-            f'voice-recv-socket-reader:{id(self):#x}',
+            f"voice-recv-socket-reader:{id(self):#x}",
             start_paused=start_paused,
         )
 
@@ -174,7 +177,7 @@ def _do_run(self) -> None:
                 data = self.state.socket.recv(4096)
             except OSError:
                 _log.debug(
-                    'Error reading from socket in %s, this should be safe to ignore',
+                    "Error reading from socket in %s, this should be safe to ignore",
                     self,
                     exc_info=True,
                 )
@@ -184,7 +187,7 @@ def _do_run(self) -> None:
                         cb(data)
                     except Exception:
                         _log.exception(
-                            'Error while calling %s in %s',
+                            "Error while calling %s in %s",
                             cb,
                             self,
                         )
@@ -196,7 +199,7 @@ def __init__(
     ) -> None:
         super().__init__(
             state,
-            f'voice-socket-event-reader:{id(self):#x}',
+            f"voice-socket-event-reader:{id(self):#x}",
             start_paused=start_paused,
         )
 
@@ -300,24 +303,28 @@ def get_user_by_ssrc(self, ssrc: int) -> abc.Snowflake | None:
         if data is None:
             return None
 
-        user = int(data['user_id'])
-        return self.guild.get_member(user) or self.client._state.get_user(user) or Object(id=user)
+        user = int(data["user_id"])
+        return (
+            self.guild.get_member(user)
+            or self.client._state.get_user(user)
+            or Object(id=user)
+        )
 
     def ws_hook(self, ws: VoiceWebSocket, msg: dict[str, Any]) -> None:
-        op = msg['op']
-        data = msg.get('d', {})
+        op = msg["op"]
+        data = msg.get("d", {})
 
         if op == OpCodes.speaking:
-            ssrc = data['ssrc']
-            user = int(data['user_id'])
-            speaking = data['speaking']
+            ssrc = data["ssrc"]
+            user = int(data["user_id"])
+            speaking = data["speaking"]
 
             if ssrc in self.user_ssrc_map:
-                self.user_ssrc_map[ssrc]['speaking'].value = speaking
+                self.user_ssrc_map[ssrc]["speaking"].value = speaking
             else:
                 self.user_ssrc_map[ssrc] = {
-                    'user_id': user,
-                    'speaking': SpeakingFlags._from_value(speaking),
+                    "user_id": user,
+                    "speaking": SpeakingFlags._from_value(speaking),
                 }
 
     @property