From f2f257e9e1f1e2a6fefd5df00a317ae721031d5a Mon Sep 17 00:00:00 2001 From: Serguey Parkhomovsky Date: Mon, 16 Mar 2026 21:13:51 -0700 Subject: add more fields to bambu status --- src/main.rs | 24 +++++++++++------------- 1 file changed, 11 insertions(+), 13 deletions(-) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index 5dc84eb..29df56d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -35,9 +35,8 @@ async fn main() { .json::() .await?; let mut lock = state_clone.lock().await; - lock.entry(name.clone()) - .and_modify(|prs| *prs = extract_status_from_prusa(&response)) - .or_insert_with(|| { extract_status_from_prusa(&response) } ); + let entry = lock.entry(name.clone()).or_default(); + extract_status_from_prusa(&response, entry); Ok(()) } .await; @@ -81,16 +80,15 @@ async fn main() { if let Event::Incoming(Packet::Publish(p)) = notification { let mut lock = state_clone.lock().await; println!("{:?}", &p.payload); - if let Ok(msg) = - serde_json::from_slice::(&p.payload) - { - lock.entry(name.clone()) - .and_modify(|prs| prs.bed_temp = msg.print.bed_temper) - .or_insert_with(|| PrinterState { - bed_temp: msg.print.bed_temper, - ..Default::default() - }); - println!("Updated state for {}: {:?}", &name, p.payload); + match serde_json::from_slice::(&p.payload) { + Ok(msg) => { + let entry = lock.entry(name.clone()).or_default(); + extract_status_from_bambu(&msg, entry); + println!("Updated state for {}: {:?}", &name, p.payload); + } + Err(e) => { + eprintln!("Failed to deserialize BambuStatus: {}", e); + } } } } -- cgit v1.2.3