rusty-mms-service 0.6.0

use std::ops::Deref;

use der_parser::Oid;
use num_bigint::ToBigInt;
use num_bigint::{BigInt, BigUint};
use rusty_mms::{ListOfVariablesItem, MmsAccessError, MmsData, MmsError, MmsObjectName, MmsTypeDescription, MmsTypeDescriptionComponent, MmsVariableAccessSpecification};

use crate::error::{MmsServiceError, to_mms_error};

#[derive(Debug, PartialEq)]
pub struct MmsServiceDataFloat {
    data: Vec<u8>,
}

impl MmsServiceDataFloat {
    pub fn new(data: Vec<u8>) -> Self {
        Self { data }
    }

    pub fn data(&self) -> Vec<u8> {
        self.data.clone()
    }

    pub fn exponent_width(&self) -> u8 {
        *self.data.get(0).unwrap_or_else(|| &0)
    }

    pub fn from_f32(value: f32) -> Self {
        let mut data = vec![8];
        data.append(&mut value.to_be_bytes().to_vec());
        Self { data }
    }

    pub fn to_f32(&self) -> Result<f32, MmsServiceError> {
        if let Some(8) = self.data.get(0)
            && self.data.len() == 5
        {
            return Ok(f32::from_be_bytes(self.data[1..5].try_into().map_err(to_mms_error(&format!("Failed to convert to f32. Data: {:?}", self.data)))?));
        }
        return Err(MmsServiceError::ProtocolError(format!("Cannot cast float data to f32. Data: {:?}", self.data)));
    }

    pub fn from_f64(value: f64) -> Self {
        let mut data = vec![11];
        data.append(&mut value.to_be_bytes().to_vec());
        Self { data }
    }

    pub fn to_f64(&self) -> Result<f64, MmsServiceError> {
        if let Some(11) = self.data.get(0)
            && self.data.len() == 9
        {
            return Ok(f64::from_be_bytes(self.data[1..5].try_into().map_err(to_mms_error(&format!("Failed to convert to f64. Data: {:?}", self.data)))?));
        }
        return Err(MmsServiceError::ProtocolError(format!("Cannot cast float data to f64. Data: {:?}", self.data)));
    }

    pub fn get_raw_data(&self) -> &Vec<u8> {
        &self.data
    }
}

#[derive(Debug, PartialEq)]
pub enum MmsServiceData {
    Array(Vec<MmsServiceData>), // Arrays are meant to contain a consistent type across all elements. This is not enforced as it means traversing trees.
    Structure(Vec<MmsServiceData>),
    Boolean(bool),
    BitString(Vec<bool>),
    Integer(BigInt),
    Unsigned(BigUint),
    FloatingPoint(MmsServiceDataFloat),
    OctetString(Vec<u8>),
    VisibleString(String),
    GeneralizedTime(String),
    BinaryTime(Vec<u8>),
    Bcd(Vec<u8>),
    BooleanArray(Vec<bool>),
    ObjectId(Oid<'static>),
    MmsString(String),
}

#[derive(Debug, PartialEq)]
pub struct Identity {
    pub vendor_name: String,
    pub model_name: String,
    pub revision: String,
    pub abstract_syntaxes: Option<Vec<Oid<'static>>>,
}

#[derive(Debug, PartialEq)]
pub struct NameList {
    pub identifiers: Vec<String>,
    pub more_follows: bool,
}

#[derive(Debug, PartialEq)]
pub struct NamedVariableListAttributes {
    pub deletable: bool,
    pub list_of_variables: Vec<ListOfVariablesItem>,
}

#[derive(Debug, PartialEq, Eq)]
pub enum MmsServiceTypeDescription {
    Array { packed: bool, number_of_elements: u32, element_type: Box<MmsServiceTypeSpecification> },
    Structure { packed: bool, components: Vec<MmsServiceTypeDescriptionComponent> },
    Boolean,
    BitString(i32),
    Integer(u8),
    Unsigned(u8),
    FloatingPoint { format_width: u8, exponent_width: u8 },
    OctetString(i32),
    VisibleString(i32),
    GeneralizedTime,
    BinaryTime(bool),
    Bcd(u8),
    ObjId,
    MmsString(i32),
}

#[derive(Debug, PartialEq, Eq)]
pub enum MmsServiceTypeSpecification {
    ObjectName(MmsObjectName),
    TypeDescription(MmsServiceTypeDescription),
}

#[derive(Debug, PartialEq, Eq)]
pub struct MmsServiceTypeDescriptionComponent {
    pub component_name: Option<String>,
    pub component_type: MmsServiceTypeSpecification,
}

#[derive(Debug, PartialEq, Eq)]
pub struct VariableAccessAttributes {
    pub deletable: bool,
    pub type_description: MmsServiceTypeDescription,
}

#[derive(Debug, PartialEq, Eq)]
pub enum MmsServiceDeleteObjectScope {
    Specific(Vec<MmsObjectName>),
    AaSpecific,
    Domain(String),
    Vmd,
}

#[derive(Debug, PartialEq)]
pub enum MmsServiceAccessResult {
    Success(MmsServiceData),
    Failure(MmsAccessError),
}

#[derive(Debug)]
pub struct InformationReportMmsServiceMessage {
    pub variable_access_specification: MmsVariableAccessSpecification,
    pub access_results: Vec<MmsServiceAccessResult>,
}

pub(crate) fn convert_high_level_data_to_low_level_data(service_data: &MmsServiceData) -> Result<MmsData, MmsError> {
    match service_data {
        MmsServiceData::Array(items) => {
            let mut low_level_data = vec![];
            for item in items {
                low_level_data.push(convert_high_level_data_to_low_level_data(item)?);
            }
            Ok(MmsData::Array(low_level_data))
        }
        MmsServiceData::Structure(items) => {
            let mut low_level_data = vec![];
            for item in items {
                low_level_data.push(convert_high_level_data_to_low_level_data(item)?);
            }
            Ok(MmsData::Structure(low_level_data))
        }
        MmsServiceData::Boolean(x) => Ok(MmsData::Boolean(*x)),
        MmsServiceData::BitString(items) => {
            let buffer_length = items.len() / 8 + 1 - (if items.len() % 8 == 0 { 1 } else { 0 });
            let padding_length = (buffer_length * 8 - items.len()) as u8;
            let mut bit_string_data = vec![0; buffer_length];
            for i in 0..items.len() {
                let byte_index = i / 8;
                let bit_index = 7 - (i % 8) as u8;
                if items[i] {
                    bit_string_data[byte_index] |= 1 << bit_index // This is lsb and LSB first.
                }
            }
            Ok(MmsData::BitString(padding_length, bit_string_data))
        }
        MmsServiceData::Integer(big_int) => Ok(MmsData::Integer(big_int.to_signed_bytes_be())),
        MmsServiceData::Unsigned(big_uint) => Ok(MmsData::Unsigned(big_uint.to_bigint().ok_or_else(|| MmsError::InternalError("This is a bug. Please contact the project team.".into()))?.to_signed_bytes_be())),
        MmsServiceData::FloatingPoint(value) => Ok(MmsData::FloatingPoint(value.get_raw_data().clone())),
        MmsServiceData::OctetString(value) => Ok(MmsData::OctetString(value.clone())),
        MmsServiceData::VisibleString(value) => Ok(MmsData::VisibleString(value.clone())),
        MmsServiceData::GeneralizedTime(value) => Ok(MmsData::GeneralizedTime(value.clone())),
        MmsServiceData::BinaryTime(value) => Ok(MmsData::BinaryTime(value.clone())),
        MmsServiceData::Bcd(value) => Ok(MmsData::Bcd(value.clone())),
        MmsServiceData::BooleanArray(items) => {
            let buffer_length = items.len() / 8 + 1 - (if items.len() % 8 == 0 { 1 } else { 0 });
            let padding_length = (buffer_length * 8 - items.len()) as u8;
            let mut bit_string_data = vec![0; buffer_length];
            for i in 0..items.len() {
                let byte_index = i / 8;
                let bit_index = 7 - (i % 8) as u8;
                if items[i] {
                    bit_string_data[byte_index] |= 1 << bit_index // This is lsb and LSB first.
                }
            }
            Ok(MmsData::BitString(padding_length, bit_string_data))
        }
        MmsServiceData::ObjectId(oid) => Ok(MmsData::ObjectId(oid.to_owned())),
        MmsServiceData::MmsString(value) => Ok(MmsData::MmsString(value.into())),
    }
}

pub(crate) fn convert_high_level_data_types_to_low_level_data_types(service_data: &MmsServiceTypeDescription) -> Result<MmsTypeDescription, MmsError> {
    match service_data {
        MmsServiceTypeDescription::Array { packed, number_of_elements, element_type } => Ok(MmsTypeDescription::Array {
            packed: if *packed { Some(true) } else { None },
            number_of_elements: BigInt::from(*number_of_elements).to_signed_bytes_be(),
            element_type: Box::new(match element_type.deref() {
                MmsServiceTypeSpecification::ObjectName(mms_object_name) => rusty_mms::MmsTypeSpecification::ObjectName(mms_object_name.clone()),
                MmsServiceTypeSpecification::TypeDescription(mms_service_type_description) => rusty_mms::MmsTypeSpecification::TypeDescription(convert_high_level_data_types_to_low_level_data_types(&mms_service_type_description)?),
            }),
        }),
        MmsServiceTypeDescription::Structure { packed, components } => Ok(MmsTypeDescription::Structure {
            packed: if *packed { Some(true) } else { None },
            components: components
                .iter()
                .map(|component| {
                    Ok(MmsTypeDescriptionComponent {
                        component_name: component.component_name.clone(),
                        component_type: match &component.component_type {
                            MmsServiceTypeSpecification::ObjectName(mms_object_name) => rusty_mms::MmsTypeSpecification::ObjectName(mms_object_name.clone()),
                            MmsServiceTypeSpecification::TypeDescription(mms_service_type_description) => {
                                rusty_mms::MmsTypeSpecification::TypeDescription(convert_high_level_data_types_to_low_level_data_types(&mms_service_type_description)?)
                            }
                        },
                    })
                })
                .collect::<Result<Vec<_>, MmsError>>()?,
        }),
        MmsServiceTypeDescription::Boolean => Ok(MmsTypeDescription::Boolean),
        MmsServiceTypeDescription::BitString(length) => Ok(MmsTypeDescription::BitString(BigInt::from(*length).to_signed_bytes_be())),
        MmsServiceTypeDescription::Integer(length) => Ok(MmsTypeDescription::Integer(BigInt::from(*length).to_signed_bytes_be())),
        MmsServiceTypeDescription::Unsigned(length) => Ok(MmsTypeDescription::Unsigned(BigInt::from(*length).to_signed_bytes_be())),
        MmsServiceTypeDescription::FloatingPoint { format_width, exponent_width } => {
            Ok(MmsTypeDescription::FloatingPoint { format_width: BigInt::from(*format_width).to_signed_bytes_be(), exponent_width: BigInt::from(*exponent_width).to_signed_bytes_be() })
        }
        MmsServiceTypeDescription::OctetString(length) => Ok(MmsTypeDescription::OctetString(BigInt::from(*length).to_signed_bytes_be())),
        MmsServiceTypeDescription::VisibleString(length) => Ok(MmsTypeDescription::VisibleString(BigInt::from(*length).to_signed_bytes_be())),
        MmsServiceTypeDescription::GeneralizedTime => Ok(MmsTypeDescription::GeneralizedTime),
        MmsServiceTypeDescription::BinaryTime(include_date) => Ok(MmsTypeDescription::BinaryTime(*include_date)),
        MmsServiceTypeDescription::Bcd(number_of_digits) => Ok(MmsTypeDescription::Bcd(BigInt::from(*number_of_digits).to_signed_bytes_be())),
        MmsServiceTypeDescription::ObjId => Ok(MmsTypeDescription::ObjId),
        MmsServiceTypeDescription::MmsString(length) => Ok(MmsTypeDescription::MmsString(BigInt::from(*length).to_signed_bytes_be())),
    }
}

pub(crate) fn convert_low_level_data_to_high_level_data(service_data: &MmsData) -> Result<MmsServiceData, MmsError> {
    match service_data {
        MmsData::Array(items) => {
            let mut high_level_data = vec![];
            for item in items {
                high_level_data.push(convert_low_level_data_to_high_level_data(item)?);
            }
            Ok(MmsServiceData::Array(high_level_data))
        }
        MmsData::Structure(items) => {
            let mut high_level_data = vec![];
            for item in items {
                high_level_data.push(convert_low_level_data_to_high_level_data(item)?);
            }
            Ok(MmsServiceData::Structure(high_level_data))
        }
        MmsData::Boolean(x) => Ok(MmsServiceData::Boolean(*x)),
        MmsData::BitString(padding, values) => {
            let padded_length = values.len() * 8;
            if *padding > 7 || padded_length == 0 {
                return Err(MmsError::ProtocolError(format!("Received Invalid BitString. Padded Length: {}, Padding: {}", padded_length, padding)));
            }

            let mut items = vec![];
            for i in 0..(padded_length - (*padding as usize)) {
                items.push(if let Some(true) = values.get(i / 8).map(|x| (x & (0x80 >> (i % 8))) != 0) { true } else { false });
            }
            Ok(MmsServiceData::BitString(items))
        }
        MmsData::Integer(value) => Ok(MmsServiceData::Integer(BigInt::from_signed_bytes_be(value))),
        MmsData::Unsigned(value) => Ok(MmsServiceData::Unsigned(BigInt::from_signed_bytes_be(value).to_biguint().ok_or_else(|| MmsError::InternalError("This is a bug. Please contact the project team.".into()))?)),
        MmsData::FloatingPoint(value) => Ok(MmsServiceData::FloatingPoint(MmsServiceDataFloat::new(value.clone()))),
        MmsData::OctetString(value) => Ok(MmsServiceData::OctetString(value.clone())),
        MmsData::VisibleString(value) => Ok(MmsServiceData::VisibleString(value.clone())),
        MmsData::GeneralizedTime(value) => Ok(MmsServiceData::GeneralizedTime(value.clone())),
        MmsData::BinaryTime(value) => Ok(MmsServiceData::BinaryTime(value.clone())),
        MmsData::Bcd(value) => Ok(MmsServiceData::Bcd(value.clone())),
        MmsData::BooleanArray(padding, values) => {
            let padded_length = values.len() * 8;
            if *padding > 7 || padded_length == 0 {
                return Err(MmsError::ProtocolError(format!("Received Invalid BitString. Padded Length: {}, Padding: {}", padded_length, padding)));
            }

            let mut items = vec![];
            for i in 0..(padded_length - (*padding as usize)) {
                items.push(if let Some(true) = values.get(i / 8).map(|x| (x & (0x80 >> (i % 8))) != 0) { true } else { false });
            }
            Ok(MmsServiceData::BitString(items))
        }
        MmsData::ObjectId(value) => Ok(MmsServiceData::ObjectId(value.to_owned())),
        MmsData::MmsString(value) => Ok(MmsServiceData::MmsString(value.into())),
    }
}

pub(crate) fn convert_low_level_data_types_to_high_level_data_types(service_data: &MmsTypeDescription) -> Result<MmsServiceTypeDescription, MmsServiceError> {
    match service_data {
        MmsTypeDescription::Array { packed, number_of_elements, element_type } => Ok(MmsServiceTypeDescription::Array {
            packed: packed.unwrap_or(false),
            number_of_elements: BigInt::from_signed_bytes_be(number_of_elements)
                .to_biguint()
                .ok_or(MmsServiceError::ProtocolError("Type Description Element Count is expected to be an unisgned 32 bit integer.".to_string()))?
                .try_into()
                .map_err(to_mms_error("Type Description Element Count is expected to be an unisgned 32 bit integer."))?,
            element_type: Box::new(match element_type.deref() {
                rusty_mms::MmsTypeSpecification::ObjectName(mms_object_name) => MmsServiceTypeSpecification::ObjectName(mms_object_name.clone()),
                rusty_mms::MmsTypeSpecification::TypeDescription(mms_type_description) => MmsServiceTypeSpecification::TypeDescription(convert_low_level_data_types_to_high_level_data_types(mms_type_description)?),
            }),
        }),
        MmsTypeDescription::Structure { packed, components } => Ok(MmsServiceTypeDescription::Structure {
            packed: packed.unwrap_or(false),
            components: components
                .iter()
                .map(|x| {
                    Ok(MmsServiceTypeDescriptionComponent {
                        component_name: x.component_name.clone(),
                        component_type: match &x.component_type {
                            rusty_mms::MmsTypeSpecification::ObjectName(mms_object_name) => MmsServiceTypeSpecification::ObjectName(mms_object_name.clone()),
                            rusty_mms::MmsTypeSpecification::TypeDescription(mms_type_description) => MmsServiceTypeSpecification::TypeDescription(convert_low_level_data_types_to_high_level_data_types(mms_type_description)?),
                        },
                    })
                })
                .collect::<Result<Vec<MmsServiceTypeDescriptionComponent>, MmsServiceError>>()?,
        }),
        MmsTypeDescription::Boolean => Ok(MmsServiceTypeDescription::Boolean),
        MmsTypeDescription::BitString(length) => Ok(MmsServiceTypeDescription::BitString(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode bitstring length"))?)),
        MmsTypeDescription::Integer(length) => Ok(MmsServiceTypeDescription::Integer(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode integer length"))?)),
        MmsTypeDescription::Unsigned(length) => Ok(MmsServiceTypeDescription::Unsigned(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode unsigned integer length"))?)),
        MmsTypeDescription::FloatingPoint { format_width, exponent_width } => Ok(MmsServiceTypeDescription::FloatingPoint {
            format_width: BigInt::from_signed_bytes_be(format_width).try_into().map_err(to_mms_error("Failed to decode unsigned integer length"))?,
            exponent_width: BigInt::from_signed_bytes_be(exponent_width).try_into().map_err(to_mms_error("Failed to decode unsigned integer length"))?,
        }),
        MmsTypeDescription::OctetString(length) => Ok(MmsServiceTypeDescription::OctetString(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode octet string length"))?)),
        MmsTypeDescription::VisibleString(length) => Ok(MmsServiceTypeDescription::VisibleString(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode visible string length"))?)),
        MmsTypeDescription::GeneralizedTime => Ok(MmsServiceTypeDescription::GeneralizedTime),
        MmsTypeDescription::BinaryTime(include_date) => Ok(MmsServiceTypeDescription::BinaryTime(*include_date)),
        MmsTypeDescription::Bcd(length) => Ok(MmsServiceTypeDescription::Bcd(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode BCD length"))?)),
        MmsTypeDescription::ObjId => Ok(MmsServiceTypeDescription::ObjId),
        MmsTypeDescription::MmsString(length) => Ok(MmsServiceTypeDescription::MmsString(BigInt::from_signed_bytes_be(length).try_into().map_err(to_mms_error("Failed to decode MMS String length"))?)),
    }
}