rmux-server 0.1.1

Tokio daemon and request dispatcher for the RMUX terminal multiplexer.
Documentation 
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

use rmux_proto::RmuxError;
use tokio::sync::oneshot;

use super::super::scripting_support::QueueExecutionContext;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub(in super::super) enum PromptType {
    Command,
    Search,
    Target,
    WindowTarget,
}

impl PromptType {
    /// Canonical ordering mirrors tmux `PROMPT_TYPE_*` so iteration over every prompt
    /// type emits rows in the same order tmux prints them.
    pub(in super::super) const ALL: [Self; 4] = [
        Self::Command,
        Self::Search,
        Self::Target,
        Self::WindowTarget,
    ];

    pub(in super::super) fn parse(value: &str) -> Option<Self> {
        match value {
            "command" => Some(Self::Command),
            "search" => Some(Self::Search),
            "target" => Some(Self::Target),
            "window-target" => Some(Self::WindowTarget),
            _ => None,
        }
    }

    pub(super) fn index(self) -> usize {
        match self {
            Self::Command => 0,
            Self::Search => 1,
            Self::Target => 2,
            Self::WindowTarget => 3,
        }
    }

    pub(in super::super) fn label(self) -> &'static str {
        match self {
            Self::Command => "command",
            Self::Search => "search",
            Self::Target => "target",
            Self::WindowTarget => "window-target",
        }
    }
}

#[derive(Debug, Clone)]
pub(in super::super) struct PromptField {
    pub(in super::super) prompt: String,
    pub(in super::super) input: String,
}

#[derive(Debug, Clone)]
pub(in super::super) struct CommandPromptPlan {
    pub(in super::super) requester_pid: u32,
    pub(in super::super) target_client: Option<String>,
    pub(in super::super) context: QueueExecutionContext,
    pub(in super::super) fields: Vec<PromptField>,
    pub(in super::super) template: String,
    pub(in super::super) flags: u8,
    pub(in super::super) prompt_type: PromptType,
    pub(in super::super) background: bool,
    pub(in super::super) format_values: Vec<(String, String)>,
}

#[derive(Debug, Clone)]
pub(in super::super) struct ConfirmBeforePlan {
    pub(in super::super) requester_pid: u32,
    pub(in super::super) target_client: Option<String>,
    pub(in super::super) context: QueueExecutionContext,
    pub(in super::super) prompt: String,
    pub(in super::super) template: String,
    pub(in super::super) confirm_key: char,
    pub(in super::super) default_yes: bool,
    pub(in super::super) background: bool,
    pub(in super::super) format_values: Vec<(String, String)>,
}

#[derive(Debug)]
pub(in super::super) enum PromptStartOutcome {
    Immediate,
    Waiting(oneshot::Receiver<PromptQueueResult>),
}

#[derive(Debug)]
pub(in super::super) struct PromptQueueResult {
    pub(in super::super) inserted: Option<(
        rmux_core::command_parser::ParsedCommands,
        QueueExecutionContext,
    )>,
    pub(in super::super) error: Option<RmuxError>,
    pub(in super::super) responses: Option<Vec<String>>,
}

impl PromptQueueResult {
    pub(in super::super) const fn noop() -> Self {
        Self {
            inserted: None,
            error: None,
            responses: None,
        }
    }
}