use alloc::vec::Vec;
use core::fmt::Debug;
use miniz_oxide::{
deflate::{compress_to_vec, CompressionLevel},
inflate::decompress_to_vec,
};
use crate::Error;
#[derive(Debug)]
pub struct GzipCompressor {
threshold: usize,
}
impl GzipCompressor {
#[must_use]
pub fn new(threshold: usize) -> Self {
Self { threshold }
}
}
impl GzipCompressor {
pub fn compress(&self, buf: &[u8]) -> Result<Option<Vec<u8>>, Error> {
if buf.len() >= self.threshold {
let compressed = compress_to_vec(buf, CompressionLevel::BestSpeed as u8);
Ok(Some(compressed))
} else {
Ok(None)
}
}
#[allow(clippy::unused_self)]
pub fn decompress(&self, buf: &[u8]) -> Result<Vec<u8>, Error> {
let decompressed = decompress_to_vec(buf);
match decompressed {
Ok(buf) => Ok(buf),
Err(_) => Err(Error::compression()),
}
}
}
#[cfg(test)]
mod tests {
use crate::bolts::compress::GzipCompressor;
#[test]
fn test_compression() {
let compressor = GzipCompressor::new(1);
assert!(
compressor
.decompress(&compressor.compress(&[1u8; 1024]).unwrap().unwrap())
.unwrap()
== vec![1u8; 1024]
);
}
#[test]
fn test_threshold() {
let compressor = GzipCompressor::new(1024);
assert!(compressor.compress(&[1u8; 1023]).unwrap().is_none());
assert!(compressor.compress(&[1u8; 1024]).unwrap().is_some());
}
}