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
|
/*
This file is part of keks-meet (https://codeberg.org/metamuffin/keks-meet)
which is licensed under the GNU Affero General Public License (version 3); see /COPYING.
Copyright (C) 2023 metamuffin <metamuffin.org>
*/
use crate::GuiPeer;
use async_std::task::block_on;
use client_native_lib::{
instance::Instance,
protocol::{ChatMesssage, RelayMessage},
};
use egui::{Key, ScrollArea, TextEdit, Ui};
use std::{
collections::VecDeque,
sync::{Arc, RwLock},
};
pub struct Chat {
instance: Arc<Instance>,
input_line: String,
pub history: VecDeque<(Option<Arc<RwLock<GuiPeer>>>, ChatMesssage)>,
}
impl Chat {
pub fn new(instance: Arc<Instance>) -> Self {
Chat {
instance,
input_line: "".into(),
history: VecDeque::new(),
}
}
pub fn ui(&mut self, ui: &mut Ui) {
ScrollArea::vertical().id_source("chat").show(ui, |ui| {
ui.label("this is the chat!");
for (sender, message) in &self.history {
let sender = sender
.as_ref()
.map(|s| s.read().unwrap().display_name())
.unwrap_or(String::from("Me"));
match message {
ChatMesssage::Text(s) => {
ui.label(&format!("{}: {}", sender, s));
}
ChatMesssage::Image(_) => {
ui.label("<image here>");
}
};
}
let r = TextEdit::singleline(&mut self.input_line).show(ui).response;
if r.lost_focus() && r.ctx.input(|i| i.key_down(Key::Enter)) {
self.send(ChatMesssage::Text(self.input_line.to_owned()));
self.input_line = "".into();
r.request_focus();
}
});
}
pub fn add(&mut self, sender: Option<Arc<RwLock<GuiPeer>>>, message: ChatMesssage) {
self.history.push_back((sender, message));
}
pub fn send(&mut self, message: ChatMesssage) {
self.add(None, message.clone());
block_on(self.instance.send_relay(None, RelayMessage::Chat(message)));
}
}
|
