hyper-jump 0.11.0

A generalist all-in-one command-line version manager toolset for a more efficient development workflow.
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

use std::path::PathBuf;

use fs4::FileExt;
use tokio::task;

use crate::ports::Lock;
use crate::ports::LockGuard;
use crate::ports::Paths;

pub struct FileLock {
    path: PathBuf,
}

impl FileLock {
    pub async fn from_paths<P: Paths>(paths: &P) -> anyhow::Result<Self> {
        let base = paths.installation_dir().await?;
        Ok(Self {
            path: base.join("hyper-jump.lock"),
        })
    }
}

impl Lock for FileLock {
    async fn acquire(&self) -> anyhow::Result<LockGuard> {
        let path = self.path.clone();
        let file = task::spawn_blocking(move || -> anyhow::Result<std::fs::File> {
            use std::io::Write;
            let mut file =
                std::fs::OpenOptions::new().read(true).write(true).create(true).open(&path)?;
            file.lock_exclusive()?;
            let _ = file.set_len(0);
            let _ = writeln!(file, "pid:{}", std::process::id());
            Ok(file)
        })
        .await??;

        Ok(LockGuard {
            path: Some(self.path.clone()),
            file: Some(file),
        })
    }
}

impl Drop for LockGuard {
    fn drop(&mut self) {
        if let Some(file) = self.file.take() {
            let _ = file.unlock();
        }
        if let Some(path) = self.path.take() {
            let _ = std::fs::remove_file(path);
        }
    }
}