wdl-modules 0.3.1

//! Safe module-content tree walk shared by hashing, verification,
//! resource-limit checking, and materialization.
//!
//! One traversal implementation enforces all module-content rules.
//! The canonical module root is carried through all recursion so
//! containment checks are never relative to the current directory.
//! Directory symlinks are rejected to prevent cycles. File symlinks
//! are allowed when they resolve inside the module root and do not
//! target non-module content.

use std::io;
use std::path::Path;
use std::path::PathBuf;

use thiserror::Error;

use crate::hash::NON_MODULE_CONTENT;

/// An error encountered while walking a module tree.
#[derive(Debug, Error)]
pub enum ModuleWalkError {
    /// A symbolic link target resolves outside the module root.
    #[error("symbolic link `{0}` resolves outside the module root")]
    SymlinkEscapesRoot(String),

    /// A symbolic link points to a directory.
    ///
    /// Directory symlinks are rejected to prevent cycles during tree
    /// traversal.
    #[error("symbolic link `{0}` targets a directory")]
    DirectorySymlink(String),

    /// A symbolic link resolves to a path that is not UTF-8.
    #[error("symbolic link target under `{0}` is not UTF-8")]
    NonUtf8SymlinkTarget(String),

    /// A symbolic link target resolves to non-module content (e.g.,
    /// `.git` or `.sparse.json`).
    #[error("symbolic link `{0}` targets non-module content")]
    SymlinkTargetsMetadata(String),

    /// I/O failure during the walk.
    #[error("i/o error at `{path}`")]
    Io {
        /// The path involved.
        path: PathBuf,
        /// The underlying I/O error.
        #[source]
        source: io::Error,
    },
}

/// Statistics collected during a tree walk.
#[derive(Clone, Debug, Default)]
pub struct TreeStats {
    /// Total regular files encountered.
    pub files: usize,
    /// Total bytes of regular files.
    pub bytes: u64,
}

/// Walks every regular file under `root`, enforcing containment and
/// metadata exclusion. Calls `visitor` for each file with its path
/// and size. Returns aggregate statistics.
///
/// Rules enforced:
/// - Entries named `.git` or `.sparse.json` are skipped.
/// - Symlinks whose canonical target is outside the module root are rejected
///   with `ModuleWalkError::SymlinkEscapesRoot`.
/// - Symlinks targeting non-module content (`.git`, `.sparse.json`) are
///   rejected with `ModuleWalkError::SymlinkTargetsMetadata`.
/// - Directory symlinks are rejected to prevent cycles.
/// - Only regular files (and file symlinks to valid targets) are visited.
pub fn walk_module_tree<E>(
    root: &Path,
    visitor: &mut dyn FnMut(&Path, u64) -> Result<(), E>,
) -> Result<TreeStats, WalkError<E>> {
    let canonical_root = std::fs::canonicalize(root).map_err(|source| {
        WalkError::Walk(ModuleWalkError::Io {
            path: root.to_path_buf(),
            source,
        })
    })?;
    let mut stats = TreeStats::default();
    walk_recursive(&canonical_root, root, visitor, &mut stats)?;
    Ok(stats)
}

/// The error type for [`walk_module_tree`]. Wraps both walk-layer
/// errors and visitor errors.
#[derive(Debug)]
pub enum WalkError<E> {
    /// An error encountered by the walker itself.
    Walk(ModuleWalkError),
    /// An error returned by the visitor callback.
    Visitor(E),
}

impl<E> From<ModuleWalkError> for WalkError<E> {
    fn from(e: ModuleWalkError) -> Self {
        Self::Walk(e)
    }
}

/// Recursive directory walker carrying the canonical module root.
fn walk_recursive<E>(
    module_root: &Path,
    dir: &Path,
    visitor: &mut dyn FnMut(&Path, u64) -> Result<(), E>,
    stats: &mut TreeStats,
) -> Result<(), WalkError<E>> {
    let entries = std::fs::read_dir(dir).map_err(|source| {
        WalkError::Walk(ModuleWalkError::Io {
            path: dir.to_path_buf(),
            source,
        })
    })?;
    for entry in entries {
        let entry = entry.map_err(|source| {
            WalkError::Walk(ModuleWalkError::Io {
                path: dir.to_path_buf(),
                source,
            })
        })?;
        let name = entry.file_name();
        if NON_MODULE_CONTENT.iter().any(|s| *s == name) {
            continue;
        }
        let path = entry.path();
        let meta = std::fs::symlink_metadata(&path).map_err(|source| {
            WalkError::Walk(ModuleWalkError::Io {
                path: path.to_path_buf(),
                source,
            })
        })?;
        if meta.file_type().is_symlink() {
            handle_symlink(module_root, &path, visitor, stats)?;
            continue;
        }
        if meta.is_dir() {
            walk_recursive(module_root, &path, visitor, stats)?;
        } else if meta.is_file() {
            stats.files += 1;
            stats.bytes = stats.bytes.saturating_add(meta.len());
            visitor(&path, meta.len()).map_err(WalkError::Visitor)?;
        }
    }
    Ok(())
}

/// Validates and processes a symlink entry against containment rules.
fn handle_symlink<E>(
    module_root: &Path,
    path: &Path,
    visitor: &mut dyn FnMut(&Path, u64) -> Result<(), E>,
    stats: &mut TreeStats,
) -> Result<(), WalkError<E>> {
    let target = std::fs::canonicalize(path).map_err(|source| {
        WalkError::Walk(ModuleWalkError::Io {
            path: path.to_path_buf(),
            source,
        })
    })?;
    if !target.starts_with(module_root) {
        return Err(WalkError::Walk(ModuleWalkError::SymlinkEscapesRoot(
            path.display().to_string(),
        )));
    }
    if let Ok(rel) = target.strip_prefix(module_root) {
        if rel.to_str().is_none() {
            return Err(WalkError::Walk(ModuleWalkError::NonUtf8SymlinkTarget(
                path.display().to_string(),
            )));
        }
        // SAFETY: the `to_str` check above guarantees all components
        // are valid UTF-8.
        let targets_metadata = rel
            .components()
            .any(|c| NON_MODULE_CONTENT.contains(&c.as_os_str().to_str().unwrap()));
        if targets_metadata {
            return Err(WalkError::Walk(ModuleWalkError::SymlinkTargetsMetadata(
                path.display().to_string(),
            )));
        }
    }
    let target_meta = std::fs::metadata(path).map_err(|source| {
        WalkError::Walk(ModuleWalkError::Io {
            path: path.to_path_buf(),
            source,
        })
    })?;
    if target_meta.is_dir() {
        return Err(WalkError::Walk(ModuleWalkError::DirectorySymlink(
            path.display().to_string(),
        )));
    }
    if target_meta.is_file() {
        stats.files += 1;
        stats.bytes = stats.bytes.saturating_add(target_meta.len());
        visitor(path, target_meta.len()).map_err(WalkError::Visitor)?;
    }
    Ok(())
}