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

use crate::protocol::{Request, Response};

pub async fn execute(
    session: &str,
    target: &str,
    until: Option<String>,
    regex: bool,
    exit: bool,
    timeout: Option<u64>,
) -> i32 {
    let req = Request::Wait {
        target: target.into(),
        until,
        regex,
        exit,
        timeout_secs: timeout,
    };
    crate::cli::request_and_handle(session, &req, false, |resp| match resp {
        Response::WaitMatch { line } => {
            println!("{}", line);
            Some(0)
        }
        Response::WaitExited { exit_code } => {
            match exit_code {
                Some(code) => println!("exited with code {}", code),
                None => println!("exited by signal"),
            }
            Some(0)
        }
        Response::WaitTimeout => {
            eprintln!("timeout");
            Some(1)
        }
        _ => None,
    })
    .await
}