Bump aiosendspin 3 (#83)

aiosendspin 3.0
https://github.com/Sendspin/aiosendspin/releases/tag/3.0.0

Fixes #74
Fixes #75

---------

Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>

Author: balloob

pyproject.toml

@@ -14,7 +14,7 @@ classifiers = [
   "Programming Language :: Python :: 3.13",
 ]
 dependencies = [
-  "aiosendspin~=2.1",
+  "aiosendspin~=3.0",
   "aiosendspin-mpris~=2.1",
   "av>=14.0.0",
   "numpy>=1.24.0",

sendspin/audio.py

@@ -24,7 +24,7 @@
 from sounddevice import CallbackFlags
 
 if TYPE_CHECKING:
-    from aiosendspin.client import PCMFormat
+    from aiosendspin.client import AudioFormat, PCMFormat
 
 logger = logging.getLogger(__name__)
 
@@ -264,13 +264,14 @@ def __init__(
         # Thread-safe flag for deferred operations (audio thread → main thread)
         self._clear_requested: bool = False
 
-    def set_format(self, pcm_format: PCMFormat, device: AudioDevice) -> None:
+    def set_format(self, audio_format: AudioFormat, device: AudioDevice) -> None:
         """Configure the audio output format.
 
         Args:
             pcm_format: PCM audio format specification.
             device: Audio device to use.
         """
+        pcm_format = audio_format.pcm_format
         self._format = pcm_format
         self._close_stream()
 

sendspin/audio_connector.py

@@ -13,7 +13,7 @@
 from sendspin.audio import AudioDevice, AudioPlayer
 
 if TYPE_CHECKING:
-    from aiosendspin.client import PCMFormat, SendspinClient
+    from aiosendspin.client import AudioFormat, SendspinClient
 
 logger = logging.getLogger(__name__)
 
@@ -45,7 +45,7 @@ def __init__(
         self._muted = muted
         self._client: SendspinClient | None = None
         self.audio_player: AudioPlayer | None = None
-        self._current_format: PCMFormat | None = None
+        self._current_format: AudioFormat | None = None
 
     def set_volume(self, volume: int, *, muted: bool) -> None:
         """Set the volume and muted state.
@@ -80,7 +80,9 @@ def attach_client(self, client: SendspinClient) -> list[Callable[[], None]]:
             client.add_stream_clear_listener(self._on_stream_clear),
         ]
 
-    def _on_audio_chunk(self, server_timestamp_us: int, audio_data: bytes, fmt: PCMFormat) -> None:
+    def _on_audio_chunk(
+        self, server_timestamp_us: int, audio_data: bytes, fmt: AudioFormat
+    ) -> None:
         """Handle incoming audio chunks."""
         assert self._client is not None, "Received audio chunk but client is not attached"
 

sendspin/serve/__init__.py

@@ -110,7 +110,7 @@ def handle_sigint() -> None:
     with suppress(NotImplementedError):
         event_loop.add_signal_handler(signal.SIGINT, handle_sigint)
 
-    async def on_server_event(server: SendspinServer, event: SendspinEvent) -> None:
+    def on_server_event(server: SendspinServer, event: SendspinEvent) -> None:
         nonlocal active_group
 
         if isinstance(event, ClientAddedEvent):
@@ -124,7 +124,7 @@ async def on_server_event(server: SendspinServer, event: SendspinEvent) -> None:
                 client_connected.set()
                 return
 
-            await active_group.add_client(client)
+            create_task(active_group.add_client(client))
 
         if isinstance(event, ClientRemovedEvent):
             if active_group is None:
@@ -163,7 +163,7 @@ async def on_server_event(server: SendspinServer, event: SendspinEvent) -> None:
         for client_url in config.clients:
             try:
                 print(f"Connecting to client: {client_url}")
-                server.connect_to_client(client_url)
+                await server.connect_to_client(client_url)
             except Exception as e:
                 logger.warning("Failed to connect to client %s: %s", client_url, e)
                 print(f"Warning: Failed to connect to client {client_url}: {e}")
@@ -205,6 +205,9 @@ async def on_server_event(server: SendspinServer, event: SendspinEvent) -> None:
                 await play_media_task
             except asyncio.CancelledError:
                 pass
+            except FileNotFoundError as e:
+                print(f"Error: {e}")
+                return 1
             except Exception as e:
                 print(f"Playback error: {e}")
                 logger.debug("Playback error", exc_info=True)