apm-core 0.1.24

pub mod builtin;
pub mod custom;
pub mod path_guard;
pub mod hook_config;
pub use builtin::ClaudeWrapper;
pub use custom::{WrapperKind, Manifest};
pub use path_guard::PathGuard;

use std::collections::HashMap;
use std::path::{Path, PathBuf};

pub const CONTRACT_VERSION: u32 = 1;

pub struct WrapperContext {
    pub worker_name: String,
    pub ticket_id: String,
    pub ticket_branch: String,
    pub worktree_path: PathBuf,
    pub system_prompt_file: PathBuf,
    pub user_message_file: PathBuf,
    pub skip_permissions: bool,
    pub profile: String,
    pub role_prefix: Option<String>,
    pub options: HashMap<String, String>,
    pub model: Option<String>,
    pub log_path: PathBuf,
    pub container: Option<String>,
    pub extra_env: HashMap<String, String>,
    pub root: PathBuf,
    pub keychain: HashMap<String, String>,
    pub current_state: String,
    /// Override for the wrapper-specific binary (e.g. for ClaudeWrapper, the
    /// claude binary path). Honoured by built-ins that shell out to a fixed
    /// binary; legacy `[workers].command` flows in here.
    pub command: Option<String>,
}

pub trait Wrapper {
    fn spawn(&self, ctx: &WrapperContext) -> anyhow::Result<std::process::Child>;
}

pub fn resolve_builtin(name: &str) -> Option<Box<dyn Wrapper>> {
    match name {
        "claude" => Some(Box::new(builtin::ClaudeWrapper)),
        "mock-happy" => Some(Box::new(builtin::MockHappyWrapper)),
        "mock-sad" => Some(Box::new(builtin::MockSadWrapper)),
        "mock-random" => Some(Box::new(builtin::MockRandomWrapper)),
        "debug" => Some(Box::new(builtin::DebugWrapper)),
        _ => None,
    }
}

pub fn list_builtin_names() -> &'static [&'static str] {
    &["claude", "mock-happy", "mock-sad", "mock-random", "debug"]
}

pub fn resolve_wrapper(root: &Path, name: &str) -> anyhow::Result<Option<WrapperKind>> {
    if let Some(script_path) = custom::find_script(root, name) {
        let manifest = custom::parse_manifest(root, name)?;
        return Ok(Some(WrapperKind::Custom { script_path, manifest }));
    }
    if resolve_builtin(name).is_some() {
        return Ok(Some(WrapperKind::Builtin(name.to_owned())));
    }
    Ok(None)
}

pub fn write_temp_file(prefix: &str, content: &str) -> anyhow::Result<PathBuf> {
    let path = std::env::temp_dir().join(format!("apm-{prefix}-{:04x}.txt", rand_u16()));
    std::fs::write(&path, content)?;
    Ok(path)
}

pub(crate) fn rand_u16() -> u16 {
    use std::time::{SystemTime, UNIX_EPOCH};
    SystemTime::now().duration_since(UNIX_EPOCH).unwrap_or_default().subsec_nanos() as u16
}

pub(crate) fn resolve_apm_cli_bin() -> String {
    std::env::current_exe()
        .and_then(|p| p.canonicalize())
        .ok()
        .map(|exe| resolve_cli_bin_from_exe(&exe))
        .map(|p| p.to_string_lossy().into_owned())
        .unwrap_or_default()
}

fn resolve_cli_bin_from_exe(exe: &std::path::Path) -> std::path::PathBuf {
    let candidate = exe
        .parent()
        .map(|dir| dir.join("apm"))
        .filter(|p| p.is_file() && *p != exe);
    candidate.unwrap_or_else(|| exe.to_path_buf())
}

#[cfg(test)]
mod tests {
    use super::*;

    // --- resolve_cli_bin_from_exe ---

    #[test]
    fn resolve_cli_bin_from_exe_uses_sibling_apm_when_running_as_apm_server() {
        use std::os::unix::fs::PermissionsExt;
        let dir = tempfile::tempdir().unwrap();
        let apm_server = dir.path().join("apm-server");
        std::fs::write(&apm_server, "#!/bin/sh").unwrap();
        std::fs::set_permissions(&apm_server, std::fs::Permissions::from_mode(0o755)).unwrap();
        let apm = dir.path().join("apm");
        std::fs::write(&apm, "#!/bin/sh").unwrap();
        std::fs::set_permissions(&apm, std::fs::Permissions::from_mode(0o755)).unwrap();
        let result = resolve_cli_bin_from_exe(&apm_server);
        assert_eq!(
            result.file_stem().and_then(|s| s.to_str()),
            Some("apm"),
            "APM_BIN must point to the apm CLI binary, not apm-server: {result:?}"
        );
    }

    #[test]
    fn resolve_cli_bin_from_exe_no_change_when_already_apm() {
        use std::os::unix::fs::PermissionsExt;
        let dir = tempfile::tempdir().unwrap();
        let apm = dir.path().join("apm");
        std::fs::write(&apm, "#!/bin/sh").unwrap();
        std::fs::set_permissions(&apm, std::fs::Permissions::from_mode(0o755)).unwrap();
        let result = resolve_cli_bin_from_exe(&apm);
        assert_eq!(result, apm);
    }

    #[test]
    fn resolve_cli_bin_from_exe_falls_back_when_no_sibling_apm() {
        let dir = tempfile::tempdir().unwrap();
        let apm_server = dir.path().join("apm-server");
        std::fs::write(&apm_server, "#!/bin/sh").unwrap();
        // No sibling apm file — must fall back to the exe itself
        let result = resolve_cli_bin_from_exe(&apm_server);
        assert_eq!(result, apm_server);
    }

    #[test]
    fn resolve_builtin_claude_returns_some() {
        assert!(resolve_builtin("claude").is_some());
    }

    #[test]
    fn resolve_builtin_unknown_returns_none() {
        assert!(resolve_builtin("bogus").is_none());
        assert!(resolve_builtin("").is_none());
    }

    #[test]
    fn resolve_builtin_mock_happy_returns_some() {
        assert!(resolve_builtin("mock-happy").is_some());
    }

    #[test]
    fn resolve_builtin_mock_sad_returns_some() {
        assert!(resolve_builtin("mock-sad").is_some());
    }

    #[test]
    fn resolve_builtin_mock_random_returns_some() {
        assert!(resolve_builtin("mock-random").is_some());
    }

    #[test]
    fn resolve_builtin_debug_returns_some() {
        assert!(resolve_builtin("debug").is_some());
    }
}