autosave 0.1.1

Automatically save all your changes to the repository
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

use super::*;
use crate::*;
use std::path::Path;
use std::sync::{Arc, Mutex, MutexGuard};
use tokio::io::AsyncWriteExt;

impl ApiState {
    /// read watch list file and init daemon state
    pub async fn read_watch_list() -> anyhow::Result<Self> {
        let file = daemon::cache_dir()
            .context("failed to get watch list path")?
            .join(daemon::WATCH_LIST_NAME);
        tracing::trace!("read watch list file: {}", file.display());
        let data = match tokio::fs::read(&file)
            .await
            .ok()
            .and_then(|data| serde_json::from_slice(&data).ok())
        {
            Some(data) => data,
            None => {
                tracing::warn!("watch list file reading error; create watch list file");
                let data = types::WatchListFile::default();
                let contents = serde_json::to_string(&data).unwrap();
                tokio::fs::write(&file, contents.as_bytes())
                    .await
                    .context("failed to read/create watch list file")?;
                data
            }
        };
        let watch_list: types::WatchList = data
            .paths
            .into_iter()
            .filter_map(|(k, v)| {
                let configs = Arc::new(Mutex::new(v.configs));
                watcher::RepoWatcher::new(&k, configs.clone())
                    .map(|watcher| (k.clone(), types::WatchListEntry { configs, watcher }))
                    .ok()
            })
            .collect();
        Ok(Self {
            watch_list: Arc::new(Mutex::new(watch_list)),
        })
    }
    /// write current watch list state into file
    pub async fn write_watch_list(&self) -> anyhow::Result<()> {
        let path = daemon::cache_dir()
            .context("failed to get watch list path")?
            .join(daemon::WATCH_LIST_NAME);
        tracing::trace!("write watch list file: {}", path.display());
        let mut file = tokio::fs::OpenOptions::new()
            .write(true)
            .create(true)
            .truncate(true)
            .open(&path)
            .await
            .context("failed to open watch list file")?;
        let paths = self
            .watch_list
            .lock()
            .unwrap()
            .iter()
            .map(|(k, v)| {
                let configs = v.configs.lock().unwrap().clone();
                (k.clone(), types::WatchListFileEntry { configs })
            })
            .collect();
        let data = types::WatchListFile { paths };
        let data = serde_json::to_string(&data).context("failed to create watch file format")?;
        file.write_all(data.as_bytes())
            .await
            .context("failed to write watch list file")
    }

    /// get current watch list
    pub async fn watch_list(&self) -> MutexGuard<'_, WatchList> {
        self.watch_list.lock().unwrap()
    }

    /// append new dir to watch list
    pub async fn append_watch_dir(
        &self,
        path: impl AsRef<Path>,
        config: config::Config,
    ) -> anyhow::Result<()> {
        self.watch_list
            .lock()
            .unwrap()
            .entry(path.as_ref().to_path_buf())
            .or_insert({
                let configs = Arc::new(Mutex::new(vec![]));
                types::WatchListEntry {
                    watcher: watcher::RepoWatcher::new(path.as_ref(), configs.clone())?,
                    configs,
                }
            })
            .configs
            .lock()
            .unwrap()
            .push(config);
        Ok(())
    }
    /// remove specified dir from watch list
    pub async fn remove_watch_dir(
        &self,
        path: impl AsRef<Path>,
    ) -> anyhow::Result<types::WatchListEntry> {
        self.watch_list
            .lock()
            .unwrap()
            .remove(path.as_ref())
            .context("specified path is not in watch list")
    }
}