poetry: bump dbus-fast to 3.1.2 in the lock file

This pulls in some fixes to prevent leaking resources and allows us to
drop a bunch of "assert reply" lines that were only there to keep type
checkers happy.

We still allow older versions of dbus-fast for better compatibility
with existing installations.

Author: dlech

bleak/backends/bluezdbus/client.py

@@ -272,7 +272,6 @@ async def disconnect_device() -> None:
                                     ],
                                 )
                             )
-                            assert reply
                             assert_reply(reply)
 
                             # REVIST: This leaves "Trusted" property set if we
@@ -306,7 +305,6 @@ async def disconnect_device() -> None:
                                     member="Connect",
                                 )
                             )
-                        assert reply
 
                         if reply.message_type == MessageType.ERROR:
                             # This error is often caused by RF interference
@@ -459,7 +457,6 @@ async def disconnect(self) -> None:
                         member="Disconnect",
                     )
                 )
-                assert reply
                 assert_reply(reply)
                 async with async_timeout(10):
                     await self._disconnecting_event.wait()
@@ -489,7 +486,6 @@ async def pair(self, *args: Any, **kwargs: Any) -> None:
                 body=[defs.DEVICE_INTERFACE, "Paired"],
             )
         )
-        assert reply
         assert_reply(reply)
         if reply.body[0].value:
             logger.debug("BLE device @ %s is already paired", self.address)
@@ -506,7 +502,6 @@ async def pair(self, *args: Any, **kwargs: Any) -> None:
                 body=[defs.DEVICE_INTERFACE, "Trusted", Variant("b", True)],
             )
         )
-        assert reply
         assert_reply(reply)
 
         logger.debug("Pairing to BLE device @ %s", self.address)
@@ -519,7 +514,6 @@ async def pair(self, *args: Any, **kwargs: Any) -> None:
                 member="Pair",
             )
         )
-        assert reply
         assert_reply(reply)
 
         # For resolvable private addresses, the address will
@@ -568,7 +562,6 @@ async def unpair(self) -> None:
                     body=[device_path],
                 )
             )
-            assert reply
             assert_reply(reply)
         except BleakDBusError as e:
             if e.dbus_error == "org.bluez.Error.DoesNotExist":
@@ -632,7 +625,6 @@ async def _acquire_mtu(self) -> None:
                 body=[{}],
             )
         )
-        assert reply
         assert_reply(reply)
 
         # we aren't actually using the write or notify, we just want the MTU
@@ -750,8 +742,6 @@ async def read_gatt_char(
                 )
             )
 
-            assert reply
-
             if reply.error_name == "org.bluez.Error.InProgress":
                 logger.debug("retrying characteristic ReadValue due to InProgress")
                 # Avoid calling in a tight loop. There is no dbus signal to
@@ -800,8 +790,6 @@ async def read_gatt_descriptor(
                 )
             )
 
-            assert reply
-
             if reply.error_name == "org.bluez.Error.InProgress":
                 logger.debug("retrying descriptor ReadValue due to InProgress")
                 # Avoid calling in a tight loop. There is no dbus signal to
@@ -843,8 +831,6 @@ async def write_gatt_char(
                 )
             )
 
-            assert reply
-
             if reply.error_name == "org.bluez.Error.InProgress":
                 logger.debug("retrying characteristic WriteValue due to InProgress")
                 # Avoid calling in a tight loop. There is no dbus signal to
@@ -890,8 +876,6 @@ async def write_gatt_descriptor(
                 )
             )
 
-            assert reply
-
             if reply.error_name == "org.bluez.Error.InProgress":
                 logger.debug("retrying descriptor WriteValue due to InProgress")
                 # Avoid calling in a tight loop. There is no dbus signal to
@@ -975,7 +959,6 @@ async def start_notify(
                     signature="a{sv}",
                 )
             )
-            assert reply
             assert_reply(reply)
 
             unix_fd = reply.unix_fds[0]
@@ -991,7 +974,6 @@ async def start_notify(
                     member="StartNotify",
                 )
             )
-            assert reply
             assert_reply(reply)
 
     @override
@@ -1041,6 +1023,5 @@ async def stop_notify(self, characteristic: BleakGATTCharacteristic) -> None:
                     member="StopNotify",
                 )
             )
-            assert reply
             assert_reply(reply)
             self._notification_callbacks.pop(characteristic.obj[0], None)

bleak/backends/bluezdbus/manager.py

@@ -308,7 +308,6 @@ async def async_init(self) -> None:
                         interface=defs.OBJECT_MANAGER_INTERFACE,
                     )
                 )
-                assert reply
                 assert_reply(reply)
 
                 # dictionaries are cleared in case AddInterfaces was received first
@@ -465,7 +464,6 @@ async def active_scan(
                         body=[filters],
                     )
                 )
-                assert reply
                 assert_reply(reply)
 
                 # Start scanning
@@ -477,7 +475,6 @@ async def active_scan(
                         member="StartDiscovery",
                     )
                 )
-                assert reply
                 assert_reply(reply)
 
                 async def stop() -> None:
@@ -502,7 +499,6 @@ async def stop() -> None:
                                 member="StopDiscovery",
                             )
                         )
-                        assert reply
 
                         try:
                             assert_reply(reply)
@@ -521,7 +517,6 @@ async def stop() -> None:
                                     body=[{}],
                                 )
                             )
-                            assert reply
                             assert_reply(reply)
 
                 return stop
@@ -589,7 +584,6 @@ async def passive_scan(
                         body=[monitor_path],
                     )
                 )
-                assert reply
 
                 if (
                     reply.message_type == MessageType.ERROR
@@ -631,7 +625,6 @@ async def stop() -> None:
                                 body=[monitor_path],
                             )
                         )
-                        assert reply
                         assert_reply(reply)
 
                 return stop

bleak/backends/bluezdbus/signals.py

@@ -193,7 +193,6 @@ async def add_match(bus: MessageBus, rules: MatchRules) -> Message:
             body=[str(rules)],
         )
     )
-    assert reply
 
     return reply
 
@@ -210,6 +209,5 @@ async def remove_match(bus: MessageBus, rules: MatchRules) -> Message:
             body=[str(rules)],
         )
     )
-    assert reply
 
     return reply