diff options
author | metamuffin <metamuffin@disroot.org> | 2025-02-07 18:49:39 +0100 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2025-02-07 18:49:39 +0100 |
commit | 6f2db738f7845b7e75ca2e85b49db0c8b7eee213 (patch) | |
tree | 539cbcfb42d2ca4850717aa933a73ff55afe0375 /client/src/chat.rs | |
parent | 422f4e8ebc02d10e41a0e1a8a570d95ba7943ee4 (diff) | |
download | weareserver-6f2db738f7845b7e75ca2e85b49db0c8b7eee213.tar weareserver-6f2db738f7845b7e75ca2e85b49db0c8b7eee213.tar.bz2 weareserver-6f2db738f7845b7e75ca2e85b49db0c8b7eee213.tar.zst |
chat
Diffstat (limited to 'client/src/chat.rs')
-rw-r--r-- | client/src/chat.rs | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/client/src/chat.rs b/client/src/chat.rs new file mode 100644 index 0000000..e5580f5 --- /dev/null +++ b/client/src/chat.rs @@ -0,0 +1,44 @@ +/* + wearechat - generic multiplayer game with voip + Copyright (C) 2025 metamuffin + + This program is free software: you can redistribute it and/or modify + it under the terms of the GNU Affero General Public License as published by + the Free Software Foundation, version 3 of the License only. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU Affero General Public License for more details. + + You should have received a copy of the GNU Affero General Public License + along with this program. If not, see <https://www.gnu.org/licenses/>. +*/ +use crate::network::Network; +use std::collections::VecDeque; +use weareshared::packets::{Message, Object, Packet}; + +pub struct Chat { + pub send_queue: VecDeque<String>, + pub history: VecDeque<String>, +} +impl Chat { + pub fn new() -> Self { + Self { + send_queue: VecDeque::new(), + history: VecDeque::new(), + } + } + + pub fn incoming(&mut self, _ob: Object, msg: String) { + self.history.push_front(msg); + if self.history.len() > 128 { + self.history.pop_back(); + } + } + pub fn update(&mut self, me: Object, net: &Network) { + for m in self.send_queue.drain(..) { + let _ = net.packet_send.send(Packet::Chat(me, Message(m))); + } + } +} |