Refactoring

lib/tools/messages/disconnect_client_message.dart

@@ -0,0 +1,3 @@
+class DisconnectClientMessage {
+  DisconnectClientMessage();
+}

lib/tools/mqtt_core.dart

@@ -25,14 +25,20 @@ import 'package:stadtbote/protocoll_messages/sync_jobs_message.dart';
 import 'package:stadtbote/protocoll_messages/track_message.dart';
 import 'package:stadtbote/tools/connection_status.dart';
 import 'package:stadtbote/tools/message_service.dart';
+import 'package:stadtbote/tools/messages/PublishPayloadMessage.dart';
+import 'package:stadtbote/tools/messages/connect_client_message.dart';
+import 'package:stadtbote/tools/messages/current_connection_status_message.dart';
+import 'package:stadtbote/tools/messages/disconnect_client_message.dart';
 import 'package:stadtbote/tools/messages/job_deleted_message.dart';
 import 'package:stadtbote/tools/messages/job_received_message.dart';
 import 'package:stadtbote/tools/messages/message_message.dart';
 import 'package:stadtbote/tools/messages/ranking_updated.dart';
+import 'package:stadtbote/tools/messages/request_connection_status_message.dart';
 import 'package:stadtbote/tools/messages/session_info_update.dart';
 import 'package:stadtbote/tools/messages/status_info_update.dart';
 // ignore: depend_on_referenced_packages
 import 'package:typed_data/typed_buffers.dart';
+import 'package:uuid/uuid.dart';
 
 import '../main.dart';
 import '../model/session_status.dart';
@@ -153,6 +159,22 @@ class MqttCore {
     }
   }
 
+  publishPayloadMessage(String topic, Map<String, dynamic> payload) {
+    var payloadContainer = PayloadContainer();
+    payloadContainer.id = const Uuid().v4().toString();
+    payloadContainer.recv = topic;
+    payloadContainer.store = true;
+    payloadContainer.payload = payload;
+
+    var json = jsonEncode(payloadContainer.toJson());
+
+    try {
+      publishText(_toServerTopic, json);
+    } catch (e) {
+      _enqueueMessage(_toServerTopic, jsonEncode(payloadContainer.toJson()));
+    }
+  }
+
   void _setupMqtt() async {
     Util.logInfo('_setupMqtt called');
 
@@ -433,7 +455,7 @@ class MqttCore {
     var startSessionMessage = StartSessionMessage();
     var jsonMap = startSessionMessage.toJson();
     var json = jsonEncode(jsonMap);
-    publishMessage("session", json);
+    publishText("session", json);
   }
 
   _sendSyncMessage() async
@@ -452,7 +474,7 @@ class MqttCore {
       answer.sync.jobs.add(syncJob);
     }
 
-    MqttCore.instance.publishMessage("sync_request_response", jsonEncode(answer.toJson()));
+    publishPayloadMessage("sync_request_response", jsonEncode(answer.toJson()));
   }
 
   void _startTrackTimer() {