fix: discord api update

Author: andyjjrt

.gitignore

@@ -31,4 +31,6 @@ dist-ssr
 *.sw?
 
 .venv
-.ruff_cache
+.ruff_cache
+
+config.ini

pyproject.toml

@@ -7,12 +7,12 @@ requires-python = ">=3.12"
 dependencies = [
     "ffmpeg-python>=0.2.0",
     "langfuse>=3.6.1",
-    "py-cord==2.6.1",
+    "py-cord==2.7.0-rc2",
     "pydantic-ai-slim[openai]>=0.0.46",
     "pynacl>=1.5.0",
     "pyyaml>=6.0.3",
     "rich>=14.2.0",
-    "yt-dlp>=2025.10.22",
+    "yt-dlp[default]>=2025.11.12",
 ]
 
 [dependency-groups]

rosetta/utils/subscriptions.py

@@ -1,4 +1,5 @@
 import asyncio
+import logging
 from queue import Empty
 
 from discord import Bot, VoiceClient
@@ -22,6 +23,7 @@ def __init__(
         self.bot = bot
         self.guildId = guildId
         self.queue = tracks
+        self.logger = logging.getLogger("rosetta")
 
         self.nowPlaying: Track | None = None
         self.checkLock = False
@@ -53,21 +55,21 @@ async def leave(self, message=True):
         self.task.cancel()
 
     async def _process(self):
-        if len(self.queue) == 0:
-            if self.loop == "Off":
-                self.checkLock = False
-                raise Empty
-        else:
-            if self.loop != "One" or not self.nowPlaying:
-                if self.loop == "Queue":
-                    self.queue.append(self.nowPlaying)
-                track = self.queue.pop(0)
-                self.nowPlaying = track
-            player = await self.nowPlaying.createAudio()
-            self.voiceClient.play(
-                player, after=lambda e: print(f"Player error: {e}") if e else None
-            )
+        if self.loop == "Off" and len(self.queue) == 0:
             self.checkLock = False
+            raise Empty
+        if self.loop != "One" or not self.nowPlaying:
+            if self.loop == "Queue":
+                self.queue.append(self.nowPlaying)
+            track = self.queue.pop(0)
+            self.nowPlaying = track
+
+        player = await self.nowPlaying.createAudio()
+        self.voiceClient.play(
+            player,
+            after=lambda e: self.logger.error(f"Player error: {e}") if e else None,
+        )
+        self.checkLock = False
 
     async def _startSession(self):
         while True:
@@ -109,7 +111,6 @@ def createQueue(
             tracks,
             loop,
         )
-        print(self._serverStatus)
 
     def remove(self, guildId: str):
         if guildId not in self._serverStatus: