fix: use iter_mut() for mutable meta_plugins
This commit is contained in:
@@ -14,7 +14,7 @@ use crate::compression_engine::get_compression_engine;
|
|||||||
use crate::db::{self};
|
use crate::db::{self};
|
||||||
use crate::digest_engine::get_digest_engine;
|
use crate::digest_engine::get_digest_engine;
|
||||||
use crate::meta_plugin::{MetaPlugin, MetaPluginType, get_meta_plugin};
|
use crate::meta_plugin::{MetaPlugin, MetaPluginType, get_meta_plugin};
|
||||||
use crate::modes::common::{cmd_args_compression_type, cmd_args_digest_type, cmd_args_meta_plugin_types, get_meta_from_env, store_item_digest_value, store_item_meta_value};
|
use crate::modes::common::{cmd_args_compression_type, cmd_args_digest_type, cmd_args_meta_plugin_types, get_digest_type_meta, store_item_digest_value};
|
||||||
use chrono::Utc;
|
use chrono::Utc;
|
||||||
|
|
||||||
pub fn mode_save(
|
pub fn mode_save(
|
||||||
@@ -142,7 +142,7 @@ pub fn mode_save(
|
|||||||
item_out.write_all(&buffer[..n])?;
|
item_out.write_all(&buffer[..n])?;
|
||||||
digest_engine.update(&buffer[..n]);
|
digest_engine.update(&buffer[..n]);
|
||||||
|
|
||||||
for meta_plugin in meta_plugins.iter() {
|
for meta_plugin in meta_plugins.iter_mut() {
|
||||||
meta_plugin.update(&buffer[..n]);
|
meta_plugin.update(&buffer[..n]);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -161,7 +161,7 @@ pub fn mode_save(
|
|||||||
|
|
||||||
store_item_digest_value(conn, item.clone(), digest_type, digest)?;
|
store_item_digest_value(conn, item.clone(), digest_type, digest)?;
|
||||||
|
|
||||||
for meta_plugin in meta_plugins.iter() {
|
for meta_plugin in meta_plugins.iter_mut() {
|
||||||
let meta_name = meta_plugin.meta_name();
|
let meta_name = meta_plugin.meta_name();
|
||||||
|
|
||||||
// TODO: Add error handling instead of unwrap.
|
// TODO: Add error handling instead of unwrap.
|
||||||
@@ -170,7 +170,6 @@ pub fn mode_save(
|
|||||||
store_item_meta_value(conn, item.clone(), meta_name, meta_value)?;
|
store_item_meta_value(conn, item.clone(), meta_name, meta_value)?;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
db::update_item(conn, item.clone())?;
|
db::update_item(conn, item.clone())?;
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
|
|||||||
Reference in New Issue
Block a user