Add logging for failed MQTT message handling

Signed-off-by: Kate Goldenring <[email protected]>

Author: kate-goldenring

Cargo.lock

@@ -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",
 ] }

Cargo.toml

@@ -7,4 +7,4 @@ fn main() {
         // Required for OpenSSL with musl
         println!("cargo:rustc-link-arg=-lc");
     }
-}
+}

build.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