ferrodock 1.14.0

A fast, native container manager for Docker, written in Rust.
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

//! The open terminal: which session it is, and its screen.

use crate::docker::TermOp;

/// Lines kept above the screen.
const SCROLLBACK: usize = 2000;

pub struct Terminal {
    pub session: u64,
    pub container_id: String,
    pub parser: vt100::Parser,
    /// Set when the shell ended; the message says why, if it wasn't a
    /// normal exit.
    pub ended: Option<Option<String>>,
    /// It ended because the container has no shell.
    pub no_shell: bool,
    /// A debug shell, running in a helper next to the container.
    pub debug: bool,
}

/// Records what a terminal request changes on screen. Returns the session
/// to close, when opening a new one replaces it.
pub fn requested(term: &mut Option<Terminal>, op: &TermOp) -> Option<u64> {
    match op {
        TermOp::Open {
            session,
            container,
            debug,
            cols,
            rows,
            ..
        } => {
            let replaced = term.take().map(|t| t.session);
            *term = Some(Terminal {
                session: *session,
                container_id: container.clone(),
                parser: vt100::Parser::new(*rows, *cols, SCROLLBACK),
                ended: None,
                no_shell: false,
                debug: *debug,
            });
            replaced
        }
        TermOp::Resize {
            session,
            cols,
            rows,
        } => {
            if let Some(t) = term.as_mut().filter(|t| t.session == *session) {
                t.parser.screen_mut().set_size(*rows, *cols);
            }
            None
        }
        TermOp::Close { session } => {
            // The screen stays, marked as ended, until a new session opens.
            if let Some(t) = term.as_mut().filter(|t| t.session == *session) {
                t.ended.get_or_insert(None);
            }
            None
        }
        TermOp::Input { .. } => None,
    }
}

pub fn output(term: &mut Option<Terminal>, session: u64, bytes: &[u8]) {
    if let Some(t) = term.as_mut().filter(|t| t.session == session) {
        t.parser.process(bytes);
    }
}

pub fn exited(term: &mut Option<Terminal>, session: u64, message: Option<String>, no_shell: bool) {
    if let Some(t) = term.as_mut().filter(|t| t.session == session) {
        t.ended = Some(message);
        t.no_shell = no_shell;
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn follows_its_session() {
        let mut term = None;
        let open = |session| TermOp::Open {
            session,
            container: "c1".into(),
            shell: String::new(),
            debug: false,
            cols: 20,
            rows: 4,
        };
        assert_eq!(requested(&mut term, &open(1)), None);
        output(&mut term, 1, b"hello");
        output(&mut term, 9, b"not mine");
        let screen = term.as_ref().unwrap().parser.screen().contents();
        assert_eq!(screen.trim(), "hello");
        // A new session replaces the old one, which should be closed.
        assert_eq!(requested(&mut term, &open(2)), Some(1));
        exited(&mut term, 2, Some("gone".into()), false);
        assert_eq!(term.as_ref().unwrap().ended, Some(Some("gone".into())));
    }
}