aether-agent-cli 0.9.14

CLI and ACP server for the Aether AI coding agent
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175

use acp_utils::notifications::{GitDiffClosePayload, GitDiffCommandPayload, WorkspaceStatusPayload};
use aether_cli::acp::testing::AcpTestHarness;
use aether_cli::workspace::testing::{git, init_repo};
use agent_client_protocol::schema::v2::AbsolutePath;
use clankerdiff_core::{DiffScope, RepositoryAction};
use clankerdiff_protocol::client::ClientCommand;
use clankerdiff_protocol::shared::{DocumentUpdate, Event, FileEntry, LIVE_PROTOCOL_VERSION};
use std::fs;

#[tokio::test(flavor = "current_thread")]
async fn git_diff_open_publishes_snapshot_over_duplex() {
    AcpTestHarness::run(|mut harness| async move {
        let tmp = tempfile::tempdir().unwrap();
        let repo = init_repo(tmp.path(), "repo");
        fs::write(repo.join("changed.txt"), "edited\n").unwrap();
        harness.append_stored_session_in("s1", "2026-05-01T00:00:00Z", &repo);
        live(&harness, "s1", &repo).await;

        initialize(&harness, "s1", DiffScope::Both);
        assert!(matches!(next_event(&mut harness).await, Event::Initialize { .. }));
        let Event::Document(update) = next_event(&mut harness).await else {
            panic!("open must publish a document");
        };
        assert_eq!(update.scope, DiffScope::Both);
        assert!(
            changed_paths(&update).iter().any(|path| path == "changed.txt"),
            "unexpected files: {:?}",
            changed_paths(&update)
        );
        close(&harness, "s1");
    })
    .await;
}

#[tokio::test(flavor = "current_thread")]
async fn git_diff_refresh_tracks_scope_and_reports_status_ref() {
    AcpTestHarness::run(|mut harness| async move {
        let tmp = tempfile::tempdir().unwrap();
        let repo = init_repo(tmp.path(), "repo");
        fs::write(repo.join("committed.txt"), "working edit\n").unwrap();
        git(&repo, &["add", "committed.txt"]);
        harness.append_stored_session_in("s1", "2026-05-01T00:00:00Z", &repo);
        live(&harness, "s1", &repo).await;

        initialize(&harness, "s1", DiffScope::Both);
        let _ = next_event(&mut harness).await;
        let _ = next_event(&mut harness).await;

        send(&harness, "s1", ClientCommand::SetScope(DiffScope::Staged));
        let Event::Document(update) = next_event(&mut harness).await else {
            panic!("set scope must publish a document");
        };
        assert_eq!(update.scope, DiffScope::Staged);
        assert!(changed_paths(&update).iter().any(|path| path == "committed.txt"), "staged change must be visible");
        assert!(matches!(next_event(&mut harness).await, Event::RequestResult(Ok(()))));

        let status = harness
            .client_cx
            .send_request(WorkspaceStatusPayload { session_id: "s1".to_string() })
            .block_task()
            .await
            .expect("status succeeds");
        assert!(!status.display_dir.is_empty());
    })
    .await;
}

#[tokio::test(flavor = "current_thread")]
async fn git_diff_apply_stage_commit_reaches_clean_tree() {
    AcpTestHarness::run(|mut harness| async move {
        let tmp = tempfile::tempdir().unwrap();
        let repo = init_repo(tmp.path(), "repo");
        fs::write(repo.join("file.txt"), "two\n").unwrap();
        harness.append_stored_session_in("s1", "2026-05-01T00:00:00Z", &repo);
        live(&harness, "s1", &repo).await;

        initialize(&harness, "s1", DiffScope::Both);
        let _ = next_event(&mut harness).await;
        let _ = next_event(&mut harness).await;

        send(&harness, "s1", ClientCommand::Apply(RepositoryAction::StageAll));
        let Event::Document(_) = next_event(&mut harness).await else { panic!("staging must publish") };
        assert!(matches!(next_event(&mut harness).await, Event::RequestResult(Ok(()))));

        send(&harness, "s1", ClientCommand::Apply(RepositoryAction::Commit { message: "update".to_string() }));
        let Event::Document(update) = next_event(&mut harness).await else { panic!("commit must publish") };
        assert!(update.files.is_empty(), "committed tree must be clean");
        assert!(matches!(next_event(&mut harness).await, Event::RequestResult(Ok(()))));
    })
    .await;
}

#[tokio::test(flavor = "current_thread")]
async fn git_diff_open_outside_repository_reports_not_repository() {
    AcpTestHarness::run(|mut harness| async move {
        let tmp = tempfile::tempdir().unwrap();
        harness.append_stored_session_in("s1", "2026-05-01T00:00:00Z", tmp.path());
        live(&harness, "s1", tmp.path()).await;

        initialize(&harness, "s1", DiffScope::Both);
        let Event::Error(error) = next_event(&mut harness).await else { panic!("expected an error event") };
        assert!(error.message.contains("not inside a Git worktree"), "unexpected message: {}", error.message);

        let status = harness
            .client_cx
            .send_request(WorkspaceStatusPayload { session_id: "s1".to_string() })
            .block_task()
            .await
            .expect("status succeeds outside a repo");
        assert_eq!(status.git_ref, None);
    })
    .await;
}

#[tokio::test(flavor = "current_thread")]
async fn git_diff_commands_for_unknown_sessions_are_ignored() {
    AcpTestHarness::run(|mut harness| async move {
        let tmp = tempfile::tempdir().unwrap();
        let repo = init_repo(tmp.path(), "repo");
        fs::write(repo.join("changed.txt"), "edited\n").unwrap();
        harness.append_stored_session_in("s1", "2026-05-01T00:00:00Z", &repo);
        live(&harness, "s1", &repo).await;

        initialize(&harness, "missing", DiffScope::Both);
        initialize(&harness, "s1", DiffScope::Both);

        let first = next_event(&mut harness).await;
        assert!(matches!(first, Event::Initialize { .. }), "the unknown session must not answer, got {first:?}");
        assert!(matches!(next_event(&mut harness).await, Event::Document(_)));
    })
    .await;
}

async fn live(harness: &AcpTestHarness, session_id: &str, cwd: &std::path::Path) {
    use agent_client_protocol::schema::v2::ResumeSessionRequest;
    harness
        .client_cx
        .send_request(ResumeSessionRequest::new(session_id, AbsolutePath::new(cwd)))
        .block_task()
        .await
        .expect("resume session for git diff");
}

fn initialize(harness: &AcpTestHarness, session_id: &str, scope: DiffScope) {
    send(harness, session_id, ClientCommand::Initialize { protocol_version: LIVE_PROTOCOL_VERSION, scope });
}

fn close(harness: &AcpTestHarness, session_id: &str) {
    harness
        .client_cx
        .send_notification(GitDiffClosePayload { session_id: session_id.to_string() })
        .expect("close sends");
}

fn send(harness: &AcpTestHarness, session_id: &str, command: ClientCommand) {
    harness
        .client_cx
        .send_notification(GitDiffCommandPayload { session_id: session_id.to_string(), command })
        .expect("git diff command sends");
}

async fn next_event(harness: &mut AcpTestHarness) -> Event<DocumentUpdate> {
    harness.peer.next_git_diff_notification().await.event
}

fn changed_paths(update: &DocumentUpdate) -> Vec<String> {
    update
        .files
        .iter()
        .map(|entry| match entry {
            FileEntry::Changed(file) => file.path.as_str().to_string(),
            FileEntry::Unchanged(path) => path.as_str().to_string(),
        })
        .collect()
}