tmux-deck 0.1.10

A Tmux session manager. Monitoring multi session Realtime preview.
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

use std::time::Duration;
use tokio::sync::mpsc;
use tokio::time::interval;

use crate::actor::messages::{RefreshControl, TmuxCommand, UIEvent};

// =============================================================================
// RefreshActor
// =============================================================================

pub struct RefreshActor {
    #[allow(dead_code)]
    tmux_tx: mpsc::Sender<TmuxCommand>,
    ui_event_tx: mpsc::Sender<UIEvent>,
    refresh_control: RefreshControl,
    interval: Duration,
}

impl RefreshActor {
    pub fn new(
        tmux_tx: mpsc::Sender<TmuxCommand>,
        ui_event_tx: mpsc::Sender<UIEvent>,
        refresh_control: RefreshControl,
        interval: Duration,
    ) -> Self {
        Self {
            tmux_tx,
            ui_event_tx,
            refresh_control,
            interval,
        }
    }

    pub async fn run(self) {
        let mut ticker = interval(self.interval);

        loop {
            ticker.tick().await;

            // Check if refresh is paused (input mode or popup active)
            if self.refresh_control.is_paused() {
                continue;
            }

            // Send RefreshAll command to TmuxActor
            // if self.tmux_tx.send(TmuxCommand::RefreshAll).await.is_err() {
            //     // TmuxActor has been dropped, exit
            //     break;
            // }

            // Notify UIActor about the tick (for capture request if needed)
            if self.ui_event_tx.send(UIEvent::Tick).await.is_err() {
                // UIActor has been dropped, exit
                break;
            }
        }
    }
}