refactor(examples): remove env-logger and setup eyre and tracing

Signed-off-by: Joshua Chapman <joshua.chapman@secomind.com>

Author: joshuachp

Cargo.lock

@@ -103,7 +103,7 @@ astarte-message-hub-proto = { workspace = true }
 astarte-message-hub-proto-mock = { workspace = true }
 async-trait = { workspace = true }
 color-eyre = { workspace = true }
-env_logger = { workspace = true }
+eyre = { workspace = true }
 mockall = { workspace = true }
 mockito = { workspace = true }
 pretty_assertions = { workspace = true }
@@ -143,7 +143,6 @@ bytes = "1.5.0"
 cfg-if = "1.0.0"
 chrono = "0.4.20"
 color-eyre = "0.6.3"
-env_logger = "0.11.0"
 eyre = "0.6.12"
 flate2 = "1.0.0"
 flume = "0.11.0"

Cargo.toml

@@ -20,6 +20,7 @@
 
 use std::time::{Duration, SystemTime};
 
+use eyre::OptionExt;
 use serde::Deserialize;
 
 use astarte_device_sdk::{
@@ -28,8 +29,7 @@ use astarte_device_sdk::{
 };
 use tokio::task::JoinSet;
 use tracing::error;
-
-type DynError = Box<dyn std::error::Error + Send + Sync + 'static>;
+use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
 #[derive(Deserialize)]
 struct Config {
@@ -40,14 +40,17 @@ struct Config {
 }
 
 #[tokio::main]
-async fn main() -> Result<(), DynError> {
-    env_logger::init();
+async fn main() -> eyre::Result<()> {
+    color_eyre::install()?;
+    tracing_subscriber::registry()
+        .with(tracing_subscriber::fmt::layer())
+        .try_init()?;
+
     let now = SystemTime::now();
 
     // Load configuration
-    let file =
-        std::fs::read_to_string("./examples/individual_datastream/configuration.json").unwrap();
-    let cfg: Config = serde_json::from_str(&file).unwrap();
+    let file = std::fs::read_to_string("./examples/individual_datastream/configuration.json")?;
+    let cfg: Config = serde_json::from_str(&file)?;
 
     let mut mqtt_config = MqttConfig::with_credential_secret(
         &cfg.realm,
@@ -67,7 +70,7 @@ async fn main() -> Result<(), DynError> {
     let client_cl = client.clone();
     println!("Connection to Astarte established.");
 
-    let mut tasks = JoinSet::<Result<(), DynError>>::new();
+    let mut tasks = JoinSet::<eyre::Result<()>>::new();
 
     // Create a task to transmit
     tasks.spawn(async move {
@@ -113,7 +116,7 @@ async fn main() -> Result<(), DynError> {
                         let led_id = iter
                             .next()
                             .and_then(|id| id.parse::<u16>().ok())
-                            .ok_or("Incorrect error received.")?;
+                            .ok_or_eyre("Incorrect error received.")?;
 
                         match iter.next() {
                             Some("enable") => {
@@ -124,7 +127,7 @@ async fn main() -> Result<(), DynError> {
                         );
                             }
                             Some("intensity") => {
-                                let value: f64 = var.try_into().unwrap();
+                                let value: f64 = var.try_into()?;
                                 println!(
                             "Received new intensity datastream for LED number {}. LED intensity is now {}",
                             led_id, value