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
//! Effects for App.
use super::{Action, App};
impl App {
/// Repository and file history share the same fully identified request.
pub(super) fn open_history_fetch(&mut self) {
if let Some(request) = self.browser.history_request().cloned() {
self.spawn_log(request);
}
}
/// Restyle prepared content at the update boundary, never during drawing.
pub(super) fn sync_highlight_theme(&mut self) {
let theme = self.effective_theme();
if theme.syntax == self.highlight_syntax && theme.semantic.text == self.highlight_text {
return;
}
self.highlighter.set_theme(&theme);
self.browser.restyle_blobs(&self.highlighter);
if let Some(commit) = self.browser.commit() {
commit.set_theme(&theme);
}
self.highlight_syntax = theme.syntax;
self.highlight_text = theme.semantic.text;
}
/// If the selected file's blob isn't loaded, fetch it.
pub(super) fn maybe_load_blob(&mut self) {
if let Some((sha, name)) = self.browser.take_blob_request() {
self.handle_action(Action::LoadBlob { sha, name });
}
}
/// Hand the prepared editor job to the main loop (which owns the
/// terminal and performs the suspend/resume dance).
pub fn take_editor_job(&mut self) -> Option<crate::editor::EditorJob> {
self.pending_editor.take()
}
/// Queued yank text, drained by the main loop once per iteration.
pub fn take_clipboard(&mut self) -> Option<String> {
self.pending_clipboard.take()
}
/// 0019 polish: the band's last-commit context for the file under
/// preview — memo hit dresses immediately, a miss spawns the
/// one-shot fetch (ambient; errors stay silent).
pub(super) fn band_apply_or_fetch(&mut self) {
if !self.provider.capabilities().log || self.browser.at_commit_view() {
return;
}
let Some((owner, name)) = self.browser.repo_coords() else {
return;
};
let Some((path, _)) = self.browser.selected_file() else {
return;
};
let ref_ = self
.browser
.current_ref()
.map(str::to_string)
.unwrap_or_default();
let key = (format!("{owner}/{name}"), path.clone(), ref_.clone());
match self.last_commits.get(&key) {
Some(entry) => {
self.browser.preview.set_band(
Some(path),
Some(crate::components::preview::BandContext {
sha: entry.sha.clone(),
subject: entry.subject.clone(),
author: entry.author.clone(),
date: entry.date.clone(),
}),
);
}
None => {
self.spawn_last_commit(format!("{owner}/{name}"), path, Some(ref_));
}
}
}
/// A malformed/unreadable config still starts on defaults — but
/// the warning is sticky-visible (0022 honesty class, 0023 round
/// 2): degraded slot when free, the status line always.
pub fn config_warning(&mut self, warning: Option<String>) {
if let Some(warning) = warning {
if self.degraded.is_none() {
self.degraded = Some(warning.clone());
}
self.status = Some(warning);
}
}
/// Clear the transient only when it still is this operation's
/// loading marker — a background success must never erase a fresh
/// ERROR from an unrelated in-flight operation (0023 round 3: the
/// default-org warm-up wiped the direct-arg repo's 404).
pub(crate) fn clear_loading_status(&mut self, prefixes: &[&str]) {
let Some(status) = &self.status else {
return;
};
let is_loading = status.ends_with('…') && prefixes.iter().any(|p| status.starts_with(p));
if is_loading {
self.status = None;
}
}
/// 0018 M3: the quit-time restart trace — only when this session
/// knew about an update (the `↑` chip), compare the on-disk
/// binary once. The caller prints it after terminal restore.
pub fn update_exit_note(&self) -> Option<String> {
self.update_tag.as_ref()?;
crate::selfupdate::disk_newer_note()
}
}