asciinema 3.2.0

Terminal session recorder, streamer, and player
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

use std::time::UNIX_EPOCH;

use async_trait::async_trait;
use tokio::io::{self, AsyncWrite, AsyncWriteExt};

use crate::asciicast;
use crate::encoder::Encoder;
use crate::notifier::Notifier;
use crate::session::{self, Metadata};

pub struct FileWriter {
    writer: Box<dyn AsyncWrite + Send + Unpin>,
    encoder: Box<dyn Encoder + Send>,
    notifier: Box<dyn Notifier>,
    metadata: Metadata,
}

pub struct LiveFileWriter {
    writer: Box<dyn AsyncWrite + Send + Unpin>,
    encoder: Box<dyn Encoder + Send>,
    notifier: Box<dyn Notifier>,
}

impl FileWriter {
    pub fn new(
        writer: Box<dyn AsyncWrite + Send + Unpin>,
        encoder: Box<dyn Encoder + Send>,
        notifier: Box<dyn Notifier>,
        metadata: Metadata,
    ) -> Self {
        FileWriter {
            writer,
            encoder,
            notifier,
            metadata,
        }
    }

    pub async fn start(mut self) -> io::Result<LiveFileWriter> {
        let timestamp = self
            .metadata
            .time
            .duration_since(UNIX_EPOCH)
            .unwrap()
            .as_secs();

        let header = asciicast::Header {
            term_cols: self.metadata.term.size.0,
            term_rows: self.metadata.term.size.1,
            term_type: self.metadata.term.type_.clone(),
            term_version: self.metadata.term.version.clone(),
            term_theme: self.metadata.term.theme.clone(),
            timestamp: Some(timestamp),
            idle_time_limit: self.metadata.idle_time_limit,
            command: self.metadata.command.as_ref().cloned(),
            title: self.metadata.title.as_ref().cloned(),
            env: Some(self.metadata.env.clone()),
        };

        if let Err(e) = self.writer.write_all(&self.encoder.header(&header)).await {
            let _ = self
                .notifier
                .notify("Write error, session won't be recorded".to_owned())
                .await;

            return Err(e);
        }

        Ok(LiveFileWriter {
            writer: self.writer,
            encoder: self.encoder,
            notifier: self.notifier,
        })
    }
}

#[async_trait]
impl session::Output for LiveFileWriter {
    async fn event(&mut self, event: session::Event) -> io::Result<()> {
        match self
            .writer
            .write_all(&self.encoder.event(event.into()))
            .await
        {
            Ok(_) => Ok(()),

            Err(e) => {
                let _ = self
                    .notifier
                    .notify("Write error, recording suspended".to_owned())
                    .await;

                Err(e)
            }
        }
    }

    async fn flush(&mut self) -> io::Result<()> {
        self.writer.write_all(&self.encoder.flush()).await
    }
}

impl From<session::Event> for asciicast::Event {
    fn from(event: session::Event) -> Self {
        match event {
            session::Event::Output(time, text) => asciicast::Event::output(time, text),
            session::Event::Input(time, text) => asciicast::Event::input(time, text),
            session::Event::Resize(time, tty_size) => {
                asciicast::Event::resize(time, tty_size.into())
            }
            session::Event::Marker(time, label) => asciicast::Event::marker(time, label),
            session::Event::Exit(time, status) => asciicast::Event::exit(time, status),
        }
    }
}