Request all properties from message hub

Signed-off-by: Luca Arato <luca.arato@secomind.com>

Author: lucaato

src/builder.rs

@@ -107,7 +107,7 @@ pub struct Config {
     pub(crate) writable_dir: Option<PathBuf>,
 }
 
-/// Struct use to pass the connection configuration to the [`ConnectionConfig`]
+/// Struct used to pass the connection configuration to the [`ConnectionConfig`]
 #[derive(Debug, Clone)]
 pub struct ConnectionBuildConfig<'a, S> {
     pub(crate) store: S,

src/transport/grpc/mod.rs

@@ -522,7 +522,7 @@ impl<S> Connection for Grpc<S>
 where
     S: PropertyStore,
 {
-    type Sender = GrpcClient<GrpcStore<S>>;
+    type Sender = GrpcClient<GrpcStore>;
 }
 
 /// Internal struct holding the received grpc message
@@ -568,7 +568,7 @@ impl<S> ConnectionConfig<S> for GrpcConfig
 where
     S: StoreCapabilities + PropertyStore + Send + Sync,
 {
-    type Store = GrpcStore<S>;
+    type Store = GrpcStore;
     type Conn = Grpc<S>;
     type Err = GrpcError;
 
@@ -577,9 +577,7 @@ where
         config: ConnectionBuildConfig<'_, S>,
     ) -> Result<DeviceTransport<Self::Store, Self::Conn>, Self::Err> {
         let ConnectionBuildConfig {
-            store,
-            interfaces,
-            config,
+            interfaces, config, ..
         } = config;
 
         let channel = self.endpoint.connect().await.map_err(GrpcError::from)?;
@@ -591,7 +589,7 @@ where
         let node_data = NodeData::try_from(interfaces)?;
         let stream = Grpc::<StoreWrapper<S>>::attach(&mut client, node_data).await?;
 
-        let grpc_store = StoreWrapper::new(GrpcStore::new(store.clone(), client.clone()));
+        let grpc_store = StoreWrapper::new(GrpcStore::new(client.clone()));
 
         let sender = GrpcClient::new(client.clone(), grpc_store.clone(), config.volatile.clone());
         let receiver = Grpc::new(self.uuid, client, stream);