Refactoring

lib/tools/mqtt_core.dart

@@ -20,12 +20,13 @@ import 'package:stadtbote/protocoll_messages/bootstrap_response_payload.dart';
 import 'package:stadtbote/protocoll_messages/device_log_request.dart';
 import 'package:stadtbote/protocoll_messages/device_log_response.dart';
 import 'package:stadtbote/protocoll_messages/device_object.dart';
+import 'package:stadtbote/protocoll_messages/payload_container.dart';
 import 'package:stadtbote/protocoll_messages/start_session_message.dart';
 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/publish_payload_message.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';
@@ -474,7 +475,7 @@ class MqttCore {
       answer.sync.jobs.add(syncJob);
     }
 
-    publishPayloadMessage("sync_request_response", jsonEncode(answer.toJson()));
+    publishPayloadMessage("sync_request_response", answer.toJson());
   }
 
   void _startTrackTimer() {
@@ -488,7 +489,7 @@ class MqttCore {
         trackMessage.pos!.long = position.longitude;
         trackMessage.pos!.acc = position.accuracy.toInt();
 
-        publishMessage("track", jsonEncode(trackMessage.toJson()));
+        publishPayloadMessage("track", trackMessage.toJson());
       }
     });
   }
@@ -515,7 +516,7 @@ class MqttCore {
     if (enqueuedMessages.isNotEmpty) {
       for (var enqueuedMessage in enqueuedMessages) {
         try {
-          publishMessage(enqueuedMessage.topic, enqueuedMessage.payload);
+          publishText(enqueuedMessage.topic, enqueuedMessage.payload);
 
           await MyApp.isarInstance.writeTxn(() async {
             await MyApp.isarInstance.enqueuedMessages.delete(enqueuedMessage.id);