knott 0.1.7

Fast Rust package manager helper for Arch Linux repos and the AUR
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

mod aur;
mod cli;
mod dep;
mod download;
mod info;
mod install;
mod localdb;
mod menu;
mod output;
mod pacman;
mod resolver;
mod search;
mod upgrade;
mod version;

use anyhow::Result;

pub async fn run(args: Vec<String>) -> Result<i32> {
    let parsed = cli::parse(args)?;

    match &parsed.command {
        cli::Command::Help => {
            cli::print_help();
            return Ok(0);
        }
        cli::Command::Version => {
            println!("knott {}", env!("CARGO_PKG_VERSION"));
            return Ok(0);
        }
        cli::Command::Diagnostics => {
            print_diagnostics();
            return Ok(0);
        }
        _ => {}
    }

    let tools = pacman::Toolchain::from_env();
    let aur = aur::AurClient::from_env_with_progress(
        !parsed.options.quiet && !parsed.options.no_progress,
    )?;

    match parsed.command {
        cli::Command::DefaultUpgrade => {
            install::sync(&parsed.options, &tools, &aur, &[], true, true).await
        }
        cli::Command::Search { terms } => {
            search::print_search(&parsed.options, &tools, &aur, &terms).await
        }
        cli::Command::Info { targets } => {
            info::print_info(&parsed.options, &tools, &aur, &targets).await
        }
        cli::Command::Install {
            targets,
            refresh,
            sysupgrade,
        } => install::sync(&parsed.options, &tools, &aur, &targets, refresh, sysupgrade).await,
        cli::Command::Get { targets, print } => {
            download::get_pkgbuilds(&parsed.options, &tools, &aur, &targets, print).await
        }
        cli::Command::QueryForeign => upgrade::print_foreign(&parsed.options, &tools).await,
        cli::Command::QueryAurUpdates => {
            upgrade::print_aur_updates(&parsed.options, &tools, &aur).await
        }
        cli::Command::Forward(args) => tools.forward(&args).await,
        cli::Command::Interactive { terms } => {
            let selected =
                search::interactive_select(&parsed.options, &tools, &aur, &terms).await?;
            if selected.is_empty() {
                return Ok(0);
            }
            install::sync(&parsed.options, &tools, &aur, &selected, false, false).await
        }
        cli::Command::Help | cli::Command::Version | cli::Command::Diagnostics => unreachable!(),
    }
}

pub fn sanitize_for_terminal(input: &str) -> String {
    output::text(input)
}

fn print_diagnostics() {
    println!("knott diagnostics");
    println!("version: {}", env!("CARGO_PKG_VERSION"));
    println!("aur_info_batch_size: {}", aur::INFO_CHUNK);
    println!("aur_info_cache_limit: {}", aur::INFO_CACHE_LIMIT);
    println!("aur_search_cache_limit: {}", aur::SEARCH_CACHE_LIMIT);
    println!(
        "aur_search_cache_result_limit: {}",
        aur::SEARCH_CACHE_RESULT_LIMIT
    );
    println!("pkgbuild_byte_limit: {}", aur::MAX_PKG_BUILD_BYTES);
    println!("resolver_node_limit: {}", resolver::MAX_RESOLVE_NODES);
    println!("local_desc_byte_limit: {}", localdb::MAX_DESC_BYTES);
    println!("spawned_tokio_tasks: 0");
    println!("channels: 0");
    println!("output_sanitization: ansi-and-control-stripped");
    println!("progress_loader: aisling:tqdm");
    match current_rss_kib() {
        Some(rss) => println!("rss_kib: {rss}"),
        None => println!("rss_kib: unavailable"),
    }
}

fn current_rss_kib() -> Option<u64> {
    let status = std::fs::read_to_string("/proc/self/status").ok()?;
    status.lines().find_map(|line| {
        line.strip_prefix("VmRSS:")?
            .split_whitespace()
            .next()?
            .parse()
            .ok()
    })
}