fix flow_input (#182)

* fix flow_input * update test files
space-operator · Jan 23, 2025 · 0f86e5a · 0f86e5a
1 parent 715ec0b
commit 0f86e5a
Show file tree

Hide file tree

Showing 6 changed files with 1,536 additions and 9 deletions.
diff --git a/.github/workflows/basic.yml b/.github/workflows/basic.yml
@@ -31,14 +31,14 @@ jobs:
             -A clippy::too_many_arguments
       - name: Assert Cargo.lock unchanged
         run: .github/assert_cargo_lock_unchanged.bash
-      - name: Install wasm32-wasi
-        run: rustup target add wasm32-wasi
+#     - name: Install wasm32-wasi
+#       run: rustup target add wasm32-wasi
       - name: Install deno
         uses: denoland/setup-deno@v1
         with:
           deno-version: v1.x
-      - name: Build WASM
-        run: ./scripts/build_wasm_tests.bash
+#     - name: Build WASM
+#       run: ./scripts/build_wasm_tests.bash
       - name: Build tests
         run: cargo test --quiet --no-run
       - name: Run tests

diff --git a/.github/workflows/deps.yml b/.github/workflows/deps.yml
@@ -21,8 +21,6 @@ jobs:
         with:
           submodules: "recursive"
       - uses: Swatinem/rust-cache@v2
-      - name: Install wasm32-wasi
-        run: rustup target add wasm32-wasi
       - run: rm Cargo.lock
       - name: Build
         run: cargo check --tests
diff --git a/crates/flow-server/src/lib.rs b/crates/flow-server/src/lib.rs
@@ -528,6 +528,29 @@ mod tests {
         dbg!(res);
     }
 
+
+    #[tokio::test]
+    async fn test_flow_input() {
+        tracing_subscriber::fmt::try_init().ok();
+        let json = include_str!("../../../test_files/HTTP Request.json");
+        let flow_config = FlowConfig::new(serde_json::from_str::<TestFile>(json).unwrap().flow);
+        let mut flow = FlowGraph::from_cfg(flow_config, <_>::default(), None)
+            .await
+            .unwrap();
+        let (tx, _rx) = event_channel();
+        let res = flow
+            .run(
+                tx,
+                <_>::default(),
+                <_>::default(),
+                <_>::default(),
+                <_>::default(),
+                <_>::default(),
+            )
+            .await;
+        dbg!(res);
+    }
+
     #[test]
     fn test_name_unique() {
         let mut m = std::collections::HashSet::new();

diff --git a/crates/flow/src/command/flow_input.rs b/crates/flow/src/command/flow_input.rs
@@ -35,7 +35,7 @@ impl CommandTrait for FlowInputCommand {
 
     fn outputs(&self) -> Vec<Output> {
         [Output {
-            name: OUTPUT.into(),
+            name: self.label.clone(),
             r#type: ValueType::Free,
             optional: false,
         }]
@@ -45,7 +45,7 @@ impl CommandTrait for FlowInputCommand {
     async fn run(&self, _ctx: Context, mut inputs: ValueSet) -> Result<ValueSet, CommandError> {
         let value = inputs.swap_remove(&self.label).unwrap_or(Value::Null);
         Ok(value::map! {
-            OUTPUT => value,
+            &self.label => value,
         })
     }