Merge pull request #433 from joshuachp/fix/grpc-store-visibility

fix(grpc): make the store public

Author: harlem88

src/builder.rs

@@ -332,7 +332,7 @@ where
         self,
     ) -> Result<(DeviceClient<C::Store>, DeviceConnection<C::Store, C::Conn>), crate::Error> {
         let channel_size = self.config.channel_size;
-        // We use the flume channel to have a clonable receiver, see the comment on the DeviceClient for more information.
+        // We use the flume channel to have a cloneable receiver, see the comment on the DeviceClient for more information.
         let (tx_connection, rx_client) = flume::bounded(channel_size);
         let (tx_client, rx_connection) = mpsc::channel(channel_size);
 
@@ -341,19 +341,18 @@ where
             .set_capacity(C::volatile_capacity_override().unwrap_or(self.config.volatile_retention))
             .await;
 
-        let transport = self
-            .connection_config
-            .connect(ConnectionBuildConfig {
-                store: self.store.clone(),
-                interfaces: &self.interfaces,
-                config: self.config,
-            })
-            .await?;
+        let config = ConnectionBuildConfig {
+            store: self.store,
+            interfaces: &self.interfaces,
+            config: self.config,
+        };
+
         let DeviceTransport {
             connection,
             sender,
             store,
-        } = transport;
+        } = self.connection_config.connect(config).await?;
+
         let interfaces = Arc::new(RwLock::new(self.interfaces));
 
         let client =

src/transport/grpc/mod.rs

@@ -24,9 +24,6 @@
 //! It defines the `Grpc` struct, which represents a GRPC connection, along with traits for publishing,
 //! receiving, and registering interfaces.
 
-pub mod convert;
-mod store;
-
 use std::borrow::Borrow;
 use std::collections::HashMap;
 use std::marker::PhantomData;
@@ -46,12 +43,12 @@ use astarte_message_hub_proto::{
     MessageHubEvent, Node,
 };
 use bytes::Bytes;
-use store::GrpcStore;
 use sync_wrapper::SyncWrapper;
 use tracing::{debug, error, trace, warn};
 use uuid::Uuid;
 
 use self::convert::MessageHubProtoError;
+use self::store::GrpcStore;
 use super::{
     Connection, Disconnect, Publish, Receive, ReceivedEvent, Reconnect, Register, TransportError,
 };
@@ -77,6 +74,9 @@ use crate::{
     Error, Interface, Timestamp,
 };
 
+pub mod convert;
+pub mod store;
+
 #[cfg(feature = "message-hub")]
 #[cfg_attr(docsrs, doc(cfg(feature = "message-hub")))]
 pub use astarte_message_hub_proto::tonic;
@@ -571,7 +571,7 @@ where
     S: StoreCapabilities + PropertyStore + Send + Sync,
 {
     type Store = GrpcStore;
-    type Conn = Grpc<S>;
+    type Conn = Grpc<GrpcStore>;
     type Err = GrpcError;
 
     async fn connect(