feat(grpc): Add GrpcStore that requests updated properties

Properties are requested to the message hub server to
ensure they are updated in the eventuality of multiple clients
with the same property interface modifying them.

BREAKING CHANGE: Move a builder method to make it available to
Mqtt config only

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

Author: lucaato

Cargo.lock

@@ -107,7 +107,7 @@ rustc-args = ["--cfg=docsrs"]
 [workspace.dependencies]
 astarte-device-sdk = { path = "./", version = "=0.9.3" }
 astarte-device-sdk-derive = { version = "=0.9.3", path = "./astarte-device-sdk-derive" }
-astarte-message-hub-proto = { git = "https://github.com/astarte-platform/astarte-message-hub-proto.git", rev = "5ff0672d8fdc8cba5a2ff023895ae505d75c3d1a" }
+astarte-message-hub-proto = { git = "https://github.com/astarte-platform/astarte-message-hub-proto.git", rev = "370be08ff90236a25b15af6e27d5363739566f2f" }
 async-trait = "0.1.67"
 base64 = "0.22.0"
 bson = "2.7.0"

Cargo.toml

@@ -166,10 +166,9 @@ async fn init() -> eyre::Result<(DeviceClient<SqliteStore>, DeviceConnection<Sql
         .store(store)
         // NOTE: here we are not defining any Astarte interface, thus the device will not be able to
         // send or receive data to/from Astarte
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
-        .await;
+        .await?;
 
     Ok((client, connection))
 }
@@ -424,8 +423,7 @@ async fn main() -> eyre::Result<()> {
     let (client, connection) = DeviceBuilder::new()
         .store(store)
         .interface_directory("interfaces")?
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
         .await;
     */

docs/get-started.md

@@ -166,10 +166,9 @@ async fn main() -> eyre::Result<()> {
         .store_dir(&test_cfg.store_directory)
         .await?
         .interface_directory(&test_cfg.interfaces_fld)?
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
-        .await;
+        .await?;
 
     let rx_data_ind_datastream = Arc::new(Mutex::new(HashMap::new()));
     let rx_data_agg_datastream = Arc::new(Mutex::new((String::new(), HashMap::new())));

e2e-test/src/main.rs

@@ -60,10 +60,9 @@ async fn main() -> Result<(), DynError> {
     let (client, connection) = DeviceBuilder::new()
         .store(MemoryStore::new())
         .interface_directory("./examples/individual_datastream/interfaces")?
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
-        .await;
+        .await?;
 
     let client_cl = client.clone();
     println!("Connection to Astarte established.");

examples/individual_datastream/main.rs

@@ -82,10 +82,9 @@ async fn main() -> Result<(), DynError> {
     let (client, connection) = DeviceBuilder::new()
         .interface_directory("./examples/individual_properties/interfaces")?
         .store(db)
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
-        .await;
+        .await?;
     let device_cpy = client.clone();
 
     println!("Connection to Astarte established.");

examples/individual_properties/main.rs

@@ -65,10 +65,9 @@ async fn main() -> Result<(), Error> {
     let (client, connection) = DeviceBuilder::new()
         .store(MemoryStore::new())
         .interface_directory("./examples/object_datastream/interfaces")?
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
-        .await;
+        .await?;
 
     // Create an thread to transmit
     tokio::task::spawn(async move {

examples/object_datastream/main.rs

@@ -72,10 +72,9 @@ async fn main() -> Result<(), DynError> {
         .await?
         .interface_str(INTERFACE_STORED)?
         .interface_str(INTERFACE_VOLATILE)?
-        .connect(mqtt_config)
-        .await?
+        .connection(mqtt_config)
         .build()
-        .await;
+        .await?;
 
     let mut tasks = tokio::task::JoinSet::new();