running-process 4.4.0

Subprocess and PTY runtime for the running-process project
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
114
115
116
117
118
119

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

use crate::broker::manifest;
use crate::broker::protocol::CacheManifest;
use crate::cleanup::{delete_path, now_unix_ms, root_is_prunable, CleanupAction, CleanupError};

/// Prune selection options.
#[derive(Debug, Clone)]
pub struct PruneOptions {
    /// Only prune manifests inactive for at least this many seconds.
    pub dormant_after_secs: Option<u64>,
    /// Keep manifests with a current daemon.
    pub keep_current: bool,
    /// Keep the N most recently active manifests per service.
    pub keep_last: Option<usize>,
    /// Restrict to one service.
    pub service: Option<String>,
    /// Restrict to one version.
    pub version: Option<String>,
    /// Delete selected paths. False means dry-run.
    pub confirm: bool,
}

/// Select and optionally delete prunable roots.
pub fn run(
    registry_dir: &Path,
    options: &PruneOptions,
) -> Result<Vec<CleanupAction>, CleanupError> {
    let manifests = manifest::enumerate_central(registry_dir);
    let keep_last = keep_last_keys(&manifests, options.keep_last);
    let now_ms = now_unix_ms();
    let mut actions = Vec::new();

    for manifest in manifests {
        if let Some(service) = &options.service {
            if &manifest.service_name != service {
                continue;
            }
        }
        if let Some(version) = &options.version {
            if &manifest.service_version != version {
                continue;
            }
        }
        let key = manifest_key(&manifest);
        if keep_last.contains_key(&key) {
            continue;
        }
        if options.keep_current && manifest.current_daemon.is_some() {
            continue;
        }
        if let Some(dormant_after_secs) = options.dormant_after_secs {
            let dormant_ms = dormant_after_secs.saturating_mul(1000);
            if now_ms.saturating_sub(manifest.last_active_unix_ms) < dormant_ms {
                continue;
            }
        }

        for root in &manifest.roots {
            let path = std::path::PathBuf::from(&root.path);
            if !root_is_prunable(root) {
                actions.push(CleanupAction {
                    service_name: manifest.service_name.clone(),
                    service_version: manifest.service_version.clone(),
                    path,
                    reason: "prune".to_string(),
                    deleted: false,
                    skipped: true,
                    skip_reason: Some("root disposition is not prunable".to_string()),
                });
                continue;
            }
            if options.confirm {
                delete_path(&path)?;
            }
            actions.push(CleanupAction {
                service_name: manifest.service_name.clone(),
                service_version: manifest.service_version.clone(),
                path,
                reason: if options.confirm {
                    "prune-confirmed".to_string()
                } else {
                    "prune-dry-run".to_string()
                },
                deleted: options.confirm,
                skipped: false,
                skip_reason: None,
            });
        }
    }

    Ok(actions)
}

fn keep_last_keys(manifests: &[CacheManifest], keep_last: Option<usize>) -> HashMap<String, ()> {
    let Some(limit) = keep_last else {
        return HashMap::new();
    };
    let mut by_service: HashMap<&str, Vec<&CacheManifest>> = HashMap::new();
    for manifest in manifests {
        by_service
            .entry(&manifest.service_name)
            .or_default()
            .push(manifest);
    }
    let mut out = HashMap::new();
    for manifests in by_service.values_mut() {
        manifests.sort_by_key(|m| std::cmp::Reverse(m.last_active_unix_ms));
        for manifest in manifests.iter().take(limit) {
            out.insert(manifest_key(manifest), ());
        }
    }
    out
}

fn manifest_key(manifest: &CacheManifest) -> String {
    format!("{}@{}", manifest.service_name, manifest.service_version)
}