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

Author: pre-commit-ci[bot]

discord/client.py

@@ -27,7 +27,6 @@
 
 import asyncio
 import logging
-import signal
 import sys
 import traceback
 from types import TracebackType
@@ -467,7 +466,7 @@ def _schedule_event(
         return task
 
     def dispatch(self, event: str, *args: Any, **kwargs: Any) -> None:
-        logging.getLogger('discord.state').debug("Dispatching event %s", event)
+        logging.getLogger("discord.state").debug("Dispatching event %s", event)
         method = f"on_{event}"
 
         listeners = self._listeners.get(event)
@@ -822,7 +821,7 @@ def run(
             is blocking. That means that registration of events or anything being
             called after this function call will not execute until it returns.
         """
-        loop = self.loop
+        self.loop
 
         async def runner():
             async with self:

discord/player.py

@@ -36,14 +36,14 @@
 import sys
 import threading
 import time
-import traceback
 from math import floor
 from typing import IO, TYPE_CHECKING, Any, Callable, Generic, TypeVar
 
-from .errors import ClientException
 from .enums import SpeakingState
+from .errors import ClientException
 from .oggparse import OggStream
-from .opus import Encoder as OpusEncoder, OPUS_SILENCE
+from .opus import OPUS_SILENCE
+from .opus import Encoder as OpusEncoder
 from .utils import MISSING
 
 if TYPE_CHECKING:
@@ -766,13 +766,13 @@ def _do_run(self) -> None:
 
             # are we disconnected from voice?
             if not client.is_connected():
-                _log.debug('Not connected, waiting for %ss...', client.timeout)
+                _log.debug("Not connected, waiting for %ss...", client.timeout)
                 # wait until we are connected, but not forever
                 connected = client.wait_until_connected(client.timeout)
                 if self._end.is_set() or not connected:
-                    _log.debug('Aborting playback')
+                    _log.debug("Aborting playback")
                     return
-                _log.debug('Reconnected, resuming playback')
+                _log.debug("Reconnected, resuming playback")
                 self._speak(SpeakingState.voice)
                 # reset our internal data
                 self.loops = 0

discord/utils.py

@@ -1413,24 +1413,26 @@ def filter_params(params, **kwargs):
 
 
 def is_docker() -> bool:
-    path = '/proc/self/cgroup'
-    return os.path.exists('/.dockerenv') or (os.path.isfile(path) and any('docker' in line for line in open(path)))
+    path = "/proc/self/cgroup"
+    return os.path.exists("/.dockerenv") or (
+        os.path.isfile(path) and any("docker" in line for line in open(path))
+    )
 
 
 def stream_supports_colour(stream: Any) -> bool:
-    is_a_tty = hasattr(stream, 'isatty') and stream.isatty()
+    is_a_tty = hasattr(stream, "isatty") and stream.isatty()
 
     # Pycharm and Vscode support colour in their inbuilt editors
-    if 'PYCHARM_HOSTED' in os.environ or os.environ.get('TERM_PROGRAM') == 'vscode':
+    if "PYCHARM_HOSTED" in os.environ or os.environ.get("TERM_PROGRAM") == "vscode":
         return is_a_tty
 
-    if sys.platform != 'win32':
+    if sys.platform != "win32":
         # Docker does not consistently have a tty attached to it
         return is_a_tty or is_docker()
 
     # ANSICON checks for things like ConEmu
     # WT_SESSION checks if this is Windows Terminal
-    return is_a_tty and ('ANSICON' in os.environ or 'WT_SESSION' in os.environ)
+    return is_a_tty and ("ANSICON" in os.environ or "WT_SESSION" in os.environ)
 
 
 class _ColourFormatter(logging.Formatter):
@@ -1444,17 +1446,17 @@ class _ColourFormatter(logging.Formatter):
     # 1 means bold, 2 means dim, 0 means reset, and 4 means underline.
 
     LEVEL_COLOURS = [
-        (logging.DEBUG, '\x1b[40;1m'),
-        (logging.INFO, '\x1b[34;1m'),
-        (logging.WARNING, '\x1b[33;1m'),
-        (logging.ERROR, '\x1b[31m'),
-        (logging.CRITICAL, '\x1b[41m'),
+        (logging.DEBUG, "\x1b[40;1m"),
+        (logging.INFO, "\x1b[34;1m"),
+        (logging.WARNING, "\x1b[33;1m"),
+        (logging.ERROR, "\x1b[31m"),
+        (logging.CRITICAL, "\x1b[41m"),
     ]
 
     FORMATS = {
         level: logging.Formatter(
-            f'\x1b[30;1m%(asctime)s\x1b[0m {colour}%(levelname)-8s\x1b[0m \x1b[35m%(name)s\x1b[0m %(message)s',
-            '%Y-%m-%d %H:%M:%S',
+            f"\x1b[30;1m%(asctime)s\x1b[0m {colour}%(levelname)-8s\x1b[0m \x1b[35m%(name)s\x1b[0m %(message)s",
+            "%Y-%m-%d %H:%M:%S",
         )
         for level, colour in LEVEL_COLOURS
     }
@@ -1467,7 +1469,7 @@ def format(self, record):
         # Override the traceback to always print in red
         if record.exc_info:
             text = formatter.formatException(record.exc_info)
-            record.exc_text = f'\x1b[31m{text}\x1b[0m'
+            record.exc_text = f"\x1b[31m{text}\x1b[0m"
 
         output = formatter.format(record)
 
@@ -1483,8 +1485,7 @@ def setup_logging(
     level: int = MISSING,
     root: bool = True,
 ) -> None:
-    """A helper method to automatically setup the library's default logging.
-    """
+    """A helper method to automatically setup the library's default logging."""
 
     if level is MISSING:
         level = logging.INFO
@@ -1493,16 +1494,20 @@ def setup_logging(
         handler = logging.StreamHandler()
 
     if formatter is MISSING:
-        if isinstance(handler, logging.StreamHandler) and stream_supports_colour(handler.stream):
+        if isinstance(handler, logging.StreamHandler) and stream_supports_colour(
+            handler.stream
+        ):
             formatter = _ColourFormatter()
         else:
-            dt_fmt = '%Y-%m-%d %H:%M:%S'
-            formatter = logging.Formatter('[{asctime}] [{levelname:<8}] {name}: {message}', dt_fmt, style='{')
+            dt_fmt = "%Y-%m-%d %H:%M:%S"
+            formatter = logging.Formatter(
+                "[{asctime}] [{levelname:<8}] {name}: {message}", dt_fmt, style="{"
+            )
 
     if root:
         logger = logging.getLogger()
     else:
-        lib, _, _ = __name__.partition('.')
+        lib, _, _ = __name__.partition(".")
         logger = logging.getLogger(lib)
 
     handler.setFormatter(formatter)

discord/voice/client.py

@@ -34,11 +34,12 @@
 
 from discord import opus
 from discord.errors import ClientException
+from discord.player import AudioPlayer, AudioSource
 from discord.utils import MISSING
-from discord.player import AudioSource, AudioPlayer
 
 from ._types import VoiceProtocol
-#from .recorder import VoiceRecorderClient
+
+# from .recorder import VoiceRecorderClient
 from .state import VoiceConnectionState
 
 if TYPE_CHECKING:
@@ -134,8 +135,8 @@ def __init__(
         self._connection: VoiceConnectionState = self.create_connection_state()
 
         # voice recv things
-        #self._recorder: VoiceRecorderClient | None = None
-        #if use_recorder:
+        # self._recorder: VoiceRecorderClient | None = None
+        # if use_recorder:
         #    self._recorder = VoiceRecorderClient(self)
 
     warn_nacl: bool = not has_nacl
@@ -551,10 +552,10 @@ def source(self) -> AudioSource | None:
     @source.setter
     def source(self, value: AudioSource) -> None:
         if not isinstance(value, AudioSource):
-            raise TypeError(f'expected AudioSource, not {value.__class__.__name__}')
+            raise TypeError(f"expected AudioSource, not {value.__class__.__name__}")
 
         if self._player is None:
-            raise ValueError('the client is not playing anything')
+            raise ValueError("the client is not playing anything")
 
         self._player._set_source(value)
 
@@ -578,7 +579,7 @@ def send_audio_packet(self, data: bytes, *, encode: bool = True) -> None:
             Encoding the data failed.
         """
 
-        self.checked_add('sequence', 1, 65535)
+        self.checked_add("sequence", 1, 65535)
         if encode:
             encoded = self.encoder.encode(data, self.encoder.SAMPLES_PER_FRAME)
         else:
@@ -588,9 +589,13 @@ def send_audio_packet(self, data: bytes, *, encode: bool = True) -> None:
         try:
             self._connection.send_packet(packet)
         except OSError:
-            _log.debug('A packet has been dropped (seq: %s, timestamp: %s)', self.sequence, self.timestamp)
+            _log.debug(
+                "A packet has been dropped (seq: %s, timestamp: %s)",
+                self.sequence,
+                self.timestamp,
+            )
 
-        self.checked_add('timestamp', opus.Encoder.SAMPLES_PER_FRAME, 4294967295)
+        self.checked_add("timestamp", opus.Encoder.SAMPLES_PER_FRAME, 4294967295)
 
     def elapsed(self) -> datetime.timedelta:
         """Returns the elapsed time of the playing audio."""

discord/voice/gateway.py

@@ -205,29 +205,29 @@ async def ready(self, data: dict[str, Any]) -> None:
         )
 
         _log.debug(
-            'Connected socket to %s (port %s)',
+            "Connected socket to %s (port %s)",
             state.endpoint_ip,
             state.voice_port,
         )
 
         state.ip, state.port = await self.get_ip()
 
-        modes = [mode for mode in data['modes'] if mode in self.state.supported_modes]
-        _log.debug('Received available voice connection modes: %s', modes)
+        modes = [mode for mode in data["modes"] if mode in self.state.supported_modes]
+        _log.debug("Received available voice connection modes: %s", modes)
 
         mode = modes[0]
         await self.select_protocol(state.ip, state.port, mode)
-        _log.debug('Selected voice protocol %s for this connection', mode)
+        _log.debug("Selected voice protocol %s for this connection", mode)
 
     async def select_protocol(self, ip: str, port: int, mode: str) -> None:
         payload = {
-            'op': int(OpCodes.select_protocol),
-            'd': {
-                'protocol': 'udp',
-                'data': {
-                    'address': ip,
-                    'port': port,
-                    'mode': mode,
+            "op": int(OpCodes.select_protocol),
+            "d": {
+                "protocol": "udp",
+                "data": {
+                    "address": ip,
+                    "port": port,
+                    "mode": mode,
                 },
             },
         }
@@ -346,12 +346,12 @@ async def from_state(
     async def identify(self) -> None:
         state = self.state
         payload = {
-            'op': int(OpCodes.identify),
-            'd': {
-                'server_id': str(state.server_id),
-                'user_id': str(state.user.id),
-                'session_id': self.session_id,
-                'token': self.token,
+            "op": int(OpCodes.identify),
+            "d": {
+                "server_id": str(state.server_id),
+                "user_id": str(state.user.id),
+                "session_id": self.session_id,
+                "token": self.token,
             },
         }
         await self.send_as_json(payload)

discord/voice/recorder.py

@@ -39,7 +39,7 @@
     from .client import VoiceClient
     from .gateway import VoiceWebSocket
 
-    VoiceClientT = TypeVar('VoiceClientT', bound=VoiceClient, covariant=True)
+    VoiceClientT = TypeVar("VoiceClientT", bound=VoiceClient, covariant=True)
 
 
 class VoiceRecorderClient(VoiceRecorderProtocol[VoiceClientT]):
@@ -67,11 +67,9 @@ def is_recording(self) -> bool:
         """Whether the current recording is actively recording."""
         return self._recording.is_set()
 
-    async def hook(self, ws: VoiceWebSocket, data: dict[str, Any]) -> None:
-        ...
+    async def hook(self, ws: VoiceWebSocket, data: dict[str, Any]) -> None: ...
 
     def record(
         self,
         sink: Sink,
-    ) -> int:
-        ...
+    ) -> int: ...

discord/voice/state.py

@@ -479,7 +479,11 @@ async def disconnect(
         if not force and not self.is_connected():
             return
 
-        _log.debug('Attempting a voice disconnect for channel %s (guild %s)', self.channel_id, self.guild_id)
+        _log.debug(
+            "Attempting a voice disconnect for channel %s (guild %s)",
+            self.channel_id,
+            self.guild_id,
+        )
         try:
             await self._voice_disconnect()
             if self.ws: