Erweiterungen

lib/tools/mqtt_core.dart

@@ -9,6 +9,7 @@ import 'package:mqtt_client/mqtt_server_client.dart';
 import 'package:stadtbote/model/enqueued_message.dart';
 import 'package:stadtbote/model/ranking.dart';
 import 'package:stadtbote/model/status.dart';
+import 'package:stadtbote/protocoll_messages/acknowledge_job.dart';
 import 'package:stadtbote/protocoll_messages/bootstrap_request.dart';
 import 'package:stadtbote/protocoll_messages/bootstrap_response_payload.dart';
 import 'package:stadtbote/protocoll_messages/device_object.dart';
@@ -285,6 +286,8 @@ class MqttCore {
       }
 
       MessageService().publish<JobReceivedMessage>(Constants.messageTopicJobReceived, arguments: JobReceivedMessage(job: newJob));
+
+      _acknowlegdeJob(newJob);
     }
   }
 
@@ -483,4 +486,30 @@ class MqttCore {
       }
     }
   }
+
+  /*
+  private void AcknowledgeJob(Job job)
+    {
+        var payloadObject = new JObject();
+
+        var receivedObject = new JObject();
+        payloadObject.Add(new JProperty("received", receivedObject));
+
+        receivedObject.Add(new JProperty("id", job.Id));
+        receivedObject.Add(new JProperty("state", job.State));
+        receivedObject.Add(new JProperty("ver", job.Ver));
+        receivedObject.Add(new JProperty("utc", Utils.GetUTCTimestamp()));
+
+        SendJsonMessageAsync("job", payloadObject);
+    }
+   */
+  void _acknowlegdeJob(Job job) {
+    var message = AcknowledgeJob();
+    message.id = job.id;
+    message.state = job.state;
+    message.ver = job.ver;
+    message.utc = DateTime.now().millisecondsSinceEpoch;
+
+    MqttCore.instance.publishPayloadMessage('job', message.toJson());
+  }
 }