tmux-deck 0.1.12

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
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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

use crate::app::TmuxSession;
use tokio::sync::oneshot;

// =============================================================================
// TmuxActor Commands (UIActor/RefreshActor → TmuxActor)
// =============================================================================

#[derive(Debug)]
pub enum TmuxCommand {
    /// Refresh all sessions, windows, and panes
    RefreshAll,

    /// Capture pane content
    CapturePane { target: String, start: i32, end: i32 },

    /// Create a new session
    NewSession { name: String },

    /// Rename an existing session
    RenameSession { old_name: String, new_name: String },

    /// Kill a session
    KillSession { name: String },

    /// Send keys to a pane
    SendKeys {
        target: String,
        keys: String,
        reply: Option<oneshot::Sender<TmuxResponse>>,
    },

    /// Switch client to a target
    SwitchClient {
        target: String,
        reply: Option<oneshot::Sender<TmuxResponse>>,
    },
}

// =============================================================================
// TmuxActor Responses (TmuxActor → UIActor)
// =============================================================================

#[derive(Debug, Clone)]
pub enum TmuxResponse {
    /// Sessions data refreshed
    SessionsRefreshed { sessions: Vec<TmuxSession> },

    /// Pane content captured
    PaneCaptured {
        #[allow(dead_code)]
        target: String,
        content: String,
    },

    /// Session created result
    SessionCreated {
        name: String,
        success: bool,
        error: Option<String>,
    },

    /// Session renamed result
    SessionRenamed {
        success: bool,
        error: Option<String>,
    },

    /// Session killed result
    SessionKilled {
        success: bool,
        error: Option<String>,
    },

    /// Keys sent result
    KeysSent {
        #[allow(dead_code)]
        success: bool,
        error: Option<String>,
    },

    /// Client switched result
    ClientSwitched {
        #[allow(dead_code)]
        target: String,
        success: bool,
        error: Option<String>,
    },

    /// Error occurred
    Error { message: String },
}

// =============================================================================
// UIActor Events (RefreshActor → UIActor)
// =============================================================================

#[derive(Debug, Clone)]
#[allow(dead_code)]
pub enum UIEvent {
    /// Request to capture the currently selected pane
    RequestCapture,

    /// Periodic tick for refresh
    Tick,

    /// Shutdown signal
    Shutdown,
}

// =============================================================================
// Shared State for RefreshActor coordination
// =============================================================================

use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;

#[derive(Debug, Clone)]
pub struct RefreshControl {
    /// Whether refresh is paused (during input mode or popup)
    paused: Arc<AtomicBool>,
}

impl RefreshControl {
    pub fn new() -> Self {
        Self {
            paused: Arc::new(AtomicBool::new(false)),
        }
    }

    pub fn pause(&self) {
        self.paused.store(true, Ordering::SeqCst);
    }

    pub fn resume(&self) {
        self.paused.store(false, Ordering::SeqCst);
    }

    pub fn is_paused(&self) -> bool {
        self.paused.load(Ordering::SeqCst)
    }
}

impl Default for RefreshControl {
    fn default() -> Self {
        Self::new()
    }
}