From 94998bdb6d68d1442c25f94d1ce141fb3f73c430 Mon Sep 17 00:00:00 2001
From: Sven Carstensen <sven.carstensen@appcreation.de>
Date: Thu, 29 Feb 2024 11:19:00 +0100
Subject: [PATCH] Nachrichten eingebaut

---
 lib/content_views/messages_page.dart | 6 +++++-
 lib/tools/mqtt_core.dart             | 4 ++--
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/lib/content_views/messages_page.dart b/lib/content_views/messages_page.dart
index 0412971..e843f60 100644
--- a/lib/content_views/messages_page.dart
+++ b/lib/content_views/messages_page.dart
@@ -1,3 +1,5 @@
+import 'dart:convert';
+
 import 'package:flutter/material.dart';
 import 'package:flutter_chat_ui/flutter_chat_ui.dart';
 import 'package:flutter_chat_types/flutter_chat_types.dart' as types;
@@ -105,7 +107,9 @@ class _MessagesPageState extends State<MessagesPage> {
       MyApp.isarInstance.messages.putSync(message);
     });
 
-    MqttCore.instance.publishPayloadMessage('mssg', message.toJson());
+    var json = jsonEncode(message.toJson());
+
+    MqttCore.instance.publishText('/appserver/to_server/100/1/104400/set_location', jsonEncode(message.toJson()));
 
     _messages.insert(0, types.TextMessage(
       author: _user,
diff --git a/lib/tools/mqtt_core.dart b/lib/tools/mqtt_core.dart
index 5a37202..ed6c642 100644
--- a/lib/tools/mqtt_core.dart
+++ b/lib/tools/mqtt_core.dart
@@ -198,7 +198,7 @@ class MqttCore {
             break;
 
           case "mssg":
-            //_messageMessageReceived(payloadData);
+            _messageMessageReceived(payload);
             break;
 
           default:
@@ -297,7 +297,7 @@ class MqttCore {
     _sendSyncMessage();
   }
 
-  void _messageMessageReceived(Map<String, dynamic> payloadData) async {
+  void _messageMessageReceived(payloadData) async {
     var newMessage = await Message.mergeFromJson(payloadData);
 
     await MyApp.isarInstance.writeTxn(() async {