Erweiterungen

lib/tools/mqtt_core.dart

@@ -144,7 +144,7 @@ class MqttCore {
     _mqttClient.updates?.listen((List<MqttReceivedMessage<MqttMessage>> c) {
       try {
         final MqttPublishMessage message = c[0].payload as MqttPublishMessage;
-        final payload = MqttPublishPayload.bytesToStringAsString(message.payload.message);
+        String payload = utf8.decode(MqttPublishPayload.bytesToStringAsString(message.payload.message).codeUnits);
         var topic = message.variableHeader?.topicName;
 
         Util.logInfo('message received');
@@ -238,6 +238,14 @@ class MqttCore {
         MyApp.isarInstance.jobs.putSync(newJob);
       });
 
+      if (newJob.state == 0) {
+        if (newJob.global) {
+          await Util.playMp3('aaa.mp3');
+        } else {
+          await Util.playMp3('job_received.mp3');
+        }
+      }
+
       MessageService().publish<JobReceivedMessage>(Constants.messageTopicJobReceived, arguments: JobReceivedMessage(job: newJob));
     }
   }
@@ -259,15 +267,7 @@ class MqttCore {
   void _syncRequestReceived(payloadData) async {
     Util.logInfo('_syncRequestReceived');
 
-    /*for (var foundJobData in payloadData) {
-      Job newJob = Job.fromJson(foundJobData);
-
-      await MyApp.isarInstance.writeTxn(() async {
-        await MyApp.isarInstance.jobs.put(newJob);
-      });
-
-      BroadcastReceiver().publish<JobReceivedMessage>(Constants.messageTopicJobReceived, arguments: JobReceivedMessage(job: newJob));
-    }*/
+    _sendSyncMessage();
   }
 
   void _messageMessageReceived(Map<String, dynamic> payloadData) async {
@@ -277,6 +277,8 @@ class MqttCore {
       await MyApp.isarInstance.messages.put(newMessage);
     });
 
+    await Util.playMp3('asbeep.mp3');
+
     MessageService().publish<MessageReceivedMessage>(Constants.messageTopicMessageReceived, arguments: MessageReceivedMessage(message: newMessage));
   }
 
@@ -400,7 +402,7 @@ class MqttCore {
   }
 
   void _cancelTrackTimer() {
-    if (_trackTimer != null) {
+    if (_trackTimer != null && _trackTimer!.isActive) {
       _trackTimer!.cancel();
     }
   }