Erweiterungen

lib/tools/mqtt_core.dart

@@ -9,9 +9,11 @@ import 'package:stadtbote/model/bootstrap_request.dart';
 import 'package:stadtbote/model/bootstrap_response_payload.dart';
 import 'package:stadtbote/model/device_object.dart';
 import 'package:stadtbote/model/job.dart';
+import 'package:stadtbote/model/message.dart';
 import 'package:stadtbote/model/start_session_message.dart';
 import 'package:stadtbote/tools/connection_status.dart';
 import 'package:stadtbote/tools/messages/job_received_message.dart';
+import 'package:stadtbote/tools/messages/message_message.dart';
 import 'package:stadtbote/tools/messages/session_info_update.dart';
 import 'package:typed_data/typed_buffers.dart';
 import 'package:http/http.dart' as http;
@@ -131,6 +133,10 @@ class MqttCore {
                   _jobMessageReceived(payloadData);
                   break;
 
+                case "mssg":
+                  _messageMessageReceived(payloadData);
+                  break;
+
                 default:
                   Util.logInfo('Unknown topic: $payloadEntry');
                   break;
@@ -171,6 +177,16 @@ class MqttCore {
     }
   }
 
+  void _messageMessageReceived(Map<String, dynamic> payloadData) async {
+    var newMessage = Message.fromJson(payloadData);
+
+    await MyApp.isarInstance.writeTxn(() async {
+      await MyApp.isarInstance.messages.put(newMessage);
+    });
+
+    BroadcastReceiver().publish<MessageReceivedMessage>(Constants.messageTopicJobReceived, arguments: MessageReceivedMessage(message: newMessage));
+  }
+
   void _startReconnectTimer() {
     Util.logInfo("_startReconnectTimer called");