osdp 0.3.0

Pure-Rust, no_std-friendly implementation of the SIA Open Supervised Device Protocol (OSDP) v2.2
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

//! Loopback example: an in-memory `VecTransport` carries POLLs from a
//! synthetic ACU to a synthetic PD that always responds with `osdp_ACK`.
//!
//! Run with:
//!
//! ```sh
//! cargo run --example loopback_poll
//! ```

use osdp::clock::SystemClock;
use osdp::command::{Command, Poll};
use osdp::driver::acu::{Acu, PdState};
use osdp::driver::pd::{Pd, PdHandler};
use osdp::reply::{Ack, Reply};
use osdp::transport::VecTransport;

struct AlwaysAck;
impl PdHandler for AlwaysAck {
    fn on_command(&mut self, _command: &Command) -> Reply {
        Reply::Ack(Ack)
    }
}

fn main() {
    let mut acu = Acu::new(VecTransport::new(), SystemClock::new());
    let mut pd = Pd::new(VecTransport::new(), SystemClock::new(), 0x05, AlwaysAck);
    let mut state = PdState::default();
    state.mark_seen(0); // pretend we discovered it on boot

    println!("loopback example: 5 POLL exchanges through a VecTransport bridge");
    for round in 1..=5u32 {
        // ACU writes POLL bytes to its outgoing queue.
        let bytes = acu
            .send_to(0x05, &mut state, &Command::Poll(Poll))
            .expect("send");
        println!(
            "  [{round}] ACU wrote {} bytes (sqn={})",
            bytes.len(),
            bytes[4] & 0x03
        );

        // Ferry ACU outgoing → PD incoming.
        acu.transport().shuffle_to(pd.transport());

        // PD processes the packet and queues its reply.
        pd.poll_once().expect("pd poll");

        // Ferry PD outgoing → ACU incoming.
        pd.transport().shuffle_to(acu.transport());

        // ACU reads its reply.
        match acu.receive(&mut state) {
            Ok(Reply::Ack(_)) => println!(
                "  [{round}] ACU got ACK; sqn now {}",
                state.next_sqn.value()
            ),
            other => println!("  [{round}] unexpected reply {other:?}"),
        }
    }
}