nambrogi
/
pomice
mirror of https://github.com/cloudwithax/pomice.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: remove non-existant on_socket_response event 

As per 56916f9241/docs/migrating.rst (L1215)
This commit is contained in:
NiceAesth 2024-02-24 14:37:07 +02:00
parent 61d363c9ee
commit 84765e0ed5
1 changed files with 0 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
pomice/pool.py
View File

@ -174,8 +174,6 @@ class Node:
if apple_music: if apple_music:
self._apple_music_client = applemusic.Client() self._apple_music_client = applemusic.Client()
self._bot.add_listener(self._update_handler, "on_socket_response")
def __repr__(self) -> str: def __repr__(self) -> str:
return ( return (
f"<Pomice.node ws_uri={self._websocket_uri} rest_uri={self._rest_uri} " f"<Pomice.node ws_uri={self._websocket_uri} rest_uri={self._rest_uri} "
@ -260,31 +258,6 @@ class Node:
if self._apple_music_client: if self._apple_music_client:
await self._apple_music_client._set_session(session=session) await self._apple_music_client._set_session(session=session)
async def _update_handler(self, data: dict) -> None:
await self._bot.wait_until_ready()
if not data:
return
if data["t"] == "VOICE_SERVER_UPDATE":
guild_id = int(data["d"]["guild_id"])
try:
player = self._players[guild_id]
await player.on_voice_server_update(data["d"])
except KeyError:
return
elif data["t"] == "VOICE_STATE_UPDATE":
if int(data["d"]["user_id"]) != self._bot_user.id:
return
guild_id = int(data["d"]["guild_id"])
try:
player = self._players[guild_id]
await player.on_voice_state_update(data["d"])
except KeyError:
return
async def _handle_node_switch(self) -> None: async def _handle_node_switch(self) -> None:
nodes = [node for node in self.pool._nodes.copy().values() if node.is_connected] nodes = [node for node in self.pool._nodes.copy().values() if node.is_connected]
new_node = random.choice(nodes) new_node = random.choice(nodes)