Merge branch 'feat/voice-rewrite-and-fixes' of https://github.com/DA-344/pycord into feat/voice-rewrite-and-fixes

Author: DA-344

discord/opus.py

@@ -581,7 +581,9 @@ def run(self):
                         data.decrypted_data
                     )
             except OpusError:
-                _log.exception("Error occurred while decoding opus frame.", exc_info=True)
+                _log.exception(
+                    "Error occurred while decoding opus frame.", exc_info=True
+                )
                 continue
 
             self.client.receive_audio(data)

discord/voice/_types.py

@@ -26,7 +26,7 @@
 from __future__ import annotations
 
 from collections.abc import Awaitable, Callable
-from typing import TYPE_CHECKING, Any, Generic, TypeVar, Union
+from typing import TYPE_CHECKING, Generic, TypeVar, Union
 
 if TYPE_CHECKING:
     from typing_extensions import ParamSpec
@@ -39,12 +39,12 @@
     )
     from discord.sinks import Sink
 
-    P = ParamSpec('P')
-    R = TypeVar('R')
+    P = ParamSpec("P")
+    R = TypeVar("R")
     RecordCallback = Union[Callable[P, R], Callable[P, Awaitable[R]]]
 
 ClientT = TypeVar("ClientT", bound="Client", covariant=True)
-VoiceProtocolT = TypeVar('VoiceProtocolT', bound='VoiceProtocol', covariant=True)
+VoiceProtocolT = TypeVar("VoiceProtocolT", bound="VoiceProtocol", covariant=True)
 
 
 class VoiceProtocol(Generic[ClientT]):
@@ -195,7 +195,9 @@ class VoiceRecorderProtocol(Generic[VoiceProtocolT]):
         :attr:`VoiceProtocol.channel`
     """
 
-    def __init__(self, client: VoiceProtocolT, channel: abc.Connectable | None = None) -> None:
+    def __init__(
+        self, client: VoiceProtocolT, channel: abc.Connectable | None = None
+    ) -> None:
         self.client: VoiceProtocolT = client
         self.channel: abc.Connectable = channel or client.channel
 
@@ -212,7 +214,7 @@ def get_ssrc(self, user_id: int) -> int:
         :class:`int`
             The ssrc for the provided user ID.
         """
-        raise NotImplementedError('subclasses must implement this')
+        raise NotImplementedError("subclasses must implement this")
 
     def unpack(self, data: bytes) -> bytes | None:
         """Takes an audio packet received from Discord and decodes it.
@@ -227,7 +229,7 @@ def unpack(self, data: bytes) -> bytes | None:
         Optional[:class:`bytes`]
             The unpacked bytes, or ``None`` if they could not be unpacked.
         """
-        raise NotImplementedError('subclasses must implement this')
+        raise NotImplementedError("subclasses must implement this")
 
     def record(
         self,
@@ -259,8 +261,8 @@ def record(
         TypeError
             You did not pass a Sink object.
         """
-        raise NotImplementedError('subclasses must implement this')
+        raise NotImplementedError("subclasses must implement this")
 
     def stop(self) -> None:
         """Stops recording."""
-        raise NotImplementedError('subclasses must implement this')
+        raise NotImplementedError("subclasses must implement this")