Erweiterungen

lib/tools/mqtt_core.dart

@@ -147,10 +147,22 @@ class MqttCore {
                   _sessionMessageReceived(payloadData);
                   break;
 
+                case 'ranks':
+                  _rankingMessageReceived(payloadData);
+                  break;
+
                 case 'jobs':
                   _jobMessageReceived(payloadData);
                   break;
 
+                case 'job_del':
+                  _jobDeleteReceived(payloadData);
+                  break;
+
+                case 'sync_request':
+                  _syncRequestReceived(payloadData);
+                  break;
+
                 case "mssg":
                   _messageMessageReceived(payloadData);
                   break;
@@ -183,6 +195,18 @@ class MqttCore {
     BroadcastReceiver().publish<StatusInfoUpdate>(Constants.messageTopicStatusInfoUpdate, arguments: StatusInfoUpdate(status: statusMessage));
   }
 
+  void _rankingMessageReceived(payloadData) async {
+    Util.logInfo('_rankingMessageReceived');
+
+    /*var statusMessage = Status.fromJson(payloadData['status']);
+
+    await MyApp.isarInstance.writeTxn(() async {
+      await MyApp.isarInstance.status.put(statusMessage);
+    });
+
+    BroadcastReceiver().publish<StatusInfoUpdate>(Constants.messageTopicStatusInfoUpdate, arguments: StatusInfoUpdate(status: statusMessage));*/
+  }
+
   void _jobMessageReceived(payloadData) async {
     for (var foundJobData in payloadData) {
       Job newJob = Job.fromJson(foundJobData);
@@ -195,6 +219,34 @@ class MqttCore {
     }
   }
 
+  void _jobDeleteReceived(payloadData) async {
+    Util.logInfo('_jobDeleteReceived');
+
+    /*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));
+    }*/
+  }
+
+  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));
+    }*/
+  }
+
   void _messageMessageReceived(Map<String, dynamic> payloadData) async {
     var newMessage = Message.fromJson(payloadData);