dnp3 1.6.0

Rust implementation of DNP3 (IEEE 1815) with idiomatic bindings for C, C++, .NET, and Java
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 crate::app::{FileStatus, FunctionCode, Group70Var4};
use crate::master::association::AssociationConfig;
use crate::master::tasks::file::REQUEST_ID;
use crate::master::tests::harness::create_association;
use crate::master::{AssociationHandle, FileError, FileHandle};

#[tokio::test]
async fn can_close_file() {
    let config = AssociationConfig::quiet();
    let mut harness = create_association(config).await;

    const HANDLE: FileHandle = FileHandle::new(42);

    let open_task = spawn_close_task(harness.association.clone(), HANDLE);

    harness.expect_write(close_file(0, HANDLE)).await;

    harness
        .process_response(super::file_status_response(
            0,
            HANDLE.into(),
            0,
            0,
            FileStatus::Success,
        ))
        .await;

    assert_eq!(open_task.await.unwrap(), Ok(()))
}

fn spawn_close_task(
    mut association: AssociationHandle,
    handle: FileHandle,
) -> tokio::task::JoinHandle<Result<(), FileError>> {
    tokio::spawn(async move { association.close_file(handle).await })
}

fn close_file(seq: u8, handle: FileHandle) -> Vec<u8> {
    super::request(
        FunctionCode::CloseFile,
        seq,
        &Group70Var4 {
            file_handle: handle.into(),
            file_size: 0,
            max_block_size: 0,
            request_id: REQUEST_ID,
            status_code: FileStatus::Success,
            text: "",
        },
    )
}