feat(proto): implement properties conversion for proto

Define function to convert a vec of StoredProp into the
corresponding protobuf value.

Signed-off-by: Riccardo Gallo <riccardo.gallo@secomind.com>

Author: rgallor

src/transport/grpc/convert.rs

@@ -21,6 +21,7 @@
 //! Contains conversion traits to convert the Astarte types in the protobuf format to the
 //! Astarte types from the Astarte device SDK.
 
+use std::collections::HashMap;
 use std::num::TryFromIntError;
 
 use astarte_message_hub_proto::astarte_data::AstarteData as ProtoData;
@@ -32,6 +33,7 @@ use astarte_message_hub_proto::{
 use chrono::TimeZone;
 use itertools::Itertools;
 
+use super::{GrpcError, GrpcPayload};
 use crate::aggregate::AstarteObject;
 use crate::interface::Ownership;
 use crate::store::StoredProp;
@@ -42,8 +44,6 @@ use crate::{
 };
 use crate::{DeviceEvent, Value};
 
-use super::{GrpcError, GrpcPayload};
-
 /// Error returned by the Message Hub types conversions.
 #[non_exhaustive]
 #[derive(thiserror::Error, Debug)]
@@ -108,6 +108,38 @@ pub(crate) fn map_set_stored_properties(
         .try_collect()
 }
 
+/// Map a list of stored properties to , unset value will result in an error of the conversion
+pub fn map_stored_properties_to_proto(
+    props: Vec<StoredProp>,
+) -> astarte_message_hub_proto::StoredProperties {
+    let interface_properties =
+        props
+            .into_iter()
+            .fold(HashMap::new(), |mut interface_properties, prop| {
+                let entry_prop = interface_properties
+                    .entry(prop.interface)
+                    .or_insert_with(|| astarte_message_hub_proto::InterfaceProperties {
+                        ownership: astarte_message_hub_proto::Ownership::from(prop.ownership)
+                            as i32,
+                        version_major: prop.interface_major,
+                        properties: vec![],
+                    });
+
+                let property = astarte_message_hub_proto::Property {
+                    path: prop.path,
+                    data: Some(prop.value.into()),
+                };
+
+                entry_prop.properties.push(property);
+
+                interface_properties
+            });
+
+    astarte_message_hub_proto::StoredProperties {
+        interface_properties,
+    }
+}
+
 impl From<astarte_message_hub_proto::Ownership> for Ownership {
     fn from(value: astarte_message_hub_proto::Ownership) -> Self {
         match value {
@@ -117,6 +149,25 @@ impl From<astarte_message_hub_proto::Ownership> for Ownership {
     }
 }
 
+impl From<Ownership> for astarte_message_hub_proto::Ownership {
+    fn from(value: Ownership) -> Self {
+        match value {
+            Ownership::Device => astarte_message_hub_proto::Ownership::Device,
+            Ownership::Server => astarte_message_hub_proto::Ownership::Server,
+        }
+    }
+}
+
+/// Construct an sdk astarte type from a property that is required to be set
+impl TryFrom<astarte_message_hub_proto::Property> for AstarteType {
+    type Error = MessageHubProtoError;
+
+    fn try_from(property: astarte_message_hub_proto::Property) -> Result<Self, Self::Error> {
+        map_property_to_astarte_type(property)
+            .and_then(|e| e.ok_or(MessageHubProtoError::ExpectedField("value")))
+    }
+}
+
 impl TryFrom<astarte_message_hub_proto::AstarteData> for AstarteType {
     type Error = MessageHubProtoError;
 

src/transport/grpc/mod.rs

@@ -645,6 +645,7 @@ mod test {
     };
     use uuid::uuid;
 
+    use super::*;
     use crate::{
         aggregate::AstarteObject,
         builder::DEFAULT_VOLATILE_CAPACITY,
@@ -656,8 +657,6 @@ mod test {
         DeviceEvent, Value,
     };
 
-    use super::*;
-
     pub(crate) const ID: Uuid = uuid!("67e55044-10b1-426f-9247-bb680e5fe0c8");
 
     #[derive(Debug)]