trail-fm 1.12.2

//! Directory preview provider.
//!
//! Defers the directory listing to the async worker pool so that
//! `fs::read_dir` on large or slow-filesystem directories never stalls the
//! UI thread. The `Loading` placeholder is shown until the worker delivers
//! the content; the generation-guard in `workers::merge` discards stale
//! results when the user navigates away before the worker finishes.

use std::fs;
use std::path::PathBuf;

use tokio::sync::mpsc;

use crate::app::state::{Entry, EntryKind};
use crate::preview::provider::{PreviewContent, PreviewCtx, PreviewOutcome, PreviewProvider};
use crate::workers::WorkerMsg;

/// Maximum number of child entry names shown in the directory preview.
const MAX_PREVIEW_ENTRIES: usize = 64;

/// Preview provider for directory entries.
///
/// Spawns an async worker task that runs `build_directory_preview` off the UI
/// thread, returning `PreviewOutcome::Deferred` immediately so navigation
/// remains responsive while the listing is being read.
pub struct DirectoryProvider;

impl PreviewProvider for DirectoryProvider {
    fn can_handle(&self, entry: &Entry) -> bool {
        entry.kind == EntryKind::Dir
    }

    fn preview(&self, entry: &Entry, ctx: &PreviewCtx) -> PreviewOutcome {
        spawn_directory_preview(
            entry.path.clone(),
            ctx.show_hidden,
            ctx.generation,
            ctx.worker_tx.clone(),
        );
        PreviewOutcome::Deferred
    }
}

/// Spawns an async task that builds a directory preview off the UI thread.
///
/// The task runs `build_directory_preview` inside `spawn_blocking` and sends
/// the result as a `WorkerMsg::Preview` tagged with `generation`. Mirrors the
/// pattern used by `workers::highlight::spawn_highlight`.
fn spawn_directory_preview(
    path: PathBuf,
    show_hidden: bool,
    generation: u64,
    tx: mpsc::Sender<WorkerMsg>,
) {
    tokio::spawn(async move {
        let path_for_msg = path.clone();
        let content =
            tokio::task::spawn_blocking(move || build_directory_preview(&path, show_hidden))
                .await
                .unwrap_or(PreviewContent::Empty);

        let msg = WorkerMsg::Preview {
            generation,
            path: path_for_msg,
            content,
            // The directory preview's own entry cap is not reported here; only
            // the text path tracks truncation against `[preview] max_lines`.
            truncated: false,
            // A directory is neither text nor binary; there is nothing to cache.
            is_text: None,
        };
        // If the channel is closed the UI thread has exited; ignore the error.
        let _ = tx.send(msg).await;
    });
}

/// Builds a `PreviewContent::Directory` for `path`.
///
/// Returns `PreviewContent::Empty` if the directory cannot be read.
pub fn build_directory_preview(path: &std::path::Path, show_hidden: bool) -> PreviewContent {
    let read = match fs::read_dir(path) {
        Ok(r) => r,
        Err(_) => return PreviewContent::Empty,
    };

    let mut file_count = 0usize;
    let mut dir_count = 0usize;
    let mut hidden_count = 0usize;
    let mut names: Vec<String> = Vec::new();

    for res in read {
        let de = match res {
            Ok(d) => d,
            Err(_) => continue,
        };

        // Sanitized here rather than at render time: a file name is allowed to
        // hold control characters on Unix, and a terminal acts on those instead
        // of drawing them.
        let name = match de.file_name().to_str() {
            Some(n) => crate::preview::provider::sanitize(n),
            None => continue,
        };

        let is_hidden = name.starts_with('.');
        if is_hidden {
            hidden_count += 1;
        }

        let metadata = de.metadata().ok();
        let is_dir = metadata.as_ref().map(|m| m.is_dir()).unwrap_or(false);

        if is_dir {
            dir_count += 1;
        } else {
            file_count += 1;
        }

        if (!is_hidden || show_hidden) && names.len() < MAX_PREVIEW_ENTRIES {
            // Suffix directories with `/` for quick visual identification.
            if is_dir {
                names.push(format!("{name}/"));
            } else {
                names.push(name);
            }
        }
    }

    // Sort names: directories first (those ending with `/`), then files.
    names.sort_by(|a, b| {
        let a_dir = a.ends_with('/');
        let b_dir = b.ends_with('/');
        match (a_dir, b_dir) {
            (true, false) => std::cmp::Ordering::Less,
            (false, true) => std::cmp::Ordering::Greater,
            _ => a.to_lowercase().cmp(&b.to_lowercase()),
        }
    });

    PreviewContent::Directory {
        file_count,
        dir_count,
        hidden_count,
        entries: names,
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use std::fs as sfs;
    use tempfile::tempdir;

    #[test]
    fn directory_preview_counts() {
        let dir = tempdir().unwrap();
        sfs::create_dir(dir.path().join("subdir")).unwrap();
        sfs::write(dir.path().join("file.txt"), b"").unwrap();
        sfs::write(dir.path().join(".hidden"), b"").unwrap();

        let content = build_directory_preview(dir.path(), false);

        if let PreviewContent::Directory {
            file_count,
            dir_count,
            hidden_count,
            entries,
        } = content
        {
            assert_eq!(dir_count, 1);
            assert_eq!(file_count, 2); // 'file.txt' and '.hidden'
            assert_eq!(hidden_count, 1);
            // With show_hidden=false, .hidden is excluded from entries.
            assert!(!entries.iter().any(|e| e.contains("hidden")));
        } else {
            panic!("expected Directory variant");
        }
    }

    #[test]
    fn directory_preview_shows_hidden_when_requested() {
        let dir = tempdir().unwrap();
        sfs::write(dir.path().join(".hidden"), b"").unwrap();

        let content = build_directory_preview(dir.path(), true);

        if let PreviewContent::Directory { entries, .. } = content {
            assert!(entries.iter().any(|e| e.contains("hidden")));
        } else {
            panic!("expected Directory variant");
        }
    }
}