longshot 0.1.13

API and CLI for ECAM-based Delonghi machines
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

use crate::display;
use crate::ecam::{Ecam, EcamError, EcamStatus};
use crate::prelude::*;
use crate::protocol::*;

pub async fn power_on(
    ecam: Ecam,
    allow_off: bool,
    allow_alarms: bool,
    turn_on: bool,
) -> Result<bool, EcamError> {
    match ecam.current_state().await? {
        EcamStatus::Ready => {
            return Ok(true);
        }
        EcamStatus::StandBy => {
            if allow_off {
                info!("Machine is off, but --allow-off will allow us to proceed");
                return Ok(true);
            } else if !turn_on {
                info!("Machine is not on, pass --turn-on to turn it on before operation");
            } else {
                info!("Waiting for the machine to turn on...");
                ecam.write_request(Request::AppControl(AppControl::TurnOn))
                    .await?;
                ecam.wait_for_state(EcamStatus::Ready, display::display_status)
                    .await?;
                return Ok(true);
            }
        }
        s => {
            if allow_alarms {
                return Ok(true);
            }
            info!(
                "Machine is in state {:?}, so we will cowardly refuse to brew coffee",
                s
            );
        }
    }
    Ok(false)
}

pub async fn app_control(ecam: Ecam, a: u8, b: u8) -> Result<(), EcamError> {
    eprintln!("Sending app control command {:02x} {:02x}", a, b);
    ecam.write_request(Request::AppControl(AppControl::Custom(a, b)))
        .await?;
    tokio::time::sleep(std::time::Duration::from_secs(1)).await;
    Ok(())
}