fix: race during disconnect when unexpectedly connected (#30)

src/bleak_retry_connector/dbus.py

@@ -2,12 +2,15 @@
 
 import contextlib
 
+import async_timeout
 from bleak.backends.bluezdbus import defs
 from bleak.backends.device import BLEDevice
 from dbus_fast.aio import MessageBus
 from dbus_fast.constants import BusType
 from dbus_fast.message import Message
 
+DISCONNECT_TIMEOUT = 5
+
 
 async def disconnect_devices(devices: list[BLEDevice]) -> None:
     """Disconnect a list of devices."""
@@ -21,12 +24,13 @@ async def disconnect_devices(devices: list[BLEDevice]) -> None:
     bus = await MessageBus(bus_type=BusType.SYSTEM, negotiate_unix_fd=True).connect()
     for device in devices:
         with contextlib.suppress(Exception):
-            await bus.send(
-                Message(
-                    destination=defs.BLUEZ_SERVICE,
-                    path=device.details["path"],
-                    interface=defs.DEVICE_INTERFACE,
-                    member="Disconnect",
+            async with async_timeout.timeout(DISCONNECT_TIMEOUT):
+                await bus.call(
+                    Message(
+                        destination=defs.BLUEZ_SERVICE,
+                        path=device.details["path"],
+                        interface=defs.DEVICE_INTERFACE,
+                        member="Disconnect",
+                    )
                 )
-            )
     bus.disconnect()