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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

use crate::app::FunctionCode;
use crate::app::RequestHeader;
use crate::app::Sequence;
use crate::outstation::tests::harness::{Event, EventSender};
use crate::outstation::traits::{BroadcastAction, OutstationInformation};

pub(crate) struct MockOutstationInformation {
    events: EventSender,
}

impl MockOutstationInformation {
    pub(crate) fn new(events: EventSender) -> Box<dyn OutstationInformation> {
        Box::new(Self { events })
    }
}

impl OutstationInformation for MockOutstationInformation {
    fn process_request_from_idle(&mut self, _header: RequestHeader) {
        // we ignore this one in tests b/c it's just too noisy
    }

    fn broadcast_received(&mut self, function: FunctionCode, action: BroadcastAction) {
        self.events.send(Event::BroadcastReceived(function, action))
    }

    fn enter_solicited_confirm_wait(&mut self, ecsn: Sequence) {
        self.events
            .send(Event::EnterSolicitedConfirmWait(ecsn.value()))
    }

    fn solicited_confirm_timeout(&mut self, ecsn: Sequence) {
        self.events
            .send(Event::SolicitedConfirmTimeout(ecsn.value()))
    }

    fn solicited_confirm_received(&mut self, ecsn: Sequence) {
        self.events
            .send(Event::SolicitedConfirmReceived(ecsn.value()))
    }

    fn solicited_confirm_wait_new_request(&mut self) {
        self.events.send(Event::SolicitedConfirmWaitNewRequest)
    }

    fn unexpected_confirm(&mut self, unsolicited: bool, seq: Sequence) {
        self.events
            .send(Event::UnexpectedConfirm(unsolicited, seq.value()))
    }

    fn wrong_solicited_confirm_seq(&mut self, ecsn: Sequence, seq: Sequence) {
        self.events
            .send(Event::WrongSolicitedConfirmSeq(ecsn.value(), seq.value()))
    }

    fn clear_restart_iin(&mut self) {
        self.events.send(Event::ClearRestartIIN)
    }

    fn enter_unsolicited_confirm_wait(&mut self, ecsn: Sequence) {
        self.events
            .send(Event::EnterUnsolicitedConfirmWait(ecsn.value()))
    }

    fn unsolicited_confirm_timeout(&mut self, ecsn: Sequence, retry: bool) {
        self.events
            .send(Event::UnsolicitedConfirmTimeout(ecsn.value(), retry))
    }

    fn unsolicited_confirmed(&mut self, ecsn: Sequence) {
        self.events
            .send(Event::UnsolicitedConfirmReceived(ecsn.value()))
    }
}