sessionizer 0.6.4

Tmux session manager
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
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

use std::{
    cmp::Reverse,
    process::{Command, Output},
};

use crate::{Entry, Result, TmuxSession, debug, info, warn};

pub fn fetch_tmux_sessions(handle: impl FnMut(Entry) -> Result<()>) {
    let mut cmd = Command::new("tmux");

    let cmd = cmd.args([
        "list-sessions",
        "-F",
        concat!(
            "#{session_attached},#{session_last_attached},#{session_name},",
            "#{session_path},created #{t/f/%Y-%m-%d %H#:%M:session_created}"
        ),
    ]);

    match cmd.output() {
        Ok(out) => {
            if let Err(err) = parse_tmux_output(out, handle) {
                warn!("failed to parse tmux sessions: {}", err);
            }
        }
        Err(err) => {
            warn!("failed to get tmux output: {}", err);
        }
    }
}

fn parse_tmux_output(out: Output, mut handle: impl FnMut(Entry) -> Result<()>) -> Result<()> {
    if !out.status.success() {
        let err = String::from_utf8_lossy(&out.stderr);
        debug!(status =? out.status, exit_code =? out.status.code(), "tmux error: {}", err);
        if out.status.code() == Some(1) {
            info!("Tmux doesn't seem to be running");
        }
    }

    let out = String::from_utf8(out.stdout)?;
    out.lines()
        .map(parse_session)
        .filter_map(Result::transpose)
        .try_for_each(move |session| handle(Entry::Session(session?)))
}

fn parse_session(tmux_ls_output: &str) -> Result<Option<TmuxSession>> {
    let line = tmux_ls_output.trim();
    if line.is_empty() {
        return Ok(None);
    }
    let parts: [&str; 5] = line
        .splitn(5, ',')
        .collect::<Vec<_>>()
        .try_into()
        .expect("tmux format");

    let attached = parts[0].parse::<u64>()? > 0;
    let last_attached = Reverse(
        Some(parts[1])
            .filter(|s| !s.is_empty())
            .and_then(|s| s.parse::<u64>().ok())
            .unwrap_or(0),
    );
    let name = parts[2].into();
    let root = parts[3].into();
    let info = parts[4].into();
    let session = TmuxSession {
        attached,
        last_attached,
        name,
        root,
        info,
    };

    Ok(Some(session))
}
#[cfg(test)]
mod tests {
    use std::path::Path;

    use super::*;

    #[test]
    fn ignore_blank_line() {
        assert!(matches!(parse_session(""), Ok(None)));
        assert!(matches!(parse_session("\n"), Ok(None)));
        assert!(matches!(parse_session("     \n"), Ok(None)));
    }

    #[test]
    fn parse_result_line() {
        let line = "1,1711654501,sessionizer,/dev/sessionizer,created 2024-03-28 20:35";
        let result = parse_session(line).unwrap().unwrap();

        assert!(result.attached);
        assert_eq!(result.last_attached.0, 1_711_654_501);
        assert_eq!(result.name, "sessionizer");
        assert_eq!(result.root, Path::new("/dev/sessionizer"));
        assert_eq!(result.info, "created 2024-03-28 20:35");
    }

    #[test]
    fn perse_result_list() {
        let result = r"
0,1711100755,neo4rs,/dev/neo4rs,created 2024-03-22 10:45
1,1711654501,sessionizer,/dev/sessionizer,created 2024-03-28 20:35
        ";

        let output = Output {
            status: std::process::ExitStatus::default(),
            stdout: result.as_bytes().to_vec(),
            stderr: Vec::new(),
        };
        let mut sessions = Vec::new();
        let handle = |entry| {
            sessions.push(entry);
            Ok(())
        };

        parse_tmux_output(output, handle).unwrap();

        assert_eq!(
            sessions,
            [
                Entry::Session(TmuxSession {
                    attached: false,
                    last_attached: Reverse(1_711_100_755),
                    name: "neo4rs".into(),
                    root: Path::new("/dev/neo4rs").into(),
                    info: "created 2024-03-22 10:45".into(),
                }),
                Entry::Session(TmuxSession {
                    attached: true,
                    last_attached: Reverse(1_711_654_501),
                    name: "sessionizer".into(),
                    root: Path::new("/dev/sessionizer").into(),
                    info: "created 2024-03-28 20:35".into(),
                }),
            ]
        );
    }
}