Refactor bridge for better visibility when waiting

thin-edge · Jul 25, 2024 · 00be96e · 00be96e
1 parent 710cead
commit 00be96e
Show file tree

Hide file tree

Showing 5 changed files with 648 additions and 138 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/extensions/tedge_mqtt_bridge/Cargo.toml b/crates/extensions/tedge_mqtt_bridge/Cargo.toml
@@ -21,6 +21,7 @@ certificate = { workspace = true }
 futures = { workspace = true }
 mqtt_channel = { workspace = true }
 mutants = { workspace = true }
+pin-project = { workspace = true }
 rumqttc = { workspace = true }
 tedge_actors = { workspace = true }
 tedge_config = { workspace = true }

diff --git a/crates/extensions/tedge_mqtt_bridge/src/health.rs b/crates/extensions/tedge_mqtt_bridge/src/health.rs
@@ -71,6 +71,7 @@ type NotificationRes = Result<Event, ConnectionError>;
 /// A client for [BridgeHealthMonitor]
 ///
 /// This is used by each bridge half to log and notify the monitor of health status updates
+#[derive(Debug)]
 pub struct BridgeHealth {
     name: &'static str,
     tx_health: mpsc::Sender<(&'static str, Status)>,
@@ -104,7 +105,8 @@ impl BridgeHealth {
             }
             self.last_err = err;
             let status = self.last_err.as_ref().map_or(Status::Up, |_| Status::Down);
-            self.tx_health.send((name, status)).await.unwrap()
+            let mut tx_health = self.tx_health.clone();
+            tokio::spawn(async move { tx_health.send((name, status)).await.unwrap() });
         }
     }
 }