compression-codecs 0.4.37

Adaptors for various compression algorithms.
Documentation 
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! This module contains lz4-specific types for async-compression.

use std::convert::TryInto;

use compression_core::Level;
pub use lz4::liblz4::BlockSize;
use lz4::{
    liblz4::{BlockChecksum, FrameType, LZ4FFrameInfo, LZ4FPreferences},
    BlockMode, ContentChecksum,
};

/// lz4 compression parameters builder. This is a stable wrapper around lz4's own encoder
/// params type, to abstract over different versions of the lz4 library.
///
/// See the [lz4 documentation](https://github.com/lz4/lz4/blob/dev/doc/lz4frame_manual.html)
/// for more information on these parameters.
///
/// # Examples
///
/// ```
/// use compression_codecs::lz4;
///
/// let params = lz4::params::EncoderParams::default()
///     .block_size(lz4::params::BlockSize::Max1MB)
///     .content_checksum(true);
/// ```
#[derive(Clone, Debug, Default)]
pub struct EncoderParams {
    block_size: Option<BlockSize>,
    block_checksum: Option<BlockChecksum>,
    content_checksum: Option<ContentChecksum>,
    level: Level,
}

impl EncoderParams {
    pub fn level(mut self, level: Level) -> Self {
        self.level = level;
        self
    }

    /// Sets input block size.
    pub fn block_size(mut self, block_size: BlockSize) -> Self {
        self.block_size = Some(block_size);
        self
    }

    /// Add a 32-bit checksum of frame's decompressed data.
    pub fn content_checksum(mut self, enable: bool) -> Self {
        self.content_checksum = Some(if enable {
            ContentChecksum::ChecksumEnabled
        } else {
            ContentChecksum::NoChecksum
        });
        self
    }

    /// Each block followed by a checksum of block's compressed data.
    pub fn block_checksum(mut self, enable: bool) -> Self {
        self.block_checksum = Some(if enable {
            BlockChecksum::BlockChecksumEnabled
        } else {
            BlockChecksum::NoBlockChecksum
        });
        self
    }
}

impl From<EncoderParams> for LZ4FPreferences {
    fn from(value: EncoderParams) -> Self {
        let block_size_id = value.block_size.clone().unwrap_or(BlockSize::Default);
        let content_checksum_flag = value
            .content_checksum
            .clone()
            .unwrap_or(ContentChecksum::NoChecksum);
        let block_checksum_flag = value
            .block_checksum
            .clone()
            .unwrap_or(BlockChecksum::NoBlockChecksum);
        let compression_level = match value.level {
            Level::Fastest => 0,
            Level::Best => 12,
            Level::Precise(quality) => quality.try_into().unwrap_or(0).clamp(0, 12),
            _ => 0,
        };

        LZ4FPreferences {
            frame_info: LZ4FFrameInfo {
                block_size_id,
                block_mode: BlockMode::Linked,
                content_checksum_flag,
                frame_type: FrameType::Frame,
                content_size: 0,
                dict_id: 0,
                block_checksum_flag,
            },
            compression_level,
            auto_flush: 0,
            favor_dec_speed: 0,
            reserved: [0; 3],
        }
    }
}