Fix disconnect issues (#28)

Author: LaStrada

.github/workflows/ci.yml

@@ -28,9 +28,10 @@ jobs:
         uses: wearerequired/lint-action@v2
         with:
           black: true
+          black_auto_fix: false
           flake8: true
+          flake8_auto_fix: false
 
-      - uses: actions/checkout@v3
       - uses: isort/isort-action@v1.0.0
 
   run-tests:

examples/read.py

@@ -1,44 +1,61 @@
 import asyncio
 import sys
 
-from bleak.backends.device import BLEDevice
+from bleak import BleakScanner
 
 from pyfreshintellivent import FreshIntelliVent
 
 
 async def main():
-    sky = FreshIntelliVent()
+    client = FreshIntelliVent()
     address = sys.argv[1]
-    authentication_code = sys.argv[2]
+    authentication_code = None
+    if len(sys.argv) == 3:
+        sys.argv[2]
 
-    ble_device = BLEDevice(address=address)
+    ble_device = await BleakScanner.find_device_by_address(address)
+
+    if ble_device is None:
+        print("Couldn't find any devices")
+        return
 
     try:
-        async with sky.connect(ble_device) as client:
+        print("Connecting...")
+        await client.connect(ble_device)
+        print("Connected")
+
+        await client.fetch_device_information()
+
+        if authentication_code is None:
+            print("No authentication code, skipping authentication")
+        else:
             await client.authenticate(authentication_code=authentication_code)
+            print("Authenticated")
 
-            sensors = await client.fetch_sensor_data()
-            print(f"Status: {sensors.as_dict()}")
+        sensors = await client.fetch_sensor_data()
+        print(f"Status: {sensors.as_dict()}")
 
-            boost = await client.fetch_boost()
-            print(f"Boost: {boost}")
+        boost = await client.fetch_boost()
+        print(f"Boost: {boost}")
 
-            constant_speed = await client.fetch_constant_speed()
-            print(f"Constant speed: {constant_speed}")
+        constant_speed = await client.fetch_constant_speed()
+        print(f"Constant speed: {constant_speed}")
 
-            humidity = await client.fetch_humidity()
-            print(f"Humidity: {humidity}")
+        humidity = await client.fetch_humidity()
+        print(f"Humidity: {humidity}")
 
-            light_and_voc = await client.fetch_light_and_voc()
-            print(f"Light and VOC: {light_and_voc}")
+        light_and_voc = await client.fetch_light_and_voc()
+        print(f"Light and VOC: {light_and_voc}")
 
-            pause = await client.fetch_pause()
-            print(f"Pause: {pause}")
+        pause = await client.fetch_pause()
+        print(f"Pause: {pause}")
 
-            timer = await client.fetch_timer()
-            print(f"Timer: {timer}")
+        timer = await client.fetch_timer()
+        print(f"Timer: {timer}")
     except Exception as e:
+        await client.disconnect()
         print(e)
 
 
-asyncio.run(main())
+if __name__ == "__main__":
+    asyncio.run(main())