Merge pull request #344 from rgallor/fix/purge-property-0.6

chore(forward): forward port release v0.5.4

CHANGELOG.md

@@ -4,6 +4,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.5.4] - 2024-05-22
+### Fixed
+- Purge property deletes only the server property [#342](https://github.com/astarte-platform/astarte-device-sdk-rust/pull/342)
+
 ## [0.6.5] - 2024-04-08
 ### Fixed
 - Delete all interface's properties, using the correct mapping, when an

astarte-device-sdk-derive/CHANGELOG.md

@@ -4,6 +4,8 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.5.4] - 2024-05-22
+
 ## [0.6.5] - 2024-04-08
 
 ## [0.6.4] - 2024-03-20

src/lib.rs

@@ -394,7 +394,7 @@ where
                             if interface == "control" && path == "/consumer/properties" {
                                 debug!("Purging properties");
 
-                                self.purge_properties(&payload).await?;
+                                self.purge_server_properties(&payload).await?;
 
                                 continue;
                             }
@@ -496,12 +496,23 @@ where
         format!("{}/{}", self.realm, self.device_id)
     }
 
-    async fn purge_properties(&self, bdata: &[u8]) -> Result<(), Error> {
+    /// This function deletes all the stored server owned properties after receiving a publish on
+    /// `/control/consumer/properties`
+    async fn purge_server_properties(&self, bdata: &[u8]) -> Result<(), Error> {
+        let paths = properties::extract_set_properties(bdata)?;
+
+        let interfaces = self.interfaces.read().await;
+
         let stored_props = self.store.load_all_props().await?;
 
-        let paths = properties::extract_set_properties(bdata)?;
+        let server_owned_properties = stored_props.into_iter().filter(|prop| {
+            interfaces
+                .get_property(&prop.interface)
+                .map(|i| i.ownership())
+                == Some(Ownership::Server)
+        });
 
-        for stored_prop in stored_props {
+        for stored_prop in server_owned_properties {
             if paths.contains(&format!("{}{}", stored_prop.interface, stored_prop.path)) {
                 continue;
             }