TDD time

crates/cli/src/workflows.rs

@@ -1,7 +1,7 @@
 use crate::updater::{SupportedApp, Updater};
 use anyhow::Result;
 use console::style;
-use log::{debug, info};
+use log::debug;
 use marzano_auth::env::{get_grit_api_url, ENV_VAR_GRIT_API_URL, ENV_VAR_GRIT_AUTH_TOKEN};
 use marzano_auth::info::AuthInfo;
 use marzano_gritmodule::config::REPO_CONFIG_DIR_NAME;

crates/cli_bin/tests/workflows.rs

@@ -134,12 +134,14 @@ fn applies_user_workflows() -> Result<()> {
 }
 
 #[test]
-fn run_workflow_args() -> Result<()> {
+fn run_workflow_input() -> Result<()> {
     let (_temp_dir, temp_fixtures_root) = get_fixture("grit_modules", true)?;
 
     let mut cmd = get_test_cmd()?;
     cmd.arg("apply")
         .arg("https://storage.googleapis.com/grit-workflows-dev-workflow_definitions/test/hello.js")
+        .arg("--input")
+        .arg("{\"query\": \"John\"}")
         .current_dir(temp_fixtures_root);
 
     let output = cmd.output()?;
@@ -154,5 +156,34 @@ fn run_workflow_args() -> Result<()> {
     let stdout = String::from_utf8(output.stdout)?;
     assert!(stdout.contains("Running hello workflow"),);
 
+    assert!(stdout.contains("John as the query"));
+
+    Ok(())
+}
+
+#[test]
+fn run_workflow_arg_input() -> Result<()> {
+    let (_temp_dir, temp_fixtures_root) = get_fixture("grit_modules", true)?;
+
+    let mut cmd = get_test_cmd()?;
+    cmd.arg("apply")
+        .arg("https://storage.googleapis.com/grit-workflows-dev-workflow_definitions/test/hello.js")
+        .arg("--query=John")
+        .current_dir(temp_fixtures_root);
+
+    let output = cmd.output()?;
+    println!("stdout: {:?}", String::from_utf8(output.stdout.clone())?);
+    println!("stderr: {:?}", String::from_utf8(output.stderr.clone())?);
+
+    assert!(
+        output.status.success(),
+        "Command didn't finish successfully"
+    );
+
+    let stdout = String::from_utf8(output.stdout)?;
+    assert!(stdout.contains("Running hello workflow"),);
+
+    assert!(stdout.contains("John as the query"));
+
     Ok(())
 }