//! This example finds the first BLE device that has a heart rate measurement characteristic,
//! connects to it and starts listening for heart rate values.

use bleasy::common::characteristics::HEART_RATE_MEASUREMENT;
use bleasy::{Error, ScanConfig, Scanner};
use futures::StreamExt;

#[tokio::main]
async fn main() -> Result<(), Error> {
    pretty_env_logger::init();

    let config = ScanConfig::default()
        .filter_by_characteristics(|chars| chars.contains(&HEART_RATE_MEASUREMENT))
        .stop_after_first_match();

    let mut scanner = Scanner::new();
    scanner.start(config).await?;

    let mut device_stream = scanner.device_stream();
    let device = device_stream.next().await.unwrap();

    scanner.stop().await?;

    for service in device.services().await.unwrap() {
        println!("Service: {}", service.uuid());
    }

    let hr_measurement = device
        .characteristic(HEART_RATE_MEASUREMENT)
        .await?
        .unwrap();
    let mut hr_stream = hr_measurement.subscribe().await?;

    while let Some(hr) = hr_stream.next().await {
        println!("RSSI: {}", device.rssi().await.unwrap_or(0));
        println!("{:?}", hr);
    }

    Ok(())
}