agent-procs 0.6.3

Concurrent process runner for AI agents
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

mod helpers;
use helpers::TestContext;

#[test]
fn test_run_and_status() {
    let ctx = TestContext::new("test-run-status");

    let output = ctx
        .cmd()
        .args([
            "--session",
            &ctx.session,
            "run",
            "sleep 60",
            "--name",
            "sleeper",
        ])
        .output()
        .unwrap();
    assert!(
        output.status.success(),
        "run failed: {}",
        String::from_utf8_lossy(&output.stderr)
    );
    assert!(String::from_utf8_lossy(&output.stdout).contains("sleeper"));

    let output = ctx
        .cmd()
        .args(["--session", &ctx.session, "status"])
        .output()
        .unwrap();
    assert!(output.status.success());
    let stdout = String::from_utf8_lossy(&output.stdout);
    assert!(stdout.contains("sleeper"));
    assert!(stdout.contains("running"));

    let output = ctx
        .cmd()
        .args(["--session", &ctx.session, "stop", "sleeper"])
        .output()
        .unwrap();
    assert!(output.status.success());

    // Cleanup daemon
    let _ = ctx
        .cmd()
        .args(["--session", &ctx.session, "stop-all"])
        .output();
}

#[test]
fn test_stop_nonexistent_returns_error() {
    let ctx = TestContext::new("test-stop-missing");

    let _ = ctx
        .cmd()
        .args(["--session", &ctx.session, "run", "sleep 60", "--name", "bg"])
        .output()
        .unwrap();

    let output = ctx
        .cmd()
        .args(["--session", &ctx.session, "stop", "nonexistent"])
        .output()
        .unwrap();
    let stderr = String::from_utf8_lossy(&output.stderr);
    assert!(stderr.contains("not found") || !output.status.success());

    let _ = ctx
        .cmd()
        .args(["--session", &ctx.session, "stop-all"])
        .output();
}

#[test]
fn test_restart_process() {
    let ctx = TestContext::new("t-restart");

    // Start a process
    let output = ctx
        .cmd()
        .args([
            "--session",
            &ctx.session,
            "run",
            "sleep 60",
            "--name",
            "srv",
        ])
        .output()
        .unwrap();
    assert!(output.status.success());

    // Get original PID from status
    let output = ctx
        .cmd()
        .args(["--session", &ctx.session, "status", "--json"])
        .output()
        .unwrap();
    let stdout = String::from_utf8_lossy(&output.stdout);
    let procs: Vec<serde_json::Value> = serde_json::from_str(&stdout).unwrap();
    let original_pid = procs[0]["pid"].as_u64().unwrap();

    // Restart it
    let output = ctx
        .cmd()
        .args(["--session", &ctx.session, "restart", "srv"])
        .output()
        .unwrap();
    assert!(output.status.success());
    assert!(String::from_utf8_lossy(&output.stdout).contains("restarted"));

    // Verify it's running with a new PID
    let output = ctx
        .cmd()
        .args(["--session", &ctx.session, "status", "--json"])
        .output()
        .unwrap();
    let stdout = String::from_utf8_lossy(&output.stdout);
    let procs: Vec<serde_json::Value> = serde_json::from_str(&stdout).unwrap();
    let new_pid = procs[0]["pid"].as_u64().unwrap();
    assert_ne!(original_pid, new_pid, "PID should change after restart");

    let _ = ctx
        .cmd()
        .args(["--session", &ctx.session, "stop-all"])
        .output();
}