bacnet-client 0.15.0

BACnet async client: TSM, segmentation, discovery, and service APIs
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

use super::*;
use bacnet_services::file::{AtomicReadFileAck, FileAccessMethod, FileReadAckMethod};

fn stream_request(count: u32) -> FileAccessMethod {
    FileAccessMethod::Stream {
        file_start_position: 4,
        requested_octet_count: count,
    }
}

fn record_request(count: u32) -> FileAccessMethod {
    FileAccessMethod::Record {
        file_start_record: 4,
        requested_record_count: count,
    }
}

#[test]
fn decoded_atomic_read_file_rejects_access_arm_mismatch() {
    let ack = AtomicReadFileAck {
        end_of_file: true,
        access: FileReadAckMethod::Record {
            file_start_record: 4,
            returned_record_count: 0,
            file_record_data: vec![],
        },
    };
    assert!(validate_atomic_read_file_ack(&stream_request(1), &ack).is_err());

    let ack = AtomicReadFileAck {
        end_of_file: true,
        access: FileReadAckMethod::Stream {
            file_start_position: 4,
            file_data: vec![],
        },
    };
    assert!(validate_atomic_read_file_ack(&record_request(1), &ack).is_err());
}

#[test]
fn decoded_atomic_read_file_rejects_oversized_window() {
    let stream_ack = AtomicReadFileAck {
        end_of_file: false,
        access: FileReadAckMethod::Stream {
            file_start_position: 4,
            file_data: vec![1, 2, 3],
        },
    };
    assert!(validate_atomic_read_file_ack(&stream_request(2), &stream_ack).is_err());

    let record_ack = AtomicReadFileAck {
        end_of_file: false,
        access: FileReadAckMethod::Record {
            file_start_record: 4,
            returned_record_count: 2,
            file_record_data: vec![vec![1], vec![2]],
        },
    };
    assert!(validate_atomic_read_file_ack(&record_request(1), &record_ack).is_err());
}

#[test]
fn decoded_atomic_read_file_accepts_matching_bounded_window() {
    let stream_ack = AtomicReadFileAck {
        end_of_file: true,
        access: FileReadAckMethod::Stream {
            file_start_position: 9,
            file_data: vec![1, 2],
        },
    };
    assert!(validate_atomic_read_file_ack(&stream_request(2), &stream_ack).is_ok());

    let record_ack = AtomicReadFileAck {
        end_of_file: true,
        access: FileReadAckMethod::Record {
            file_start_record: 9,
            returned_record_count: 2,
            file_record_data: vec![vec![], vec![0xFF]],
        },
    };
    assert!(validate_atomic_read_file_ack(&record_request(2), &record_ack).is_ok());
}