Erweiterungen

lib/tools/mqtt_core.dart

@@ -321,11 +321,15 @@ class MqttCore {
 
   void _jobDeleteReceived(payloadData) async {
     var jobDelMessage = JobDelMessage.fromJson(payloadData);
-    await MyApp.isarInstance.writeTxn(() async {
-      await MyApp.isarInstance.jobs.delete(jobDelMessage.id);
-    });
 
-    MessageService().publish<JobDeletedMessage>(Constants.messageTopicJobDeleted, arguments: JobDeletedMessage(id: jobDelMessage.id));
+    var foundJobs = await MyApp.isarInstance.jobs.where().filter().idEqualTo(jobDelMessage.id).findAll();
+    if (foundJobs.isNotEmpty) {
+      await MyApp.isarInstance.writeTxn(() async {
+        await MyApp.isarInstance.jobs.delete(jobDelMessage.id);
+      });
+
+      MessageService().publish<JobDeletedMessage>(Constants.messageTopicJobDeleted, arguments: JobDeletedMessage(id: jobDelMessage.id));
+    }
   }
 
   void _syncRequestReceived(payloadData) async {