repoke 0.7.0

Finds the package managers on your system and keeps them up to date, interactively or unattended
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

use std::collections::HashMap;
use std::path::Path;

use crate::manager::{Installed, Manager, Package, Step, capture, lines, needs_sudo};

pub struct Dnf;

impl Manager for Dnf {
    fn id(&self) -> &'static str {
        "dnf"
    }

    fn name(&self) -> &'static str {
        "DNF"
    }

    fn binary(&self) -> &'static str {
        "dnf"
    }

    fn supported(&self) -> bool {
        cfg!(target_os = "linux")
    }

    /// `check-update` refreshes stale metadata itself and exits 100 when there are updates.
    fn outdated(&self, bin: &Path) -> Result<Vec<Package>, String> {
        let mut packages =
            parse_check_update(&capture(bin, ["check-update", "--quiet"])?.expect(&[0, 100])?);
        if packages.is_empty() {
            return Ok(packages);
        }
        // Not knowing the installed version only costs the "from" column, so rpm may fail.
        let format = "%{NAME} %{EPOCH}:%{VERSION}-%{RELEASE}\\n";
        let args = ["-q", "--qf", format]
            .into_iter()
            .map(String::from)
            .chain(packages.iter().map(|p| p.name.clone()));
        if let Ok(out) = capture("rpm", args) {
            let installed = parse_rpm_query(&out.stdout);
            for p in &mut packages {
                if let Some(version) = installed.get(&p.name) {
                    p.current = version.clone();
                }
            }
        }
        Ok(packages)
    }

    fn needs_root(&self, _bin: &Path) -> bool {
        needs_sudo()
    }

    fn upgrade_steps(&self, _bin: &Path, packages: &[Package]) -> Vec<Step> {
        let names = packages.iter().map(|p| p.name.clone());
        vec![Step::new(
            ["upgrade".to_string(), "-y".to_string()]
                .into_iter()
                .chain(names),
            packages,
        )]
    }

    fn installed(&self, bin: &Path) -> Result<Vec<Installed>, String> {
        let args = [
            "repoquery",
            "--userinstalled",
            "--queryformat",
            "%{name}\\n",
        ];
        let mut names = lines(bin, args)?;
        names.dedup();
        Ok(names.into_iter().map(Installed::new).collect())
    }

    fn install_steps(&self, _bin: &Path, packages: &[Installed]) -> Vec<Step> {
        Step::install_all(&["install", "-y"], packages)
    }
}

/// `kernel-core.x86_64   6.11.4-301.fc41   updates`; dnf doesn't print the installed version.
fn parse_check_update(text: &str) -> Vec<Package> {
    text.lines()
        .take_while(|l| !l.starts_with("Obsoleting"))
        .filter_map(|line| {
            let mut tokens = line.split_whitespace();
            let (name_arch, latest, _repo) = (tokens.next()?, tokens.next()?, tokens.next()?);
            let (name, _arch) = name_arch.rsplit_once('.')?;
            Some(Package {
                name: name.to_string(),
                current: String::new(),
                latest: latest.to_string(),
            })
        })
        .collect()
}

/// `xz 1:5.6.2-2.fc41` or `bash (none):5.2.32-1.fc41`, written the way dnf writes versions.
fn parse_rpm_query(text: &str) -> HashMap<String, String> {
    let mut installed = HashMap::new();
    for line in text.lines() {
        let Some((name, version)) = line
            .split_once(' ')
            .filter(|_| !line.ends_with("not installed"))
        else {
            continue;
        };
        let version = version.strip_prefix("(none):").unwrap_or(version);
        installed
            .entry(name.to_string())
            .or_insert_with(|| version.to_string());
    }
    installed
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn parses_check_update() {
        let text = "\nkernel-core.x86_64          6.11.4-301.fc41     updates\npython3.11.x86_64  3.11.10-1.fc41  updates\nObsoleting Packages\nold.noarch 1.0 updates\n";
        let packages = parse_check_update(text);
        let names: Vec<_> = packages.iter().map(|p| p.name.as_str()).collect();
        assert_eq!(names, ["kernel-core", "python3.11"]);
        assert_eq!(packages[0].latest, "6.11.4-301.fc41");
    }

    #[test]
    fn reads_installed_versions_like_dnf_writes_them() {
        let installed = parse_rpm_query(
            "xz 1:5.6.2-2.fc41\nbash (none):5.2.32-1.fc41\nbash (none):5.2.32-1.fc41\npackage nope is not installed\n",
        );
        assert_eq!(installed["xz"], "1:5.6.2-2.fc41");
        assert_eq!(installed["bash"], "5.2.32-1.fc41");
        assert_eq!(installed.len(), 2);
    }
}