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
|
use std::{mem::size_of, usize};
use img_parts::jpeg::{markers, Jpeg, JpegSegment};
use thiserror::Error;
use crate::codec::Codec;
#[derive(Debug, PartialEq, Eq)]
pub struct JpegSegmentCodec {
pub start_index: usize,
}
impl Codec for JpegSegmentCodec {
type Carrier = Vec<u8>;
type Payload = Vec<u8>;
type Output = Self::Carrier;
type Error = JpegSegmentError;
fn encode(&self, carrier: impl Into<Self::Carrier>, payload: impl Into<Self::Payload>) -> Result<Self::Output, Self::Error> {
let mut jpeg = match Jpeg::from_bytes(carrier.into().into()) {
Ok(image) => image,
Err(err) => return Err(JpegSegmentError::ParseFailed { inner: err })
};
let mut payload_bytes: Self::Carrier = payload.into();
let segment_count = ((payload_bytes.len() + size_of::<u64>()) as u64).div_ceil((u16::MAX as usize - size_of::<u16>()) as u64);
payload_bytes.splice(0..0, segment_count.to_le_bytes());
for (index, payload_chunk) in payload_bytes.chunks(u16::MAX as usize - size_of::<u16>()).enumerate() {
let segment = JpegSegment::new_with_contents(markers::COM, payload_chunk.to_vec().into());
jpeg.segments_mut().insert(self.start_index + index, segment);
}
Ok(jpeg.encoder().bytes().to_vec())
}
fn decode(&self, encoded: impl Into<Self::Output>) -> Result<(Self::Carrier, Self::Payload), Self::Error> {
let mut jpeg = match Jpeg::from_bytes(encoded.into().into()) {
Ok(image) => image,
Err(err) => return Err(JpegSegmentError::ParseFailed { inner: err })
};
let segment = jpeg.segments_mut().remove(self.start_index);
let segment_bytes = segment.contents();
let segment_count = u64::from_le_bytes(segment_bytes[0..size_of::<u64>()].try_into().unwrap()) as usize;
let mut payload_vec: Vec<u8> = Vec::with_capacity((u16::MAX as usize - size_of::<u16>()) * segment_count);
payload_vec.extend(segment_bytes[size_of::<u64>()..].to_vec());
for _ in 0..segment_count-1 {
let segment = jpeg.segments_mut().remove(self.start_index);
payload_vec.extend(segment.contents());
}
Ok((jpeg.encoder().bytes().to_vec(), payload_vec))
}
}
impl Default for JpegSegmentCodec {
fn default() -> Self {
Self {
start_index: 3,
}
}
}
#[derive(Error, Debug)]
pub enum JpegSegmentError {
#[error("Failed to parse JPEG data: {inner:?}")]
ParseFailed { inner: img_parts::Error }
}
|
