cc_talk_core 0.0.1

A no-std implementation of the CCtalk protocol.
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

const REGISTER_1_MASK: u16 = 0;
const REGISTER_2_MASK: u16 = 256;

#[repr(u16)]
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[cfg_attr(feature = "defmt", derive(defmt::Format))]
pub enum ChangerFlags {
    SingulatorRunning = REGISTER_1_MASK + (1 << 0),
    EscalatorRunning = REGISTER_1_MASK + (1 << 1),
    PrcessingMoneyIn = REGISTER_1_MASK + (1 << 2),
    ProcessingMoneyOut = REGISTER_1_MASK + (1 << 3),
    FaultDetected = REGISTER_1_MASK + (1 << 4),
    AvalancheDetected = REGISTER_1_MASK + (1 << 5),
    ChangerInitialising = REGISTER_1_MASK + (1 << 6),
    EntryFlapOpen = REGISTER_1_MASK + (1 << 7),
    ContinuousRejects = REGISTER_2_MASK + (1 << 0),
    HopperConfigChange = REGISTER_2_MASK + (1 << 1),
    RejectDivertActive = REGISTER_2_MASK + (1 << 2),
    ExitCupFull = REGISTER_2_MASK + (1 << 3),
    NonFatalFaultDetected = REGISTER_2_MASK + (1 << 4),
}

impl ChangerFlags {
    pub fn has_flag(&self, register: u8, register_id: u8) -> bool {
        let register_mask = match register_id {
            1 => REGISTER_1_MASK,
            2 => REGISTER_2_MASK,
            _ => panic!("Invalid register: {}", register),
        };

        let flag_raw_value = *self as u16;
        if flag_raw_value < register_mask || flag_raw_value >= register_mask + 256 {
            return false;
        }

        let flag_value = (flag_raw_value ^ register_mask) as u8;
        (flag_value & register) == flag_value
    }

    const fn all_flags() -> [ChangerFlags; 13] {
        [
            ChangerFlags::SingulatorRunning,
            ChangerFlags::EscalatorRunning,
            ChangerFlags::PrcessingMoneyIn,
            ChangerFlags::ProcessingMoneyOut,
            ChangerFlags::FaultDetected,
            ChangerFlags::AvalancheDetected,
            ChangerFlags::ChangerInitialising,
            ChangerFlags::EntryFlapOpen,
            ChangerFlags::ContinuousRejects,
            ChangerFlags::HopperConfigChange,
            ChangerFlags::RejectDivertActive,
            ChangerFlags::ExitCupFull,
            ChangerFlags::NonFatalFaultDetected,
        ]
    }
}

pub fn parse_changer_flags_heapless(registers: &[u8]) -> heapless::Vec<ChangerFlags, 13> {
    assert!(
        (0..=2).contains(&registers.len()),
        "registers must be 0,1 or 2 bytes long"
    );

    let mut flags = heapless::Vec::new();
    for flag in ChangerFlags::all_flags() {
        if flag.has_flag(registers[0], 1) || flag.has_flag(registers[1], 2) {
            flags.push(flag).ok();
        }
    }
    flags
}