tfio 0.3.1

A library that provides a Transaction-like interface traditionally used in databases, applied to FileIO operations.
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

use std::fs::{FileTimes, OpenOptions};
use std::io;
use std::path::{Path, PathBuf};
use std::time::SystemTime;

use super::{AsyncOpFuture, AsyncRollbackableOperation};

enum TouchState {
    NotExecuted,
    Created,
    Touched {
        original_accessed: SystemTime,
        original_modified: SystemTime,
    },
}

/// Asynchronously creates a file if absent, or updates its access and modification times to now.
pub struct AsyncTouchFile {
    path: PathBuf,
    state: TouchState,
}

impl AsyncTouchFile {
    /// Constructs a new `AsyncTouchFile` operation.
    pub fn new<S: AsRef<Path>>(path: S) -> Self {
        Self {
            path: path.as_ref().into(),
            state: TouchState::NotExecuted,
        }
    }
}

impl AsyncRollbackableOperation for AsyncTouchFile {
    fn execute(&mut self) -> AsyncOpFuture<'_> {
        Box::pin(async move {
            match tokio::fs::metadata(&self.path).await {
                Ok(meta) => {
                    let original_accessed = meta.accessed()?;
                    let original_modified = meta.modified()?;
                    self.state = TouchState::Touched {
                        original_accessed,
                        original_modified,
                    };
                    let path = self.path.clone();
                    tokio::task::spawn_blocking(move || {
                        OpenOptions::new().write(true).open(&path)?.set_times(
                            FileTimes::new()
                                .set_accessed(SystemTime::now())
                                .set_modified(SystemTime::now()),
                        )
                    })
                    .await
                    .map_err(io::Error::other)?
                }
                Err(_) => {
                    tokio::fs::File::create(&self.path).await?;
                    self.state = TouchState::Created;
                    Ok(())
                }
            }
        })
    }

    fn rollback(&mut self) -> AsyncOpFuture<'_> {
        Box::pin(async move {
            match &self.state {
                TouchState::NotExecuted => Ok(()),
                TouchState::Created => tokio::fs::remove_file(&self.path).await,
                TouchState::Touched {
                    original_accessed,
                    original_modified,
                } => {
                    let path = self.path.clone();
                    let accessed = *original_accessed;
                    let modified = *original_modified;
                    tokio::task::spawn_blocking(move || {
                        OpenOptions::new().write(true).open(&path)?.set_times(
                            FileTimes::new()
                                .set_accessed(accessed)
                                .set_modified(modified),
                        )
                    })
                    .await
                    .map_err(io::Error::other)?
                }
            }
        })
    }
}