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

updated change_nodes and check task

This commit is contained in:
Crussader 2021-10-27 20:56:08 +04:00 committed by GitHub
parent 81d25e3868
commit fc113e362f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pomice/player.py
View File

@ -299,13 +299,14 @@ class Player(VoiceProtocol):
async def change_node(self, node: Node = None) -> None: async def change_node(self, node: Node = None) -> None:
if node := (node or NodePool.get_node()): if node := (node or NodePool.get_node()):
await self.set_pause(True)
await self._node.send(op="destroy", guildId = str(self._guild.id))
del self._node.players[self.guild.id] del self._node.players[self.guild.id]
self._node = node self._node = node
self._node.players[self.guild.id] = self self._node.players[self.guild.id] = self
if self._voice_state: if self._voice_state:
await self._dispatch_voice_update(self._voice_state) await self._dispatch_voice_update(self._voice_state)
await self.set_pause(False)
if self._current: if self._current:
await self._node.send( await self._node.send(
@ -316,16 +317,17 @@ class Player(VoiceProtocol):
endTime=self.current.length, endTime=self.current.length,
noReplace = False noReplace = False
) )
self._volume = 100
self._last_update = time.time() * 1000 self._last_update = time.time() * 1000
if self.is_paused: if self.is_paused:
await self._node.send(op='pause', guildId=str(self.guild.id), pause=self.is_paused) await self._node.send(op='pause', guildId=str(self.guild.id), pause=self.is_paused)
await self._node.send(op="volume", guildId = str(self.guild.id), volume=self.volume) await self._node.send(op="volume", guildId = str(self.guild.id), volume=self._volume)
@tasks.loop(seconds=5) @tasks.loop(seconds=5)
async def check(self): async def check(self):
if not self.node.is_connected: if not self.node.is_connected:
print(self.node.is_connected) await self.change_node(NodePool.get_node())