get topic from message and update template

Signed-off-by: karthik2804 <[email protected]>

Author: karthik2804

src/lib.rs

@@ -206,7 +206,11 @@ impl MqttTrigger {
                 Ok(Some(msg)) => {
                     // Handle the received message
                     _ = self
-                        .handle_mqtt_event(&component_id, msg.payload().to_vec(), topic.clone())
+                        .handle_mqtt_event(
+                            &component_id,
+                            msg.payload().to_vec(),
+                            msg.topic().to_owned(),
+                        )
                         .await
                         .map_err(|err| tracing::error!("{err}"));
                 }

templates/mqtt-rust/content/src/lib.rs

@@ -1,8 +1,8 @@
-use spin_mqtt_sdk::{mqtt_component, Payload};
 use chrono::{DateTime, Utc};
+use spin_mqtt_sdk::{mqtt_component, Metadata, Payload};
 
 #[mqtt_component]
-fn handle_message(message: Payload) -> anyhow::Result<()> {
+async fn handle_message(message: Payload, metadata: Metadata) -> anyhow::Result<()> {
     let datetime: DateTime<Utc> = std::time::SystemTime::now().into();
     let formatted_time = datetime.format("%Y-%m-%d %H:%M:%S.%f").to_string();
 
@@ -12,4 +12,4 @@ fn handle_message(message: Payload) -> anyhow::Result<()> {
         String::from_utf8_lossy(&message)
     );
     Ok(())
-}
+}