bacnet-server 0.15.0

BACnet server: APDU dispatch and service handlers
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

use super::*;

#[tokio::test]
async fn exact_confirmed_multiple_preserves_routed_peer_and_mode() {
    let router = MacAddr::from_slice(&[192, 168, 1, 1, 0xBA, 0xC0]);
    let remote = NpduAddress {
        network: 222,
        mac_address: MacAddr::from_slice(&[9, 8, 7]),
    };
    let mut sub = subscription(
        Some(PropertyIdentifier::SILENCED),
        CovNotificationKind::Multiple,
        14,
    );
    sub.subscriber_mac = router.clone();
    sub.subscriber_network = Some(remote.clone());
    sub.issue_confirmed_notifications = true;
    let fixture = ExactFixture::new([sub]).await;

    fixture.fire(&[PropertyIdentifier::SILENCED]).await;
    for _ in 0..32 {
        if !fixture.sent.is_empty() {
            break;
        }
        tokio::task::yield_now().await;
    }

    let sent = fixture.sent.lock();
    assert_eq!(sent.len(), 1);
    assert_eq!(sent[0].mac, router);
    let npdu = decode_npdu(sent[0].npdu.clone()).unwrap();
    assert_eq!(npdu.destination, Some(remote.clone()));
    let Apdu::ConfirmedRequest(request) = decode_apdu(npdu.payload).unwrap() else {
        panic!("expected confirmed COVNotificationMultiple");
    };
    assert_eq!(
        request.service_choice,
        ConfirmedServiceChoice::CONFIRMED_COV_NOTIFICATION_MULTIPLE
    );
    let invoke_id = request.invoke_id;
    drop(sent);
    assert!(fixture.transactions.admit_terminal(
        &router,
        Some(&remote),
        None,
        &Apdu::SimpleAck(SimpleAck {
            invoke_id,
            service_choice: ConfirmedServiceChoice::CONFIRMED_COV_NOTIFICATION_MULTIPLE,
        }),
    ));
}