asp/keep
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: add finalization state tracking to meta plugins

Browse Source 
Co-authored-by: aider (openai/andrew/openrouter/qwen/qwen3-coder) <aider@aider.chat>
This commit is contained in:
Andrew Phillips
2025-08-26 18:23:02 -03:00
parent 6574b5a072
commit bd879100be
3 changed files with 76 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/services/meta_service.rs
View File

@@ -125,15 +125,47 @@ impl MetaService {
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::<crate::meta_plugin::BinaryMetaPlugin>() {
if internal_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::<crate::meta_plugin::BinaryMetaPlugin>() {
internal_plugin.set_finalized(true);
}
// Add similar checks for other internal plugin types as needed
}
}
}
pub fn finalize_plugins(&self, plugins: &mut [Box<dyn MetaPlugin>], 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::<crate::meta_plugin::BinaryMetaPlugin>() {
if internal_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::<crate::meta_plugin::BinaryMetaPlugin>() {
internal_plugin.set_finalized(true);
}
// Add similar checks for other internal plugin types as needed
}
}
}