m365 0.1.1

A lightweight rust library to receive BLE Xiaomi M365 scooter messages
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 btleplug::platform::{Peripheral};
use btleplug::api::{Peripheral as _};
use anyhow::Result;
use tokio::time;
use std::time::Duration;

pub struct ConnectionHelper {
  device: Peripheral
}

impl ConnectionHelper {
  pub fn new(device: &Peripheral) -> Self {
    Self { device: device.clone() }
  }

  pub async fn connect(&self) -> Result<bool, btleplug::Error> {
    tracing::debug!("Connecting to device.");
    let mut retries = 5;
    while retries >= 0 {
      if self.device.is_connected().await? {
        tracing::debug!("Connected to device");
        break;
      }
      match self.device.connect().await {
        Ok(_) => break,
        Err(err) if retries > 0 => {
          retries -= 1;
          tracing::debug!("Retrying connection: {} retries left, reason: {}", retries, err);
          time::sleep(Duration::from_secs(1)).await;
        },

        Err(err) => return Err(err)
      }
    }

    Ok(true)
  }

  pub async fn disconnect(&self) -> Result<bool> {
    if !self.device.is_connected().await? {
      tracing::debug!("Already disconnected.");
      return Ok(true);
    }

    if let Err(error) = self.device.disconnect().await {
      tracing::error!("Could not disconnect: {}", error);
      return Ok(false)
    }

    tracing::debug!("Disconnected from device");
    Ok(true)
  }

  pub async fn reconnect(&self) -> Result<bool> {
    tracing::debug!("Reconnecting...");
    self.disconnect().await?;
    time::sleep(Duration::from_secs(5)).await;
    self.connect().await?;
    Ok(true)
  }
}