unified-agent-api-codex 0.3.5

Async wrapper around the Codex CLI for programmatic prompting
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

use std::fs as std_fs;
#[cfg(unix)]
use std::os::unix::fs::PermissionsExt;
use std::path::{Path, PathBuf};
use std::sync::OnceLock;

fn env_mutex() -> &'static tokio::sync::Mutex<()> {
    static ENV_MUTEX: OnceLock<tokio::sync::Mutex<()>> = OnceLock::new();
    ENV_MUTEX.get_or_init(|| tokio::sync::Mutex::new(()))
}

pub(super) fn env_guard() -> tokio::sync::MutexGuard<'static, ()> {
    env_mutex().blocking_lock()
}

pub(super) async fn env_guard_async() -> tokio::sync::MutexGuard<'static, ()> {
    env_mutex().lock().await
}

fn write_executable(dir: &Path, name: &str, script: &str) -> PathBuf {
    let path = dir.join(name);
    std_fs::write(&path, script).unwrap();
    let mut perms = std_fs::metadata(&path).unwrap().permissions();
    #[cfg(unix)]
    {
        perms.set_mode(0o755);
    }
    std_fs::set_permissions(&path, perms).unwrap();
    path
}

pub(super) fn write_fake_codex(dir: &Path, script: &str) -> PathBuf {
    write_executable(dir, "codex", script)
}

pub(super) fn write_fake_bundled_codex(dir: &Path, platform: &str, script: &str) -> PathBuf {
    write_executable(dir, super::bundled_binary_filename(platform), script)
}