a7n-core 0.15.3

Pure state machines for the Apeirogon software KVM
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

// SPDX-License-Identifier: GPL-3.0-or-later

use super::*;

fn settings(set_at: u64, by: u8) -> Settings {
    Settings {
        set_at,
        by: MachineId::try_from(&[by; MachineId::LEN][..]).unwrap(),
        values: BTreeMap::new(),
    }
}

#[test]
fn try_from_unknown_and_security_keys_drops_everything_outside_allow_list() {
    // Arrange
    let mut wire = settings(1, 1).to_proto();
    wire.values = [
        ("input.speed".into(), "2".into()),
        (
            "peers.01010101010101010101010101010101.allow_drive".into(),
            "false".into(),
        ),
        ("name".into(), "remote".into()),
        ("sync.settings".into(), "false".into()),
        ("clipboard.policy".into(), "allow".into()),
        (
            "peers.01010101010101010101010101010101.clipboard".into(),
            "both".into(),
        ),
        ("clipboard.deny_apps".into(), "[]".into()),
        ("notifications.files".into(), "false".into()),
        ("unknown".into(), "value".into()),
    ]
    .into();

    // Act
    let filtered = Settings::try_from(&wire).unwrap();

    // Assert
    assert_eq!(filtered.values, [("input.speed".into(), "2".into())].into());
}

#[test]
fn try_from_invalid_machine_id_rejects_message() {
    // Arrange
    let wire = v1::SettingsSync {
        by: vec![1; MachineId::LEN - 1],
        ..Default::default()
    };

    // Act
    let result = Settings::try_from(&wire);

    // Assert
    assert!(matches!(result, Err(ProtoError::BadMachineId(_))));
}

#[test]
fn newer_timestamp_and_machine_id_order_requires_strict_increase() {
    // Arrange
    let current = settings(10, 2);
    for (incoming, expected) in [
        (settings(9, 3), false),
        (settings(10, 1), false),
        (settings(10, 2), false),
        (settings(10, 3), true),
        (settings(11, 1), true),
    ] {
        // Act
        let result = newer(Some(&current), &incoming);

        // Assert
        assert_eq!(result, expected);
    }
    assert!(newer(None, &current));
}

#[test]
fn try_from_set_at_above_counter_max_is_rejected() {
    // Arrange
    let wire = settings(a7n_proto::limits::COUNTER_MAX + 1, 1).to_proto();

    // Act
    let result = Settings::try_from(&wire);

    // Assert
    assert!(matches!(result, Err(ProtoError::CounterTooLarge)));
}