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

Author: pre-commit-ci[bot]

discord/gateway.py

@@ -28,7 +28,6 @@
 import asyncio
 import concurrent.futures
 import logging
-import struct
 import sys
 import threading
 import time

discord/opus.py

@@ -34,8 +34,6 @@
 import os.path
 import struct
 import sys
-import threading
-import time
 from typing import TYPE_CHECKING, Any, Callable, Literal, TypedDict, TypeVar
 
 from .errors import DiscordException
@@ -525,7 +523,9 @@ def _get_last_packet_duration(self):
 
     def decode(self, data, *, fec=False):
         if data is None and fec:
-            raise OpusError(message="Invalid arguments: FEC cannot be used with null data")
+            raise OpusError(
+                message="Invalid arguments: FEC cannot be used with null data"
+            )
 
         if data is None:
             frame_size = self._get_last_packet_duration() or self.SAMPLES_PER_FRAME

discord/sinks/core.py

@@ -26,17 +26,16 @@
 from __future__ import annotations
 
 import asyncio
-from collections import namedtuple
 import logging
 import struct
 import sys
 import time
+from collections import namedtuple
 from collections.abc import Callable, Coroutine, Iterable
 from functools import partial
-import threading
 from typing import TYPE_CHECKING, Any, Generic, TypeVar, overload
 
-from discord import utils, opus
+from discord import opus, utils
 from discord.enums import SpeakingState
 from discord.utils import MISSING
 
@@ -154,16 +153,25 @@ def filter_speaking_state(
 
     @overload
     async def filter_user_connect(
-        self, sink: S, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        sink: S,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> bool: ...
 
     @overload
     def filter_user_connect(
-        self, sink: S, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        sink: S,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> bool: ...
 
     def filter_user_connect(
-        self, sink: S, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        sink: S,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> bool | Coroutine[Any, Any, bool]:
         """|maybecoro|
 
@@ -256,16 +264,25 @@ def handle_speaking_state(
 
     @overload
     async def handle_user_connect(
-        self, sink: S, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        sink: S,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> Any: ...
 
     @overload
     def handle_user_connect(
-        self, sink: S, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        sink: S,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> Any: ...
 
     def handle_user_connect(
-        self, sink: S, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        sink: S,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> Any | Coroutine[Any, Any, Any]:
         """|maybecoro|
 
@@ -292,9 +309,9 @@ class RawData:
     .. versionadded:: 2.0
     """
 
-    unpacker = struct.Struct('>xxHII')
-    _ext_header = namedtuple('Extension', 'profile length values')
-    _ext_magic = b'\xbe\xde'
+    unpacker = struct.Struct(">xxHII")
+    _ext_header = namedtuple("Extension", "profile length values")
+    _ext_magic = b"\xbe\xde"
 
     if TYPE_CHECKING:
         sequence: int
@@ -322,14 +339,14 @@ def __init__(self, raw_data: bytes, client: VoiceClient):
         self.decrypted_data: bytes | None = None
         self.decoded_data: bytes = MISSING
 
-        self.nonce: bytes = b''
+        self.nonce: bytes = b""
         self._rtpsize: bool = False
 
         self._decoder: opus.Decoder = opus.Decoder()
         self.receive_time: float = time.perf_counter()
 
         if self.cc:
-            fmt = '>%sI' % self.cc
+            fmt = ">%sI" % self.cc
             offset = struct.calcsize(fmt) + 12
             self.csrcs = struct.unpack(fmt, data[12:offset])
             self.data = data[offset:]
@@ -351,12 +368,12 @@ def update_headers(self, data: bytes) -> int:
         if self._rtpsize:
             data = self.header[-4:] + data
 
-        profile, length = struct.unpack_from('>2sH', data)
+        profile, length = struct.unpack_from(">2sH", data)
 
         if profile == self._ext_magic:
             self._parse_bede_header(data, length)
 
-        values = struct.unpack('>%sI' % length, data[4 : 4 + length * 4])
+        values = struct.unpack(">%sI" % length, data[4 : 4 + length * 4])
         self.extension = self._ext_header(profile, length, values)
 
         offset = 4 + length * 4
@@ -371,23 +388,25 @@ def _parse_bede_header(self, data: bytes, length: int) -> None:
         while n < length:
             next_byte = data[offset : offset + 1]
 
-            if next_byte == b'\x00':
+            if next_byte == b"\x00":
                 offset += 1
                 continue
 
-            header = struct.unpack('>B', next_byte)[0]
+            header = struct.unpack(">B", next_byte)[0]
 
             element_id = header >> 4
             element_len = 1 + (header & 0b0000_1111)
 
-            self.extension_data[element_id] = data[offset + 1 : offset + 1 + element_len]
+            self.extension_data[element_id] = data[
+                offset + 1 : offset + 1 + element_len
+            ]
             offset += 1 + element_len
             n += 1
 
     async def decode(self) -> bytes:
         if not self.decrypted_data:
-            _log.debug('Attempted to decode an empty decrypted data frame')
-            return b''
+            _log.debug("Attempted to decode an empty decrypted data frame")
+            return b""
 
         return await asyncio.to_thread(
             self._decoder.decode,
@@ -529,7 +548,9 @@ def _call_voice_packet_handlers(self, user: abc.Snowflake, packet: RawData) -> N
             task.add_done_callback(self.__dispatch_set.discard)
 
     def _call_user_connect_handlers(
-        self, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> None:
         for handler in self._handlers:
             task = asyncio.create_task(
@@ -742,7 +763,9 @@ async def on_unfiltered_speaking_state_update(
         pass
 
     async def on_user_connect(
-        self, user: abc.Snowflake, channel: abc.Snowflake,
+        self,
+        user: abc.Snowflake,
+        channel: abc.Snowflake,
     ) -> None:
         pass
 

discord/sinks/m4a.py

@@ -47,9 +47,7 @@
 
 _log = logging.getLogger(__name__)
 
-__all__ = (
-    "M4ASink",
-)
+__all__ = ("M4ASink",)
 
 
 class M4ASink(Sink):

discord/sinks/mka.py

@@ -45,9 +45,7 @@
 
 _log = logging.getLogger(__name__)
 
-__all__ = (
-    "MKASink",
-)
+__all__ = ("MKASink",)
 
 
 class MKASink(Sink):

discord/sinks/mkv.py

@@ -45,9 +45,7 @@
 
 _log = logging.getLogger(__name__)
 
-__all__ = (
-    "MKVSink",
-)
+__all__ = ("MKVSink",)
 
 
 class MKVSink(Sink):

discord/sinks/mp3.py

@@ -45,9 +45,7 @@
 
 _log = logging.getLogger(__name__)
 
-__all__ = (
-    "MP3Sink",
-)
+__all__ = ("MP3Sink",)
 
 
 class MP3Sink(Sink):
@@ -92,12 +90,12 @@ def __init__(
     def get_user_audio(self, user_id: int) -> io.BytesIO | None:
         """Gets a user's saved audio data, or ``None``."""
         ret = self.__audio_data.get(user_id)
-        _log.debug('Found stored user ID %s with buffer %s', user_id, ret)
+        _log.debug("Found stored user ID %s with buffer %s", user_id, ret)
         return ret
 
     def _create_audio_packet_for(self, uid: int) -> io.BytesIO:
         data = self.__audio_data[uid] = io.BytesIO()
-        _log.debug('Created user ID %s buffer', uid)
+        _log.debug("Created user ID %s buffer", uid)
         return data
 
     @overload

discord/sinks/mp4.py

@@ -47,9 +47,7 @@
 
 _log = logging.getLogger(__name__)
 
-__all__ = (
-    "MP4Sink",
-)
+__all__ = ("MP4Sink",)
 
 
 class MP4Sink(Sink):

discord/sinks/ogg.py

@@ -45,9 +45,7 @@
 
 _log = logging.getLogger(__name__)
 
-__all__ = (
-    "OGGSink",
-)
+__all__ = ("OGGSink",)
 
 
 class OGGSink(Sink):

discord/sinks/pcm.py

@@ -39,9 +39,7 @@
 
     from discord import abc
 
-__all__ = (
-    "PCMSink",
-)
+__all__ = ("PCMSink",)
 
 
 class PCMSink(Sink):