Erweiterungen

lib/tools/mqtt_core.dart

@@ -1,11 +1,9 @@
 import 'dart:async';
 import 'dart:convert';
 import 'dart:math';
-import 'dart:typed_data';
 
 import 'package:archive/archive.dart';
 import 'package:device_info_plus/device_info_plus.dart';
-import 'package:flutter/foundation.dart';
 import 'package:isar/isar.dart';
 import 'package:mqtt_client/mqtt_client.dart';
 import 'package:mqtt_client/mqtt_server_client.dart';
@@ -24,7 +22,6 @@ 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';
@@ -223,10 +220,6 @@ class MqttCore {
                   _messageUploadDeviceLogReceived(payloadData);
                   break;
 
-                case "tail":
-                  _messageTailReceived(payloadData);
-                  break;
-
                 default:
                   Util.logInfo('Unknown topic: $payloadEntry');
                   break;
@@ -359,12 +352,6 @@ class MqttCore {
     publishBinary(topic, gzipBytes!);
   }
 
-  void _messageTailReceived(payloadData) async {
-    var tailMessage = Tail.fromJson(payloadData);
-
-    Util.logInfo('message');
-  }
-
   void _startReconnectTimer() {
     connectionState = ConnectionStateEnum.notConnected;