bacnet-endpoint 0.15.0

BACnet endpoint that owns one transport and runs client and server roles through it
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

use super::*;

#[test]
fn object_audit_policy_snapshot_is_forwarded_from_the_original_instance() {
    use bacnet_objects::{
        analog::AnalogValueObject,
        audit::{AuditPriorityPolicy, ObjectAuditPolicy},
    };
    use bacnet_types::enums::EngineeringUnits;
    let policy = ObjectAuditPolicy {
        level: Some(AuditLevel::NONE),
        operations: Some(AuditOperationFlags::empty()),
        priority_filter: Some(AuditPriorityPolicy::Inherit),
    };
    let mut value =
        AnalogValueObject::new(7, "wrapped AV", EngineeringUnits::DEGREES_CELSIUS).unwrap();
    value.set_audit_policy(policy);
    let mut object: Box<dyn BACnetObject> = Box::new(value);
    let owner = bacnet_objects::database::AuditOwnership::for_source(
        oid(ObjectType::DEVICE, 123),
        selected(),
    );
    source_reporter::install(&mut object, &owner).unwrap();
    assert_eq!(object.audit_object_policy_internal(), policy);
    object
        .write_property(
            PropertyIdentifier::AUDIT_LEVEL,
            None,
            PropertyValue::Enumerated(AuditLevel::AUDIT_ALL.to_raw()),
            None,
        )
        .unwrap();
    assert_eq!(
        object.audit_object_policy_internal().level,
        Some(AuditLevel::AUDIT_ALL)
    );
    assert_eq!(
        object
            .read_property(PropertyIdentifier::AUDIT_LEVEL, None)
            .unwrap(),
        PropertyValue::Enumerated(AuditLevel::AUDIT_ALL.to_raw())
    );
    owner.seal();
    assert_eq!(
        object.audit_object_policy_internal().level,
        Some(AuditLevel::AUDIT_ALL)
    );
}

#[test]
fn sealed_policy_authority_forwards_assignment_and_dropped_preparation() {
    use bacnet_objects::{analog::AnalogValueObject, audit::ObjectAuditPolicy};
    use bacnet_types::enums::EngineeringUnits;
    let mut value =
        AnalogValueObject::new(7, "wrapped", EngineeringUnits::DEGREES_CELSIUS).unwrap();
    value.set_audit_policy(ObjectAuditPolicy {
        level: Some(AuditLevel::NONE),
        ..Default::default()
    });
    let mut object: Box<dyn BACnetObject> = Box::new(value);
    let owner = bacnet_objects::database::AuditOwnership::for_source(
        oid(ObjectType::DEVICE, 123),
        selected(),
    );
    source_reporter::install(&mut object, &owner).unwrap();
    let value = PropertyValue::Enumerated(AuditLevel::AUDIT_ALL.to_raw());
    object
        .audit_policy_authority_internal()
        .unwrap()
        .prepare(PropertyIdentifier::AUDIT_LEVEL, None, &value, None)
        .unwrap()
        .unwrap();
    assert_eq!(
        object.audit_object_policy_internal().level,
        Some(AuditLevel::NONE)
    );
    object
        .audit_policy_authority_internal()
        .unwrap()
        .prepare(PropertyIdentifier::AUDIT_LEVEL, None, &value, None)
        .unwrap()
        .unwrap()
        .commit();
    assert_eq!(
        object.audit_object_policy_internal().level,
        Some(AuditLevel::AUDIT_ALL)
    );
}