fix: Resolve critical BLE interface issues and improve pub/sub consistency

- Fix disconnect callback to properly handle BleakClient and close BLEClient wrapper
- Add meshtastic.connection.status messages with connected boolean to align with example
- Improve reconnect_example.py exception handling to continue loop instead of exiting
- Prevent thread leaks by properly closing BLE client wrapper in background thread
- Fix AttributeError in disconnect callback by using correct client.address attribute

Critical fixes that ensure the BLE reconnection feature works correctly and
prevents resource leaks during disconnection events.

Author: jeremiah-k

examples/reconnect_example.py

@@ -74,7 +74,8 @@ def main():
             print(f"An unexpected error occurred: {e}")
             if iface:
                 iface.close()
-            raise
+            print("Retrying in 5 seconds...")
+            time.sleep(5)
 
 if __name__ == "__main__":
     main()

meshtastic/ble_interface.py

@@ -106,13 +106,17 @@ def __repr__(self):
         rep += ")"
         return rep
 
-    def _on_ble_disconnect(self, client: "BLEClient") -> None:
+    def _on_ble_disconnect(self, client) -> None:
         """Disconnected callback from Bleak."""
-        logger.debug(f"BLE client {client.bleak_client.address} disconnected.")
+        address = getattr(client, "address", repr(client))
+        logger.debug(f"BLE client {address} disconnected.")
         if self.auto_reconnect:
-            # We only cleanup the client, but do not call close()
-            # This allows the application to handle reconnection.
+            previous_client = self.client
             self.client = None
+            if previous_client:
+                Thread(
+                    target=previous_client.close, name="BLEClientClose", daemon=True
+                ).start()
             self._disconnected()
         else:
             Thread(target=self.close, name="BLEClose", daemon=True).start()

meshtastic/mesh_interface.py

@@ -1132,6 +1132,9 @@ def _disconnected(self):
         publishingThread.queueWork(
             lambda: pub.sendMessage("meshtastic.connection.lost", interface=self)
         )
+        publishingThread.queueWork(
+            lambda: pub.sendMessage("meshtastic.connection.status", interface=self, connected=False)
+        )
 
     def sendHeartbeat(self):
         """Sends a heartbeat to the radio. Can be used to verify the connection is healthy."""
@@ -1165,6 +1168,9 @@ def _connected(self):
                     "meshtastic.connection.established", interface=self
                 )
             )
+            publishingThread.queueWork(
+                lambda: pub.sendMessage("meshtastic.connection.status", interface=self, connected=True)
+            )
 
     def _startConfig(self):
         """Start device packets flowing"""