Erweiterungen

lib/tools/mqtt_core.dart

@@ -192,11 +192,11 @@ class MqttCore {
             break;
 
           case 'job_del':
-            //_jobDeleteReceived(payloadData);
+            _jobDeleteReceived(messageData);
             break;
 
           case 'sync_request':
-            //_syncRequestReceived(payloadData);
+            _syncRequestReceived(messageData);
             break;
 
           case "mssg":
@@ -215,6 +215,7 @@ class MqttCore {
     _mqttClient.subscribe(_fromServerTopic + "/session", MqttQos.exactlyOnce);
     _mqttClient.subscribe(_fromServerTopic + "/status", MqttQos.exactlyOnce);
     _mqttClient.subscribe(_fromServerTopic + "/job", MqttQos.exactlyOnce);
+    _mqttClient.subscribe(_fromServerTopic + "/job_del", MqttQos.exactlyOnce);
     Util.logInfo('subscribed to topic: $_fromServerTopic');
 
     MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.connected));
@@ -278,12 +279,10 @@ class MqttCore {
     MessageService().publish<JobReceivedMessage>(Constants.messageTopicJobReceived, arguments: JobReceivedMessage(job: newJob));
   }
 
-  void _jobDeleteReceived(List<dynamic> payloadData) async {
-    Map<String, dynamic> map = {};
-    map["jobDel"] = payloadData;
-    var jobDelMessage = JobDelMessage.fromJson(map);
+  void _jobDeleteReceived(payloadData) async {
+    var jobDelMessage = JobDelMessage.fromJson(payloadData);
 
-    for(var jobId in jobDelMessage.jobDel) {
+    for(var jobId in jobDelMessage.jobs) {
       await MyApp.isarInstance.writeTxn(() async {
         await MyApp.isarInstance.jobs.delete(jobId);
       });