refactor: Rename get_engine to get_compression_engine and update references
This commit is contained in:
@@ -128,7 +128,7 @@ lazy_static! {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn get_engine(compression_type: CompressionType) -> Result<Box<dyn CompressionEngine>> {
|
pub fn get_compression_engine(compression_type: CompressionType) -> Result<Box<dyn CompressionEngine>> {
|
||||||
match compression_type {
|
match compression_type {
|
||||||
CompressionType::LZ4 => Ok(Box::new(CompressionEngineLZ4::new())),
|
CompressionType::LZ4 => Ok(Box::new(CompressionEngineLZ4::new())),
|
||||||
CompressionType::GZip => Ok(Box::new(CompressionEngineGZip::new())),
|
CompressionType::GZip => Ok(Box::new(CompressionEngineGZip::new())),
|
||||||
|
|||||||
@@ -38,7 +38,7 @@ pub fn mode_get(
|
|||||||
item_path.push(item.id.unwrap().to_string());
|
item_path.push(item.id.unwrap().to_string());
|
||||||
|
|
||||||
let compression_type = CompressionType::from_str(&item.compression)?;
|
let compression_type = CompressionType::from_str(&item.compression)?;
|
||||||
let compression_engine = crate::compression_engine::get_engine(compression_type)?;
|
let compression_engine = crate::compression_engine::get_compression_engine(compression_type)?;
|
||||||
compression_engine.cat(item_path.clone())?;
|
compression_engine.cat(item_path.clone())?;
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
|
|||||||
@@ -110,7 +110,7 @@ pub fn mode_info(
|
|||||||
]));
|
]));
|
||||||
|
|
||||||
let compression_engine =
|
let compression_engine =
|
||||||
get_engine(compression_type).expect("Unable to get compression engine");
|
get_compression_engine(compression_type).expect("Unable to get compression engine");
|
||||||
let magic = compression_engine.magic(item_path.clone());
|
let magic = compression_engine.magic(item_path.clone());
|
||||||
|
|
||||||
let file_magic_cell = match magic {
|
let file_magic_cell = match magic {
|
||||||
|
|||||||
@@ -131,7 +131,7 @@ pub fn mode_save(
|
|||||||
let mut stdout = io::stdout().lock();
|
let mut stdout = io::stdout().lock();
|
||||||
let mut buffer = [0; libc::BUFSIZ as usize];
|
let mut buffer = [0; libc::BUFSIZ as usize];
|
||||||
|
|
||||||
let compression_engine = crate::compression_engine::get_engine(compression_type.clone())
|
let compression_engine = crate::compression_engine::get_compression_engine(compression_type.clone())
|
||||||
.expect("Unable to get compression engine");
|
.expect("Unable to get compression engine");
|
||||||
let mut item_out: Box<dyn Write> =
|
let mut item_out: Box<dyn Write> =
|
||||||
compression_engine
|
compression_engine
|
||||||
|
|||||||
@@ -47,7 +47,7 @@ pub fn mode_update(
|
|||||||
if item_file_metadata.is_ok() {
|
if item_file_metadata.is_ok() {
|
||||||
debug!("MAIN: Updating stream size of {:?}", item_path);
|
debug!("MAIN: Updating stream size of {:?}", item_path);
|
||||||
let compression_type = CompressionType::from_str(&item.compression)?;
|
let compression_type = CompressionType::from_str(&item.compression)?;
|
||||||
let compression_engine = crate::compression_engine::get_engine(compression_type)
|
let compression_engine = crate::compression_engine::get_compression_engine(compression_type)
|
||||||
.expect("Unable to get compression engine");
|
.expect("Unable to get compression engine");
|
||||||
let size = compression_engine.size(item_path)? as i64;
|
let size = compression_engine.size(item_path)? as i64;
|
||||||
item.size = Some(size);
|
item.size = Some(size);
|
||||||
|
|||||||
Reference in New Issue
Block a user