flowey: use typestate pattern for gh variables

flowey/flowey_cli/src/cli/debug/interrogate.rs

@@ -168,10 +168,10 @@ impl flowey_core::node::NodeCtxBackend for InterrogateCtx {
         _uses: &str,
         _with: BTreeMap<String, ClaimedGhParam>,
         _condvar: Option<String>,
-        _outputs: BTreeMap<String, Vec<(String, bool)>>,
+        _outputs: BTreeMap<String, Vec<(String, bool, bool)>>,
         _permissions: BTreeMap<GhPermission, GhPermissionValue>,
-        _gh_to_rust: Vec<(String, String, bool)>,
-        _rust_to_gh: Vec<(String, String, bool)>,
+        _gh_to_rust: Vec<(String, String, bool, bool)>,
+        _rust_to_gh: Vec<(String, String, bool, bool)>,
     ) {
         println!("[step][yaml]    # {}", label);
         self.idx_tracker += 1;

flowey/flowey_cli/src/cli/exec_snippet.rs

@@ -310,10 +310,10 @@ impl flowey_core::node::NodeCtxBackend for ExecSnippetCtx<'_, '_> {
         _uses: &str,
         _with: BTreeMap<String, ClaimedGhParam>,
         _condvar: Option<String>,
-        _outputs: BTreeMap<String, Vec<(String, bool)>>,
+        _outputs: BTreeMap<String, Vec<(String, bool, bool)>>,
         _permissions: BTreeMap<GhPermission, GhPermissionValue>,
-        _gh_to_rust: Vec<(String, String, bool)>,
-        _rust_to_gh: Vec<(String, String, bool)>,
+        _gh_to_rust: Vec<(String, String, bool, bool)>,
+        _rust_to_gh: Vec<(String, String, bool, bool)>,
     ) {
         self.idx_tracker += 1;
     }

flowey/flowey_cli/src/flow_resolver/stage1_dag.rs

@@ -599,8 +599,8 @@ pub(crate) enum Step {
         >,
     },
     GitHubYaml {
-        gh_to_rust: Vec<(String, String, bool)>,
-        rust_to_gh: Vec<(String, String, bool)>,
+        gh_to_rust: Vec<(String, String, bool, bool)>,
+        rust_to_gh: Vec<(String, String, bool, bool)>,
         label: String,
         step_id: String,
         uses: String,
@@ -779,10 +779,10 @@ impl flowey_core::node::NodeCtxBackend for EmitFlowCtx<'_> {
         uses: &str,
         with: BTreeMap<String, ClaimedGhParam>,
         condvar: Option<String>,
-        outputs: BTreeMap<String, Vec<(String, bool)>>,
+        outputs: BTreeMap<String, Vec<(String, bool, bool)>>,
         permissions: BTreeMap<GhPermission, GhPermissionValue>,
-        mut gh_to_rust: Vec<(String, String, bool)>,
-        mut rust_to_gh: Vec<(String, String, bool)>,
+        mut gh_to_rust: Vec<(String, String, bool, bool)>,
+        mut rust_to_gh: Vec<(String, String, bool, bool)>,
     ) {
         let mut fresh_yaml_var = || {
             *self.yaml_var_ordinal += 1;
@@ -803,10 +803,15 @@ impl flowey_core::node::NodeCtxBackend for EmitFlowCtx<'_> {
                 ClaimedGhParam::Static(v) => (k, v),
                 ClaimedGhParam::GhVar(v) => (k, format!("${{{{ {} }}}}", v.as_raw_var_name())),
                 ClaimedGhParam::FloweyVar(v) => {
-                    let (backing_var, is_secret) = read_var_internals(&v);
+                    let (backing_var, is_secret, is_object) = read_var_internals(&v);
                     let backing_var = backing_var.unwrap();
                     let new_gh_var_name = fresh_yaml_var();
-                    rust_to_gh.push((backing_var.clone(), new_gh_var_name.clone(), is_secret));
+                    rust_to_gh.push((
+                        backing_var.clone(),
+                        new_gh_var_name.clone(),
+                        is_secret,
+                        is_object,
+                    ));
                     (k, format!("${{{{ env.{} }}}}", new_gh_var_name))
                 }
             })
@@ -815,7 +820,7 @@ impl flowey_core::node::NodeCtxBackend for EmitFlowCtx<'_> {
         for (name, output_vars) in outputs {
             for output in output_vars {
                 let gh_context_var_name = format!("steps.{step_id}.outputs.{name}");
-                gh_to_rust.push((gh_context_var_name, output.0, output.1));
+                gh_to_rust.push((gh_context_var_name, output.0, output.1, output.2));
             }
         }
 

flowey/flowey_cli/src/pipeline_resolver/github_yaml/mod.rs

@@ -836,12 +836,12 @@ fn resolve_flow_as_github_yaml_steps(
                     output_steps.push(map.into());
                 }
 
-                for (rust_var, gh_var, is_secret) in rust_to_gh {
+                for (rust_var, gh_var, is_secret, is_object) in rust_to_gh {
                     let mut cmd = String::new();
 
                     // flowey considers all GitHub vars to be typed as raw strings
                     let set_gh_env_var =
-                        var_db_cmd(&rust_var, is_secret, None, true, Some(gh_var.clone()));
+                        var_db_cmd(&rust_var, is_secret, None, !is_object, Some(gh_var.clone()));
                     writeln!(cmd, r#"{set_gh_env_var}"#)?;
 
                     let mut map = serde_yaml::Mapping::new();
@@ -878,10 +878,15 @@ fn resolve_flow_as_github_yaml_steps(
                     output_steps.push(step);
                 }
 
-                for (gh_var, rust_var, is_secret) in gh_to_rust {
+                for (gh_var, rust_var, is_secret, is_object) in gh_to_rust {
                     // flowey considers all GitHub vars to be typed as raw strings
-                    let write_rust_var = var_db_cmd(&rust_var, is_secret, Some("{0}"), true, None);
-                    let cmd = format!(r#"${{{{ {gh_var} }}}}"#);
+                    let write_rust_var =
+                        var_db_cmd(&rust_var, is_secret, Some("{0}"), !is_object, None);
+                    let cmd = if is_object {
+                        format!(r#"${{{{ toJSON({gh_var}) }}}}"#)
+                    } else {
+                        format!(r#"${{{{ {gh_var} }}}}"#)
+                    };
 
                     let mut map = serde_yaml::Mapping::new();
                     map.insert("run".into(), serde_yaml::Value::String(cmd));