update textual and aiohttp

fixes #195

.github/workflows/release.yml

@@ -179,6 +179,8 @@ jobs:
 
 
   publish-to-release:
+    permissions:
+      contents: write
     needs:
       - build-sdist-and-wheel
       - build-binaries

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "iSponsorBlockTV"
-version = "2.1.0"
+version = "2.2.1"
 authors = [
     {"name" = "dmunozv04"}
 ]

requirements.txt

@@ -1,11 +1,10 @@
-aiohttp==3.9.5
+aiohttp==3.10.6
 appdirs==1.4.4
-argparse==1.4.0
 async-cache==1.1.1
-pyytlounge==2.0.0
+pyytlounge==2.1.1
-rich==13.7.1
+rich==13.8.1
 ssdp==1.3.0
-textual==0.58.0
+textual==0.81.0
-textual-slider==0.1.1
+textual-slider==0.1.2
 xmltodict==0.13.0
 rich_click==1.8.3

src/iSponsorBlockTV/ytlounge.py

@@ -35,6 +35,7 @@ class YtLoungeApi(pyytlounge.YtLoungeApi):
             self.mute_ads = config.mute_ads
             self.skip_ads = config.skip_ads
             self.auto_play = config.auto_play
+        self._command_mutex = asyncio.Lock()
 
     # Ensures that we still are subscribed to the lounge
     async def _watchdog(self):
@@ -145,9 +146,12 @@ class YtLoungeApi(pyytlounge.YtLoungeApi):
                 self.shorts_disconnected = False
                 create_task(self.play_video(video_id_saved))
         elif event_type == "loungeScreenDisconnected":
-            data = args[0]
+            if args:  # Sometimes it's empty
-            if data["reason"] == "disconnectedByUserScreenInitiated":  # Short playing?
+                data = args[0]
-                self.shorts_disconnected = True
+                if (
+                    data["reason"] == "disconnectedByUserScreenInitiated"
+                ):  # Short playing?
+                    self.shorts_disconnected = True
         elif event_type == "onAutoplayModeChanged":
             create_task(self.set_auto_play_mode(self.auto_play))
 
@@ -181,3 +185,9 @@ class YtLoungeApi(pyytlounge.YtLoungeApi):
 
     async def play_video(self, video_id: str) -> bool:
         return await self._command("setPlaylist", {"videoId": video_id})
+
+    # Test to wrap the command function in a mutex to avoid race conditions with
+    # the _command_offset (TODO: move to upstream if it works)
+    async def _command(self, command: str, command_parameters: dict = None) -> bool:
+        async with self._command_mutex:
+            return await super()._command(command, command_parameters)