use crate::{
error::Error,
response::{Code, Response, SubFunction},
utils, DataIdentifier, Configuration, ResponseData, Service,
};
use bitfield_struct::bitfield;
use std::{collections::HashSet, sync::LazyLock};
pub static READ_SCALING_DID_NEGATIVES: LazyLock<HashSet<Code>> = LazyLock::new(|| {
HashSet::from([
Code::IncorrectMessageLengthOrInvalidFormat,
Code::ConditionsNotCorrect,
Code::RequestOutOfRange,
Code::SecurityAccessDenied,
#[cfg(any(feature = "std2020"))]
Code::AuthenticationRequired,
])
});
rsutil::enum_extend!(
#[derive(Debug, Copy, Clone, Eq, PartialEq, Hash)]
pub enum ScalingByteType {
UnSignedNumeric = 0x00, SignedNumeric = 0x10, BitMappedReportedWithOutMask = 0x20, BitMappedReportedWithMask = 0x30, BinaryCodedDecimal = 0x40, StateEncodedVariable = 0x50, ASCII = 0x60, SignedFloatingPoint = 0x70, Packet = 0x80,
Formula = 0x90,
UnitFormat = 0xA0,
StateAndConnectionType = 0xB0, },
u8,
Error,
ReservedError
);
#[derive(Debug, Copy, Clone, Eq, PartialEq)]
pub enum Formula {
Formula0, Formula1, Formula2, Formula3, Formula4, Formula5, Formula6, Formula7, Formula8, Formula9, Reserved(u8),
VehicleManufacturerSpecific(u8),
}
impl From<u8> for Formula {
fn from(v: u8) -> Self {
match v {
0x00 => Self::Formula0,
0x01 => Self::Formula1,
0x02 => Self::Formula2,
0x03 => Self::Formula3,
0x04 => Self::Formula4,
0x05 => Self::Formula5,
0x06 => Self::Formula6,
0x07 => Self::Formula7,
0x08 => Self::Formula8,
0x09 => Self::Formula9,
0x0A..=0x7F => Self::Reserved(v),
0x80..=0xFF => Self::VehicleManufacturerSpecific(v),
}
}
}
impl From<Formula> for u8 {
fn from(val: Formula) -> Self {
match val {
Formula::Formula0 => 0x00,
Formula::Formula1 => 0x01,
Formula::Formula2 => 0x02,
Formula::Formula3 => 0x03,
Formula::Formula4 => 0x04,
Formula::Formula5 => 0x05,
Formula::Formula6 => 0x06,
Formula::Formula7 => 0x07,
Formula::Formula8 => 0x08,
Formula::Formula9 => 0x09,
Formula::VehicleManufacturerSpecific(v) => v,
Formula::Reserved(v) => v,
}
}
}
#[bitfield(u16, order = Msb)]
pub struct TwoByteRealNumber {
#[bits(4)]
pub exponent: u8,
#[bits(12)]
pub mantissa: u16,
}
impl TwoByteRealNumber {
pub fn value(&self) -> u128 {
self.mantissa() as u128 * (10 ^ (self.exponent() as u128))
}
}
#[derive(Debug, Clone, Eq, PartialEq)]
pub struct ScalingByteData {
pub byte_type: ScalingByteType,
pub byte_len: u8,
pub extensions: Vec<u8>,
}
#[derive(Debug, Clone, Eq, PartialEq)]
pub struct ReadScalingDID {
pub did: DataIdentifier,
pub data: ScalingByteData,
pub others: Vec<ScalingByteData>, }
impl From<ReadScalingDID> for Vec<u8> {
fn from(v: ReadScalingDID) -> Self {
let did: u16 = v.did.into();
let mut result = did.to_be_bytes().to_vec();
let byte_type: u8 = v.data.byte_type.into();
result.push(byte_type | v.data.byte_len);
v.others.into_iter().for_each(|mut v| {
let byte_type: u8 = v.byte_type.into();
result.push(byte_type | v.byte_len);
result.append(&mut v.extensions);
});
result
}
}
impl ResponseData for ReadScalingDID {
fn new_response<T: AsRef<[u8]>>(
data: T,
sub_func: Option<u8>,
_: &Configuration,
) -> Result<Response, Error> {
let data = data.as_ref();
match sub_func {
Some(_) => Err(Error::SubFunctionError(Service::ReadScalingDID)),
None => {
let data_len = data.len();
utils::data_length_check(data_len, 2, false)?;
Ok(Response {
service: Service::ReadScalingDID,
negative: false,
sub_func: None,
data: data.to_vec(),
})
}
}
}
}
impl TryFrom<(&Response, &Configuration)> for ReadScalingDID {
type Error = Error;
fn try_from((resp, _): (&Response, &Configuration)) -> Result<Self, Self::Error> {
let service = resp.service();
if service != Service::ReadScalingDID || resp.sub_func.is_some() {
return Err(Error::ServiceError(service));
}
let data = &resp.data;
let data_len = data.len();
let mut offset = 0;
let did = DataIdentifier::from(u16::from_be_bytes([data[offset], data[offset + 1]]));
offset += 2;
let byte_context = data[offset];
offset += 1;
let byte_type = ScalingByteType::try_from(byte_context & 0xF0)?;
let byte_len = (byte_context & 0x0F) as usize;
let mut extensions = Vec::new();
match byte_type {
ScalingByteType::BitMappedReportedWithOutMask
| ScalingByteType::Formula
| ScalingByteType::UnitFormat => {
utils::data_length_check(data_len, offset + byte_len, false)?;
extensions.extend(&data[offset..offset + byte_len]);
offset += byte_len;
}
_ => {}
}
let mut others = Vec::new();
while data_len > offset {
let byte_context = data[offset];
offset += 1;
let byte_type = ScalingByteType::try_from(byte_context & 0xF0)?;
let byte_len = (byte_context & 0x0F) as usize;
let mut extensions = Vec::new();
match byte_type {
ScalingByteType::BitMappedReportedWithOutMask
| ScalingByteType::Formula
| ScalingByteType::UnitFormat => {
utils::data_length_check(data_len, offset + byte_len, false)?;
extensions.extend(&data[offset..offset + byte_len]);
offset += byte_len;
}
_ => {}
}
others.push(ScalingByteData {
byte_type,
byte_len: byte_len as u8,
extensions,
});
}
Ok(Self {
did,
data: ScalingByteData {
byte_type,
byte_len: byte_len as u8,
extensions,
},
others,
})
}
}