From 30a3b0fa0d45fe52c950506e729df714f880cf13 Mon Sep 17 00:00:00 2001 From: Claas Date: Sat, 2 Nov 2024 21:43:09 +0100 Subject: [PATCH] Make echo optional to allow only listening --- debug-listener/src/main.rs | 23 ++++++++++++++--------- 1 file changed, 14 insertions(+), 9 deletions(-) diff --git a/debug-listener/src/main.rs b/debug-listener/src/main.rs index bf1316d..bc3ee8e 100644 --- a/debug-listener/src/main.rs +++ b/debug-listener/src/main.rs @@ -27,6 +27,7 @@ async fn main() -> serialport::Result<()> { let mut port = open_serial_port()?; let mut count = 0u64; + let is_echo = false; println!("\nListening on device {}", PORT_NAME); loop { @@ -45,17 +46,21 @@ async fn main() -> serialport::Result<()> { // let bytes_read = port.read_to_end(&mut buffer)?; println!( "message {count} - bytes_read: ({:?}) {:?} {:#b} {:#b} ", - bytes_read, buffer, buffer[0], buffer[1] + bytes_read, + &buffer[..bytes_read], + buffer[0], + buffer[1] ); - // Wait as the fan would wait too - tokio::time::sleep(std::time::Duration::from_secs(1)).await; - // Echo - let result = port.write(&buffer[..bytes_read]); - println!("Echoed message back {:?}", result); - let result = port.flush(); - println!("Flushed message back {:?}", result); - + if is_echo { + // Wait as the fan would wait too + tokio::time::sleep(std::time::Duration::from_secs(1)).await; + // Echo + let result = port.write(&buffer[..bytes_read]); + println!("Echoed message back {:?}", result); + let result = port.flush(); + println!("Flushed message back {:?}", result); + } // let inverse: Vec = buffer.iter().map(|byte| byte.to_be()).collect::>(); // println!("message {count} - inverse: {:?}", inverse); count += 1; -- 2.51.2