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

use super::*;

#[tokio::test(start_paused = true)]
async fn immediate_and_delayed_reporter_raw_1474_emit_header_1024() {
    for delayed in [false, true] {
        let mut reporter = if delayed {
            batching::delayed(1)
        } else {
            reporter()
        };
        reporter.set_issue_confirmed_notifications(true).unwrap();
        let mut f = try_servers_config(
            vec![reporter],
            &[1],
            Some(BACnetRecipient::Device(oid(ObjectType::DEVICE, 20))),
            vec![DeviceBinding::local(oid(ObjectType::DEVICE, 20), LOGGER).unwrap()],
            true,
            1474,
            AuditCapture::default(),
        )
        .await
        .unwrap();
        assert!(matches!(
            write_value(&f.server, None).await,
            Apdu::SimpleAck(_)
        ));
        settle().await;
        if delayed {
            assert!(f.transport.sent.lock().unwrap().is_empty());
            tokio::time::advance(Duration::from_secs(1)).await;
            settle().await;
        }
        let request = confirmed_notification(&f.transport.sent, 0);
        assert_eq!(request.max_apdu_length, 1024);
        assert!(f.server.notification_transactions.admit_terminal(
            LOGGER,
            None,
            None,
            &Apdu::SimpleAck(SimpleAck {
                invoke_id: request.invoke_id,
                service_choice: request.service_choice
            })
        ));
        f.server.stop().await.unwrap();
    }
}