diff --git a/src/services/meta_service.rs b/src/services/meta_service.rs index 417ac85..922f66f 100644 --- a/src/services/meta_service.rs +++ b/src/services/meta_service.rs @@ -126,22 +126,16 @@ impl MetaService { ) { for meta_plugin in plugins.iter_mut() { // Skip plugins that are already finalized - if let Some(internal_plugin) = meta_plugin.as_any_mut().downcast_mut::() { - if internal_plugin.is_finalized() { - continue; - } + if meta_plugin.is_finalized() { + continue; } - // Add similar checks for other internal plugin types as needed let response = meta_plugin.update(chunk); self.process_plugin_response(conn, item_id, meta_plugin, response); // Set finalized flag if response indicates finalization if response.is_finalized { - if let Some(internal_plugin) = meta_plugin.as_any_mut().downcast_mut::() { - internal_plugin.set_finalized(true); - } - // Add similar checks for other internal plugin types as needed + meta_plugin.set_finalized(true); } } } @@ -149,22 +143,16 @@ impl MetaService { pub fn finalize_plugins(&self, plugins: &mut [Box], conn: &Connection, item_id: i64) { for meta_plugin in plugins.iter_mut() { // Skip plugins that are already finalized - if let Some(internal_plugin) = meta_plugin.as_any_mut().downcast_mut::() { - if internal_plugin.is_finalized() { - continue; - } + if meta_plugin.is_finalized() { + continue; } - // Add similar checks for other internal plugin types as needed let response = meta_plugin.finalize(); self.process_plugin_response(conn, item_id, meta_plugin, response); // Set finalized flag if response indicates finalization if response.is_finalized { - if let Some(internal_plugin) = meta_plugin.as_any_mut().downcast_mut::() { - internal_plugin.set_finalized(true); - } - // Add similar checks for other internal plugin types as needed + meta_plugin.set_finalized(true); } } }