dis-rs 0.13.0

An implementation of the Distributed Interactive Simulation protocol (IEEE-1278.1) in Rust. This main crate contains PDU implementations and facilities to read/write PDUs from Rust data structures to the wire format and vice versa. It supports versions 6 and 7 of the protocol.
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

use crate::constants::{
    BITS_2_3_IN_BYTE, BITS_5_6_IN_BYTE, BIT_2_IN_BYTE, BIT_3_IN_BYTE, BIT_4_IN_BYTE, BIT_7_IN_BYTE,
};
use crate::enumerations::{
    ActiveInterrogationIndicator, CoupledExtensionIndicator, DetonationTypeIndicator,
    FireTypeIndicator, IffSimulationMode, IntercomAttachedIndicator, LvcIndicator, PduType,
    RadioAttachedIndicator, TransferredEntityIndicator,
};
use crate::v7::builder::{
    build_pdu_status_aii_ism_cei_lvc_tei, build_pdu_status_cei_lvc, build_pdu_status_cei_lvc_tei,
    build_pdu_status_dti_cei_lvc, build_pdu_status_fti_cei_lvc, build_pdu_status_iai_cei_lvc_tei,
    build_pdu_status_lvc, build_pdu_status_rai_cei_lvc_tei,
};
use crate::v7::model::PduStatus;
use nom::number::complete::be_u8;
use nom::IResult;

pub fn parse_pdu_status(pdu_type: PduType) -> impl Fn(&[u8]) -> IResult<&[u8], (PduStatus, u16)> {
    move |input: &[u8]| {
        let type_u8: u8 = pdu_type.into();
        let (input, status) = be_u8(input)?;
        let (input, padding) = be_u8(input)?;
        Ok((
            input,
            (parse_pdu_status_fields(type_u8, status), u16::from(padding)),
        ))
    }
}

/// Parses the pdu status sub-fields into a `PduStatus` struct, depending on the `PduType`
///
/// Note: parser should not be fed input that is consumed, but a copy of the pdu status byte (as it is already parsed earlier)
#[must_use]
pub fn parse_pdu_status_fields(pdu_type: u8, input: u8) -> PduStatus {
    let tei = status_tei(input);
    let lvc = status_lvc(input);
    let cei = status_cei(input);
    let fti = status_fti(input);
    let dti = status_dti(input);
    let rai = status_rai(input);
    let iai = status_iai(input);
    let ism = status_ism(input);
    let aii = status_aii(input);

    #[allow(clippy::match_same_arms)]
    match pdu_type {
        1 => build_pdu_status_cei_lvc_tei(cei, lvc, tei),
        2 => build_pdu_status_fti_cei_lvc(fti, cei, lvc),
        3 => build_pdu_status_dti_cei_lvc(dti, cei, lvc),
        4..=22 => build_pdu_status_cei_lvc(cei, lvc),
        23 => build_pdu_status_cei_lvc_tei(cei, lvc, tei),
        24 => build_pdu_status_cei_lvc_tei(cei, lvc, tei),
        25 => build_pdu_status_rai_cei_lvc_tei(rai, cei, lvc, tei),
        26 => build_pdu_status_rai_cei_lvc_tei(rai, cei, lvc, tei),
        27 => build_pdu_status_rai_cei_lvc_tei(rai, cei, lvc, tei),
        28 => build_pdu_status_aii_ism_cei_lvc_tei(aii, ism, cei, lvc, tei),
        29..=30 => build_pdu_status_cei_lvc(cei, lvc),
        31 => build_pdu_status_iai_cei_lvc_tei(iai, cei, lvc, tei),
        32 => build_pdu_status_iai_cei_lvc_tei(iai, cei, lvc, tei),
        33..=40 => build_pdu_status_cei_lvc(cei, lvc),
        41 => build_pdu_status_cei_lvc_tei(cei, lvc, tei),
        42..=66 => build_pdu_status_cei_lvc(cei, lvc),
        67 => build_pdu_status_cei_lvc_tei(cei, lvc, tei),
        68 => build_pdu_status_cei_lvc(cei, lvc),
        69 => build_pdu_status_cei_lvc(cei, lvc),
        70 => build_pdu_status_cei_lvc(cei, lvc),
        71 => build_pdu_status_cei_lvc(cei, lvc),
        72 => build_pdu_status_lvc(lvc),
        _ => {
            // also covers 73..=255
            PduStatus::default()
        }
    }
}

fn status_tei(pdu_status_field: u8) -> TransferredEntityIndicator {
    let tei = pdu_status_field & BIT_7_IN_BYTE;
    TransferredEntityIndicator::from(tei)
}

fn status_lvc(pdu_status_field: u8) -> LvcIndicator {
    let lvc = (pdu_status_field & BITS_5_6_IN_BYTE) >> 1;
    LvcIndicator::from(lvc)
}

fn status_cei(pdu_status_field: u8) -> CoupledExtensionIndicator {
    let cei = (pdu_status_field & BIT_4_IN_BYTE) >> 3;
    CoupledExtensionIndicator::from(cei)
}

fn status_fti(pdu_status_field: u8) -> FireTypeIndicator {
    let fti = (pdu_status_field & BIT_3_IN_BYTE) >> 4;
    FireTypeIndicator::from(fti)
}

fn status_dti(pdu_status_field: u8) -> DetonationTypeIndicator {
    let dti = (pdu_status_field & BITS_2_3_IN_BYTE) >> 4;
    DetonationTypeIndicator::from(dti)
}

fn status_rai(pdu_status_field: u8) -> RadioAttachedIndicator {
    let rai = (pdu_status_field & BITS_2_3_IN_BYTE) >> 4;
    RadioAttachedIndicator::from(rai)
}

fn status_iai(pdu_status_field: u8) -> IntercomAttachedIndicator {
    let iai = (pdu_status_field & BITS_2_3_IN_BYTE) >> 4;
    IntercomAttachedIndicator::from(iai)
}

fn status_ism(pdu_status_field: u8) -> IffSimulationMode {
    let ism = (pdu_status_field & BIT_3_IN_BYTE) >> 4;
    IffSimulationMode::from(ism)
}

fn status_aii(pdu_status_field: u8) -> ActiveInterrogationIndicator {
    let aii = (pdu_status_field & BIT_2_IN_BYTE) >> 5;
    ActiveInterrogationIndicator::from(aii)
}