sync.rs

use std::path::Path;

use anyhow::Result;

use crate::commands::init::{
    DevOverrides, copy_example_files, inject_dev_overrides, write_dev_variables_tf,
};
use crate::helpers::{ci_log_group, example_dir, project_root, read_tfvars};

/// Re-copies example .tf files into an existing test run directory,
/// overwriting the current versions. Useful for picking up local
/// changes to the terraform modules without re-initializing.
pub async fn phase_sync(dir: &Path) -> Result<()> {
    ci_log_group("Sync", || async {
        let tfvars = read_tfvars(dir)?;
        let provider = tfvars.cloud_provider();
        let common = tfvars.common();
        let src = example_dir(provider)?;
        let root = project_root()?;

        println!(
            "Syncing terraform files for test run: {}",
            dir.file_name().unwrap().to_string_lossy()
        );
        println!(
            "  Source: {}",
            src.strip_prefix(&root).unwrap_or(&src).display()
        );
        println!(
            "  Dest:   {}",
            dir.strip_prefix(&root).unwrap_or(dir).display()
        );

        println!("\nCopying terraform files...");
        copy_example_files(&src, dir, provider).await?;

        // Re-apply dev overrides that were set during init.
        let overrides = DevOverrides {
            local_chart: common.helm_chart.is_some() && common.use_local_chart == Some(true),
            orchestratord_version: common.orchestratord_version.is_some(),
            environmentd_version: common.environmentd_version.is_some(),
        };
        if overrides.any() {
            println!("\nRe-applying dev overrides...");
            write_dev_variables_tf(dir).await?;
            inject_dev_overrides(dir, &overrides).await?;
        }

        println!("\nSync completed successfully.");
        Ok(())
    })
    .await
}