sr_core/

release.rs

use std::fs;
use std::path::Path;

use semver::Version;
use serde::Serialize;

use crate::changelog::{ChangelogEntry, ChangelogFormatter};
use crate::commit::{CommitParser, ConventionalCommit, DefaultCommitClassifier};
use crate::config::ReleaseConfig;
use crate::error::ReleaseError;
use crate::git::GitRepository;
use crate::version::{BumpLevel, apply_bump, apply_prerelease_bump, determine_bump};
use crate::version_files::{bump_version_file, discover_lock_files, is_supported_version_file};

/// The computed plan for a release, before execution.
#[derive(Debug, Serialize)]
pub struct ReleasePlan {
    pub current_version: Option<Version>,
    pub next_version: Version,
    pub bump: BumpLevel,
    pub commits: Vec<ConventionalCommit>,
    pub tag_name: String,
    pub floating_tag_name: Option<String>,
    pub prerelease: bool,
}

/// Orchestrates the release flow.
pub trait ReleaseStrategy: Send + Sync {
    /// Plan the release without executing it.
    fn plan(&self) -> Result<ReleasePlan, ReleaseError>;

    /// Execute the release.
    fn execute(&self, plan: &ReleasePlan, dry_run: bool) -> Result<(), ReleaseError>;
}

/// Abstraction over a remote VCS provider (e.g. GitHub, GitLab).
pub trait VcsProvider: Send + Sync {
    /// Create a release on the remote VCS.
    fn create_release(
        &self,
        tag: &str,
        name: &str,
        body: &str,
        prerelease: bool,
        draft: bool,
    ) -> Result<String, ReleaseError>;

    /// Generate a compare URL between two refs.
    fn compare_url(&self, base: &str, head: &str) -> Result<String, ReleaseError>;

    /// Check if a release already exists for the given tag.
    fn release_exists(&self, tag: &str) -> Result<bool, ReleaseError>;

    /// Delete a release by tag.
    fn delete_release(&self, tag: &str) -> Result<(), ReleaseError>;

    /// Return the base URL of the repository (e.g. `https://github.com/owner/repo`).
    fn repo_url(&self) -> Option<String> {
        None
    }

    /// Update an existing release (name and body) using PATCH semantics,
    /// preserving any previously uploaded assets.
    fn update_release(
        &self,
        tag: &str,
        name: &str,
        body: &str,
        prerelease: bool,
        draft: bool,
    ) -> Result<String, ReleaseError> {
        self.delete_release(tag)?;
        self.create_release(tag, name, body, prerelease, draft)
    }

    /// Upload asset files to an existing release identified by tag.
    fn upload_assets(&self, _tag: &str, _files: &[&str]) -> Result<(), ReleaseError> {
        Ok(())
    }

    /// Verify that a release exists and is in the expected state after creation.
    fn verify_release(&self, _tag: &str) -> Result<(), ReleaseError> {
        Ok(())
    }
}

/// Concrete release strategy implementing the trunk-based release flow.
pub struct TrunkReleaseStrategy<G, V, C, F> {
    pub git: G,
    pub vcs: Option<V>,
    pub parser: C,
    pub formatter: F,
    pub config: ReleaseConfig,
    /// When true, re-release the current tag if HEAD is at the latest tag.
    pub force: bool,
}

impl<G, V, C, F> TrunkReleaseStrategy<G, V, C, F>
where
    G: GitRepository,
    V: VcsProvider,
    C: CommitParser,
    F: ChangelogFormatter,
{
    fn format_changelog(&self, plan: &ReleasePlan) -> Result<String, ReleaseError> {
        let today = today_string();
        let compare_url = self.vcs.as_ref().and_then(|vcs| {
            let base = match &plan.current_version {
                Some(v) => format!("{}{v}", self.config.tag_prefix),
                None => return None,
            };
            vcs.compare_url(&base, &plan.tag_name).ok()
        });
        let entry = ChangelogEntry {
            version: plan.next_version.to_string(),
            date: today,
            commits: plan.commits.clone(),
            compare_url,
            repo_url: self.vcs.as_ref().and_then(|v| v.repo_url()),
        };
        self.formatter.format(&[entry])
    }

    /// Render the release name from the configured template, or fall back to the tag name.
    fn release_name(&self, plan: &ReleasePlan) -> String {
        if let Some(ref template_str) = self.config.release_name_template {
            let mut env = minijinja::Environment::new();
            if env.add_template("release_name", template_str).is_ok()
                && let Ok(tmpl) = env.get_template("release_name")
                && let Ok(rendered) = tmpl.render(minijinja::context! {
                    version => plan.next_version.to_string(),
                    tag_name => &plan.tag_name,
                    tag_prefix => &self.config.tag_prefix,
                })
            {
                return rendered;
            }
            eprintln!("warning: invalid release_name_template, falling back to tag name");
        }
        plan.tag_name.clone()
    }
}

impl<G, V, C, F> ReleaseStrategy for TrunkReleaseStrategy<G, V, C, F>
where
    G: GitRepository,
    V: VcsProvider,
    C: CommitParser,
    F: ChangelogFormatter,
{
    fn plan(&self) -> Result<ReleasePlan, ReleaseError> {
        let is_prerelease = self.config.prerelease.is_some();

        // For stable releases, find the latest stable tag (skip pre-release tags).
        // For pre-releases, find the latest tag of any kind to determine commits since.
        let all_tags = self.git.all_tags(&self.config.tag_prefix)?;
        let latest_stable = all_tags.iter().rev().find(|t| t.version.pre.is_empty());
        let latest_any = all_tags.last();

        // Use the latest tag (any kind) for commit range, but the latest stable for base version
        let tag_info = if is_prerelease {
            latest_any
        } else {
            latest_stable.or(latest_any)
        };

        let (current_version, from_sha) = match tag_info {
            Some(info) => (Some(info.version.clone()), Some(info.sha.as_str())),
            None => (None, None),
        };

        let raw_commits = if let Some(ref path) = self.config.path_filter {
            self.git.commits_since_in_path(from_sha, path)?
        } else {
            self.git.commits_since(from_sha)?
        };
        if raw_commits.is_empty() {
            // Force mode: re-release if HEAD is exactly at the latest tag
            if self.force
                && let Some(info) = tag_info
            {
                let head = self.git.head_sha()?;
                if head == info.sha {
                    let floating_tag_name = if self.config.floating_tags {
                        Some(format!("{}{}", self.config.tag_prefix, info.version.major))
                    } else {
                        None
                    };
                    return Ok(ReleasePlan {
                        current_version: Some(info.version.clone()),
                        next_version: info.version.clone(),
                        bump: BumpLevel::Patch,
                        commits: vec![],
                        tag_name: info.name.clone(),
                        floating_tag_name,
                        prerelease: is_prerelease,
                    });
                }
            }
            let (tag, sha) = match tag_info {
                Some(info) => (info.name.clone(), info.sha.clone()),
                None => ("(none)".into(), "(none)".into()),
            };
            return Err(ReleaseError::NoCommits { tag, sha });
        }

        let conventional_commits: Vec<ConventionalCommit> = raw_commits
            .iter()
            .filter(|c| !c.message.starts_with("chore(release):"))
            .filter_map(|c| self.parser.parse(c).ok())
            .collect();

        let classifier = DefaultCommitClassifier::new(
            self.config.types.clone(),
            self.config.commit_pattern.clone(),
        );
        let tag_for_err = tag_info
            .map(|i| i.name.clone())
            .unwrap_or_else(|| "(none)".into());
        let commit_count = conventional_commits.len();
        let bump = match determine_bump(&conventional_commits, &classifier) {
            Some(b) => b,
            None if self.force => BumpLevel::Patch,
            None => {
                return Err(ReleaseError::NoBump {
                    tag: tag_for_err,
                    commit_count,
                });
            }
        };

        // For pre-releases, base the version on the latest *stable* tag
        let base_version = if is_prerelease {
            latest_stable
                .map(|t| t.version.clone())
                .or(current_version.clone())
                .unwrap_or(Version::new(0, 0, 0))
        } else {
            current_version.clone().unwrap_or(Version::new(0, 0, 0))
        };

        // v0 protection: downshift Major → Minor when version is 0.x.y
        // to prevent accidentally leaving v0. Use --force to bump to v1.
        let bump = if base_version.major == 0 && bump == BumpLevel::Major && !self.force {
            eprintln!(
                "v0 protection: breaking change detected at v{base_version}, \
                 downshifting major → minor (use --force to bump to v1)"
            );
            BumpLevel::Minor
        } else {
            bump
        };

        let next_version = if let Some(ref prerelease_id) = self.config.prerelease {
            let existing_versions: Vec<Version> =
                all_tags.iter().map(|t| t.version.clone()).collect();
            apply_prerelease_bump(&base_version, bump, prerelease_id, &existing_versions)
        } else {
            apply_bump(&base_version, bump)
        };

        let tag_name = format!("{}{next_version}", self.config.tag_prefix);

        // Don't update floating tags for pre-releases
        let floating_tag_name = if self.config.floating_tags && !is_prerelease {
            Some(format!("{}{}", self.config.tag_prefix, next_version.major))
        } else {
            None
        };

        Ok(ReleasePlan {
            current_version,
            next_version,
            bump,
            commits: conventional_commits,
            tag_name,
            floating_tag_name,
            prerelease: is_prerelease,
        })
    }

    fn execute(&self, plan: &ReleasePlan, dry_run: bool) -> Result<(), ReleaseError> {
        let version_str = plan.next_version.to_string();

        if dry_run {
            let changelog_body = self.format_changelog(plan)?;
            if let Some(ref cmd) = self.config.pre_release_command {
                eprintln!("[dry-run] Would run pre-release command: {cmd}");
            }
            let sign_label = if self.config.sign_tags {
                " (signed)"
            } else {
                ""
            };
            eprintln!("[dry-run] Would create tag: {}{sign_label}", plan.tag_name);
            eprintln!("[dry-run] Would push tag: {}", plan.tag_name);
            if let Some(ref floating) = plan.floating_tag_name {
                eprintln!("[dry-run] Would create/update floating tag: {floating}");
                eprintln!("[dry-run] Would force-push floating tag: {floating}");
            }
            if self.vcs.is_some() {
                let draft_label = if self.config.draft { " (draft)" } else { "" };
                let release_name = self.release_name(plan);
                eprintln!(
                    "[dry-run] Would create GitHub release \"{release_name}\" for {}{draft_label}",
                    plan.tag_name
                );
            }
            for file in &self.config.version_files {
                let filename = Path::new(file)
                    .file_name()
                    .and_then(|n| n.to_str())
                    .unwrap_or_default();
                if is_supported_version_file(filename) {
                    eprintln!("[dry-run] Would bump version in: {file}");
                } else if self.config.version_files_strict {
                    return Err(ReleaseError::VersionBump(format!(
                        "unsupported version file: {filename}"
                    )));
                } else {
                    eprintln!("[dry-run] warning: unsupported version file, would skip: {file}");
                }
            }
            if !self.config.artifacts.is_empty() {
                let resolved = resolve_artifact_globs(&self.config.artifacts)?;
                if resolved.is_empty() {
                    eprintln!("[dry-run] Artifact patterns matched no files");
                } else {
                    eprintln!("[dry-run] Would upload {} artifact(s):", resolved.len());
                    for f in &resolved {
                        eprintln!("[dry-run]   {f}");
                    }
                }
            }
            if let Some(ref cmd) = self.config.build_command {
                eprintln!("[dry-run] Would run build command: {cmd}");
            }
            if !self.config.stage_files.is_empty() {
                eprintln!(
                    "[dry-run] Would stage additional files: {}",
                    self.config.stage_files.join(", ")
                );
            }
            if let Some(ref cmd) = self.config.post_release_command {
                eprintln!("[dry-run] Would run post-release command: {cmd}");
            }
            eprintln!("[dry-run] Changelog:\n{changelog_body}");
            return Ok(());
        }

        // 0. Run pre-release command if configured
        if let Some(ref cmd) = self.config.pre_release_command {
            eprintln!("Running pre-release command: {cmd}");
            run_lifecycle_hook(cmd, &version_str, &plan.tag_name, "pre_release_command")?;
        }

        // 1. Format changelog
        let changelog_body = self.format_changelog(plan)?;

        // 2. Snapshot files before mutation (for rollback on failure)
        let mut file_snapshots: Vec<(String, Option<String>)> = Vec::new();
        for file in &self.config.version_files {
            let path = Path::new(file);
            let contents = if path.exists() {
                Some(
                    fs::read_to_string(path)
                        .map_err(|e| ReleaseError::VersionBump(e.to_string()))?,
                )
            } else {
                None
            };
            file_snapshots.push((file.clone(), contents));
        }
        if let Some(ref changelog_file) = self.config.changelog.file {
            let path = Path::new(changelog_file);
            let contents = if path.exists() {
                Some(fs::read_to_string(path).map_err(|e| ReleaseError::Changelog(e.to_string()))?)
            } else {
                None
            };
            file_snapshots.push((changelog_file.clone(), contents));
        }

        // Run the mutable pre-commit steps with rollback on failure
        let bumped_files = match self.execute_pre_commit(plan, &version_str, &changelog_body) {
            Ok(files) => files,
            Err(e) => {
                eprintln!("error during pre-commit steps, restoring files...");
                restore_snapshots(&file_snapshots);
                return Err(e);
            }
        };

        // 4. Resolve stage_files globs and collect all paths to stage
        {
            let mut paths_to_stage: Vec<String> = Vec::new();
            if let Some(ref changelog_file) = self.config.changelog.file {
                paths_to_stage.push(changelog_file.clone());
            }
            for file in &bumped_files {
                paths_to_stage.push(file.clone());
            }
            if !self.config.stage_files.is_empty() {
                let extra = resolve_glob_patterns(&self.config.stage_files)?;
                paths_to_stage.extend(extra);
            }
            if !paths_to_stage.is_empty() {
                let refs: Vec<&str> = paths_to_stage.iter().map(|s| s.as_str()).collect();
                let commit_msg = format!("chore(release): {} [skip ci]", plan.tag_name);
                self.git.stage_and_commit(&refs, &commit_msg)?;
            }
        }

        // 5. Create tag (skip if it already exists locally)
        if !self.git.tag_exists(&plan.tag_name)? {
            let tag_message = format!("{}\n\n{}", plan.tag_name, changelog_body);
            self.git
                .create_tag(&plan.tag_name, &tag_message, self.config.sign_tags)?;
        }

        // 6. Push commit (safe to re-run — no-op if up to date)
        self.git.push()?;

        // 7. Push tag (skip if tag already exists on remote)
        if !self.git.remote_tag_exists(&plan.tag_name)? {
            self.git.push_tag(&plan.tag_name)?;
        }

        // 8. Force-create and force-push floating tag (e.g. v3)
        if let Some(ref floating) = plan.floating_tag_name {
            self.git.force_create_tag(floating)?;
            self.git.force_push_tag(floating)?;
        }

        // 9. Create or update GitHub release
        let release_name = self.release_name(plan);
        if let Some(ref vcs) = self.vcs {
            if vcs.release_exists(&plan.tag_name)? {
                // PATCH update preserves existing assets
                vcs.update_release(
                    &plan.tag_name,
                    &release_name,
                    &changelog_body,
                    plan.prerelease,
                    self.config.draft,
                )?;
            } else {
                vcs.create_release(
                    &plan.tag_name,
                    &release_name,
                    &changelog_body,
                    plan.prerelease,
                    self.config.draft,
                )?;
            }
        }

        // 10. Upload artifacts (with SHA256 checksums)
        if let Some(ref vcs) = self.vcs
            && !self.config.artifacts.is_empty()
        {
            let resolved = resolve_artifact_globs(&self.config.artifacts)?;
            if !resolved.is_empty() {
                // Generate SHA256 checksum sidecar files
                let checksum_files = generate_checksums(&resolved)?;
                let mut all_files = resolved.clone();
                all_files.extend(checksum_files.iter().cloned());

                let file_refs: Vec<&str> = all_files.iter().map(|s| s.as_str()).collect();
                vcs.upload_assets(&plan.tag_name, &file_refs)?;
                eprintln!(
                    "Uploaded {} artifact(s) + {} checksum(s) to {}",
                    resolved.len(),
                    checksum_files.len(),
                    plan.tag_name
                );

                // Clean up generated checksum files
                for f in &checksum_files {
                    let _ = fs::remove_file(f);
                }
            }
        }

        // 11. Verify release was created/updated successfully
        if let Some(ref vcs) = self.vcs
            && let Err(e) = vcs.verify_release(&plan.tag_name)
        {
            eprintln!("warning: post-release verification failed: {e}");
            eprintln!(
                "  The tag {} was pushed but the GitHub release may be incomplete.",
                plan.tag_name
            );
            eprintln!("  Re-run with --force to retry.");
        }

        // 12. Run post-release command if configured
        if let Some(ref cmd) = self.config.post_release_command {
            eprintln!("Running post-release command: {cmd}");
            run_lifecycle_hook(cmd, &version_str, &plan.tag_name, "post_release_command")?;
        }

        eprintln!("Released {}", plan.tag_name);
        Ok(())
    }
}

impl<G, V, C, F> TrunkReleaseStrategy<G, V, C, F>
where
    G: GitRepository,
    V: VcsProvider,
    C: CommitParser,
    F: ChangelogFormatter,
{
    /// Execute the mutable pre-commit steps: bump version files, write changelog, run build command.
    /// Returns the list of bumped files on success. On error the caller restores snapshots.
    fn execute_pre_commit(
        &self,
        plan: &ReleasePlan,
        version_str: &str,
        changelog_body: &str,
    ) -> Result<Vec<String>, ReleaseError> {
        // 2. Bump version files
        let mut bumped_files: Vec<String> = Vec::new();
        for file in &self.config.version_files {
            match bump_version_file(Path::new(file), version_str) {
                Ok(extra) => {
                    bumped_files.push(file.clone());
                    for extra_path in extra {
                        bumped_files.push(extra_path.to_string_lossy().into_owned());
                    }
                }
                Err(e) if !self.config.version_files_strict => {
                    eprintln!("warning: {e} — skipping {file}");
                }
                Err(e) => return Err(e),
            }
        }

        // 2.5. Auto-discover and stage lock files associated with bumped manifests
        for lock_file in discover_lock_files(&bumped_files) {
            let lock_str = lock_file.to_string_lossy().into_owned();
            if !bumped_files.contains(&lock_str) {
                bumped_files.push(lock_str);
            }
        }

        // 3. Write changelog file if configured
        if let Some(ref changelog_file) = self.config.changelog.file {
            let path = Path::new(changelog_file);
            let existing = if path.exists() {
                fs::read_to_string(path).map_err(|e| ReleaseError::Changelog(e.to_string()))?
            } else {
                String::new()
            };
            let new_content = if existing.is_empty() {
                format!("# Changelog\n\n{changelog_body}\n")
            } else {
                match existing.find("\n\n") {
                    Some(pos) => {
                        let (header, rest) = existing.split_at(pos);
                        format!("{header}\n\n{changelog_body}\n{rest}")
                    }
                    None => format!("{existing}\n\n{changelog_body}\n"),
                }
            };
            fs::write(path, new_content).map_err(|e| ReleaseError::Changelog(e.to_string()))?;
        }

        // 3.5. Run build command if configured
        if let Some(ref cmd) = self.config.build_command {
            eprintln!("Running build command: {cmd}");
            run_lifecycle_hook(cmd, version_str, &plan.tag_name, "build_command")?;
        }

        Ok(bumped_files)
    }
}

/// Restore file contents from snapshots (best-effort, used during rollback).
fn restore_snapshots(snapshots: &[(String, Option<String>)]) {
    for (file, contents) in snapshots {
        let path = Path::new(file);
        match contents {
            Some(data) => {
                if let Err(e) = fs::write(path, data) {
                    eprintln!("warning: failed to restore {file}: {e}");
                }
            }
            None => {
                // File didn't exist before — remove it
                if path.exists()
                    && let Err(e) = fs::remove_file(path)
                {
                    eprintln!("warning: failed to remove {file}: {e}");
                }
            }
        }
    }
}

/// Run a release lifecycle command with SR_VERSION and SR_TAG env vars.
fn run_lifecycle_hook(
    cmd: &str,
    version: &str,
    tag: &str,
    label: &str,
) -> Result<(), ReleaseError> {
    crate::hooks::run_shell(cmd, None, &[("SR_VERSION", version), ("SR_TAG", tag)])
        .map_err(|e| ReleaseError::BuildCommand(format!("{label}: {e}")))
}

/// Resolve glob patterns into a list of file paths.
fn resolve_glob_patterns(patterns: &[String]) -> Result<Vec<String>, ReleaseError> {
    let mut files = Vec::new();
    for pattern in patterns {
        let paths = glob::glob(pattern)
            .map_err(|e| ReleaseError::Config(format!("invalid glob pattern '{pattern}': {e}")))?;
        for entry in paths {
            match entry {
                Ok(path) if path.is_file() => {
                    files.push(path.to_string_lossy().into_owned());
                }
                Ok(_) => {}
                Err(e) => {
                    eprintln!("warning: glob error: {e}");
                }
            }
        }
    }
    Ok(files)
}

fn resolve_artifact_globs(patterns: &[String]) -> Result<Vec<String>, ReleaseError> {
    let mut files = std::collections::BTreeSet::new();
    for pattern in patterns {
        let paths = glob::glob(pattern)
            .map_err(|e| ReleaseError::Vcs(format!("invalid glob pattern '{pattern}': {e}")))?;
        for entry in paths {
            match entry {
                Ok(path) if path.is_file() => {
                    files.insert(path.to_string_lossy().into_owned());
                }
                Ok(_) => {} // skip directories
                Err(e) => {
                    eprintln!("warning: glob error: {e}");
                }
            }
        }
    }
    Ok(files.into_iter().collect())
}

/// Generate SHA256 checksum sidecar files for a list of artifact paths.
/// Returns the paths to the generated `.sha256` files.
fn generate_checksums(files: &[String]) -> Result<Vec<String>, ReleaseError> {
    use sha2::{Digest, Sha256};

    let mut checksum_paths = Vec::new();
    for file_path in files {
        let data = fs::read(file_path).map_err(|e| {
            ReleaseError::Vcs(format!("failed to read {file_path} for checksum: {e}"))
        })?;
        let hash = Sha256::digest(&data);
        let hex = format!("{hash:x}");
        let file_name = Path::new(file_path)
            .file_name()
            .and_then(|n| n.to_str())
            .unwrap_or("unknown");
        let checksum_content = format!("{hex}  {file_name}\n");
        let checksum_path = format!("{file_path}.sha256");
        fs::write(&checksum_path, checksum_content)
            .map_err(|e| ReleaseError::Vcs(format!("failed to write checksum file: {e}")))?;
        checksum_paths.push(checksum_path);
    }
    Ok(checksum_paths)
}

pub fn today_string() -> String {
    // Portable date calculation from UNIX epoch (no external deps or subprocess).
    // Uses Howard Hinnant's civil_from_days algorithm.
    let secs = std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .unwrap_or_default()
        .as_secs() as i64;

    let z = secs / 86400 + 719468;
    let era = (if z >= 0 { z } else { z - 146096 }) / 146097;
    let doe = (z - era * 146097) as u32;
    let yoe = (doe - doe / 1460 + doe / 36524 - doe / 146096) / 365;
    let y = yoe as i64 + era * 400;
    let doy = doe - (365 * yoe + yoe / 4 - yoe / 100);
    let mp = (5 * doy + 2) / 153;
    let d = doy - (153 * mp + 2) / 5 + 1;
    let m = if mp < 10 { mp + 3 } else { mp - 9 };
    let y = if m <= 2 { y + 1 } else { y };

    format!("{y:04}-{m:02}-{d:02}")
}

#[cfg(test)]
mod tests {
    use std::sync::Mutex;

    use super::*;
    use crate::changelog::DefaultChangelogFormatter;
    use crate::commit::{Commit, DefaultCommitParser};
    use crate::config::ReleaseConfig;
    use crate::git::{GitRepository, TagInfo};

    // --- Fakes ---

    struct FakeGit {
        tags: Vec<TagInfo>,
        commits: Vec<Commit>,
        /// Commits returned when path filtering is active (None = fall back to `commits`).
        path_commits: Option<Vec<Commit>>,
        head: String,
        created_tags: Mutex<Vec<String>>,
        pushed_tags: Mutex<Vec<String>>,
        committed: Mutex<Vec<(Vec<String>, String)>>,
        push_count: Mutex<u32>,
        force_created_tags: Mutex<Vec<String>>,
        force_pushed_tags: Mutex<Vec<String>>,
    }

    impl FakeGit {
        fn new(tags: Vec<TagInfo>, commits: Vec<Commit>) -> Self {
            let head = tags
                .last()
                .map(|t| t.sha.clone())
                .unwrap_or_else(|| "0".repeat(40));
            Self {
                tags,
                commits,
                path_commits: None,
                head,
                created_tags: Mutex::new(Vec::new()),
                pushed_tags: Mutex::new(Vec::new()),
                committed: Mutex::new(Vec::new()),
                push_count: Mutex::new(0),
                force_created_tags: Mutex::new(Vec::new()),
                force_pushed_tags: Mutex::new(Vec::new()),
            }
        }
    }

    impl GitRepository for FakeGit {
        fn latest_tag(&self, _prefix: &str) -> Result<Option<TagInfo>, ReleaseError> {
            Ok(self.tags.last().cloned())
        }

        fn commits_since(&self, _from: Option<&str>) -> Result<Vec<Commit>, ReleaseError> {
            Ok(self.commits.clone())
        }

        fn create_tag(&self, name: &str, _message: &str, _sign: bool) -> Result<(), ReleaseError> {
            self.created_tags.lock().unwrap().push(name.to_string());
            Ok(())
        }

        fn push_tag(&self, name: &str) -> Result<(), ReleaseError> {
            self.pushed_tags.lock().unwrap().push(name.to_string());
            Ok(())
        }

        fn stage_and_commit(&self, paths: &[&str], message: &str) -> Result<bool, ReleaseError> {
            self.committed.lock().unwrap().push((
                paths.iter().map(|s| s.to_string()).collect(),
                message.to_string(),
            ));
            Ok(true)
        }

        fn push(&self) -> Result<(), ReleaseError> {
            *self.push_count.lock().unwrap() += 1;
            Ok(())
        }

        fn tag_exists(&self, name: &str) -> Result<bool, ReleaseError> {
            Ok(self
                .created_tags
                .lock()
                .unwrap()
                .contains(&name.to_string()))
        }

        fn remote_tag_exists(&self, name: &str) -> Result<bool, ReleaseError> {
            Ok(self.pushed_tags.lock().unwrap().contains(&name.to_string()))
        }

        fn all_tags(&self, _prefix: &str) -> Result<Vec<TagInfo>, ReleaseError> {
            Ok(self.tags.clone())
        }

        fn commits_between(
            &self,
            _from: Option<&str>,
            _to: &str,
        ) -> Result<Vec<Commit>, ReleaseError> {
            Ok(self.commits.clone())
        }

        fn tag_date(&self, _tag_name: &str) -> Result<String, ReleaseError> {
            Ok("2026-01-01".into())
        }

        fn force_create_tag(&self, name: &str) -> Result<(), ReleaseError> {
            self.force_created_tags
                .lock()
                .unwrap()
                .push(name.to_string());
            Ok(())
        }

        fn force_push_tag(&self, name: &str) -> Result<(), ReleaseError> {
            self.force_pushed_tags
                .lock()
                .unwrap()
                .push(name.to_string());
            Ok(())
        }

        fn head_sha(&self) -> Result<String, ReleaseError> {
            Ok(self.head.clone())
        }

        fn commits_since_in_path(
            &self,
            _from: Option<&str>,
            _path: &str,
        ) -> Result<Vec<Commit>, ReleaseError> {
            Ok(self
                .path_commits
                .clone()
                .unwrap_or_else(|| self.commits.clone()))
        }
    }

    struct FakeVcs {
        releases: Mutex<Vec<(String, String)>>,
        deleted_releases: Mutex<Vec<String>>,
        uploaded_assets: Mutex<Vec<(String, Vec<String>)>>,
    }

    impl FakeVcs {
        fn new() -> Self {
            Self {
                releases: Mutex::new(Vec::new()),
                deleted_releases: Mutex::new(Vec::new()),
                uploaded_assets: Mutex::new(Vec::new()),
            }
        }
    }

    impl VcsProvider for FakeVcs {
        fn create_release(
            &self,
            tag: &str,
            _name: &str,
            body: &str,
            _prerelease: bool,
            _draft: bool,
        ) -> Result<String, ReleaseError> {
            self.releases
                .lock()
                .unwrap()
                .push((tag.to_string(), body.to_string()));
            Ok(format!("https://github.com/test/release/{tag}"))
        }

        fn compare_url(&self, base: &str, head: &str) -> Result<String, ReleaseError> {
            Ok(format!("https://github.com/test/compare/{base}...{head}"))
        }

        fn release_exists(&self, tag: &str) -> Result<bool, ReleaseError> {
            Ok(self.releases.lock().unwrap().iter().any(|(t, _)| t == tag))
        }

        fn delete_release(&self, tag: &str) -> Result<(), ReleaseError> {
            self.deleted_releases.lock().unwrap().push(tag.to_string());
            self.releases.lock().unwrap().retain(|(t, _)| t != tag);
            Ok(())
        }

        fn upload_assets(&self, tag: &str, files: &[&str]) -> Result<(), ReleaseError> {
            self.uploaded_assets.lock().unwrap().push((
                tag.to_string(),
                files.iter().map(|s| s.to_string()).collect(),
            ));
            Ok(())
        }

        fn repo_url(&self) -> Option<String> {
            Some("https://github.com/test/repo".into())
        }
    }

    // --- Helpers ---

    fn raw_commit(msg: &str) -> Commit {
        Commit {
            sha: "a".repeat(40),
            message: msg.into(),
        }
    }

    fn make_strategy(
        tags: Vec<TagInfo>,
        commits: Vec<Commit>,
        config: ReleaseConfig,
    ) -> TrunkReleaseStrategy<FakeGit, FakeVcs, DefaultCommitParser, DefaultChangelogFormatter>
    {
        let types = config.types.clone();
        let breaking_section = config.breaking_section.clone();
        let misc_section = config.misc_section.clone();
        TrunkReleaseStrategy {
            git: FakeGit::new(tags, commits),
            vcs: Some(FakeVcs::new()),
            parser: DefaultCommitParser,
            formatter: DefaultChangelogFormatter::new(None, types, breaking_section, misc_section),
            config,
            force: false,
        }
    }

    // --- plan() tests ---

    #[test]
    fn plan_no_commits_returns_error() {
        let s = make_strategy(vec![], vec![], ReleaseConfig::default());
        let err = s.plan().unwrap_err();
        assert!(matches!(err, ReleaseError::NoCommits { .. }));
    }

    #[test]
    fn plan_no_releasable_returns_error() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("chore: tidy up")],
            ReleaseConfig::default(),
        );
        let err = s.plan().unwrap_err();
        assert!(matches!(err, ReleaseError::NoBump { .. }));
    }

    #[test]
    fn force_releases_patch_when_no_releasable_commits() {
        let tag = TagInfo {
            name: "v1.2.3".into(),
            version: Version::new(1, 2, 3),
            sha: "d".repeat(40),
        };
        let mut s = make_strategy(
            vec![tag],
            vec![raw_commit("chore: rename package")],
            ReleaseConfig::default(),
        );
        s.force = true;
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version, Version::new(1, 2, 4));
        assert_eq!(plan.bump, BumpLevel::Patch);
    }

    #[test]
    fn plan_first_release() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: initial feature")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version, Version::new(0, 1, 0));
        assert_eq!(plan.tag_name, "v0.1.0");
        assert!(plan.current_version.is_none());
    }

    #[test]
    fn plan_increments_existing() {
        let tag = TagInfo {
            name: "v1.2.3".into(),
            version: Version::new(1, 2, 3),
            sha: "b".repeat(40),
        };
        let s = make_strategy(
            vec![tag],
            vec![raw_commit("fix: patch bug")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version, Version::new(1, 2, 4));
    }

    #[test]
    fn plan_breaking_bump() {
        let tag = TagInfo {
            name: "v1.2.3".into(),
            version: Version::new(1, 2, 3),
            sha: "c".repeat(40),
        };
        let s = make_strategy(
            vec![tag],
            vec![raw_commit("feat!: breaking change")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version, Version::new(2, 0, 0));
    }

    #[test]
    fn plan_v0_breaking_downshifts_to_minor() {
        let tag = TagInfo {
            name: "v0.5.0".into(),
            version: Version::new(0, 5, 0),
            sha: "c".repeat(40),
        };
        let s = make_strategy(
            vec![tag],
            vec![raw_commit("feat!: breaking change")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        // v0 protection: Major → Minor, so 0.5.0 → 0.6.0 (not 1.0.0)
        assert_eq!(plan.next_version, Version::new(0, 6, 0));
        assert_eq!(plan.bump, BumpLevel::Minor);
    }

    #[test]
    fn plan_v0_breaking_with_force_bumps_major() {
        let tag = TagInfo {
            name: "v0.5.0".into(),
            version: Version::new(0, 5, 0),
            sha: "c".repeat(40),
        };
        let mut s = make_strategy(
            vec![tag],
            vec![raw_commit("feat!: breaking change")],
            ReleaseConfig::default(),
        );
        s.force = true;
        let plan = s.plan().unwrap();
        // --force bypasses v0 protection
        assert_eq!(plan.next_version, Version::new(1, 0, 0));
        assert_eq!(plan.bump, BumpLevel::Major);
    }

    #[test]
    fn plan_v0_feat_stays_minor() {
        let tag = TagInfo {
            name: "v0.5.0".into(),
            version: Version::new(0, 5, 0),
            sha: "c".repeat(40),
        };
        let s = make_strategy(
            vec![tag],
            vec![raw_commit("feat: new feature")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        // Non-breaking feat in v0 stays as minor bump
        assert_eq!(plan.next_version, Version::new(0, 6, 0));
        assert_eq!(plan.bump, BumpLevel::Minor);
    }

    #[test]
    fn plan_v0_fix_stays_patch() {
        let tag = TagInfo {
            name: "v0.5.0".into(),
            version: Version::new(0, 5, 0),
            sha: "c".repeat(40),
        };
        let s = make_strategy(
            vec![tag],
            vec![raw_commit("fix: bug fix")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        // Fix in v0 stays as patch
        assert_eq!(plan.next_version, Version::new(0, 5, 1));
        assert_eq!(plan.bump, BumpLevel::Patch);
    }

    // --- execute() tests ---

    #[test]
    fn execute_dry_run_no_side_effects() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        s.execute(&plan, true).unwrap();

        assert!(s.git.created_tags.lock().unwrap().is_empty());
        assert!(s.git.pushed_tags.lock().unwrap().is_empty());
    }

    #[test]
    fn execute_creates_and_pushes_tag() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        assert_eq!(*s.git.created_tags.lock().unwrap(), vec!["v0.1.0"]);
        assert_eq!(*s.git.pushed_tags.lock().unwrap(), vec!["v0.1.0"]);
    }

    #[test]
    fn execute_calls_vcs_create_release() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        let releases = s.vcs.as_ref().unwrap().releases.lock().unwrap();
        assert_eq!(releases.len(), 1);
        assert_eq!(releases[0].0, "v0.1.0");
        assert!(!releases[0].1.is_empty());
    }

    #[test]
    fn execute_commits_changelog_before_tag() {
        let dir = tempfile::tempdir().unwrap();
        let changelog_path = dir.path().join("CHANGELOG.md");

        let config = ReleaseConfig {
            changelog: crate::config::ChangelogConfig {
                file: Some(changelog_path.to_str().unwrap().to_string()),
                ..Default::default()
            },
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        // Verify changelog was committed
        let committed = s.git.committed.lock().unwrap();
        assert_eq!(committed.len(), 1);
        assert_eq!(
            committed[0].0,
            vec![changelog_path.to_str().unwrap().to_string()]
        );
        assert!(committed[0].1.contains("chore(release): v0.1.0"));

        // Verify tag was created after commit
        assert_eq!(*s.git.created_tags.lock().unwrap(), vec!["v0.1.0"]);
    }

    #[test]
    fn execute_skips_existing_tag() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();

        // Pre-populate the tag to simulate it already existing
        s.git
            .created_tags
            .lock()
            .unwrap()
            .push("v0.1.0".to_string());

        s.execute(&plan, false).unwrap();

        // Tag should not be created again (still only the one we pre-populated)
        assert_eq!(s.git.created_tags.lock().unwrap().len(), 1);
    }

    #[test]
    fn execute_skips_existing_release() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();

        // Pre-populate a release to simulate it already existing
        s.vcs
            .as_ref()
            .unwrap()
            .releases
            .lock()
            .unwrap()
            .push(("v0.1.0".to_string(), "old notes".to_string()));

        s.execute(&plan, false).unwrap();

        // Should have deleted the old release and created a new one
        let deleted = s.vcs.as_ref().unwrap().deleted_releases.lock().unwrap();
        assert_eq!(*deleted, vec!["v0.1.0"]);

        let releases = s.vcs.as_ref().unwrap().releases.lock().unwrap();
        assert_eq!(releases.len(), 1);
        assert_eq!(releases[0].0, "v0.1.0");
        assert_ne!(releases[0].1, "old notes");
    }

    #[test]
    fn execute_idempotent_rerun() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();

        // First run
        s.execute(&plan, false).unwrap();

        // Second run should also succeed (idempotent)
        s.execute(&plan, false).unwrap();

        // Tag should only have been created once (second run skips because tag_exists)
        assert_eq!(s.git.created_tags.lock().unwrap().len(), 1);

        // Tag push should only happen once (second run skips because remote_tag_exists)
        assert_eq!(s.git.pushed_tags.lock().unwrap().len(), 1);

        // Push (commit) should happen twice (always safe)
        assert_eq!(*s.git.push_count.lock().unwrap(), 2);

        // Release should be deleted and recreated on second run
        let deleted = s.vcs.as_ref().unwrap().deleted_releases.lock().unwrap();
        assert_eq!(*deleted, vec!["v0.1.0"]);

        let releases = s.vcs.as_ref().unwrap().releases.lock().unwrap();
        // One entry: delete removed the first, create added a replacement
        assert_eq!(releases.len(), 1);
        assert_eq!(releases[0].0, "v0.1.0");
    }

    #[test]
    fn execute_bumps_version_files() {
        let dir = tempfile::tempdir().unwrap();
        let cargo_path = dir.path().join("Cargo.toml");
        std::fs::write(
            &cargo_path,
            "[package]\nname = \"test\"\nversion = \"0.0.0\"\n",
        )
        .unwrap();

        let config = ReleaseConfig {
            version_files: vec![cargo_path.to_str().unwrap().to_string()],
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        // Verify the file was bumped
        let contents = std::fs::read_to_string(&cargo_path).unwrap();
        assert!(contents.contains("version = \"0.1.0\""));

        // Verify it was staged alongside the commit
        let committed = s.git.committed.lock().unwrap();
        assert_eq!(committed.len(), 1);
        assert!(
            committed[0]
                .0
                .contains(&cargo_path.to_str().unwrap().to_string())
        );
    }

    #[test]
    fn execute_stages_changelog_and_version_files_together() {
        let dir = tempfile::tempdir().unwrap();
        let cargo_path = dir.path().join("Cargo.toml");
        std::fs::write(
            &cargo_path,
            "[package]\nname = \"test\"\nversion = \"0.0.0\"\n",
        )
        .unwrap();

        let changelog_path = dir.path().join("CHANGELOG.md");

        let config = ReleaseConfig {
            changelog: crate::config::ChangelogConfig {
                file: Some(changelog_path.to_str().unwrap().to_string()),
                ..Default::default()
            },
            version_files: vec![cargo_path.to_str().unwrap().to_string()],
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        // Both changelog and version file should be staged in a single commit
        let committed = s.git.committed.lock().unwrap();
        assert_eq!(committed.len(), 1);
        assert!(
            committed[0]
                .0
                .contains(&changelog_path.to_str().unwrap().to_string())
        );
        assert!(
            committed[0]
                .0
                .contains(&cargo_path.to_str().unwrap().to_string())
        );
    }

    // --- artifact upload tests ---

    #[test]
    fn execute_uploads_artifacts() {
        let dir = tempfile::tempdir().unwrap();
        std::fs::write(dir.path().join("app.tar.gz"), "fake tarball").unwrap();
        std::fs::write(dir.path().join("app.zip"), "fake zip").unwrap();

        let config = ReleaseConfig {
            artifacts: vec![
                dir.path().join("*.tar.gz").to_str().unwrap().to_string(),
                dir.path().join("*.zip").to_str().unwrap().to_string(),
            ],
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        let uploaded = s.vcs.as_ref().unwrap().uploaded_assets.lock().unwrap();
        assert_eq!(uploaded.len(), 1);
        assert_eq!(uploaded[0].0, "v0.1.0");
        // 2 artifacts + 2 SHA256 checksum sidecar files
        assert_eq!(uploaded[0].1.len(), 4);
        assert!(uploaded[0].1.iter().any(|f| f.ends_with("app.tar.gz")));
        assert!(uploaded[0].1.iter().any(|f| f.ends_with("app.zip")));
        assert!(
            uploaded[0]
                .1
                .iter()
                .any(|f| f.ends_with("app.tar.gz.sha256"))
        );
        assert!(uploaded[0].1.iter().any(|f| f.ends_with("app.zip.sha256")));
    }

    #[test]
    fn execute_dry_run_shows_artifacts() {
        let dir = tempfile::tempdir().unwrap();
        std::fs::write(dir.path().join("app.tar.gz"), "fake tarball").unwrap();

        let config = ReleaseConfig {
            artifacts: vec![dir.path().join("*.tar.gz").to_str().unwrap().to_string()],
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, true).unwrap();

        // No uploads should happen during dry-run
        let uploaded = s.vcs.as_ref().unwrap().uploaded_assets.lock().unwrap();
        assert!(uploaded.is_empty());
    }

    #[test]
    fn execute_no_artifacts_skips_upload() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        let uploaded = s.vcs.as_ref().unwrap().uploaded_assets.lock().unwrap();
        assert!(uploaded.is_empty());
    }

    #[test]
    fn resolve_artifact_globs_basic() {
        let dir = tempfile::tempdir().unwrap();
        std::fs::write(dir.path().join("a.txt"), "a").unwrap();
        std::fs::write(dir.path().join("b.txt"), "b").unwrap();
        std::fs::create_dir(dir.path().join("subdir")).unwrap();

        let pattern = dir.path().join("*.txt").to_str().unwrap().to_string();
        let result = resolve_artifact_globs(&[pattern]).unwrap();
        assert_eq!(result.len(), 2);
        assert!(result.iter().any(|f| f.ends_with("a.txt")));
        assert!(result.iter().any(|f| f.ends_with("b.txt")));
    }

    #[test]
    fn resolve_artifact_globs_deduplicates() {
        let dir = tempfile::tempdir().unwrap();
        std::fs::write(dir.path().join("file.txt"), "data").unwrap();

        let pattern = dir.path().join("*.txt").to_str().unwrap().to_string();
        // Same pattern twice should not produce duplicates
        let result = resolve_artifact_globs(&[pattern.clone(), pattern]).unwrap();
        assert_eq!(result.len(), 1);
    }

    // --- floating tags tests ---

    #[test]
    fn plan_floating_tag_when_enabled() {
        let tag = TagInfo {
            name: "v3.2.0".into(),
            version: Version::new(3, 2, 0),
            sha: "d".repeat(40),
        };
        let config = ReleaseConfig {
            floating_tags: true,
            ..Default::default()
        };

        let s = make_strategy(vec![tag], vec![raw_commit("fix: patch")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version, Version::new(3, 2, 1));
        assert_eq!(plan.floating_tag_name.as_deref(), Some("v3"));
    }

    #[test]
    fn plan_no_floating_tag_when_disabled() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        assert!(plan.floating_tag_name.is_none());
    }

    #[test]
    fn plan_floating_tag_custom_prefix() {
        let tag = TagInfo {
            name: "release-2.5.0".into(),
            version: Version::new(2, 5, 0),
            sha: "e".repeat(40),
        };
        let config = ReleaseConfig {
            floating_tags: true,
            tag_prefix: "release-".into(),
            ..Default::default()
        };

        let s = make_strategy(vec![tag], vec![raw_commit("fix: patch")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.floating_tag_name.as_deref(), Some("release-2"));
    }

    #[test]
    fn execute_floating_tags_force_create_and_push() {
        let config = ReleaseConfig {
            floating_tags: true,
            ..Default::default()
        };

        let tag = TagInfo {
            name: "v1.2.3".into(),
            version: Version::new(1, 2, 3),
            sha: "f".repeat(40),
        };
        let s = make_strategy(vec![tag], vec![raw_commit("fix: a bug")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.floating_tag_name.as_deref(), Some("v1"));

        s.execute(&plan, false).unwrap();

        assert_eq!(*s.git.force_created_tags.lock().unwrap(), vec!["v1"]);
        assert_eq!(*s.git.force_pushed_tags.lock().unwrap(), vec!["v1"]);
    }

    #[test]
    fn execute_no_floating_tags_when_disabled() {
        let s = make_strategy(
            vec![],
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        assert!(plan.floating_tag_name.is_none());

        s.execute(&plan, false).unwrap();

        assert!(s.git.force_created_tags.lock().unwrap().is_empty());
        assert!(s.git.force_pushed_tags.lock().unwrap().is_empty());
    }

    #[test]
    fn execute_floating_tags_dry_run_no_side_effects() {
        let config = ReleaseConfig {
            floating_tags: true,
            ..Default::default()
        };

        let tag = TagInfo {
            name: "v2.0.0".into(),
            version: Version::new(2, 0, 0),
            sha: "a".repeat(40),
        };
        let s = make_strategy(vec![tag], vec![raw_commit("fix: something")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.floating_tag_name.as_deref(), Some("v2"));

        s.execute(&plan, true).unwrap();

        assert!(s.git.force_created_tags.lock().unwrap().is_empty());
        assert!(s.git.force_pushed_tags.lock().unwrap().is_empty());
    }

    #[test]
    fn execute_floating_tags_idempotent() {
        let config = ReleaseConfig {
            floating_tags: true,
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.floating_tag_name.as_deref(), Some("v0"));

        // Run twice
        s.execute(&plan, false).unwrap();
        s.execute(&plan, false).unwrap();

        // Force ops run every time (correct for floating tags)
        assert_eq!(s.git.force_created_tags.lock().unwrap().len(), 2);
        assert_eq!(s.git.force_pushed_tags.lock().unwrap().len(), 2);
    }

    // --- force mode tests ---

    #[test]
    fn force_rerelease_when_tag_at_head() {
        let tag = TagInfo {
            name: "v1.2.3".into(),
            version: Version::new(1, 2, 3),
            sha: "a".repeat(40),
        };
        let mut s = make_strategy(vec![tag], vec![], ReleaseConfig::default());
        // HEAD == tag SHA, and no new commits
        s.git.head = "a".repeat(40);
        s.force = true;

        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version, Version::new(1, 2, 3));
        assert_eq!(plan.tag_name, "v1.2.3");
        assert!(plan.commits.is_empty());
        assert_eq!(plan.current_version, Some(Version::new(1, 2, 3)));
    }

    #[test]
    fn force_fails_when_tag_not_at_head() {
        let tag = TagInfo {
            name: "v1.2.3".into(),
            version: Version::new(1, 2, 3),
            sha: "a".repeat(40),
        };
        let mut s = make_strategy(vec![tag], vec![], ReleaseConfig::default());
        // HEAD != tag SHA
        s.git.head = "b".repeat(40);
        s.force = true;

        let err = s.plan().unwrap_err();
        assert!(matches!(err, ReleaseError::NoCommits { .. }));
    }

    // --- build_command tests ---

    #[test]
    fn execute_runs_build_command_after_version_bump() {
        let dir = tempfile::tempdir().unwrap();
        let output_file = dir.path().join("sr_test_version");

        let config = ReleaseConfig {
            build_command: Some(format!(
                "echo $SR_VERSION > {}",
                output_file.to_str().unwrap()
            )),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        let contents = std::fs::read_to_string(&output_file).unwrap();
        assert_eq!(contents.trim(), "0.1.0");
    }

    #[test]
    fn execute_build_command_failure_aborts_release() {
        let config = ReleaseConfig {
            build_command: Some("exit 1".into()),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        let result = s.execute(&plan, false);

        assert!(result.is_err());
        assert!(s.git.created_tags.lock().unwrap().is_empty());
    }

    #[test]
    fn execute_dry_run_skips_build_command() {
        let dir = tempfile::tempdir().unwrap();
        let output_file = dir.path().join("sr_test_should_not_exist");

        let config = ReleaseConfig {
            build_command: Some(format!("echo test > {}", output_file.to_str().unwrap())),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, true).unwrap();

        assert!(!output_file.exists());
    }

    #[test]
    fn force_fails_with_no_tags() {
        let mut s = make_strategy(vec![], vec![], ReleaseConfig::default());
        s.force = true;

        let err = s.plan().unwrap_err();
        assert!(matches!(err, ReleaseError::NoCommits { .. }));
    }

    // --- stage_files tests ---

    #[test]
    fn execute_stages_extra_files() {
        let dir = tempfile::tempdir().unwrap();
        let lock_file = dir.path().join("Cargo.lock");
        std::fs::write(&lock_file, "old lock").unwrap();

        let config = ReleaseConfig {
            build_command: Some(format!("echo 'new lock' > {}", lock_file.to_str().unwrap())),
            stage_files: vec![lock_file.to_str().unwrap().to_string()],
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        let committed = s.git.committed.lock().unwrap();
        assert!(!committed.is_empty());
        let (staged, _) = &committed[0];
        assert!(
            staged.iter().any(|f| f.contains("Cargo.lock")),
            "Cargo.lock should be staged, got: {staged:?}"
        );
    }

    #[test]
    fn execute_dry_run_shows_stage_files() {
        let config = ReleaseConfig {
            stage_files: vec!["Cargo.lock".into()],
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        // dry-run should not error
        s.execute(&plan, true).unwrap();
    }

    // --- rollback tests ---

    #[test]
    fn execute_build_failure_restores_version_files() {
        let dir = tempfile::tempdir().unwrap();
        let cargo_toml = dir.path().join("Cargo.toml");
        std::fs::write(
            &cargo_toml,
            "[package]\nname = \"test\"\nversion = \"1.0.0\"\n",
        )
        .unwrap();

        let config = ReleaseConfig {
            version_files: vec![cargo_toml.to_str().unwrap().to_string()],
            build_command: Some("exit 1".into()),
            ..Default::default()
        };

        let tag = TagInfo {
            name: "v1.0.0".into(),
            version: Version::new(1, 0, 0),
            sha: "d".repeat(40),
        };
        let s = make_strategy(vec![tag], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        let result = s.execute(&plan, false);

        assert!(result.is_err());
        // Version file should be restored to original contents
        let contents = std::fs::read_to_string(&cargo_toml).unwrap();
        assert!(
            contents.contains("version = \"1.0.0\""),
            "version should be restored, got: {contents}"
        );
    }

    // --- pre/post release hook tests ---

    #[test]
    fn execute_pre_release_command_runs() {
        let dir = tempfile::tempdir().unwrap();
        let marker = dir.path().join("pre_release_ran");

        let config = ReleaseConfig {
            pre_release_command: Some(format!("touch {}", marker.to_str().unwrap())),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        assert!(marker.exists(), "pre-release command should have run");
    }

    #[test]
    fn execute_post_release_command_runs() {
        let dir = tempfile::tempdir().unwrap();
        let marker = dir.path().join("post_release_ran");

        let config = ReleaseConfig {
            post_release_command: Some(format!("touch {}", marker.to_str().unwrap())),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        assert!(marker.exists(), "post-release command should have run");
    }

    #[test]
    fn execute_pre_release_failure_aborts_release() {
        let config = ReleaseConfig {
            pre_release_command: Some("exit 1".into()),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        let result = s.execute(&plan, false);

        assert!(result.is_err());
        // Nothing should have been committed or tagged
        assert!(s.git.created_tags.lock().unwrap().is_empty());
        assert!(s.git.committed.lock().unwrap().is_empty());
    }

    #[test]
    fn execute_hooks_receive_version_env_vars() {
        let dir = tempfile::tempdir().unwrap();
        let output_file = dir.path().join("hook_output");

        let config = ReleaseConfig {
            post_release_command: Some(format!(
                "echo $SR_VERSION $SR_TAG > {}",
                output_file.to_str().unwrap()
            )),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, false).unwrap();

        let contents = std::fs::read_to_string(&output_file).unwrap();
        assert!(contents.contains("0.1.0"), "SR_VERSION should be set");
        assert!(contents.contains("v0.1.0"), "SR_TAG should be set");
    }

    #[test]
    fn execute_dry_run_skips_hooks() {
        let dir = tempfile::tempdir().unwrap();
        let pre_marker = dir.path().join("pre_hook");
        let post_marker = dir.path().join("post_hook");

        let config = ReleaseConfig {
            pre_release_command: Some(format!("touch {}", pre_marker.to_str().unwrap())),
            post_release_command: Some(format!("touch {}", post_marker.to_str().unwrap())),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        s.execute(&plan, true).unwrap();

        assert!(
            !pre_marker.exists(),
            "pre-release hook should not run in dry-run"
        );
        assert!(
            !post_marker.exists(),
            "post-release hook should not run in dry-run"
        );
    }

    // --- pre-release tests ---

    #[test]
    fn plan_prerelease_first_release() {
        let config = ReleaseConfig {
            prerelease: Some("alpha".into()),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version.to_string(), "0.1.0-alpha.1");
        assert_eq!(plan.tag_name, "v0.1.0-alpha.1");
        assert!(plan.prerelease);
    }

    #[test]
    fn plan_prerelease_increments_from_stable() {
        let tag = TagInfo {
            name: "v1.0.0".into(),
            version: Version::new(1, 0, 0),
            sha: "d".repeat(40),
        };
        let config = ReleaseConfig {
            prerelease: Some("beta".into()),
            ..Default::default()
        };

        let s = make_strategy(vec![tag], vec![raw_commit("feat: new feature")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version.to_string(), "1.1.0-beta.1");
        assert!(plan.prerelease);
    }

    #[test]
    fn plan_prerelease_increments_counter() {
        let tags = vec![
            TagInfo {
                name: "v1.0.0".into(),
                version: Version::new(1, 0, 0),
                sha: "a".repeat(40),
            },
            TagInfo {
                name: "v1.1.0-alpha.1".into(),
                version: Version::parse("1.1.0-alpha.1").unwrap(),
                sha: "b".repeat(40),
            },
            TagInfo {
                name: "v1.1.0-alpha.2".into(),
                version: Version::parse("1.1.0-alpha.2").unwrap(),
                sha: "c".repeat(40),
            },
        ];
        let config = ReleaseConfig {
            prerelease: Some("alpha".into()),
            ..Default::default()
        };

        let s = make_strategy(tags, vec![raw_commit("feat: another")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version.to_string(), "1.1.0-alpha.3");
    }

    #[test]
    fn plan_prerelease_different_id_starts_at_1() {
        let tags = vec![
            TagInfo {
                name: "v1.0.0".into(),
                version: Version::new(1, 0, 0),
                sha: "a".repeat(40),
            },
            TagInfo {
                name: "v1.1.0-alpha.3".into(),
                version: Version::parse("1.1.0-alpha.3").unwrap(),
                sha: "b".repeat(40),
            },
        ];
        let config = ReleaseConfig {
            prerelease: Some("beta".into()),
            ..Default::default()
        };

        let s = make_strategy(tags, vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        assert_eq!(plan.next_version.to_string(), "1.1.0-beta.1");
    }

    #[test]
    fn plan_prerelease_no_floating_tags() {
        let config = ReleaseConfig {
            prerelease: Some("rc".into()),
            floating_tags: true,
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        let plan = s.plan().unwrap();
        assert!(
            plan.floating_tag_name.is_none(),
            "pre-releases should not create floating tags"
        );
    }

    #[test]
    fn plan_stable_skips_prerelease_tags() {
        let tags = vec![
            TagInfo {
                name: "v1.0.0".into(),
                version: Version::new(1, 0, 0),
                sha: "a".repeat(40),
            },
            TagInfo {
                name: "v1.1.0-alpha.1".into(),
                version: Version::parse("1.1.0-alpha.1").unwrap(),
                sha: "b".repeat(40),
            },
        ];
        // No prerelease config — stable release
        let s = make_strategy(
            tags,
            vec![raw_commit("feat: something")],
            ReleaseConfig::default(),
        );
        let plan = s.plan().unwrap();
        // Should base on v1.0.0, not v1.1.0-alpha.1
        assert_eq!(plan.next_version, Version::new(1, 1, 0));
        assert!(!plan.prerelease);
    }

    #[test]
    fn plan_prerelease_marks_plan_as_prerelease() {
        let config = ReleaseConfig {
            prerelease: Some("alpha".into()),
            ..Default::default()
        };

        let s = make_strategy(vec![], vec![raw_commit("fix: bug")], config);
        let plan = s.plan().unwrap();
        assert!(plan.prerelease);
        assert!(plan.next_version.to_string().contains("alpha"));
    }

    // --- monorepo (path_filter) tests ---

    #[test]
    fn plan_with_path_filter_uses_filtered_commits() {
        let config = ReleaseConfig {
            path_filter: Some("crates/core".into()),
            ..Default::default()
        };

        // All commits include a feat, but path-filtered commits only have a fix
        let mut s = make_strategy(
            vec![],
            vec![raw_commit("feat: big feature"), raw_commit("fix: patch")],
            config,
        );
        s.git.path_commits = Some(vec![raw_commit("fix: patch only in core")]);

        let plan = s.plan().unwrap();
        // Should be a patch bump (from path-filtered commits), not minor
        assert_eq!(plan.bump, BumpLevel::Patch);
        assert_eq!(plan.commits.len(), 1);
        assert_eq!(plan.commits[0].description, "patch only in core");
    }

    #[test]
    fn plan_without_path_filter_uses_all_commits() {
        let config = ReleaseConfig::default();

        let mut s = make_strategy(vec![], vec![raw_commit("feat: big feature")], config);
        s.git.path_commits = Some(vec![raw_commit("fix: filtered")]);

        let plan = s.plan().unwrap();
        // path_filter is None, so should use all commits (feat → minor)
        assert_eq!(plan.bump, BumpLevel::Minor);
    }

    #[test]
    fn plan_with_path_filter_no_commits_returns_error() {
        let config = ReleaseConfig {
            path_filter: Some("crates/core".into()),
            ..Default::default()
        };

        let mut s = make_strategy(vec![], vec![raw_commit("feat: something")], config);
        s.git.path_commits = Some(vec![]);

        let err = s.plan().unwrap_err();
        assert!(matches!(err, ReleaseError::NoCommits { .. }));
    }

    #[test]
    fn plan_with_path_filter_custom_tag_prefix() {
        let config = ReleaseConfig {
            path_filter: Some("crates/core".into()),
            tag_prefix: "core/v".into(),
            ..Default::default()
        };

        let tag = TagInfo {
            name: "core/v1.0.0".into(),
            version: Version::new(1, 0, 0),
            sha: "a".repeat(40),
        };
        let mut s = make_strategy(vec![tag], vec![raw_commit("feat: something")], config);
        s.git.path_commits = Some(vec![raw_commit("fix: core bug")]);

        let plan = s.plan().unwrap();
        assert_eq!(plan.tag_name, "core/v1.0.1");
        assert_eq!(plan.current_version, Some(Version::new(1, 0, 0)));
    }
}