ezgitx 0.1.0

Agent-native multi-repo git CLI: JSONL output, zero interactivity, cross-repo dependency awareness
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

mod cli;
mod commands;
mod config;
mod errors;
mod exec;
mod git;
mod graph;
mod lock;
mod output;
mod state;
mod workspace;

use std::path::Path;

use clap::Parser;

use cli::{Cli, Command};
use errors::EXIT_USAGE;
use workspace::{Repo, Workspace};

fn main() {
    let cli = Cli::parse();
    let runtime = tokio::runtime::Builder::new_multi_thread()
        .enable_all()
        .build()
        .expect("failed to start tokio runtime");
    let code = runtime.block_on(dispatch(cli));
    std::process::exit(code);
}

async fn dispatch(cli: Cli) -> i32 {
    let cwd = match std::env::current_dir() {
        Ok(d) => d,
        Err(e) => {
            errors::print_top_level(&errors::ErrorInfo::new(
                errors::ErrorCode::ConfigInvalid,
                format!("cannot determine current directory: {e}"),
            ));
            return EXIT_USAGE;
        }
    };
    let ws = match workspace::load(&cwd) {
        Ok(ws) => ws,
        Err(e) => {
            errors::print_top_level(&e);
            return EXIT_USAGE;
        }
    };
    let jobs = cli.jobs.unwrap_or_else(num_cpus::get);
    let max_bytes = cli.max_bytes;
    let human = cli.human;

    match cli.command {
        Command::Status { target } => match ws.select(&target.targeting(), &cwd) {
            Ok(repos) => {
                commands::status::run(&ws, repos, target.dirty, jobs, max_bytes, human).await
            }
            Err(e) => usage(e),
        },
        Command::Pull { target, wait } => {
            match select_filtered(&ws, &target, &cwd, jobs, max_bytes).await {
                Ok(repos) => commands::pull::run(&ws, repos, wait, jobs, max_bytes, human).await,
                Err(e) => usage(e),
            }
        }
        Command::Run {
            cmd,
            with_deps,
            target,
        } => match select_filtered(&ws, &target, &cwd, jobs, max_bytes).await {
            Ok(repos) => {
                commands::run::run(&ws, repos, cmd, with_deps, jobs, max_bytes, human).await
            }
            Err(e) => usage(e),
        },
        Command::InitSkill => commands::init_skill::run(&ws, human),
        Command::CheckImpact { repo, check } => {
            commands::check_impact::run(&ws, &cwd, repo, check, jobs, max_bytes, human).await
        }
    }
}

fn usage(e: errors::ErrorInfo) -> i32 {
    errors::print_top_level(&e);
    EXIT_USAGE
}

/// Resolve targeting and apply the `--dirty` filter (PRD ยง4.3). Repos whose
/// status cannot be read stay selected so the command itself reports the
/// structured error (lazy validation).
async fn select_filtered(
    ws: &Workspace,
    target: &cli::TargetArgs,
    cwd: &Path,
    jobs: usize,
    max_bytes: usize,
) -> Result<Vec<Repo>, errors::ErrorInfo> {
    let repos = ws.select(&target.targeting(), cwd)?;
    if !target.dirty {
        return Ok(repos);
    }
    let mut kept = Vec::new();
    exec::run_parallel(
        repos,
        jobs,
        |repo| async move {
            let keep = match git::check_is_repo(&repo.path) {
                Err(_) => true,
                Ok(()) => match git::status(&repo.path, max_bytes).await {
                    Ok(s) => matches!(s.state, git::TreeState::Dirty | git::TreeState::Conflicted),
                    Err(_) => true,
                },
            };
            (repo, keep)
        },
        |(repo, keep)| {
            if keep {
                kept.push(repo);
            }
        },
    )
    .await;
    kept.sort_by(|a, b| a.name.cmp(&b.name));
    Ok(kept)
}