Erweiterungen

lib/tools/mqtt_core.dart

@@ -52,8 +52,6 @@ import 'util.dart';
 
 enum ConnectionStateEnum { notConnected, connected }
 
-//const AndroidInitializationSettings initializationSettingsAndroid = AndroidInitializationSettings('app_icon');
-
 class MqttCore {
   late ConnectionStateEnum connectionState = ConnectionStateEnum.notConnected;
 
@@ -81,18 +79,21 @@ class MqttCore {
     _processBootstrap();
   }
 
-  _disconnect() {
+  _disconnectMqttClient() {
+    MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));
+
     _disconnectInProgress = true;
 
     _cancelReconnectTimer();
 
     _cancelTrackTimer();
 
-    if (_mqttClient != null) {
+    if (_mqttClient != null && _mqttClient!.connectionStatus == ConnectionStateEnum.connected) {
       _mqttClient!.disconnect();
     }
 
     connectionState = ConnectionStateEnum.notConnected;
+
   }
 
   _connectToBroker() async {
@@ -102,15 +103,17 @@ class MqttCore {
       Util.logInfo("broker uri: $_brokerUri");
       Util.logInfo("broker port: $_brokerPort");
 
-      _mqttClient = MqttServerClient.withPort(_brokerUri, clientId, _brokerPort);
-      _mqttClient!.logging(on: false);
-      _mqttClient!.keepAlivePeriod = 60;
-      _mqttClient!.disconnectOnNoResponsePeriod = 10;
-      _mqttClient!.autoReconnect = true;
-      _mqttClient!.onDisconnected = _clientDisconnected;
-      _mqttClient!.onAutoReconnect = _clientDisconnected;
-      _mqttClient!.onAutoReconnected = _clientConnected;
-      _mqttClient!.connectionMessage = MqttConnectMessage().withClientIdentifier(await Util.getAppUuid()).authenticateAs("app", "apppwd");
+      if (_mqttClient == null) {
+        _mqttClient = MqttServerClient.withPort(_brokerUri, clientId, _brokerPort);
+        _mqttClient!.logging(on: false);
+        _mqttClient!.keepAlivePeriod = 60;
+        _mqttClient!.disconnectOnNoResponsePeriod = 10;
+        _mqttClient!.autoReconnect = true;
+        _mqttClient!.onDisconnected = _clientDisconnected;
+        _mqttClient!.onAutoReconnect = _clientDisconnected;
+        _mqttClient!.onAutoReconnected = _clientConnected;
+        _mqttClient!.connectionMessage = MqttConnectMessage().withClientIdentifier(await Util.getAppUuid()).authenticateAs("app", "apppwd");
+      }
 
       await _mqttClient!.connect();
 
@@ -384,8 +387,10 @@ class MqttCore {
   }
 
   void _cancelReconnectTimer() {
-    if (_reconnectTimer != null && _reconnectTimer!.isActive) {
-      _reconnectTimer!.cancel();
+    if (!_disconnectInProgress) {
+      if (_reconnectTimer != null && _reconnectTimer!.isActive) {
+        _reconnectTimer!.cancel();
+      }
     }
   }
 
@@ -394,7 +399,7 @@ class MqttCore {
 
     connectionState = ConnectionStateEnum.notConnected;
 
-    _startTrackTimer();
+    _cancelTrackTimer();
 
     MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));
   }
@@ -546,7 +551,7 @@ class MqttCore {
 
     MessageService().subscribe<DisconnectClientMessage>(Constants.messageTopicDisconnectClient, this,
         (DisconnectClientMessage disconnectClientMessage) {
-      _disconnect();
+      _disconnectMqttClient();
     });
 
     MessageService().subscribe<ConnectClientMessage>(Constants.messageTopicConnectClient, this, (ConnectClientMessage connectClientMessage) {