dis_rs/common/action_response/
model.rs

1use crate::common::action_response::builder::ActionResponseBuilder;
2use crate::common::model::{length_padded_to_num, BASE_VARIABLE_DATUM_LENGTH, FIXED_DATUM_LENGTH};
3use crate::common::model::{EntityId, FixedDatum, PduBody, VariableDatum};
4use crate::common::{BodyInfo, Interaction};
5use crate::constants::EIGHT_OCTETS;
6use crate::enumerations::{PduType, RequestStatus};
7#[cfg(feature = "serde")]
8use serde::{Deserialize, Serialize};
9
10pub const BASE_ACTION_RESPONSE_BODY_LENGTH: u16 = 28;
11
12#[derive(Clone, Debug, Default, PartialEq)]
13#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
14pub struct ActionResponse {
15    pub originating_id: EntityId,
16    pub receiving_id: EntityId,
17    pub request_id: u32,
18    pub request_status: RequestStatus,
19    pub fixed_datum_records: Vec<FixedDatum>,
20    pub variable_datum_records: Vec<VariableDatum>,
21}
22
23impl ActionResponse {
24    #[must_use]
25    pub fn builder() -> ActionResponseBuilder {
26        ActionResponseBuilder::new()
27    }
28
29    #[must_use]
30    pub fn into_builder(self) -> ActionResponseBuilder {
31        ActionResponseBuilder::new_from_body(self)
32    }
33
34    #[must_use]
35    pub fn into_pdu_body(self) -> PduBody {
36        PduBody::ActionResponse(self)
37    }
38}
39
40impl BodyInfo for ActionResponse {
41    fn body_length(&self) -> u16 {
42        BASE_ACTION_RESPONSE_BODY_LENGTH
43            + (FIXED_DATUM_LENGTH * self.fixed_datum_records.len() as u16)
44            + (self
45                .variable_datum_records
46                .iter()
47                .map(|datum| {
48                    let padded_record = length_padded_to_num(
49                        BASE_VARIABLE_DATUM_LENGTH as usize + datum.datum_value.len(),
50                        EIGHT_OCTETS,
51                    );
52                    padded_record.record_length as u16
53                })
54                .sum::<u16>())
55    }
56
57    fn body_type(&self) -> PduType {
58        PduType::ActionResponse
59    }
60}
61
62impl Interaction for ActionResponse {
63    fn originator(&self) -> Option<&EntityId> {
64        Some(&self.originating_id)
65    }
66
67    fn receiver(&self) -> Option<&EntityId> {
68        Some(&self.receiving_id)
69    }
70}