max/sensirion_exporter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add verbose mode and hide logs by default

Browse Source
This commit is contained in:
Maxime Augier 2024-04-20 12:55:57 +02:00
parent cc63f34e9e
commit 6f03f9e4e7
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main.rs
View File

@ -15,7 +15,7 @@ const VENDOR_ID_SENSIRION: u16 = 0x06d5;
struct Data { struct Data {
/// ID /// ID
addr: Address, addr: Address,
/// Temperature in °C /// Temperature in °C
temperature: f32, temperature: f32,
@ -83,12 +83,17 @@ struct CLI {
#[arg(short, long)] #[arg(short, long)]
interface: Option<String>, interface: Option<String>,
/// Log measurements to stderr
#[arg(short, long)]
verbose: bool
} }
#[tokio::main(flavor="current_thread")] #[tokio::main(flavor="current_thread")]
async fn main() -> Result<()> { async fn main() -> Result<()> {
let args = CLI::parse(); let args = CLI::parse();
let verbose = args.verbose;
let session = bluer::Session::new().await?; let session = bluer::Session::new().await?;
let adapter = match &args.interface { let adapter = match &args.interface {
@ -104,7 +109,7 @@ async fn main() -> Result<()> {
let sniffer_store = Arc::clone(&store); let sniffer_store = Arc::clone(&store);
tokio::spawn(async move { tokio::spawn(async move {
while let Some(data) = stream.next().await { while let Some(data) = stream.next().await {
eprintln!("Data point: {:?}", data); if verbose { eprintln!("Data point: {:?}", data) };
sniffer_store.lock().await.insert(data, SystemTime::now()); sniffer_store.lock().await.insert(data, SystemTime::now());
} }
}); });
@ -118,6 +123,8 @@ async fn main() -> Result<()> {
let host = tokio::net::lookup_host(&args.bind).await? let host = tokio::net::lookup_host(&args.bind).await?
.next() .next()
.ok_or(anyhow!("Cannot resolve host to bind {}", &args.bind))?; .ok_or(anyhow!("Cannot resolve host to bind {}", &args.bind))?;
eprintln!("Binding to {}", host);
Ok(warp::serve(filter).run(host).await) Ok(warp::serve(filter).run(host).await)
} }