Updated Manager.exit_with_error and all calls, to write the error. 'Device <address> not found' will now cause the script to exit.

Author: slespersen

evseMQTT/ble_manager.py

@@ -30,8 +30,7 @@ async def scan(self):
                 self.connectiondata[address] = device
             return self.available_devices
         except BleakError as e:
-            self.logger.error(f"BleakError during scanning: {e}")
-            await self.manager.exit_with_error()
+            await self.manager.exit_with_error(f"BleakError during scanning: {e}")
 
     async def connect_device(self, address):
         if address in self.available_devices:
@@ -47,16 +46,14 @@ async def connect_device(self, address):
                     self._schedule_reconnect_check()
                     return True
                 except BleakError as e:
-                    self.logger.error(f"Attempt {attempt + 1} failed with BleakError: {e}")
-                    await self.manager.exit_with_error()
+                    await self.manager.exit_with_error(f"Attempt {attempt + 1} failed with BleakError: {e}")
                 except Exception as e:
                     self.logger.error(f"Attempt {attempt + 1} failed with error: {e}")
                 await asyncio.sleep(2)  # Wait a bit before retrying
-            self.logger.error(f"Failed to connect to {address} after {self.max_retries} attempts")
-            await self.manager.exit_with_error()
+            await self.manager.exit_with_error(f"Failed to connect to {address} after {self.max_retries} attempts")
             return False
         else:
-            self.logger.error(f"Device {address} not found")
+            await self.manager.exit_with_error(f"Device {address} not found")
             return False
 
     async def start_notifications(self, address, characteristic_uuid):

main.py

@@ -113,8 +113,8 @@ async def restart_run(self, address=None):
 
         await self.run(address)
 
-    async def exit_with_error(self):
-        self.logger.error("Exiting due to repeated connection failures.")
+    async def exit_with_error(self, error):
+        self.logger.error(f"Error encountered:\n{error}")
         # Perform necessary cleanup actions
         if self.mqtt_client:
             self.mqtt_client.publish_availability(self.device.info['serial'], "offline")