rencfs 0.14.11

WARNING! UNDER ACTIVE DEVELOPMENT. An encrypted file system that is mounted with FUSE on Linux. It can be used to create encrypted directories.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

#[cfg(unix)]
use atomic_write_file::unix::OpenOptionsExt;
use atomic_write_file::AtomicWriteFile;
use futures_util::TryStreamExt;
use std::path::Path;
use std::{fs, io};
use tokio_stream::wrappers::ReadDirStream;

/// Recursively moves the content of a directory to another.
/// It will create destination directory if it doesn't exist. It will delete the source directory after the move.
pub async fn rename_dir_content(src: &Path, dst: &Path) -> io::Result<()> {
    if !src.is_dir() {
        return Err(io::Error::new(
            io::ErrorKind::NotFound,
            "source directory does not exist",
        ));
    }
    if !dst.exists() {
        fs::create_dir_all(dst)?;
    }
    let read_dir = tokio::fs::read_dir(src).await?;
    let read_dir_stream = ReadDirStream::new(read_dir);
    let vec = read_dir_stream.try_collect::<Vec<_>>().await?;
    let entries = vec.iter().collect::<Vec<_>>();
    for entry in entries {
        let dst = dst.join(entry.file_name());
        if entry.path().is_dir() {
            fs::create_dir_all(&dst)?;
            Box::pin(rename_dir_content(&entry.path(), &dst)).await?;
            fs::remove_dir(entry.path())?;
        } else {
            fs::rename(entry.path(), dst)?;
        }
    }
    fs::remove_dir(src)?;
    Ok(())
}

pub fn open_atomic_write(file: &Path) -> io::Result<AtomicWriteFile> {
    let mut opt = AtomicWriteFile::options();
    opt.read(true);
    #[cfg(unix)]
    opt.preserve_mode(true).preserve_owner(true);
    opt.open(file)
}