Merge pull request #81 from boschglobal/feature/subscribe_by_id_imple…

…mentation Subscribe by id Integer32 implementation
eclipse-kuksa · Oct 22, 2024 · d0424e9 · d0424e9
2 parents d94497e + a8df2f6
commit d0424e9
Show file tree

Hide file tree

Showing 2 changed files with 272 additions and 55 deletions.
diff --git a/databroker/src/broker.rs b/databroker/src/broker.rs
@@ -132,6 +132,7 @@ pub struct QueryField {
 
 #[derive(Debug)]
 pub struct ChangeNotification {
+    pub id: i32,
     pub update: EntryUpdate,
     pub fields: HashSet<Field>,
 }
@@ -775,6 +776,7 @@ impl ChangeSubscription {
                                             // fill unit field always
                                             update.unit.clone_from(&entry.metadata.unit);
                                             notifications.updates.push(ChangeNotification {
+                                                id: *id,
                                                 update,
                                                 fields: notify_fields,
                                             });
@@ -824,6 +826,7 @@ impl ChangeSubscription {
                                     notify_fields.insert(Field::ActuatorTarget);
                                 }
                                 notifications.updates.push(ChangeNotification {
+                                    id: *id,
                                     update,
                                     fields: notify_fields,
                                 });