bacnet-objects 0.12.0

BACnet object model: traits, database, and standard object types
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

use super::*;

#[test]
fn fallible_trend_hook_preserves_state_on_clock_error_and_retries() {
    for kind in [FamilyKind::Trend, FamilyKind::TrendMultiple] {
        for clock in [None, Some(TestClock::invalid())] {
            let mut object = kind.object(2);
            object
                .object_mut()
                .bind_clock_internal(clock.map(|clock| clock as Arc<dyn ClockReader>));
            object
                .write(
                    PropertyIdentifier::STOP_WHEN_FULL,
                    PropertyValue::Boolean(true),
                )
                .unwrap();
            object.add_trend_record(ordinary(1, 10)).unwrap();
            let records = object.records();
            let identities = object.identities();
            let total = object.total();
            assert_protocol(
                object.add_trend_record(ordinary(2, 20)).unwrap_err(),
                ErrorClass::DEVICE,
                ErrorCode::OPERATIONAL_PROBLEM,
            );
            assert_eq!(object.records(), records);
            assert_eq!(object.identities(), identities);
            assert_eq!(object.total(), total);
            assert!(object.enabled());

            object.bind_clock(TestClock::valid());
            object.add_trend_record(ordinary(2, 20)).unwrap();
            assert!(!object.enabled());
            assert_eq!(object.total(), total + 1);
            assert_eq!(object.records().len(), 2);
            assert_eq!(object.records()[0], records[0]);
            assert_eq!(object.identities()[0], identities[0]);
            assert_status(&object, LOG_DISABLED);

            object.object_mut().bind_clock_internal(None);
            let before = object.records();
            let identities = object.identities();
            object.add_trend_record(ordinary(3, 30)).unwrap();
            assert_eq!(
                object.records(),
                before,
                "disabled insertion succeeds unchanged"
            );
            assert_eq!(object.identities(), identities);
            assert_eq!(object.total(), total + 1);
        }
    }
}

#[test]
fn fallible_insertion_keeps_count_only_success_and_rejects_unsupported_objects() {
    for kind in FamilyKind::ALL {
        let mut object = kind.object(0);
        object.add_record(ordinary(1, 10)).unwrap();
        assert!(object.records().is_empty());
        assert!(object.identities().is_empty());
        assert_eq!(object.total(), 1);
        if !matches!(kind, FamilyKind::Event) {
            object.add_trend_record(ordinary(2, 20)).unwrap();
            assert!(object.records().is_empty());
            assert!(object.identities().is_empty());
            assert_eq!(object.total(), 2);
        }
    }
    let mut unsupported = crate::analog::AnalogInputObject::new(1, "AI", 62).unwrap();
    assert_protocol(
        unsupported.add_trend_record(ordinary(1, 10)).unwrap_err(),
        ErrorClass::OBJECT,
        ErrorCode::OPTIONAL_FUNCTIONALITY_NOT_SUPPORTED,
    );
}