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
|
// In a chat window add dozens of nicks, each printing some random lines.
use libtiny_common::{ChanNameRef, Event, MsgTarget};
use libtiny_tui::TUI;
use std::fs::File;
use std::io::Read;
use std::path::PathBuf;
use tokio::sync::mpsc;
use tokio::time::timeout;
use tokio_stream::wrappers::ReceiverStream;
use tokio_stream::StreamExt;
static SERV: &str = "debug";
static CHAN: &str = "chan";
fn main() {
let chan_target = MsgTarget::Chan {
serv: SERV,
chan: ChanNameRef::new(CHAN),
};
let runtime = tokio::runtime::Builder::new_current_thread()
.enable_all()
.build()
.unwrap();
let local = tokio::task::LocalSet::new();
local.block_on(&runtime, async move {
let (tui, rcv_ev) = TUI::run(PathBuf::from("../tiny/config.yml"));
tui.new_server_tab("debug", None);
tui.new_chan_tab("debug", ChanNameRef::new("chan"));
tui.set_topic(
"This is channel topic",
time::OffsetDateTime::now_utc(),
SERV,
ChanNameRef::new(CHAN),
);
tui.draw();
{
let mut text = String::new();
let mut file = File::open("test/lipsum.txt").unwrap();
file.read_to_string(&mut text).unwrap();
for (line_idx, line) in text.lines().enumerate() {
let now = time::OffsetDateTime::now_utc();
let nick = format!("nick_{}", line_idx);
tui.add_nick(&nick, Some(now), &chan_target);
tui.add_privmsg(&nick, line, now, &chan_target, false, false);
}
}
tui.set_nick(SERV, "some_long_nick_name____");
tui.draw();
// For testing purposes, change the nick between short and long nicks every 5 seconds
let tui_clone = tui.clone();
let (snd_abort, rcv_abort) = mpsc::channel(1);
tokio::task::spawn_local(async move {
let nicks = ["short", "some_long_nick_name____"];
let mut nick_idx = 1;
let mut rcv_abort_fused = ReceiverStream::new(rcv_abort).fuse();
while (timeout(std::time::Duration::from_secs(3), rcv_abort_fused.next()).await)
.is_err()
{
tui_clone.set_nick(SERV, nicks[nick_idx]);
tui_clone.draw();
nick_idx = (nick_idx + 1) % nicks.len();
}
});
ui_task(tui, rcv_ev, snd_abort).await;
});
runtime.block_on(local);
}
async fn ui_task(ui: TUI, rcv_ev: mpsc::Receiver<Event>, mut abort: mpsc::Sender<()>) {
let mut rcv_ev = ReceiverStream::new(rcv_ev);
while let Some(ev) = rcv_ev.next().await {
handle_input_ev(&ui, ev, &mut abort);
ui.draw();
}
}
fn handle_input_ev(ui: &TUI, ev: Event, abort: &mut mpsc::Sender<()>) {
use libtiny_common::Event::*;
match ev {
Cmd { cmd, .. } => {
let words: Vec<&str> = cmd.split_whitespace().collect();
if words.len() == 2 && words[0] == "nick" {
let new_nick = words[1];
ui.set_nick(SERV, new_nick);
}
}
Quit { .. } => {
abort.try_send(()).unwrap();
}
Msg { .. } | Lines { .. } => {}
}
}
|
