vato007/ingey
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add file paths to dynamic node
All checks were successful
test / test (push) Successful in 14m15s
Details

Browse Source
This commit is contained in:
vato007
2025-01-23 13:03:37 +10:30
parent e2604d4e70
commit b0446f8ea3
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/graph/dynamic/mod.rs
View File

@@ -23,7 +23,7 @@ mod read_map;
#[derive(Serialize, Deserialize, Clone, JsonSchema)] #[derive(Serialize, Deserialize, Clone, JsonSchema)]
pub struct DynamicNode { pub struct DynamicNode {
pub wasm_file_path: String, pub wasm_file_path: String,
pub input_file_paths: Vec<String>, pub input_file_paths: HashMap<String, String>,
pub output_file: String, pub output_file: String,
} }
@@ -46,7 +46,7 @@ impl RunnableNode for DynamicNodeRunner {
); );
let bindings = Dynamic::instantiate(&mut store, &component, &linker)?; let bindings = Dynamic::instantiate(&mut store, &component, &linker)?;
let read_map = store.data_mut().resources.push(ReadMapData { data: HashMap::new() })?; let read_map = store.data_mut().resources.push(ReadMapData { data: HashMap::new() })?;
let readers = store.data_mut().resources.push(CsvReadersData { readers: HashMap::new() })?; let readers = store.data_mut().resources.push(CsvReadersData { readers: self.dynamic_node.input_file_paths.clone() })?;
let writer = CsvWriterData::new(self.dynamic_node.output_file.clone())?; let writer = CsvWriterData::new(self.dynamic_node.output_file.clone())?;
let writer = store.data_mut().resources.push(writer)?; let writer = store.data_mut().resources.push(writer)?;
bindings.call_evaluate(&mut store, read_map, readers, writer)?; bindings.call_evaluate(&mut store, read_map, readers, writer)?;