Logging

lib/tools/mqtt_core.dart

@@ -23,6 +23,7 @@ import 'package:stadtbote/model/message.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/tail.dart';
 import 'package:stadtbote/protocoll_messages/track_message.dart';
 import 'package:stadtbote/tools/connection_status.dart';
 import 'package:stadtbote/tools/message_service.dart';
@@ -218,8 +219,12 @@ class MqttCore {
                   _messageMessageReceived(payloadData);
                   break;
 
-                case "device_log":
-                  _messageDeviceLogReceived(payloadData);
+                case "upload_device_log":
+                  _messageUploadDeviceLogReceived(payloadData);
+                  break;
+
+                case "tail":
+                  _messageTailReceived(payloadData);
                   break;
 
                 default:
@@ -336,7 +341,7 @@ class MqttCore {
     MessageService().publish<MessageReceivedMessage>(Constants.messageTopicMessageReceived, arguments: MessageReceivedMessage(message: newMessage));
   }
 
-  void _messageDeviceLogReceived(payloadData) async {
+  void _messageUploadDeviceLogReceived(payloadData) async {
     var deviceLogRequest = DeviceLogRequest.fromJson(payloadData);
 
     var logEintries = await MyApp.isarInstance.logEntrys.filter().timeGreaterThan(deviceLogRequest.startDateTime).findAll();
@@ -354,6 +359,12 @@ class MqttCore {
     publishBinary(topic, gzipBytes!);
   }
 
+  void _messageTailReceived(payloadData) async {
+    var tailMessage = Tail.fromJson(payloadData);
+
+    Util.logInfo('message');
+  }
+
   void _startReconnectTimer() {
     connectionState = ConnectionStateEnum.notConnected;