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

use std::env;
use tempfile::TempDir;

#[test]
fn test_socket_base_dir_uses_tmp() {
    let result = agent_procs::paths::socket_base_dir();
    let uid = nix::unistd::getuid();
    assert_eq!(
        result,
        std::path::PathBuf::from(format!("/tmp/agent-procs-{}", uid))
    );
}

#[test]
fn test_socket_path() {
    let result = agent_procs::paths::socket_path("mysession");
    let uid = nix::unistd::getuid();
    assert_eq!(
        result,
        std::path::PathBuf::from(format!("/tmp/agent-procs-{}/mysession.sock", uid))
    );
}

#[test]
fn test_pid_path() {
    let result = agent_procs::paths::pid_path("mysession");
    let uid = nix::unistd::getuid();
    assert_eq!(
        result,
        std::path::PathBuf::from(format!("/tmp/agent-procs-{}/mysession.pid", uid))
    );
}

#[test]
fn test_state_dir_uses_xdg_when_set() {
    let tmp = TempDir::new().unwrap();
    // SAFETY: Test-only; no concurrent env access in this test.
    unsafe { env::set_var("XDG_STATE_HOME", tmp.path()) };
    let result = agent_procs::paths::state_dir("test-session");
    assert_eq!(result, tmp.path().join("agent-procs/sessions/test-session"));
    unsafe { env::remove_var("XDG_STATE_HOME") };
}

#[test]
fn test_state_dir_defaults_to_home() {
    // SAFETY: Test-only; no concurrent env access in this test.
    unsafe { env::remove_var("XDG_STATE_HOME") };
    let result = agent_procs::paths::state_dir("test-session");
    let home = env::var("HOME").unwrap();
    let expected = std::path::PathBuf::from(format!(
        "{}/.local/state/agent-procs/sessions/test-session",
        home
    ));
    assert_eq!(result, expected);
}

#[test]
fn test_log_dir() {
    let tmp = TempDir::new().unwrap();
    // SAFETY: Test-only; no concurrent env access in this test.
    unsafe { env::set_var("XDG_STATE_HOME", tmp.path()) };
    let result = agent_procs::paths::log_dir("mysession");
    assert_eq!(
        result,
        tmp.path().join("agent-procs/sessions/mysession/logs")
    );
    unsafe { env::remove_var("XDG_STATE_HOME") };
}

#[test]
fn test_socket_path_is_short() {
    // Verify socket paths stay well under macOS 103-byte limit
    let path =
        agent_procs::paths::socket_path("my-long-session-name-that-would-have-failed-before");
    assert!(
        path.to_string_lossy().len() < 100,
        "socket path too long: {}",
        path.display()
    );
}