Merge pull request #399 from lucaato/feature/get-properties

Feature/get properties

Author: harlem88

Cargo.lock

@@ -119,7 +119,7 @@ rustc-args = ["--cfg=docsrs"]
 [workspace.dependencies]
 astarte-device-sdk = { path = "./", version = "=0.9.6" }
 astarte-device-sdk-derive = { version = "=0.9.6", 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

@@ -170,10 +170,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();