qtcloud-devops-cli 0.3.0-rc.8

use std::path::Path;

use crate::model::release::{FileStorage, ReleaseStatus, Storage, TransitionError};

pub fn run(version: &str, repo_path: &Path) -> Result<String, Box<dyn std::error::Error>> {
    let mut storage = FileStorage::new(repo_path);
    let mut record = storage
        .load(version)
        .ok_or_else(|| format!("版本 {} 不存在", version))?;

    if record.status != ReleaseStatus::Staged {
        return Err(Box::new(TransitionError::NotStaged(version.to_string())));
    }

    crate::commands::release::rollback_tag(version, repo_path);

    if let Some(repo) = crate::commands::release::get_remote_repo(repo_path) {
        std::process::Command::new("gh")
            .args(["release", "delete", version, "--repo", &repo, "--yes"])
            .output()
            .ok();
        println!("✓ GitHub Release {} 已删除", version);
    }

    record.status = ReleaseStatus::Cancelled;
    record.updated_at = std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .unwrap_or_default()
        .as_secs()
        .to_string();
    storage.save(&record)?;

    let id = record.id.clone();
    println!("✓ 版本 {} 已取消 (发布尝试 ID: {})", version, id);
    Ok(id)
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::model::release::{ReleaseRecord, ReleaseStatus, Storage};

    fn make_record(version: &str, status: ReleaseStatus) -> ReleaseRecord {
        let now = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .unwrap_or_default()
            .as_secs()
            .to_string();
        ReleaseRecord {
            id: uuid::Uuid::new_v4().to_string(),
            version: version.to_string(),
            status,
            created_at: now.clone(),
            updated_at: now,
        }
    }

    #[test]
    fn test_cancel_not_staged() {
        let dir = tempfile::tempdir().unwrap();
        let mut s = FileStorage::new(dir.path());
        s.save(&make_record("v1.0.0", ReleaseStatus::Published))
            .unwrap();
        assert!(run("v1.0.0", dir.path()).is_err());
    }

    #[test]
    fn test_cancel_nonexistent() {
        let dir = tempfile::tempdir().unwrap();
        assert!(run("v9.9.9", dir.path()).is_err());
    }

    #[test]
    fn test_cancel_happy_path() {
        let dir = tempfile::tempdir().unwrap();
        let record_id;
        {
            let mut s = FileStorage::new(dir.path());
            let r = ReleaseRecord::new_staged("v1.0.0");
            record_id = r.id.clone();
            s.save(&r).unwrap();
        }
        run("v1.0.0", dir.path()).unwrap();
        let s = FileStorage::new(dir.path());
        let loaded = s.load("v1.0.0").unwrap();
        assert_eq!(loaded.status, ReleaseStatus::Cancelled);
        assert_eq!(loaded.id, record_id);
    }
}