Merge branch 'A2XX' into new_appserver

# Conflicts:
#	lib/model/rank.dart
#	lib/model/rank.g.dart
#	lib/tools/mqtt_core.dart
#	pubspec.lock
#	pubspec.yaml

lib/tools/mqtt_core.dart

@@ -94,12 +94,14 @@ class MqttCore {
 
       _mqttClient = MqttServerClient.withPort(_brokerUri, clientId, _brokerPort);
       _mqttClient.logging(on: false);
-      _mqttClient.keepAlivePeriod = 20;
-      _mqttClient.autoReconnect = false;
+      _mqttClient.keepAlivePeriod = 5;
+      _mqttClient.disconnectOnNoResponsePeriod = 10;
+      _mqttClient.autoReconnect = true;
       _mqttClient.onDisconnected = _clientDisconnected;
+      _mqttClient.onAutoReconnect = _clientDisconnected;
+      _mqttClient.onAutoReconnected = _clientConnected;
       _mqttClient.connectionMessage = MqttConnectMessage()
           .withClientIdentifier(await Util.getAppUuid())
-          .withWillQos(MqttQos.atMostOnce)
           .authenticateAs("app", "apppwd");
 
       await _mqttClient.connect();
@@ -116,13 +118,9 @@ class MqttCore {
         Util.logInfo('Verbindung zum MQTT-Broker fehlgeschlagen!');
 
         MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));
-
-        _startReconnectTimer();
       }
 
     } catch (ex) {
-      _startReconnectTimer();
-
       Util.logInfo('Verbindung zum MQTT-Broker fehlgeschlagen!: $ex');
 
       MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));
@@ -328,7 +326,7 @@ class MqttCore {
     publishBinary(topic, gzipBytes!);
   }
 
-  void _startReconnectTimer() {
+  void _startBootstrapReconnectTimer() {
     connectionState = ConnectionStateEnum.notConnected;
 
     if (!_disconnectInProgress) {
@@ -349,17 +347,23 @@ class MqttCore {
   }
 
   void _clientDisconnected() {
-    connectionState = ConnectionStateEnum.notConnected;
-
-    _cancelTrackTimer();
-
     Util.logInfo("_clientDisconnected called");
 
-    MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));
+    connectionState = ConnectionStateEnum.notConnected;
 
-    if (!_disconnectInProgress) {
-      _startReconnectTimer();
-    }
+    _startTrackTimer();
+
+    MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.notConnected));
+  }
+
+  void _clientConnected() {
+    Util.logInfo("_clientDisconnected called");
+
+    connectionState = ConnectionStateEnum.connected;
+
+    _initSession();
+
+    MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.connected));
   }
 
   void _processBootstrap() async {
@@ -401,7 +405,7 @@ class MqttCore {
 
       _connectToBroker();
     } catch (ex) {
-      _startReconnectTimer();
+      _startBootstrapReconnectTimer();
     }
   }