Bump go2rtc-client to 0.0.1b4 (#129942)

homeassistant/components/go2rtc/__init__.py

@@ -222,7 +222,10 @@ class WebRTCProvider(CameraWebRTCProvider):
         if (stream := streams.get(camera.entity_id)) is None or not any(
             stream_source == producer.url for producer in stream.producers
         ):
-            await self._rest_client.streams.add(camera.entity_id, stream_source)
+            await self._rest_client.streams.add(
+                camera.entity_id,
+                [stream_source, f"ffmpeg:{camera.entity_id}#audio=opus"],
+            )
 
         @callback
         def on_messages(message: ReceiveMessages) -> None:

homeassistant/components/go2rtc/manifest.json

@@ -7,6 +7,6 @@
   "documentation": "https://www.home-assistant.io/integrations/go2rtc",
   "integration_type": "system",
   "iot_class": "local_polling",
-  "requirements": ["go2rtc-client==0.0.1b3"],
+  "requirements": ["go2rtc-client==0.0.1b4"],
   "single_config_entry": true
 }

homeassistant/package_constraints.txt

@@ -26,7 +26,7 @@ ciso8601==2.3.1
 cryptography==43.0.1
 dbus-fast==2.24.3
 fnv-hash-fast==1.0.2
-go2rtc-client==0.0.1b3
+go2rtc-client==0.0.1b4
 ha-av==10.1.1
 ha-ffmpeg==3.2.1
 habluetooth==3.6.0

requirements_all.txt

@@ -986,7 +986,7 @@ gitterpy==0.1.7
 glances-api==0.8.0
 
 # homeassistant.components.go2rtc
-go2rtc-client==0.0.1b3
+go2rtc-client==0.0.1b4
 
 # homeassistant.components.goalzero
 goalzero==0.2.2

requirements_test_all.txt

@@ -836,7 +836,7 @@ gios==5.0.0
 glances-api==0.8.0
 
 # homeassistant.components.go2rtc
-go2rtc-client==0.0.1b3
+go2rtc-client==0.0.1b4
 
 # homeassistant.components.goalzero
 goalzero==0.2.2

tests/components/go2rtc/test_init.py

@@ -237,24 +237,28 @@ async def _test_setup_and_signaling(
 
     await test()
 
-    rest_client.streams.add.assert_called_once_with(entity_id, "rtsp://stream")
+    rest_client.streams.add.assert_called_once_with(
+        entity_id, ["rtsp://stream", f"ffmpeg:{camera.entity_id}#audio=opus"]
+    )
 
     # Stream exists but the source is different
     rest_client.streams.add.reset_mock()
     rest_client.streams.list.return_value = {
-        entity_id: Stream([Producer("rtsp://different")])
+        entity_id: Stream([Producer("rtsp://different", [])])
     }
 
     receive_message_callback.reset_mock()
     ws_client.reset_mock()
     await test()
 
-    rest_client.streams.add.assert_called_once_with(entity_id, "rtsp://stream")
+    rest_client.streams.add.assert_called_once_with(
+        entity_id, ["rtsp://stream", f"ffmpeg:{camera.entity_id}#audio=opus"]
+    )
 
     # If the stream is already added, the stream should not be added again.
     rest_client.streams.add.reset_mock()
     rest_client.streams.list.return_value = {
-        entity_id: Stream([Producer("rtsp://stream")])
+        entity_id: Stream([Producer("rtsp://stream", [])])
     }
 
     receive_message_callback.reset_mock()