OXYGENHUB
# 1db74949c876 oxygen / src / cli / format.rs
6.4 KiB · Rust · last changed Release 0.4.6: agents push as themselves 18 days ago source blame history raw
1 
//! Shared presentation helpers.
2
3 
use super::ui;
4 
use anyhow::Result;
5 
use oxy_core::hash::{ChangeHash, KeyId};
6 
use oxy_core::objects::Change;
7 
use oxy_core::repo::{Repo, SignatureStatus};
8 
use oxy_core::state::ChangeMeta;
9
10 
pub fn short_id(c: &Change) -> String {
11 
    c.change_id.short(8)
12 
}
13
14 
/// `n head` / `n heads`.
15 
pub fn plural(n: usize, word: &str) -> String {
16 
    format!("{n} {word}{}", if n == 1 { "" } else { "s" })
17 
}
18
19 
/// Milliseconds since the Unix epoch as `YYYY-MM-DD HH:MM:SSZ`.
20 
pub fn when(ms: u64) -> String {
21 
    let secs = (ms / 1000) as i64;
22 
    let days = secs.div_euclid(86_400);
23 
    let rem = secs.rem_euclid(86_400);
24 
    // Civil-from-days (Howard Hinnant), UTC.
25 
    let z = days + 719_468;
26 
    let era = z.div_euclid(146_097);
27 
    let doe = z - era * 146_097;
28 
    let yoe = (doe - doe / 1460 + doe / 36_524 - doe / 146_096) / 365;
29 
    let y = yoe + era * 400;
30 
    let doy = doe - (365 * yoe + yoe / 4 - yoe / 100);
31 
    let mp = (5 * doy + 2) / 153;
32 
    let d = doy - (153 * mp + 2) / 5 + 1;
33 
    let m = if mp < 10 { mp + 3 } else { mp - 9 };
34 
    let y = if m <= 2 { y + 1 } else { y };
35 
    format!(
36 
        "{y:04}-{m:02}-{d:02} {:02}:{:02}:{:02}Z",
37 
        rem / 3600,
38 
        (rem % 3600) / 60,
39 
        rem % 60
40 
    )
41 
}
42
43 
/// One line describing how a change is authenticated.
44 
pub fn signature_line(repo: &Repo, h: &ChangeHash) -> Result<String> {
45 
    Ok(match repo.authenticate_change(h)? {
46 
        SignatureStatus::Unsigned => "unsigned".to_string(),
47 
        SignatureStatus::Valid {
48 
            key,
49 
            name,
50 
            email,
51 
            sealed,
52 
            revoked,
53 
        } => {
54 
            format!(
55 
                "{} by {name} <{email}> key {}{}",
56 
                if sealed { "sealed" } else { "signed" },
57 
                key.short(12),
58 
                if revoked { " (KEY REVOKED)" } else { "" }
59 
            )
60 
        }
61 
        SignatureStatus::Invalid(why) => format!("INVALID signature: {why}"),
62 
    })
63 
}
64
65 
/// Who signed for the author when it was not the author: a delegate such
66 
/// as an agent (`author.signer`), with the delegation that let it.
67 
#[derive(Clone, Debug)]
68 
pub struct Via {
69 
    pub name: String,
70 
    pub email: String,
71 
    pub key: KeyId,
72 
    /// The delegation as the author's identity lists it, if it still does.
73 
    pub scope: Option<String>,
74 
    pub expires: Option<u64>,
75 
    pub revoked: bool,
76 
}
77
78 
impl Via {
79 
    /// `↳ Antigravity <[email protected]> · delegate for changes, until … · key 3195…`
80 
    pub fn line(&self) -> String {
81 
        let delegation = match (&self.scope, self.revoked) {
82 
            (_, true) => ui::err("delegation revoked"),
83 
            (Some(scope), false) => ui::dim(format!(
84 
                "delegate for {scope}{}",
85 
                self.expires
86 
                    .map(|e| format!(", until {}", when(e)))
87 
                    .unwrap_or_default()
88 
            )),
89 
            (None, false) => ui::warn("not a delegate of the author now"),
90 
        };
91 
        format!(
92 
            "{} {} <{}> · {} · key {}",
93 
            ui::glyph("↳", "->"),
94 
            ui::author(&self.name),
95 
            self.email,
96 
            delegation,
97 
            ui::hash(self.key.short(12))
98 
        )
99 
    }
100 
}
101
102 
/// The delegate that signed for `author`, when one did. `None` when the
103 
/// author signed, or nothing valid did.
104 
pub fn via(repo: &Repo, status: &SignatureStatus, author: &KeyId) -> Option<Via> {
105 
    match status {
106 
        SignatureStatus::Valid {
107 
            key,
108 
            name,
109 
            email,
110 
            revoked,
111 
            ..
112 
        } if !author.is_zero() && key != author => {
113 
            let entry = repo
114 
                .identity(author)
115 
                .ok()
116 
                .and_then(|a| a.delegate(key).copied());
117 
            // A short-lived key acting under the author's grant (§14.7)
118 
            // is no delegate, and not a revoked one either.
119 
            let certified = entry.is_none() && repo.certified_subject(key).is_some();
120 
            Some(Via {
121 
                name: name.clone(),
122 
                email: email.clone(),
123 
                key: *key,
124 
                scope: entry.map(|d| d.scope.to_string()),
125 
                expires: entry.and_then(|d| d.expires),
126 
                revoked: *revoked || (entry.is_none() && !certified),
127 
            })
128 
        }
129 
        _ => None,
130 
    }
131 
}
132
133 
/// A compact, styled authentication marker for log lines, from a status
134 
/// already in hand (the caller also reads who signed, see [`via`]).
135 
pub fn signature_mark_of(status: &SignatureStatus) -> String {
136 
    match status {
137 
        SignatureStatus::Unsigned => ui::dim(format!("{} unsigned", ui::glyph("·", "-"))),
138 
        SignatureStatus::Valid {
139 
            sealed,
140 
            revoked: true,
141 
            ..
142 
        } => ui::warn(format!(
143 
            "{} {} (key revoked)",
144 
            ui::glyph("⚠", "!"),
145 
            if *sealed { "sealed" } else { "signed" }
146 
        )),
147 
        SignatureStatus::Valid { sealed, .. } => ui::ok(format!(
148 
            "{} {}",
149 
            ui::glyph("✔", "v"),
150 
            if *sealed { "sealed" } else { "signed" }
151 
        )),
152 
        SignatureStatus::Invalid(why) => ui::err(format!("{} INVALID: {why}", ui::glyph("✖", "x"))),
153 
    }
154 
}
155
156 
/// The author's display name: the identity's name, or a Git-Author trailer
157 
/// for imported changes, or a shortened key.
158 
pub fn author_name(repo: &Repo, c: &ChangeMeta) -> String {
159 
    if !c.author.is_zero() {
160 
        if let Ok(id) = repo.identity(&c.author) {
161 
            return id.name;
162 
        }
163 
        return c.author.short(12);
164 
    }
165 
    c.message
166 
        .lines()
167 
        .rev()
168 
        .find_map(|l| l.strip_prefix("Git-Author: "))
169 
        .map(|a| a.split('<').next().unwrap_or(a).trim().to_string())
170 
        .unwrap_or_else(|| "unknown".into())
171 
}
172
173 
/// The first line of a message, or a placeholder.
174 
pub fn subject_of(message: &str) -> &str {
175 
    match message.lines().next() {
176 
        Some(l) if !l.trim().is_empty() => l,
177 
        _ => "(no description)",
178 
    }
179 
}
180
181 
pub fn deps_line(c: &Change) -> String {
182 
    deps_of(&c.deps)
183 
}
184
185 
pub fn deps_of(deps: &[oxy_core::hash::ChangeHash]) -> String {
186 
    deps.iter()
187 
        .map(|d| format!("#{}", d.short(12)))
188 
        .collect::<Vec<_>>()
189 
        .join(" ")
190 
}
191
192 
#[cfg(test)]
193 
mod tests {
194 
    use super::*;
195
196 
    #[test]
197 
    fn dates() {
198 
        assert_eq!(when(0), "1970-01-01 00:00:00Z");
199 
        assert_eq!(when(1_700_000_000_000), "2023-11-14 22:13:20Z");
200 
        assert_eq!(plural(1, "head"), "1 head");
201 
        assert_eq!(plural(2, "head"), "2 heads");
202 
    }
203 
}