Add logging for failed MQTT message handling

Signed-off-by: Kate Goldenring <[email protected]>
spinkube · Aug 2, 2024 · cecc464 · cecc464
1 parent fa32e53
commit cecc464
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 7 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -16,6 +16,7 @@ spin-expressions = { git = "https://github.com/fermyon/spin", tag = "v2.6.0" }
 spin-trigger = { git = "https://github.com/fermyon/spin", tag = "v2.6.0" }
 spin-telemetry = { git = "https://github.com/fermyon/spin", tag = "v2.6.0" }
 tokio = { version = "1.37", features = ["full"] }
+tracing = { version = "0.1", features = ["log"] }
 paho-mqtt = { version = "0.12.3", features = [
     "vendored-ssl",
 ] }

diff --git a/build.rs b/build.rs
@@ -7,4 +7,4 @@ fn main() {
         // Required for OpenSSL with musl
         println!("cargo:rustc-link-arg=-lc");
     }
-}
+}
diff --git a/src/lib.rs b/src/lib.rs
@@ -205,12 +205,16 @@ impl MqttTrigger {
             match rx.recv().await {
                 Ok(Some(msg)) => {
                     // Handle the received message
-                    self.handle_mqtt_event(
-                        &component_id,
-                        msg.payload().to_vec(),
-                        msg.topic().to_owned(),
-                    )
-                    .await?;
+                    if let Err(e) = self
+                        .handle_mqtt_event(
+                            &component_id,
+                            msg.payload().to_vec(),
+                            msg.topic().to_owned(),
+                        )
+                        .await
+                    {
+                        tracing::error!("Error handling MQTT message: {:?}", e);
+                    }
                 }
                 Ok(None) => {
                     // Todo: Figure out what this case is
-Original file line number
+Diff line change
@@ Expand Up / @@ -7,4 +7,4 @@ fn main() { @@
             // Required for OpenSSL with musl
             println!("cargo:rustc-link-arg=-lc");
         }
-    }
+    }