Erweiterungen

lib/tools/mqtt_core.dart

@@ -30,9 +30,16 @@ import '../model/status.dart';
 import 'constants.dart';
 import 'util.dart';
 
+enum ConnectionStateEnum {
+  not_connected,
+  connected
+}
+
 class MqttCore {
   static late MqttCore instance;
 
+  late ConnectionStateEnum connectionState = ConnectionStateEnum.not_connected;
+
   late String _brokerUri;
   late int _brokerPort;
   late String _fromServerTopic;
@@ -191,6 +198,8 @@ class MqttCore {
   }
 
   void _sessionMessageReceived(payloadData) async {
+    connectionState = ConnectionStateEnum.connected;
+
     await _sendSyncMessage();
 
     var statusMessage = Status.fromJson(payloadData['status']);
@@ -265,6 +274,8 @@ class MqttCore {
   }
 
   void _startReconnectTimer() {
+    connectionState = ConnectionStateEnum.not_connected;
+
     Util.logInfo("_startReconnectTimer called");
 
     _reconnectDelay = min(_reconnectDelay + 1, 30);
@@ -275,6 +286,8 @@ class MqttCore {
   }
 
   void _clientDisconnected() {
+    connectionState = ConnectionStateEnum.not_connected;
+
     Util.logInfo("_clientDisconnected called");
 
     BroadcastReceiver().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));