use core::fmt::Display;
use core::fmt::Write;
use super::BlockError;
use super::block_header::BlockHeader;
use super::block_header::block_header_parser;
use super::inflate::decompress_data_block;
use nom::IResult;
use nom::Parser;
use nom::bytes::streaming::take;
use nom::combinator::verify;
use nom::number::streaming::le_u16;
use nom::number::streaming::le_u32;
use nom::sequence::preceded;
use super::default_params::Param;
use super::default_params::param_parser;
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct SlicerBlock<'a> {
header: BlockHeader,
param: Param,
data: &'a [u8],
checksum: Option<u32>,
}
impl Display for SlicerBlock<'_> {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
let datablock: String =
match decompress_data_block(self.data, &self.param.encoding, &self.header) {
Ok((_remain, data)) => String::from_utf8_lossy(&data).to_string(),
Err(_e) => String::from("failed to decompress"),
};
writeln!(
f,
"-------------------------- SlicerBlock --------------------------"
)?;
writeln!(f, "Params")?;
writeln!(f, "params {:#?}", self.param)?;
writeln!(f)?;
writeln!(f, "DataBlock {datablock:?}")?;
writeln!(f)?;
write!(f, "-------------------------- SlicerBlock ")?;
match self.checksum {
Some(checksum) => writeln!(f, "Checksum Ox{checksum:X} ---------")?,
None => writeln!(f, "No checksum")?,
}
Ok(())
}
}
impl SlicerBlock<'_> {
pub fn markdown<W>(&self, f: &mut W) -> core::fmt::Result
where
W: Write,
{
let datablock: String =
match decompress_data_block(self.data, &self.param.encoding, &self.header) {
Ok((_remain, data)) => String::from_utf8_lossy(&data).to_string(),
Err(_e) => String::from("failed to decompress"),
};
writeln!(f)?;
writeln!(f, "## SlicerBlock")?;
writeln!(f)?;
writeln!(f, "### Params")?;
writeln!(f)?;
writeln!(f, "params {:#?}", self.param)?;
writeln!(f, "<details>")?;
writeln!(f, "<summary>DataBlock</summary>")?;
writeln!(f, "<br>")?;
writeln!(f, "{datablock:?}",)?;
writeln!(f, "</details>")?;
writeln!(f)?;
match self.checksum {
Some(checksum) => writeln!(f, "Checksum Ox{checksum:X}")?,
None => writeln!(f, "No checksum")?,
}
Ok(())
}
}
pub fn slicer_parser(input: &[u8]) -> IResult<&[u8], SlicerBlock<'_>, BlockError> {
let (after_block_header, header) = preceded(
verify(le_u16, |block_type| {
log::debug!(
"Looking for SLICER_BLOCK_ID {SLICER_BLOCK_ID} found {block_type} cond {}",
*block_type == SLICER_BLOCK_ID
);
*block_type == SLICER_BLOCK_ID
}),
block_header_parser,
)
.parse(input)
.map_err(|e| e.map(|_e| BlockError::Slicer))?;
log::info!("Found slicer block id");
let (after_param, param) = param_parser(after_block_header)
.map_err(|e| e.map(|_e: nom::error::Error<_>| BlockError::Slicer))?;
let (after_data, data) = match header.compressed_size {
Some(size) => take(size)(after_param)?,
None => take(header.uncompressed_size)(after_param)?,
};
let (after_checksum, checksum) =
le_u32(after_data).map_err(|e| e.map(|_e: nom::error::Error<_>| BlockError::Slicer))?;
Ok((
after_checksum,
SlicerBlock {
header,
param,
data,
checksum: Some(checksum),
},
))
}
static SLICER_BLOCK_ID: u16 = 2u16;
pub fn slicer_parser_with_checksum(input: &[u8]) -> IResult<&[u8], SlicerBlock<'_>, BlockError> {
let (remain, slicer) = slicer_parser(input)?;
if let Some(checksum) = slicer.checksum {
let param_size = 2;
let block_size =
slicer.header.size_in_bytes() + param_size + slicer.header.payload_size_in_bytes();
let crc_input = &input[..block_size];
let computed_checksum = crc32fast::hash(crc_input);
log::debug!(
"slicer checksum 0x{checksum:04x} computed checksum 0x{computed_checksum:04x} "
);
if checksum == computed_checksum {
log::debug!("checksum match");
} else {
log::error!("fail checksum");
return Err(nom::Err::Error(BlockError::Slicer));
}
}
Ok((remain, slicer))
}