1 | use crate::{encoder::compression::*, tags::CompressionMethod}; |
2 | use flate2::{write::ZlibEncoder, Compression as FlateCompression}; |
3 | use std::io::Write; |
4 | |
5 | /// The Deflate algorithm used to compress image data in TIFF files. |
6 | #[derive (Debug, Clone, Copy)] |
7 | pub struct Deflate { |
8 | level: FlateCompression, |
9 | } |
10 | |
11 | /// The level of compression used by the Deflate algorithm. |
12 | /// It allows trading compression ratio for compression speed. |
13 | #[derive (Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)] |
14 | #[non_exhaustive ] |
15 | pub enum DeflateLevel { |
16 | /// The fastest possible compression mode. |
17 | Fast = 1, |
18 | /// The conserative choice between speed and ratio. |
19 | Balanced = 6, |
20 | /// The best compression available with Deflate. |
21 | Best = 9, |
22 | } |
23 | |
24 | impl Default for DeflateLevel { |
25 | fn default() -> Self { |
26 | DeflateLevel::Balanced |
27 | } |
28 | } |
29 | |
30 | impl Deflate { |
31 | /// Create a new deflate compressor with a specific level of compression. |
32 | pub fn with_level(level: DeflateLevel) -> Self { |
33 | Self { |
34 | level: FlateCompression::new(level as u32), |
35 | } |
36 | } |
37 | } |
38 | |
39 | impl Default for Deflate { |
40 | fn default() -> Self { |
41 | Self::with_level(DeflateLevel::default()) |
42 | } |
43 | } |
44 | |
45 | impl Compression for Deflate { |
46 | const COMPRESSION_METHOD: CompressionMethod = CompressionMethod::Deflate; |
47 | |
48 | fn get_algorithm(&self) -> Compressor { |
49 | Compressor::Deflate(*self) |
50 | } |
51 | } |
52 | |
53 | impl CompressionAlgorithm for Deflate { |
54 | fn write_to<W: Write>(&mut self, writer: &mut W, bytes: &[u8]) -> Result<u64, io::Error> { |
55 | let mut encoder: ZlibEncoder<&mut W> = ZlibEncoder::new(w:writer, self.level); |
56 | encoder.write_all(buf:bytes)?; |
57 | encoder.try_finish()?; |
58 | Ok(encoder.total_out()) |
59 | } |
60 | } |
61 | |
62 | #[cfg (test)] |
63 | mod tests { |
64 | use super::*; |
65 | use crate::encoder::compression::tests::TEST_DATA; |
66 | use std::io::Cursor; |
67 | |
68 | #[test ] |
69 | fn test_deflate() { |
70 | const EXPECTED_COMPRESSED_DATA: [u8; 64] = [ |
71 | 0x78, 0x9C, 0x15, 0xC7, 0xD1, 0x0D, 0x80, 0x20, 0x0C, 0x04, 0xD0, 0x55, 0x6E, 0x02, |
72 | 0xA7, 0x71, 0x81, 0xA6, 0x41, 0xDA, 0x28, 0xD4, 0xF4, 0xD0, 0xF9, 0x81, 0xE4, 0xFD, |
73 | 0xBC, 0xD3, 0x9C, 0x58, 0x04, 0x1C, 0xE9, 0xBD, 0xE2, 0x8A, 0x84, 0x5A, 0xD1, 0x7B, |
74 | 0xE7, 0x97, 0xF4, 0xF8, 0x08, 0x8D, 0xF6, 0x66, 0x21, 0x3D, 0x3A, 0xE4, 0xA9, 0x91, |
75 | 0x3E, 0xAC, 0xF1, 0x98, 0xB9, 0x70, 0x17, 0x13, |
76 | ]; |
77 | |
78 | let mut compressed_data = Vec::<u8>::new(); |
79 | let mut writer = Cursor::new(&mut compressed_data); |
80 | Deflate::default().write_to(&mut writer, TEST_DATA).unwrap(); |
81 | assert_eq!(EXPECTED_COMPRESSED_DATA, compressed_data.as_slice()); |
82 | } |
83 | } |
84 | |