Erweiterungen

lib/tools/mqtt_core.dart

@@ -7,11 +7,13 @@ import 'package:isar/isar.dart';
 import 'package:mqtt_client/mqtt_client.dart';
 import 'package:mqtt_client/mqtt_server_client.dart';
 import 'package:stadtbote/model/enqueued_message.dart';
+import 'package:stadtbote/model/log_entry.dart';
 import 'package:stadtbote/model/ranking.dart';
 import 'package:stadtbote/model/status.dart';
 import 'package:stadtbote/protocoll_messages/acknowledge_job.dart';
 import 'package:stadtbote/protocoll_messages/bootstrap_request.dart';
 import 'package:stadtbote/protocoll_messages/bootstrap_response_payload.dart';
+import 'package:stadtbote/protocoll_messages/device_log.dart';
 import 'package:stadtbote/protocoll_messages/device_object.dart';
 import 'package:stadtbote/model/job.dart';
 import 'package:stadtbote/model/message.dart';
@@ -204,6 +206,10 @@ class MqttCore {
                   _messageMessageReceived(payloadData);
                   break;
 
+                case "device_log":
+                  _messageDeviceLogReceived(payloadData);
+                  break;
+
                 default:
                   Util.logInfo('Unknown topic: $payloadEntry');
                   break;
@@ -318,6 +324,15 @@ class MqttCore {
     MessageService().publish<MessageReceivedMessage>(Constants.messageTopicMessageReceived, arguments: MessageReceivedMessage(message: newMessage));
   }
 
+  void _messageDeviceLogReceived(payloadData) async {
+    var logEintries = await MyApp.isarInstance.logEntrys.where().findAll();
+
+    var deviceLog = DeviceLog();
+    deviceLog.entries = logEintries;
+
+    MqttCore.instance.publishPayloadMessage("device_log", deviceLog.toJson());
+  }
+
   void _startReconnectTimer() {
     connectionState = ConnectionStateEnum.notConnected;