prns-core 0.3.4

Pure Reticulum engine and wire contract for Personal Reticulum
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

use super::*;
use crate::engine::test_support::*;
use crate::interfaces::InboundPacket;

#[test]
fn ingest_counts_each_packet_without_a_clock() {
    let mut state: EngineState<TestStorageLayout> = EngineState::<TestStorageLayout>::default();

    let mut first_bytes = [1, 2, 3];
    let first = state.ingest_packet_with(
        InboundPacket {
            arrived_at: InstantMillis(10),
            source_interface: InterfaceId::new([0u8; 8]),
            bytes: &mut first_bytes,
        },
        &mut |_| {},
        AttachedInterfaces::new(&transporting_interfaces()),
        &mut |_| {},
        None,
    );
    let mut second_bytes = [4];
    let second = state.ingest_packet_with(
        InboundPacket {
            arrived_at: InstantMillis(20),
            source_interface: InterfaceId::new([0u8; 8]),
            bytes: &mut second_bytes,
        },
        &mut |_| {},
        AttachedInterfaces::new(&transporting_interfaces()),
        &mut |_| {},
        None,
    );

    assert_eq!(first, IngestPacketOutcome::Ignored(IgnoreReason::Malformed));
    assert_eq!(
        second,
        IngestPacketOutcome::Ignored(IgnoreReason::Malformed)
    );
    assert_eq!(state.ingested_packet_count(), 2);
}

#[test]
fn ingest_processes_but_does_not_accept_non_announce_bytes() {
    let mut state: EngineState<TestStorageLayout> = EngineState::<TestStorageLayout>::default();
    let junk = InboundPacket {
        arrived_at: InstantMillis(1),
        source_interface: InterfaceId::new([0u8; 8]),
        bytes: &mut [0x00, 0x00, 0x01, 0x02, 0x03],
    };
    let out = state.ingest_packet_with(
        junk,
        &mut |_| {},
        AttachedInterfaces::new(&transporting_interfaces()),
        &mut |_| {},
        None,
    );
    assert_eq!(out, IngestPacketOutcome::Ignored(IgnoreReason::Malformed));
    assert_eq!(state.route_count(), 0);
}

#[test]
fn an_ifac_flagged_packet_is_dropped_on_an_open_interface() {
    let mut raw = bytes_from_hex(RNS_1_4_2_ANNOUNCE);
    raw[0] |= 0x80;
    let mut state: EngineState<TestStorageLayout> = EngineState::<TestStorageLayout>::default();
    let out = state.ingest_packet_with(
        InboundPacket {
            arrived_at: InstantMillis(1_000),
            source_interface: InterfaceId::new([0u8; 8]),
            bytes: &mut raw,
        },
        &mut |_| {},
        AttachedInterfaces::new(&transporting_interfaces()),
        &mut |_| {},
        None,
    );
    assert_eq!(out, IngestPacketOutcome::Ignored(IgnoreReason::IfacRefused));
    assert_eq!(state.route_count(), 0);
}