Add automatic reconnecting

This allows to use the app after a temporary disconnect between app and
MQTT broker.

1 files changed, 13 insertions, 0 deletions

diff --git a/lib/data.dart b/lib/data.dart
index f5a24e8..38fd564 100644
--- a/lib/data.dart
+++ b/lib/data.dart
@@ -32,11 +32,14 @@ class AppState with ChangeNotifier {
 
     _client.port = brokerPort;
     _client.keepAlivePeriod = 2;
+    _client.autoReconnect = true;
     _client.disconnectOnNoResponsePeriod = 1;
     _client.logging(on: false);
 
     _client.onConnected = _onConnected;
     _client.onDisconnected = _onDisconnected;
+    _client.onAutoReconnect = _onAutoReconnect;
+    _client.onAutoReconnected = _onAutoReconnected;
 
     try {
       await _client.connect();
@@ -59,6 +62,16 @@ class AppState with ChangeNotifier {
     notifyListeners();
   }
 
+  void _onAutoReconnect() {
+    _brokerConnected = false;
+    notifyListeners();
+  }
+
+  void _onAutoReconnected() {
+    _brokerConnected = true;
+    notifyListeners();
+  }
+
   void _onMessage(List<MqttReceivedMessage<MqttMessage>> messages) {
     for (final MqttReceivedMessage<MqttMessage> message in messages) {
       final String topic = message.topic;