summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSerguey Parkhomovsky <xindigo@gmail.com>2026-03-17 20:47:58 -0700
committerSerguey Parkhomovsky <xindigo@gmail.com>2026-03-17 20:49:23 -0700
commit06693b731e2fecefdee8db554ac1c6d113b9a819 (patch)
tree500ccd053564076c72c8409b91f37be411a5d34d /src
parentb42ed72e7d8f6b0a3538acdc299b1d132f8f22cb (diff)
Add tracing macros
Diffstat (limited to 'src')
-rw-r--r--src/main.rs14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/main.rs b/src/main.rs
index d1e7a03..3c2c772 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -22,12 +22,12 @@ async fn main() {
for printer in config.printers {
match printer {
Printer::Prusa { name, host, api_key } => {
- println!("Found Prusa: {} at {}", name, host);
+ tracing::info!(name, host, "Found Prusa");
let state_clone = state.clone();
tokio::spawn(poll_prusa(name, host, api_key, state_clone));
}
Printer::Bambu { name, host, serial_number, access_code } => {
- println!("Found Bambu: {} at {}", name, host);
+ tracing::info!(name, host, "Found Bambu");
let state_clone = state.clone();
tokio::spawn(poll_bambu(name, host, serial_number, access_code, state_clone));
}
@@ -65,7 +65,7 @@ async fn poll_prusa(
}
.await;
if let Err(e) = result {
- eprintln!("Error polling Prusa printer {}: {}", name, e);
+ tracing::error!(name, error = %e, "Error polling Prusa printer");
}
tokio::time::sleep(Duration::from_secs(5)).await;
}
@@ -99,20 +99,20 @@ async fn poll_bambu(
// eventloop.poll() yields back to Tokio when there's no data
match eventloop.poll().await {
Ok(Event::Incoming(Packet::Publish(p))) => {
- println!("{:?}", &p.payload);
+ tracing::debug!(payload = ?p.payload, "Received Bambu payload");
match serde_json::from_slice::<BambuStatus>(&p.payload) {
Ok(msg) => {
let mut lock = state.lock().await;
let entry = lock.entry(name.clone()).or_default();
extract_status_from_bambu(&msg, entry);
- println!("Updated state for {}: {:?}", &name, p.payload);
+ tracing::debug!(name, payload = ?p.payload, "Updated state");
}
- Err(e) => eprintln!("Failed to deserialize BambuStatus: {}", e),
+ Err(e) => tracing::error!(error = %e, "Failed to deserialize BambuStatus"),
}
}
Ok(_) => {}
Err(e) => {
- eprintln!("MQTT error: {:?}", e);
+ tracing::error!(error = ?e, "MQTT error");
tokio::time::sleep(Duration::from_secs(5)).await; // Simple retry
}
}