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

Author: pre-commit-ci[bot]

discord/gateway.py

@@ -33,7 +33,6 @@
 import time
 import traceback
 import zlib
-from collections import deque
 from collections.abc import Callable
 from typing import TYPE_CHECKING, Any, NamedTuple
 

discord/voice/gateway.py

@@ -35,8 +35,8 @@
 from typing import TYPE_CHECKING, Any
 
 import aiohttp
-
 import davey
+
 from discord import utils
 from discord.enums import SpeakingState
 from discord.errors import ConnectionClosed
@@ -152,7 +152,9 @@ async def _hook(self, *args: Any) -> Any:
 
     async def send_as_bytes(self, op: int, data: bytes) -> None:
         packet = bytes(op) + data
-        _log.debug("Sending voice websocket binary frame: op: %s data: %s", op, str(data))
+        _log.debug(
+            "Sending voice websocket binary frame: op: %s data: %s", op, str(data)
+        )
         await self.ws.send_bytes(packet)
 
     async def send_as_json(self, data: Any) -> None:
@@ -208,7 +210,10 @@ async def received_message(self, msg: Any, /):
             self._keep_alive.start()
         elif self.dave_session:
             if op == OpCodes.dave_prepare_transition:
-                _log.info("Preparing to upgrade to a DAVE connection for channel %s", state.channel_id)
+                _log.info(
+                    "Preparing to upgrade to a DAVE connection for channel %s",
+                    state.channel_id,
+                )
                 state.dave_pending_transition = data
 
                 transition_id = data["transition_id"]
@@ -220,11 +225,17 @@ async def received_message(self, msg: Any, /):
                         self.dave_session.set_passthrough_mode(True, 120)
                     await self.send_dave_transition_ready(transition_id)
             elif op == OpCodes.dave_execute_transition:
-                _log.info("Upgrading to DAVE connection for channel %s", state.channel_id)
+                _log.info(
+                    "Upgrading to DAVE connection for channel %s", state.channel_id
+                )
                 await state.execute_dave_transition(data["transition_id"])
             elif op == OpCodes.dave_prepare_epoch:
                 epoch = data["epoch"]
-                _log.debug("Preparing for DAVE epoch in channel %s: %s", state.channel_id, epoch)
+                _log.debug(
+                    "Preparing for DAVE epoch in channel %s: %s",
+                    state.channel_id,
+                    epoch,
+                )
                 # if epoch is 1 then a new MLS group is to be created for the proto version
                 if epoch == 1:
                     state.dave_protocol_version = data["protocol_version"]
@@ -237,7 +248,12 @@ async def received_message(self, msg: Any, /):
     async def received_binary_message(self, msg: bytes) -> None:
         self.seq_ack = struct.unpack_from(">H", msg, 0)[0]
         op = msg[2]
-        _log.debug("Voice websocket binary frame received: %d bytes, seq: %s, op: %s", len(msg), self.seq_ack, op)
+        _log.debug(
+            "Voice websocket binary frame received: %d bytes, seq: %s, op: %s",
+            len(msg),
+            self.seq_ack,
+            op,
+        )
 
         state = self.state
 
@@ -249,14 +265,22 @@ async def received_binary_message(self, msg: bytes) -> None:
         elif op == OpCodes.mls_proposals:
             op_type = msg[3]
             result = self.dave_session.process_proposals(
-                davey.ProposalsOperationType.append if op_type == 0 else davey.ProposalsOperationType.revoke,
+                (
+                    davey.ProposalsOperationType.append
+                    if op_type == 0
+                    else davey.ProposalsOperationType.revoke
+                ),
                 msg[4:],
             )
 
             if isinstance(result, davey.CommitWelcome):
                 await self.send_as_bytes(
                     OpCodes.mls_key_package.value,
-                    (result.commit + result.welcome) if result.welcome else result.commit,
+                    (
+                        (result.commit + result.welcome)
+                        if result.welcome
+                        else result.commit
+                    ),
                 )
             _log.debug("Processed MLS proposals for current dave session")
         elif op == OpCodes.mls_commit_transition:
@@ -271,7 +295,10 @@ async def received_binary_message(self, msg: bytes) -> None:
                     await self.send_dave_transition_ready(transt_id)
                 _log.debug("Processed MLS commit for transition %s", transt_id)
             except Exception as exc:
-                _log.debug("An exception ocurred while processing a MLS commit, this should be safe to ignore: %s", exc)
+                _log.debug(
+                    "An exception ocurred while processing a MLS commit, this should be safe to ignore: %s",
+                    exc,
+                )
                 await state.recover_dave_from_invalid_commit(transt_id)
         elif op == OpCodes.mls_welcome:
             transt_id = struct.unpack_from(">H", msg, 3)[0]
@@ -285,7 +312,10 @@ async def received_binary_message(self, msg: bytes) -> None:
                     await self.send_dave_transition_ready(transt_id)
                 _log.debug("Processed MLS welcome for transition %s", transt_id)
             except Exception as exc:
-                _log.debug("An exception ocurred while processing a MLS welcome, this should be safe to ignore: %s", exc)
+                _log.debug(
+                    "An exception ocurred while processing a MLS welcome, this should be safe to ignore: %s",
+                    exc,
+                )
                 await state.recover_dave_from_invalid_commit(transt_id)
 
     async def ready(self, data: dict[str, Any]) -> None:

discord/voice/state.py

@@ -35,15 +35,15 @@
 from collections.abc import Callable, Coroutine
 from typing import TYPE_CHECKING, Any, TypedDict
 
+import davey
+
 from discord import opus, utils
 from discord.backoff import ExponentialBackoff
 from discord.enums import SpeakingState, try_enum
 from discord.errors import ConnectionClosed
 from discord.object import Object
 from discord.sinks import RawData, Sink
 
-import davey
-
 from .enums import ConnectionFlowState, OpCodes
 from .gateway import VoiceWebSocket
 
@@ -1211,7 +1211,9 @@ async def reinit_dave_session(self) -> None:
 
         if self.dave_protocol_version > 0:
             if session:
-                session.reinit(self.dave_protocol_version, self.user.id, self.channel_id)
+                session.reinit(
+                    self.dave_protocol_version, self.user.id, self.channel_id
+                )
             else:
                 session = self.dave_session = davey.DaveSession(
                     self.dave_protocol_version,
@@ -1255,8 +1257,13 @@ async def execute_dave_transition(self, transition: int) -> None:
             old_version = self.dave_protocol_version
             self.dave_protocol_version = pending_proto
 
-            if old_version != self.dave_protocol_version and self.dave_protocol_version == 0:
-                _log.warning("DAVE was downgraded, voice client non-e2ee session has been deprecated since 2.7")
+            if (
+                old_version != self.dave_protocol_version
+                and self.dave_protocol_version == 0
+            ):
+                _log.warning(
+                    "DAVE was downgraded, voice client non-e2ee session has been deprecated since 2.7"
+                )
                 self.downgraded_dave = True
             elif transition > 0 and self.downgraded_dave:
                 self.downgraded_dave = False