apm-cli 0.1.43

CLI project manager for running AI coding agents in parallel, isolated by design.
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
109
110
111
112
113
114

use anyhow::Result;
use apm_core::{classify_recovery_options, config::resolve_identity, is_merge_failure_state, RecoveryKind, RecoveryOption};
use std::path::Path;
use crate::ctx::CmdContext;

pub fn run(root: &Path, state_filter: Option<String>, unassigned: bool, all: bool, actionable_filter: Option<String>, no_aggressive: bool, mine: bool, author: Option<String>, owner: Option<String>) -> Result<()> {
    let ctx = CmdContext::load(root, no_aggressive)?;

    let mine_user: Option<String> = if mine {
        Some(resolve_identity(root))
    } else {
        None
    };
    let author_filter = if mine { None } else { author };

    let filtered = apm_core::ticket::list_filtered(
        &ctx.tickets,
        &ctx.config,
        state_filter.as_deref(),
        unassigned,
        all,
        actionable_filter.as_deref(),
        author_filter.as_deref(),
        owner.as_deref(),
        mine_user.as_deref(),
    );

    // Pre-compute stale epic IDs before printing rows.
    let default_branch = &ctx.config.project.default_branch;
    let mut epic_map: std::collections::BTreeMap<String, String> = std::collections::BTreeMap::new();
    for t in &filtered {
        if let Some(tb) = t.frontmatter.target_branch.as_deref() {
            if tb.starts_with("epic/") {
                let id = apm_core::epic::epic_id_from_branch(tb).to_owned();
                epic_map.entry(id).or_insert_with(|| tb.to_owned());
            }
        }
    }
    let mut stale_epic_ids: std::collections::HashSet<String> = std::collections::HashSet::new();
    for (id, branch) in &epic_map {
        let s = apm_core::epic::merge_tree_status(root, default_branch, branch)
            .unwrap_or(apm_core::epic::MergeStatus { ahead: 0, clean: true });
        if s.ahead > 0 {
            stale_epic_ids.insert(id.clone());
        }
    }

    let mut stale_tickets: Vec<(&str, &str)> = Vec::new();
    let mut diverged_tickets: Vec<(&str, &str)> = Vec::new();

    for t in &filtered {
        let fm = &t.frontmatter;
        let owner = fm.owner.as_deref().unwrap_or("-");
        let base = match fm.target_branch.as_deref() {
            Some(branch) if branch.starts_with("epic/") => {
                let id = apm_core::epic::epic_id_from_branch(branch);
                if stale_epic_ids.contains(id) {
                    format!("{}↓", id)
                } else {
                    id.to_owned()
                }
            }
            Some(branch) => apm_core::epic::epic_id_from_branch(branch).to_owned(),
            None => ctx.config.project.default_branch.clone(),
        };
        let id_display = if t.local_stale {
            format!("*{}", fm.id)
        } else {
            fm.id.clone()
        };
        println!("{:<9} [{:<12}] {:<16} {:<12} {}", id_display, fm.state, owner, base, fm.title);

        if t.local_stale {
            stale_tickets.push((&fm.id, &fm.title));
        }
        if t.local_diverged {
            diverged_tickets.push((&fm.id, &fm.title));
        }
    }

    if !diverged_tickets.is_empty() {
        eprintln!();
        eprintln!("warning: local ref has diverged from origin on {} ticket(s) — showing local content:", diverged_tickets.len());
        for (id, title) in &diverged_tickets {
            eprintln!("    {}  {}", id, title);
        }
    }

    if !stale_tickets.is_empty() {
        println!();
        println!("  * local ref behind origin — run `apm sync` to fast-forward:");
        for (id, title) in &stale_tickets {
            println!("      *{}  {}", id, title);
        }
    }

    if let Some(state) = &state_filter {
        if is_merge_failure_state(state, &ctx.config.workflow) {
            let opts = classify_recovery_options(state, &ctx.config.workflow);
            let relevant: Vec<&RecoveryOption> = opts.iter().filter(|o| matches!(
                o.kind,
                RecoveryKind::RetryMerge | RecoveryKind::ReturnToWorker
            )).collect();
            if !relevant.is_empty() {
                let parts: Vec<String> = relevant.iter()
                    .map(|o| format!("{} → apm state <id> {}", o.label, o.to))
                    .collect();
                println!("\nRecovery: {}", parts.join("  "));
            }
        }
    }

    Ok(())
}