SubscribeById implementation

eclipse-kuksa · Oct 22, 2024 · f1b9b71 · f1b9b71
1 parent 7b47ed9
commit f1b9b71
Show file tree

Hide file tree

Showing 2 changed files with 268 additions and 39 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>,
 }
@@ -774,6 +775,7 @@ impl ChangeSubscription {
                                             // fill unit field always
                                             update.unit.clone_from(&entry.metadata.unit);
                                             notifications.updates.push(ChangeNotification {
+                                                id: *id,
                                                 update,
                                                 fields: notify_fields,
                                             });
@@ -823,6 +825,7 @@ impl ChangeSubscription {
                                     notify_fields.insert(Field::ActuatorTarget);
                                 }
                                 notifications.updates.push(ChangeNotification {
+                                    id: *id,
                                     update,
                                     fields: notify_fields,
                                 });