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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use anyhow::{Result, Context};
use btleplug::api::{BDAddr};
use tracing_subscriber;
use tokio::io::AsyncReadExt;
use std::path::Path;
use tokio::fs::File;
use tracing::Level;
use std::env;
use tracing_subscriber::fmt::format::FmtSpan;
use tokio::time;
use std::time::Duration;

use m365::{
  AuthToken,
  ScooterScanner,
  LoginRequest,
  ConnectionHelper,
  TailLight
};

async fn load_token() -> Result<AuthToken> {
  let path = Path::new(".mi-token");
  tracing::debug!("Opening token: {:?}", path);

  let mut f = File::open(path).await?;
  let mut buffer : AuthToken = [0; 12];

  f.read(&mut buffer).await?;

  Ok(buffer)
}

#[tokio::main(flavor = "multi_thread")]
async fn main() -> Result<()>{
  tracing_subscriber::fmt()
    .with_max_level(Level::INFO)
    .with_span_events(FmtSpan::CLOSE)
    .init();

  let args: Vec<String> = env::args().collect();
  if args.len() < 2 || args[1].is_empty() {
    panic!("First argument is scooter mac address");
  }

  let token = load_token().await
    .with_context(|| "Could not load registration token")?;

  let mac = BDAddr::from_str_delim(&args[1]).expect("Invalid mac address");
  tracing::info!("Searching scooter with address: {}", mac);

  let mut scanner = ScooterScanner::new().await?;
  let scooter = scanner.wait_for(&mac).await?;
  let device = scanner.peripheral(&scooter).await?;
  let connection = ConnectionHelper::new(&device);
  connection.reconnect().await?;

  let mut request = LoginRequest::new(&device, &token).await?;
  let mut session = request.start().await?;

  tracing::info!("Logged in with success, reading data...");

  tracing::info!("  Supplementary info {:?}", session.supplementary_info().await?);
  tracing::info!("  Cruise enabled: {}", session.is_cruise_on().await?);
  tracing::info!("  Tail light enabled: {:?}", session.tail_light().await?);

  tracing::info!("  Cruise status: {}, Switching on", session.is_cruise_on().await?);
  session.set_cruise(true).await?;
  tracing::info!("  Supplementary info {:?}", session.supplementary_info().await?);
  tracing::info!("  Cruise status: {}, Switching off", session.is_cruise_on().await?);
  session.set_cruise(false).await?;
  tracing::info!("  Cruise status: {}", session.is_cruise_on().await?);
  tracing::info!("  Supplementary info {:?}", session.supplementary_info().await?);

  tracing::info!("  Tail light enabled: {:?}, Switching on", session.tail_light().await?);
  session.set_tail_light(TailLight::Always).await?;
  tracing::info!("  Supplementary info {:?}", session.supplementary_info().await?);
  tracing::info!("  Tail light enabled: {:?}, Switching off", session.tail_light().await?);
  time::sleep(Duration::from_secs(2)).await;
  session.set_tail_light(TailLight::Off).await?;
  tracing::info!("  Tail light enabled: {:?}", session.tail_light().await?);
  tracing::info!("  Supplementary info {:?}", session.supplementary_info().await?);

  Ok(())
}