tuile 0.3.0

Textual-grade widgets, design system, animation and app runtime on top of ratatui
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

//! Customizing tuile: your own palette, your own spinner frames, and the AI widgets wired to
//! a fake streaming model. Everything here is public API.
//!
//! ```sh
//! cargo run -p tuile --example custom
//! ```

use tuile::prelude::*;

/// A palette: name, dark?, primary; every other role is derived (override any with the setters).
const BRAND: ThemeSpec = ThemeSpec::new("brand", true, Rgb(124, 58, 237));

/// A spinner is just frames + interval; this one lives in your crate, not ours.
const ORBIT: SpinnerDef = SpinnerDef::new("orbit", 120, &["●∙∙", "∙●∙", "∙∙●", "∙●∙"]);

const REPLY: &str = "Sure - I'll switch the cache to an LRU with a 1 000 entry cap and add a hit/miss counter so we can see whether it earns its keep.";

struct Demo {
    chat: ChatState,
    composer: ComposerState,
    started: Instant,
    stream_from: Option<Instant>,
}

impl App for Demo {
    fn draw(&mut self, frame: &mut Frame, now: Instant) {
        let area = frame.area();
        let buf = frame.buffer_mut();
        let th = theme::current();
        fill(buf, area, th.background);

        // stream the canned reply into the last message
        if let Some(t0) = self.stream_from {
            let shown = revealed(REPLY, elapsed(t0, now), 45.0);
            if let Some(last) = self.chat.messages.last_mut() {
                last.text.clear();
                last.text.push_str(shown);
            }
            if shown.len() == REPLY.len() {
                self.chat.finish_stream();
                self.stream_from = None;
            }
        }

        let [chat, status, composer] = Layout::vertical([
            Constraint::Fill(1),
            Constraint::Length(1),
            Constraint::Length(5),
        ])
        .areas(pad(area, 1, 0));
        ChatView::new()
            .show_time(true)
            .now(now)
            .render(chat, buf, &mut self.chat);

        // status line: a custom spinner while streaming, the context gauge always
        let [left, right] =
            Layout::horizontal([Constraint::Length(28), Constraint::Fill(1)]).areas(status);
        if self.stream_from.is_some() {
            Thinking::new("Generating")
                .spinner(&ORBIT)
                .started(self.started)
                .now(now)
                .render(left, buf);
        } else {
            Spinner::new(&spinners::SPARKLE)
                .label("idle - Enter to send")
                .now(now)
                .render(left, buf);
        }
        let used = self
            .chat
            .messages
            .iter()
            .map(|m| m.text.len() as u32 / 4)
            .sum();
        ContextGauge::new(TokenUsage {
            prompt: used,
            completion: 0,
            limit: 8_000,
        })
        .compact(true)
        .render(right, buf);

        PromptComposer::new()
            .model("brand-1")
            .focused(true)
            .now(now)
            .render(composer, buf, &mut self.composer);
    }

    fn event(&mut self, ev: Event, now: Instant) -> Flow {
        if let Event::Key(k) = &ev
            && (ctrl(k, 'c') || k.code == KeyCode::Esc)
        {
            return Flow::Quit;
        }
        self.chat.handle(&ev);
        self.composer.handle(&ev);
        if let Some(text) = self.composer.take_submitted() {
            self.chat.push(ChatMessage::new(Role::User, text));
            self.chat
                .push(ChatMessage::new(Role::Assistant, "").streaming(true));
            self.chat.scroll_to_end();
            self.started = now;
            self.stream_from = Some(now);
        }
        Flow::Continue
    }

    fn animating(&self, _now: Instant) -> bool {
        true // spinner always visible
    }
}

fn main() -> std::io::Result<()> {
    theme::set(Theme::resolve(&BRAND, None));
    let mut chat = ChatState::new();
    chat.push(ChatMessage::new(
        Role::System,
        "brand-1 · custom theme · custom spinner",
    ));
    chat.push(ChatMessage::new(
        Role::Assistant,
        "Ask me anything. Replies are canned, the widgets are not.",
    ));
    run(&mut Demo {
        chat,
        composer: ComposerState::default(),
        started: Instant::now(),
        stream_from: None,
    })
}