1use crate::ResultExt;
  2use anyhow::{Result, bail};
  3use async_fs as fs;
  4use futures_lite::StreamExt;
  5use std::path::{Path, PathBuf};
  6
  7/// Removes all files and directories matching the given predicate
  8pub async fn remove_matching<F>(dir: &Path, predicate: F)
  9where
 10    F: Fn(&Path) -> bool,
 11{
 12    if let Some(mut entries) = fs::read_dir(dir).await.log_err() {
 13        while let Some(entry) = entries.next().await {
 14            if let Some(entry) = entry.log_err() {
 15                let entry_path = entry.path();
 16                if predicate(entry_path.as_path()) {
 17                    if let Ok(metadata) = fs::metadata(&entry_path).await {
 18                        if metadata.is_file() {
 19                            fs::remove_file(&entry_path).await.log_err();
 20                        } else {
 21                            fs::remove_dir_all(&entry_path).await.log_err();
 22                        }
 23                    }
 24                }
 25            }
 26        }
 27    }
 28}
 29
 30pub async fn collect_matching<F>(dir: &Path, predicate: F) -> Vec<PathBuf>
 31where
 32    F: Fn(&Path) -> bool,
 33{
 34    let mut matching = vec![];
 35
 36    if let Some(mut entries) = fs::read_dir(dir).await.log_err() {
 37        while let Some(entry) = entries.next().await {
 38            if let Some(entry) = entry.log_err() {
 39                if predicate(entry.path().as_path()) {
 40                    matching.push(entry.path());
 41                }
 42            }
 43        }
 44    }
 45
 46    matching
 47}
 48
 49pub async fn find_file_name_in_dir<F>(dir: &Path, predicate: F) -> Option<PathBuf>
 50where
 51    F: Fn(&str) -> bool,
 52{
 53    if let Some(mut entries) = fs::read_dir(dir).await.log_err() {
 54        while let Some(entry) = entries.next().await {
 55            if let Some(entry) = entry.log_err() {
 56                let entry_path = entry.path();
 57
 58                if let Some(file_name) = entry_path
 59                    .file_name()
 60                    .map(|file_name| file_name.to_string_lossy())
 61                {
 62                    if predicate(&file_name) {
 63                        return Some(entry_path);
 64                    }
 65                }
 66            }
 67        }
 68    }
 69
 70    None
 71}
 72
 73pub async fn move_folder_files_to_folder<P: AsRef<Path>>(
 74    source_path: P,
 75    target_path: P,
 76) -> Result<()> {
 77    if !target_path.as_ref().is_dir() {
 78        bail!("Folder not found or is not a directory");
 79    }
 80
 81    let mut entries = fs::read_dir(source_path.as_ref()).await?;
 82    while let Some(entry) = entries.next().await {
 83        let entry = entry?;
 84        let old_path = entry.path();
 85        let new_path = target_path.as_ref().join(entry.file_name());
 86
 87        fs::rename(&old_path, &new_path).await?;
 88    }
 89
 90    fs::remove_dir(source_path).await?;
 91
 92    Ok(())
 93}
 94
 95#[cfg(unix)]
 96/// Set the permissions for the given path so that the file becomes executable.
 97/// This is a noop for non-unix platforms.
 98pub async fn make_file_executable(path: &Path) -> std::io::Result<()> {
 99    fs::set_permissions(
100        path,
101        <fs::Permissions as fs::unix::PermissionsExt>::from_mode(0o755),
102    )
103    .await
104}
105
106#[cfg(not(unix))]
107#[allow(clippy::unused_async)]
108/// Set the permissions for the given path so that the file becomes executable.
109/// This is a noop for non-unix platforms.
110pub async fn make_file_executable(_path: &Path) -> std::io::Result<()> {
111    Ok(())
112}