Merge pull request #271 from egohygiene/copilot/implement-command-based-executor

feat: integrate command-based executor into build pipeline

Author: szmyty

src/commands/build.rs

@@ -16,6 +16,7 @@ use crate::optimization::OptimizationMode;
 use crate::pipeline::{Pipeline, StrategyStep};
 use crate::strategies::select_strategy;
 use crate::template::{init_tera, validate_templates};
+use crate::transforms::{load_transforms_from_yaml, FailureMode, TransformRegistry};
 
 /// Run the full build pipeline.
 ///
@@ -120,6 +121,20 @@ fn run_impl(config_path: &str, dry_run: bool, resilient: bool, optimization: Opt
     // gracefully.  Only write back to disk in non-dry-run mode.
     let mut transform_cache = load_cache(&cache_path);
 
+    // Load command-based transforms from the YAML file specified in config, if any.
+    // These are applied after the standard built-in pipeline (emoji, variables, syntax).
+    let command_registry: Option<TransformRegistry> = if let Some(ref path) = config.transforms {
+        info!(path = %path, "Loading command-based transforms");
+        let mode = if resilient { FailureMode::ContinueOnError } else { FailureMode::FailFast };
+        Some(
+            load_transforms_from_yaml(path)
+                .with_context(|| format!("Failed to load command-based transforms from '{}'", path))?
+                .with_failure_mode(mode),
+        )
+    } else {
+        None
+    };
+
     pb.set_message(if dry_run { "[DRY RUN] Applying transforms" } else { "Applying transforms" });
     let mut format_transformed: HashMap<String, String> = HashMap::new();
     for output in &config.outputs {
@@ -139,9 +154,18 @@ fn run_impl(config_path: &str, dry_run: bool, resilient: bool, optimization: Opt
             } else {
                 Pipeline::with_standard_transforms(&config.variables, format)
             };
-            pipeline
+            let standard_output = pipeline
                 .run_transforms(normalized_content.as_ref().to_owned())
-                .with_context(|| format!("Transform pipeline failed for format: {format_str}; aborting build"))?
+                .with_context(|| format!("Transform pipeline failed for format: {format_str}; aborting build"))?;
+            // Apply command-based transforms (e.g. ImageMagick, Pandoc) if configured.
+            if let Some(ref cmd_registry) = command_registry {
+                debug!(format = %format_str, "Applying command-based transforms");
+                cmd_registry
+                    .apply_all(standard_output)
+                    .with_context(|| format!("Command transform pipeline failed for format: {format_str}"))?
+            } else {
+                standard_output
+            }
         };
 
         if !dry_run {

src/config.rs

@@ -83,6 +83,14 @@ pub struct Config {
     /// Defaults to [`OptimizationMode::Balanced`] when omitted.
     #[serde(default)]
     pub optimization: OptimizationMode,
+    /// Optional path to a YAML file defining additional command-based transforms.
+    ///
+    /// When set, the named transforms are loaded and applied after the standard
+    /// built-in pipeline (emoji replacement, variable substitution, syntax
+    /// highlighting).  The file must conform to the schema expected by
+    /// [`crate::transforms::load_transforms_from_yaml`].
+    #[serde(default)]
+    pub transforms: Option<String>,
 }
 
 impl Config {
@@ -603,4 +611,31 @@ output_dir: "dist"
             "error should mention unsupported output: {msg}"
         );
     }
+
+    #[test]
+    fn test_load_config_with_transforms_path() {
+        let yaml = r#"
+outputs:
+  - type: html
+input: "input.md"
+output_dir: "dist"
+transforms: "transforms.yaml"
+"#;
+        let f = write_temp_yaml(yaml);
+        let config = load_config(f.path().to_str().unwrap()).expect("should parse with transforms");
+        assert_eq!(config.transforms.as_deref(), Some("transforms.yaml"));
+    }
+
+    #[test]
+    fn test_load_config_without_transforms_defaults_to_none() {
+        let yaml = r#"
+outputs:
+  - type: html
+input: "input.md"
+output_dir: "dist"
+"#;
+        let f = write_temp_yaml(yaml);
+        let config = load_config(f.path().to_str().unwrap()).expect("should parse without transforms");
+        assert!(config.transforms.is_none());
+    }
 }

src/transforms/mod.rs

@@ -6,10 +6,9 @@ mod transform;
 mod variable;
 pub mod yaml_loader;
 
-pub use command::CommandTransform;
 pub use emoji::EmojiTransform;
 pub use registry::{register_transforms, FailureMode, TransformRegistry};
 pub use syntax_highlight::SyntaxHighlightTransform;
 pub use transform::Transform;
 pub use variable::VariableSubstitutionTransform;
-pub use yaml_loader::{load_transforms_from_yaml, parse_transforms_from_str, YamlTransformConfig, YamlTransformDef};
+pub use yaml_loader::load_transforms_from_yaml;