diff --git a/src/api/processing.rs b/src/api/processing.rs index eba8b5f..ed71656 100644 --- a/src/api/processing.rs +++ b/src/api/processing.rs @@ -233,8 +233,16 @@ async fn trigger_processing( .await .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?; + let valid: std::collections::HashSet<&str> = crate::core::db::ProcessorType::all() + .iter() + .map(|p| p.as_str()) + .collect(); let processors_to_run: Vec = if let Some(procs) = &req.processors { - procs.iter().map(|s| s.to_string()).collect() + procs + .iter() + .filter(|s| valid.contains(s.as_str())) + .map(|s| s.to_string()) + .collect() } else { crate::core::db::ProcessorType::all() .iter()