feat(hooks): deterministic pipeline enforcement via CSA:NEXT_STEP directives

Cargo.toml

@@ -3,7 +3,7 @@ members = ["crates/*"]
 resolver = "2"
 
 [workspace.package]
-version = "0.1.201"
+version = "0.1.202"
 edition = "2024"
 rust-version = "1.88"
 license = "Apache-2.0"

crates/cli-sub-agent/src/plan_cmd_steps.rs

@@ -8,6 +8,7 @@ use tracing::{error, info, warn};
 use csa_config::ProjectConfig;
 use csa_core::types::ToolName;
 use csa_executor::ModelSpec;
+use csa_hooks::format_next_step_directive;
 use weave::compiler::{ExecutionPlan, FailAction, PlanStep};
 
 use super::plan_cmd_exec::{
@@ -267,6 +268,21 @@ pub(super) async fn execute_plan_with_journal(
             persist_plan_journal(path, run_ctx.journal)?;
         }
 
+        // Emit CSA:NEXT_STEP directive for pipeline chaining.
+        // On success: point to the next step in the plan.
+        // On failure: no directive (pipeline stops on abort).
+        if !is_failure
+            && !result.skipped
+            && let Some(next_step) = find_next_step(step, &plan.steps)
+        {
+            let cmd = format!(
+                "csa plan run --step {} \"{}\"",
+                next_step.id, next_step.title
+            );
+            let required = matches!(next_step.on_fail, FailAction::Abort);
+            eprintln!("{}", format_next_step_directive(&cmd, required));
+        }
+
         // Abort on failure when: on_fail=abort, or retry exhausted (retries
         // already happened inside execute_step; reaching here means all failed),
         // or delegate (unsupported in v1 — treated as abort).
@@ -615,3 +631,11 @@ pub(crate) fn should_inject_assignment_markers(step: &PlanStep) -> bool {
 pub(crate) fn is_assignment_marker_key(key: &str) -> bool {
     validate_variable_name(key).is_ok()
 }
+
+/// Find the next step in the plan after the current step.
+///
+/// Returns the first step with an ID greater than the current step's ID,
+/// which is the sequential successor in a linear workflow.
+fn find_next_step<'a>(current: &PlanStep, steps: &'a [PlanStep]) -> Option<&'a PlanStep> {
+    steps.iter().find(|s| s.id > current.id)
+}

crates/cli-sub-agent/src/review_cmd.rs

@@ -21,6 +21,9 @@ use csa_core::consensus::AgentResponse;
 use csa_core::types::{OutputFormat, ToolName};
 use csa_session::state::ReviewSessionMeta;
 
+/// Next-step command emitted after a clean review verdict for pipeline chaining.
+const NEXT_STEP_PR_BOT_CMD: &str = "csa plan run patterns/dev2merge/workflow.toml --step pr-bot";
+
 #[path = "review_cmd_output.rs"]
 mod output;
 use output::{
@@ -374,6 +377,16 @@ pub(crate) async fn handle_review(args: ReviewArgs, current_depth: u32) -> Resul
                 ],
                 &project_root,
             );
+
+            // Emit CSA:NEXT_STEP directive for pipeline chaining.
+            // Orchestrators can parse this to mechanically chain review → pr-bot.
+            if verdict == CLEAN {
+                eprintln!(
+                    "{}",
+                    csa_hooks::format_next_step_directive(NEXT_STEP_PR_BOT_CMD, true,)
+                );
+            }
+
             return Ok(effective_exit_code);
         }
 
@@ -430,6 +443,14 @@ pub(crate) async fn handle_review(args: ReviewArgs, current_depth: u32) -> Resul
             &project_root,
         );
 
+        // Emit CSA:NEXT_STEP directive for pipeline chaining after fix loop.
+        if fix_passed {
+            eprintln!(
+                "{}",
+                csa_hooks::format_next_step_directive(NEXT_STEP_PR_BOT_CMD, true,)
+            );
+        }
+
         return fix_exit_code;
     }