bacnet-objects 0.13.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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

use super::*;

use crate::event::{EventStateChange, EventTransition, EventTransitionCommit, PendingTransition};

fn committed_input() -> AnalogInputObject {
    let mut object = AnalogInputObject::new(1, "AI-correlated", 62).unwrap();
    object
        .commit_event_transition_internal(EventTransitionCommit {
            change: EventStateChange {
                from: EventState::NORMAL,
                to: EventState::HIGH_LIMIT,
            },
            coordinate: EventTransition::ToOffnormal,
            ack_required: true,
            timestamp: BACnetTimeStamp::SequenceNumber(42),
            message_text: Some("high".into()),
        })
        .unwrap();
    object.event_detector.pending = Some(PendingTransition {
        state: EventState::NORMAL,
        remaining: 3,
    });
    object.event_detector.fault_reliability = Some(Reliability::OVER_RANGE);
    object
}

fn assert_invalid_event_state(error: Error) {
    assert!(matches!(
        error,
        Error::Protocol { class, code }
            if class == ErrorClass::SERVICES.to_raw() as u32
                && code == ErrorCode::INVALID_EVENT_STATE.to_raw() as u32
    ));
}

#[test]
fn rejected_correlation_preserves_detector_pending_and_all_event_history() {
    let mut object = committed_input();
    let before = (
        object.event_detector.event_state,
        object.event_detector.acked_transitions,
        object.event_detector.pending.clone(),
        object.event_detector.fault_reliability,
        object.event_history.clone(),
    );

    let error = object
        .acknowledge_alarm_correlated_internal(
            EventState::LOW_LIMIT,
            &BACnetTimeStamp::SequenceNumber(99),
        )
        .unwrap_err();

    assert_invalid_event_state(error);
    assert_eq!(
        (
            object.event_detector.event_state,
            object.event_detector.acked_transitions,
            object.event_detector.pending,
            object.event_detector.fault_reliability,
            object.event_history,
        ),
        before
    );
}

#[test]
fn idempotent_valid_correlation_changes_no_detector_or_history_state() {
    let mut object = committed_input();
    object.event_detector.acked_transitions |= EventTransition::ToOffnormal.bit_mask();
    let before = (
        object.event_detector.event_state,
        object.event_detector.acked_transitions,
        object.event_detector.pending.clone(),
        object.event_detector.fault_reliability,
        object.event_history.clone(),
    );

    object
        .acknowledge_alarm_correlated_internal(
            EventState::HIGH_LIMIT,
            &BACnetTimeStamp::SequenceNumber(42),
        )
        .unwrap();

    assert_eq!(
        (
            object.event_detector.event_state,
            object.event_detector.acked_transitions,
            object.event_detector.pending,
            object.event_detector.fault_reliability,
            object.event_history,
        ),
        before
    );
}