emplace 1.6.0

Command-line tool to mirror installed software on multiple machines.
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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152

use anyhow::{anyhow, Context, Result};
use itertools::Itertools;
use log::{debug, error};
use std::{
    path::{Path, PathBuf},
    process::{Command, Stdio},
    str,
};

fn build_command<P: AsRef<Path>>(command: Vec<&str>, path: &P) -> Result<Command> {
    let mut iter = command.iter();
    let cmd_name = iter
        .next()
        .ok_or_else(|| anyhow!("Malformed git command"))?;

    let mut cmd = Command::new(cmd_name);
    cmd.stderr(Stdio::null());
    cmd.current_dir(path);

    debug!(
        "Calling \"{}\" on path {:?}",
        command.iter().join(" "),
        path.as_ref()
    );

    for arg in iter {
        if !arg.is_empty() {
            cmd.arg(arg);
        }
    }

    Ok(cmd)
}

fn call_on_path<P: AsRef<Path>>(command: Vec<&str>, path: &P) -> Result<bool> {
    let mut cmd = build_command(command, path)?;
    cmd.stdout(Stdio::null());

    let mut child = cmd.spawn().context("failed spawning process")?;
    let result = child.wait().context("failed waiting for result")?;

    Ok(result.success())
}

fn call_on_path_has_output<P: AsRef<Path>>(command: Vec<&str>, path: &P) -> Result<bool> {
    let mut cmd = build_command(command, path)?;

    Ok(str::from_utf8(&cmd.output()?.stdout)?.trim() != "")
}

pub fn commit_all<P: AsRef<Path>>(dir: &P, msg: &str, sign: bool) -> Result<bool> {
    call_on_path(
        vec!["git", "commit", if sign { "-S" } else { "" }, "-am", msg],
        dir,
    )
    .context("failed committing everything in git")
}

pub fn push<P: AsRef<Path>>(dir: &P) -> Result<bool> {
    call_on_path(vec!["git", "push"], dir).context("failed pushing in git")
}

/// Perform a pull on the git repo by fetching & merging.
pub fn pull<P: AsRef<Path>>(dir: &P, branch: &str) -> Result<bool> {
    // First fetch the remote changes
    call_on_path(
        vec![
            "git",
            "fetch",
            // We don't care about tags
            "--no-tags",
            // We don't care about submodules
            "--no-recurse-submodules",
            "origin",
            branch,
        ],
        dir,
    )
    .context("failed pulling in git: fetch")?;
    // Then merge them into this branch
    call_on_path(
        vec![
            "git",
            "merge",
            "--strategy-option",
            "theirs",
            "origin",
            branch,
        ],
        dir,
    )
    .context("failed pulling in git: merge")
}

/// Clone a full repository.
pub fn clone_full(dir: &str, url: &str) -> Result<bool> {
    // Create a dummy path since we specify absolute path for cloning
    let dummy_path = PathBuf::from("./");
    call_on_path(vec!["git", "clone", url, dir], &dummy_path)
}

pub fn clone_single_branch<P: AsRef<Path>>(dir: &P, url: &str, branch: &str) -> Result<bool> {
    let success = call_on_path(
        vec![
            "git",
            "clone",
            "--single-branch",
            "--branch",
            branch,
            url,
            ".",
        ],
        dir,
    )
    .context("failed cloning branch in git")?;

    if !success {
        // The git process reported that it succeeded but no clone has been done successfully
        error!("Cloning git branch failed, please execute the following code manually:\n\n\tgit clone --single-branch --branch {} {} {}\n", branch, url, dir.as_ref().to_str().unwrap())
    }

    Ok(success)
}
/// Set remote origin
pub fn set_remote<P: AsRef<Path>>(dir: &P, remote: &str) -> Result<bool> {
    call_on_path(vec!["git", "remote", "add", "origin", remote], dir)
        .context("failed setting remote origin")
}

/// Stage a specific file for committing.
pub fn add_file<P: AsRef<Path>>(dir: &P, file: &str) -> Result<bool> {
    call_on_path(vec!["git", "add", file], dir).context("failed adding file in git")
}

/// Stage all files for committing.
pub fn add_all_files<P: AsRef<Path>>(dir: &P) -> Result<bool> {
    call_on_path(vec!["git", "add", "-A"], dir).context("failed adding all files in git")
}

/// Do a git status to verify if there are local changes.
pub fn has_changes<P: AsRef<Path>>(dir: &P) -> Result<bool> {
    call_on_path_has_output(
        vec!["git", "ls-files", "--others", "--exclude-standard"],
        dir,
    )
    .context("failed checking if there are git changes")
}

/// Initialize an empty repository
pub fn init_repo<P: AsRef<Path>>(dir: &P) -> Result<bool> {
    call_on_path(vec!["git", "init"], dir).context("Failed initializing the repository")
}