use std::{path::PathBuf, time::Duration}; use chrono::{NaiveDate, NaiveDateTime, TimeDelta}; use iced::{ border::Radius, widget::{ button, column, container, image, row, scrollable, text, text_editor, text_editor::Content, }, Border, Color, Element, Length::{Fill, Shrink}, Theme, }; use indexmap::IndexMap; use jid::JID; use serde::{Deserialize, Serialize}; use uuid::Uuid; use crate::{icons::Icon, MacawChat, MacawMessage}; pub struct MessageView { pub file_root: PathBuf, // references chats, users pub chat: MacawChat, // references users, messages pub messages: IndexMap, pub config: Config, pub new_message: Content, pub shift_pressed: bool, } #[derive(Serialize, Deserialize, Clone)] pub struct Config { pub send_on_enter: bool, } impl Default for Config { fn default() -> Self { Self { send_on_enter: true, } } } #[derive(Debug, Clone)] pub enum Message { MessageHistory(Vec), Message(MacawMessage), MessageCompose(text_editor::Action), SendMessage(String), } pub enum Action { None, SendMessage(String), } impl MessageView { pub fn new(chat: MacawChat, config: &super::Config, file_root: PathBuf) -> Self { Self { chat, // TODO: save position in message history messages: IndexMap::new(), // TODO: save draft (as part of chat struct?) new_message: Content::new(), config: config.message_view_config.clone(), // TODO: have centralised modifier state location? shift_pressed: false, file_root, } } pub fn update(&mut self, message: Message) -> Action { match message { Message::MessageCompose(a) => { match &a { text_editor::Action::Edit(edit) => match edit { text_editor::Edit::Enter => { if self.config.send_on_enter { if !self.shift_pressed { let message = self.new_message.text(); self.new_message = Content::new(); return Action::SendMessage(message); } } else { if self.shift_pressed { let message = self.new_message.text(); self.new_message = Content::new(); return Action::SendMessage(message); } } } _ => {} }, _ => {} } self.new_message.perform(a); Action::None } Message::SendMessage(m) => { self.new_message = Content::new(); Action::SendMessage(m) } Message::MessageHistory(macaw_messages) => { if self.messages.is_empty() { self.messages = macaw_messages .into_iter() .map(|message| (message.id, message)) .collect() } else { for message in macaw_messages { let index = match self .messages .binary_search_by(|_, value| value.timestamp.cmp(&message.timestamp)) { Ok(i) => i, Err(i) => i, }; self.messages.insert_before(index, message.id, message); } } Action::None } Message::Message(macaw_message) => { if let Some((_, last)) = self.messages.last() { if last.timestamp < macaw_message.timestamp { self.messages.insert(macaw_message.id, macaw_message); } else { let index = match self.messages.binary_search_by(|_, value| { value.timestamp.cmp(&macaw_message.timestamp) }) { Ok(i) => i, Err(i) => i, }; self.messages .insert_before(index, macaw_message.id, macaw_message); } } else { self.messages.insert(macaw_message.id, macaw_message); } Action::None } } } pub fn view(&self) -> Element { let mut messages_view = column![].spacing(8).padding(8); let mut last_timestamp = NaiveDateTime::MIN; let mut last_user: Option = None; for (_id, message) in &self.messages { let message_timestamp = message.timestamp.naive_local(); if message_timestamp.date() > last_timestamp.date() { messages_view = messages_view.push(date(message_timestamp.date())); } if last_user.as_ref() != Some(&message.from.jid) || message_timestamp - last_timestamp > TimeDelta::minutes(3) { messages_view = messages_view.push(self.message(message, true)); } else { messages_view = messages_view.push(self.message(message, false)); } last_user = Some(message.from.jid.clone()); last_timestamp = message_timestamp; } let text_editor = text_editor(&self.new_message) .placeholder("new message") .on_action(Message::MessageCompose) .wrapping(text::Wrapping::WordOrGlyph); let message_send_input = row![ text_editor, button(Icon::NewBubble24).on_press(Message::SendMessage(self.new_message.text())) ] .padding(8); column![ scrollable(messages_view) .height(Fill) .width(Fill) .spacing(1) .anchor_bottom(), message_send_input ] .into() } pub fn message<'a>(&'a self, message: &'a MacawMessage, major: bool) -> Element<'a, Message> { let timestamp = message.timestamp.naive_local(); let timestamp = timestamp.time().format("%H:%M").to_string(); if major { let nick: String = if let Some(nick) = &message.from.nick { nick.to_string() } else { message.from.jid.as_bare().to_string() }; let mut header = row![text(nick), text(timestamp)]; if let Some(delivery) = message.delivery { let icon = match delivery { filamento::chat::Delivery::Sending => Some(Icon::Sending16), filamento::chat::Delivery::Written => None, filamento::chat::Delivery::Sent => Some(Icon::Sent16), filamento::chat::Delivery::Delivered => Some(Icon::Delivered16), filamento::chat::Delivery::Read => Some(Icon::Delivered16), filamento::chat::Delivery::Failed => Some(Icon::Error16Color), filamento::chat::Delivery::Queued => Some(Icon::Sending16), }; if let Some(icon) = icon { header = header.push(icon); } } let message_right = column![header, text(&message.body.body)]; let mut major_message = row([]); if let Some(avatar) = &message.from.avatar { let mut path = self.file_root.join(avatar); path.set_extension("jpg"); // info!("got avatar: {:?}", path); major_message = major_message.push(image(path).width(48).height(48)); } major_message = major_message.push(message_right); major_message.into() } else { row![ container(text(timestamp)).width(48), text(&message.body.body) ] .into() } } } pub fn date(date: NaiveDate) -> Element<'static, Message> { container(text(date.to_string())).center_x(Fill).into() }