agent_exec/

list.rs

//! Implementation of the `list` sub-command.
//!
//! Enumerates job directories under root, reads meta.json and state.json
//! for each, and emits a JSON array sorted by started_at descending.
//! Directories that cannot be parsed as jobs are silently counted in `skipped`.
//!
//! ## CWD filtering (filter-list-by-cwd)
//!
//! By default, `list` only returns jobs whose `meta.json.cwd` matches the
//! caller's current working directory.  Two flags override this behaviour:
//!
//! - `--cwd <PATH>`: show only jobs created from `<PATH>` (overrides auto-detect).
//! - `--all`: disable cwd filtering entirely and show all jobs.
//!
//! Jobs that were created before this feature (i.e. `meta.json.cwd` is absent)
//! are treated as having no cwd and will therefore not appear in the default
//! filtered view.  Use `--all` to see them.
//!
//! ## Tag filtering (add-job-tags)
//!
//! `--tag <PATTERN>` filters jobs to those whose persisted `meta.json.tags`
//! satisfy the pattern.  Repeated `--tag` flags apply logical AND.
//! Two pattern forms are supported:
//!   - Exact: `aaa`, `hoge.fuga.geho`
//!   - Namespace prefix: `hoge.*`, `hoge.fuga.*`
//!
//! Tag filtering composes with cwd and state filtering.

use anyhow::Result;
use tracing::debug;

use crate::jobstore::resolve_root;
use crate::jobstore::short_job_id;
use crate::run::resolve_effective_cwd;
use crate::schema::{JobStatus, JobSummary, ListData, Response};
use crate::tag::{matches_all_patterns, validate_filter_pattern};

#[cfg(unix)]
fn pid_is_alive(pid: u32) -> bool {
    let ret = unsafe { libc::kill(pid as libc::pid_t, 0) };
    if ret == 0 {
        return true;
    }

    let err = std::io::Error::last_os_error();
    matches!(err.raw_os_error(), Some(libc::EPERM))
}

#[cfg(windows)]
fn pid_is_alive(pid: u32) -> bool {
    use windows::Win32::Foundation::{CloseHandle, STILL_ACTIVE};
    use windows::Win32::System::Threading::{
        GetExitCodeProcess, OpenProcess, PROCESS_QUERY_LIMITED_INFORMATION,
    };

    let handle = match unsafe { OpenProcess(PROCESS_QUERY_LIMITED_INFORMATION, false, pid) } {
        Ok(handle) => handle,
        Err(_) => return false,
    };

    let mut exit_code = 0u32;
    let ok = unsafe { GetExitCodeProcess(handle, &mut exit_code) }.is_ok();
    unsafe {
        let _ = CloseHandle(handle);
    }
    ok && exit_code == STILL_ACTIVE.0
}

#[cfg(not(any(unix, windows)))]
fn pid_is_alive(_pid: u32) -> bool {
    true
}

fn effective_state(state: &crate::schema::JobState) -> String {
    if *state.status() != JobStatus::Running {
        return state.status().as_str().to_string();
    }

    match state.pid {
        Some(pid) if pid_is_alive(pid) => "running".to_string(),
        Some(pid) => {
            debug!(
                job_id = %state.job_id(),
                pid,
                "list: persisted running job has dead pid; presenting as unknown"
            );
            "unknown".to_string()
        }
        None => {
            debug!(
                job_id = %state.job_id(),
                "list: persisted running job has no pid; presenting as unknown"
            );
            "unknown".to_string()
        }
    }
}

/// Options for the `list` sub-command.
#[derive(Debug)]
pub struct ListOpts<'a> {
    pub root: Option<&'a str>,
    /// Maximum number of jobs to return; 0 = no limit.
    pub limit: u64,
    /// Optional state filter: running|exited|killed|failed|unknown.
    pub state: Option<&'a str>,
    /// Optional cwd filter: show only jobs created from this directory.
    /// Conflicts with `all`.
    pub cwd: Option<&'a str>,
    /// When true, disable cwd filtering and show all jobs.
    /// Conflicts with `cwd`.
    pub all: bool,
    /// Tag filter patterns (AND semantics); empty means no tag filtering.
    pub tags: Vec<String>,
}

/// Execute `list`: enumerate jobs and emit JSON.
pub fn execute(opts: ListOpts) -> Result<()> {
    let root = resolve_root(opts.root);
    let root_str = root.display().to_string();

    // Validate all tag filter patterns upfront before doing any I/O.
    for pattern in &opts.tags {
        validate_filter_pattern(pattern).map_err(anyhow::Error::from)?;
    }

    // Determine the cwd filter to apply.
    // Priority: --all (no filter) > --cwd <PATH> > current_dir (default).
    let cwd_filter: Option<String> = if opts.all {
        // --all: show every job regardless of cwd.
        None
    } else if let Some(cwd_arg) = opts.cwd {
        // --cwd <PATH>: canonicalize and use as filter.
        Some(resolve_effective_cwd(Some(cwd_arg)))
    } else {
        // Default: filter by current process working directory.
        Some(resolve_effective_cwd(None))
    };

    debug!(
        cwd_filter = ?cwd_filter,
        all = opts.all,
        "list: cwd filter determined"
    );

    // If root does not exist, return an empty list (normal termination).
    if !root.exists() {
        debug!(root = %root_str, "root does not exist; returning empty list");
        let response = Response::new(
            "list",
            ListData {
                root: root_str,
                jobs: vec![],
                truncated: false,
                skipped: 0,
            },
        );
        response.print();
        return Ok(());
    }

    // Read directory entries.
    let read_dir = std::fs::read_dir(&root)
        .map_err(|e| anyhow::anyhow!("failed to read root directory {}: {}", root_str, e))?;

    let mut jobs: Vec<JobSummary> = Vec::new();
    let mut skipped: u64 = 0;

    for entry in read_dir {
        let entry = match entry {
            Ok(e) => e,
            Err(e) => {
                debug!(error = %e, "failed to read directory entry; skipping");
                skipped += 1;
                continue;
            }
        };

        let path = entry.path();
        if !path.is_dir() {
            // Skip non-directory entries (e.g. stray files in root).
            continue;
        }

        // meta.json must exist and be parseable to consider this a job.
        let meta_path = path.join("meta.json");
        let meta_bytes = match std::fs::read(&meta_path) {
            Ok(b) => b,
            Err(_) => {
                debug!(path = %path.display(), "meta.json missing or unreadable; skipping");
                skipped += 1;
                continue;
            }
        };
        let meta: crate::schema::JobMeta = match serde_json::from_slice(&meta_bytes) {
            Ok(m) => m,
            Err(e) => {
                debug!(path = %path.display(), error = %e, "meta.json parse error; skipping");
                skipped += 1;
                continue;
            }
        };

        // Apply cwd filter: if a filter is active, skip jobs whose cwd doesn't match.
        if let Some(ref filter_cwd) = cwd_filter {
            match meta.cwd.as_deref() {
                Some(job_cwd) if job_cwd == filter_cwd => {
                    // Match: include this job.
                }
                _ => {
                    // No cwd in meta (old job) or different cwd: exclude.
                    debug!(
                        path = %path.display(),
                        job_cwd = ?meta.cwd,
                        filter_cwd = %filter_cwd,
                        "list: skipping job (cwd mismatch)"
                    );
                    continue;
                }
            }
        }

        // Apply tag filters: all patterns must match (logical AND).
        if !opts.tags.is_empty() && !matches_all_patterns(&meta.tags, &opts.tags) {
            debug!(
                path = %path.display(),
                job_tags = ?meta.tags,
                patterns = ?opts.tags,
                "list: skipping job (tag mismatch)"
            );
            continue;
        }

        // state.json is optional: read if available, continue without it if not.
        let state_opt: Option<crate::schema::JobState> = {
            let state_path = path.join("state.json");
            match std::fs::read(&state_path) {
                Ok(b) => serde_json::from_slice(&b).ok(),
                Err(_) => None,
            }
        };

        let (state_str, exit_code, finished_at, updated_at) = if let Some(ref s) = state_opt {
            (
                effective_state(s),
                s.exit_code(),
                s.finished_at.clone(),
                Some(s.updated_at.clone()),
            )
        } else {
            ("unknown".to_string(), None, None, None)
        };

        let job_started_at = state_opt
            .as_ref()
            .and_then(|s| s.started_at().map(|t| t.to_string()));
        jobs.push(JobSummary {
            job_id: meta.job.id.clone(),
            short_job_id: short_job_id(&meta.job.id),
            state: state_str,
            command: meta.command.clone(),
            exit_code,
            created_at: meta.created_at.clone(),
            started_at: job_started_at,
            finished_at,
            updated_at,
            tags: meta.tags.clone(),
        });
    }

    // Apply state filter before sorting and limiting.
    if let Some(filter_state) = opts.state {
        jobs.retain(|j| j.state == filter_state);
    }

    // Sort by started_at descending; tie-break by job_id descending.
    jobs.sort_by(|a, b| {
        b.started_at
            .cmp(&a.started_at)
            .then_with(|| b.job_id.cmp(&a.job_id))
    });

    // Apply limit.
    let truncated = opts.limit > 0 && jobs.len() as u64 > opts.limit;
    if truncated {
        jobs.truncate(opts.limit as usize);
    }

    debug!(
        root = %root_str,
        count = jobs.len(),
        skipped,
        truncated,
        "list complete"
    );

    let response = Response::new(
        "list",
        ListData {
            root: root_str,
            jobs,
            truncated,
            skipped,
        },
    );
    response.print();
    Ok(())
}