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
//! Event dispatching for background events.
use super::App;
use super::types::{AppEvent, PrListState};
impl App {
/// Apply a background event to app state.
/// Called from the main loop when an AppEvent arrives on the unified channel.
pub fn apply_event(&mut self, event: AppEvent) {
match event {
AppEvent::Terminal(_) => {} // handled separately in main loop
AppEvent::GitStatus(path, status) => {
self.git_statuses.insert(path, status);
}
AppEvent::PrStatus(repo_root, prs) => {
// Clear stale state when a repo has no PRs, otherwise update
if prs.is_empty() {
self.pr_statuses.remove(&repo_root);
} else {
self.pr_statuses.insert(repo_root, prs);
}
// Re-apply worktree filters to merge new PR data
if !self.all_worktrees.is_empty() {
self.apply_worktree_filters();
}
}
AppEvent::WorktreeList(worktrees) => {
let needs_pr_fetch = self.all_worktrees.is_empty() && !worktrees.is_empty();
self.all_worktrees = worktrees;
self.apply_worktree_filters();
// Force a PR re-fetch on initial load or after project switch
// (confirm_project_picker clears all_worktrees, so this fires)
if needs_pr_fetch {
self.last_pr_fetch = std::time::Instant::now() - super::PR_FETCH_INTERVAL;
}
}
AppEvent::WorktreeLog(path, log) => {
if self.worktree_preview_path.as_ref() == Some(&path) {
self.worktree_preview = Some(log);
}
}
AppEvent::AddWorktreeResult(result) => {
self.handle_add_worktree_result(result);
}
AppEvent::AddWorktreePrList(request_id, result) => {
if let Some(ref mut state) = self.pending_add_worktree
&& request_id == state.pr_request_counter
{
state.pr_list = Some(match result {
Ok(prs) => PrListState::Loaded { prs },
Err(msg) => PrListState::Error { message: msg },
});
}
}
AppEvent::SweepProgressUpdate(current, total, handle) => {
self.sweep_progress = Some(super::types::SweepProgress {
total,
current,
handle,
});
}
AppEvent::SweepComplete(result) => {
self.sweep_progress = None;
match result {
Ok(()) => {
self.status_message =
Some(("Sweep complete".to_string(), std::time::Instant::now()));
}
Err(e) => {
self.status_message =
Some((format!("Sweep failed: {e}"), std::time::Instant::now()));
}
}
self.trigger_worktree_refetch();
}
}
}
}