apiforge 0.4.0

Production-grade API release automation CLI. From merged code to healthy pods in production — one command.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

use crate::error::{GitError, Result};
use crate::integrations::git::GitRepo;
use crate::steps::{Step, StepContext, StepOutput};
use async_trait::async_trait;

pub struct GitPreflightStep;

impl Default for GitPreflightStep {
    fn default() -> Self {
        Self::new()
    }
}

impl GitPreflightStep {
    pub fn new() -> Self {
        Self
    }
}

#[async_trait]
impl Step for GitPreflightStep {
    fn name(&self) -> &str {
        "git-preflight"
    }

    fn description(&self) -> &str {
        "Validate Git repository state"
    }

    async fn validate(&self, ctx: &StepContext) -> Result<()> {
        let repo = GitRepo::open()?;

        if ctx.config.git.require_clean && !repo.is_working_tree_clean()? {
            let changes = repo.get_uncommitted_changes()?;
            return Err(GitError::DirtyWorkingTree(format!(
                "{} uncommitted file(s): {}",
                changes.len(),
                changes.join(", ")
            ))
            .into());
        }

        if ctx.config.git.require_main_branch {
            let current = repo.current_branch()?;
            if current != ctx.config.git.main_branch {
                return Err(GitError::WrongBranch {
                    current,
                    required: ctx.config.git.main_branch.clone(),
                }
                .into());
            }
        }

        if !repo.remote_exists(&ctx.config.git.remote) {
            return Err(GitError::RemoteNotFound(ctx.config.git.remote.clone()).into());
        }

        let current_branch = repo.current_branch()?;
        let repo_path = repo.root_path();
        drop(repo);

        let timeout_config = crate::integrations::git::GitTimeoutConfig::from_config(
            ctx.config.git.fetch_timeout_secs,
            ctx.config.git.push_timeout_secs,
            ctx.config.git.operation_timeout_secs,
        );

        if !ctx.dry_run {
            // Refresh remote tracking refs before comparing ahead/behind.
            // This ensures sync checks are based on current remote state.
            let remote_name = ctx.config.git.remote.clone();
            crate::integrations::git::fetch_with_timeout(
                move || {
                    let repo = GitRepo::open_at(&repo_path)?;
                    repo.fetch(&remote_name)?;
                    Ok(())
                },
                &timeout_config,
            )
            .await?;
        } else {
            tracing::debug!(
                "Skipping remote fetch during dry-run preflight; using local tracking refs only"
            );
        }

        let repo = GitRepo::open()?;
        let (ahead, behind) = repo.check_remote_sync(&current_branch, &ctx.config.git.remote)?;

        if behind > 0 {
            return Err(GitError::BehindRemote(behind).into());
        }

        if ahead > 0 {
            return Err(GitError::AheadOfRemote(ahead).into());
        }

        Ok(())
    }

    async fn execute(&self, _ctx: &StepContext) -> Result<StepOutput> {
        Ok(StepOutput::ok("Repository state validated"))
    }

    async fn dry_run(&self, _ctx: &StepContext) -> Result<StepOutput> {
        Ok(StepOutput::ok("Would validate repository state"))
    }
}