fluentci_shared/
pipeline.rs

1use extism::{convert::Json, *};
2use fluentci_common::pipeline::pipeline as common_pipeline;
3
4use crate::state::State;
5
6host_fn!(pub pipeline(user_data: State; name: String) -> Json<Pipeline> {
7    let state = user_data.get()?;
8    let state = state.lock().unwrap();
9    let graph = state.graph.clone();
10    let pipeline = common_pipeline(graph, name)?;
11    Ok(Json(pipeline))
12});