libaprs-engine 2.6.0

Protocol-first APRS engine core primitives
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

use libaprs_engine::{
    parse_packet,
    service::{
        DuplicateDecision, DuplicateWindow, PacketRateBudget, RateLimitDecision, SemanticBlocklist,
        SemanticFamily,
    },
    Engine,
};

fn main() -> Result<(), libaprs_engine::ParseError> {
    let mut engine = Engine::default();
    let mut duplicates = DuplicateWindow::new(128);
    let mut rate = PacketRateBudget::new(100);
    let blocked = SemanticBlocklist::new(&[SemanticFamily::Unsupported, SemanticFamily::Malformed]);

    for packet_bytes in [b"N0CALL>APRS:>service".as_slice()] {
        if rate.try_consume() == RateLimitDecision::Limited {
            continue;
        }
        if duplicates.observe(packet_bytes) == DuplicateDecision::Duplicate {
            continue;
        }

        let packet = parse_packet(packet_bytes)?;
        if blocked.rejects(&packet.aprs_data()) {
            continue;
        }

        let _event = engine.process_event(packet.raw().as_bytes());
    }

    Ok(())
}