agent-team-mail 1.0.0

Daemon-free CLI for local agent team mail workflows.
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

use anyhow::{Context, Result};
use atm_core::ack::{self, AckRequest};
use atm_core::home;
use atm_core::schema::LegacyMessageId;
use atm_core::types::{AgentName, TeamName};
use clap::Args;

use crate::observability::CliObservability;
use crate::output;

#[derive(Debug, Args)]
/// Acknowledge one pending-ack message and send a reply.
pub struct AckCommand {
    message_id: String,
    reply: String,

    #[arg(long)]
    team: Option<String>,

    #[arg(long = "as")]
    actor: Option<String>,

    #[arg(long)]
    json: bool,
}

impl AckCommand {
    /// Execute the `atm ack` command.
    pub fn run(self, observability: &CliObservability) -> Result<()> {
        let current_dir = std::env::current_dir()?;
        let home_dir = home::atm_home()?;
        let message_id = self
            .message_id
            .parse::<LegacyMessageId>()
            .with_context(|| format!("invalid message id: {}", self.message_id))?;

        let outcome = ack::ack_mail(
            AckRequest {
                home_dir,
                current_dir,
                actor_override: self.actor.map(AgentName::from),
                team_override: self.team.map(TeamName::from),
                message_id,
                reply_body: self.reply,
            },
            observability,
        )?;

        output::print_ack_result(&outcome, self.json)
    }
}