kondis 0.3.2

a simple library to communicate with exercise equipment
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use std::sync::mpsc::Receiver;

use btleplug::{
    api::{Central as _, CentralEvent, Manager as _, Peripheral as _, ScanFilter},
    platform::{Manager, Peripheral},
};
use futures::StreamExt as _;

use crate::EquipmentType;

/// Get a Bluetooth peripheral for the specified equipment type
pub async fn get_peripheral(
    equipment_type: EquipmentType,
    shutdown_rx: &mut Receiver<()>,
) -> anyhow::Result<Option<(Peripheral, String)>> {
    let manager = Manager::new().await.unwrap();
    let adapters = manager.adapters().await?;
    let mut events = Vec::new();
    let mut peripheral_meta: Option<(Peripheral, String)> = None;

    for adapter in &adapters {
        events.push(adapter.events().await?);
        adapter.start_scan(ScanFilter::default()).await?;
    }

    let contains_predicate = match equipment_type {
        EquipmentType::Iconsole0028Bike => "iConsole+0028",
        EquipmentType::DebugBike => "Console",
        _ => "bike",
    };

    if shutdown_rx.try_recv().is_ok() {
        return Ok(peripheral_meta);
    }

    while let Some(event) = futures::stream::iter(events.iter_mut())
        .flatten()
        .next()
        .await
    {
        if shutdown_rx.try_recv().is_ok() {
            break;
        }
        if let CentralEvent::DeviceDiscovered(id) = event {
            let central = adapters.get(1).unwrap();
            let peripheral = central.peripheral(&id).await?;
            if let Some(name) = peripheral.properties().await.unwrap().unwrap().local_name
                // todo: make this configurable ()
                && name.contains(contains_predicate)
            {
                peripheral_meta = Some((peripheral, name.to_string()));
                break;
            }
        }
    }
    for adapter in adapters {
        adapter.stop_scan().await?;
    }

    Ok(peripheral_meta)
}