refactor: update engine calls to use imported functions
This commit is contained in:
@@ -110,7 +110,7 @@ pub fn mode_info(
|
|||||||
]));
|
]));
|
||||||
|
|
||||||
let compression_engine =
|
let compression_engine =
|
||||||
get_compression_engine(compression_type).expect("Unable to get compression engine");
|
crate::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 {
|
||||||
|
|||||||
@@ -64,7 +64,7 @@ pub fn mode_save(
|
|||||||
|
|
||||||
// Create a new digest engine
|
// Create a new digest engine
|
||||||
let digest_type = DigestType::from_str(&digest_name).unwrap_or(DigestType::Sha256);
|
let digest_type = DigestType::from_str(&digest_name).unwrap_or(DigestType::Sha256);
|
||||||
let mut digest_engine = get_digest_engine(digest_type);
|
let mut digest_engine = crate::digest_engine::get_digest_engine(digest_type);
|
||||||
|
|
||||||
let mut item = db::Item {
|
let mut item = db::Item {
|
||||||
id: None,
|
id: None,
|
||||||
@@ -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_compression_engine(compression_type.clone())
|
let 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
|
||||||
|
|||||||
@@ -48,7 +48,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_compression_engine(compression_type)
|
let 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