using Gdk; using Gee; using Gtk; using Dino.Entities; using Xmpp; namespace Dino.Ui.ChatInput { [GtkTemplate (ui = "/im/dino/Dino/chat_input.ui")] public class View : Box { public string text { owned get { return chat_text_view.text_view.buffer.text; } set { chat_text_view.text_view.buffer.text = value; } } private StreamInteractor stream_interactor; private Conversation? conversation; private HashMap entry_cache = new HashMap(Conversation.hash_func, Conversation.equals_func); [GtkChild] public unowned Box quote_box; [GtkChild] public unowned ChatTextView chat_text_view; [GtkChild] public unowned Button file_button; [GtkChild] public unowned MenuButton emoji_button; [GtkChild] public unowned MenuButton encryption_button; [GtkChild] public unowned Separator file_separator; [GtkChild] public unowned Label chat_input_status; [GtkChild] public unowned Box unavailable_box; [GtkChild] public unowned Image unavailable_icon; [GtkChild] public unowned Label unavailable_label; public EncryptionButton encryption_widget; private bool is_dnd = false; private bool is_night = false; public View init(StreamInteractor stream_interactor) { this.stream_interactor = stream_interactor; stream_interactor.get_module(PresenceManager.IDENTITY).show_received.connect(on_show_received); encryption_widget = new EncryptionButton(stream_interactor, encryption_button); EmojiChooser chooser = new EmojiChooser(); chooser.emoji_picked.connect((emoji) => { chat_text_view.text_view.buffer.insert_at_cursor(emoji, emoji.data.length); }); chooser.closed.connect(do_focus); emoji_button.set_popover(chooser); file_button.tooltip_text = Util.string_if_tooltips_active(_("Send a file")); return this; } public void set_file_upload_active(bool active) { file_button.visible = active; file_separator.visible = active; } public void initialize_for_conversation(Conversation conversation) { if (this.conversation != null) entry_cache[this.conversation] = chat_text_view.text_view.buffer.text; this.conversation = conversation; chat_text_view.text_view.buffer.text = ""; if (entry_cache.has_key(conversation)) { chat_text_view.text_view.buffer.text = entry_cache[conversation]; } update_unavailable_message(); do_focus(); } private void on_show_received(Jid jid, Account account) { if (this.conversation.type_ == Conversation.Type.CHAT && this.conversation.counterpart.equals_bare(jid)) { update_unavailable_message(); } } private void update_unavailable_message() { if (conversation.type_ != Conversation.Type.CHAT) { is_dnd = false; is_night = false; set_unavailable_message(null, null); } else { PresenceManager presence_manager = stream_interactor.get_module(PresenceManager.IDENTITY); Gee.List? full_jids = presence_manager.get_full_jids(conversation.counterpart, conversation.account); if (full_jids != null) { foreach (Jid full_jid in full_jids) { if (presence_manager.get_last_show(full_jid, conversation.account) == Presence.Stanza.SHOW_DND) { if (update_utc_offset_minutes_timeout != 0) { Source.remove(update_utc_offset_minutes_timeout); update_utc_offset_minutes_timeout = 0; } is_dnd = true; set_unavailable_message(Markup.printf_escaped(_("%s has paused their notifications"), Util.get_conversation_display_name(stream_interactor, conversation)), "dino-bell-large-none-symbolic", true); return; } } } is_dnd = false; update_utc_offset_minutes(); } } private uint update_utc_offset_minutes_timeout = 0; private void update_utc_offset_minutes() { Conversation conversation = this.conversation; if (update_utc_offset_minutes_timeout != 0) { Source.remove(update_utc_offset_minutes_timeout); update_utc_offset_minutes_timeout = 0; } if (conversation.type_ == Conversation.Type.CHAT) { stream_interactor.get_module(EntityInfo.IDENTITY).get_utc_offset_minutes_for_bare_jid.begin(conversation.account, conversation.counterpart, (_, res) => { set_utc_offset_minutes(conversation, stream_interactor.get_module(EntityInfo.IDENTITY).get_utc_offset_minutes_for_bare_jid.end(res)); update_utc_offset_minutes_timeout = WeakTimeout.add_once(60000 - (int) (new DateTime.now_utc().get_seconds()*1000d), this, update_utc_offset_minutes); }); } } private void set_utc_offset_minutes(Conversation conversation, int utc_offset_minutes) { if (this.conversation != conversation) return; string? display_time = null; if (utc_offset_minutes != int.MIN && new DateTime.now_local().get_utc_offset() / TimeSpan.MINUTE != utc_offset_minutes) { var datetime = new DateTime.now(new TimeZone.offset(utc_offset_minutes * 60)); if (datetime.get_hour() >= 22 || datetime.get_hour() < 8) { display_time = datetime.format(Util.is_24h_format() ? /* xgettext:no-c-format */ /* Time in 24h format (w/o seconds) */ _("%H∶%M") : /* xgettext:no-c-format */ /* Time in 12h format (w/o seconds) */ _("%l∶%M %p")); } } is_night = (display_time != null); if (!is_dnd) { if (!is_night) { set_unavailable_message(null, null); } else { set_unavailable_message(Markup.printf_escaped(_("It's %s for %s"), display_time, Util.get_conversation_display_name(stream_interactor, conversation)), "dino-clock-alt-symbolic", true); } } } private void set_unavailable_message(string? message, string? icon, bool use_markup = false) { if (message == null) { unavailable_box.visible = false; } else { if (use_markup) { unavailable_label.set_markup(message); } else { unavailable_label.use_markup = use_markup; unavailable_label.label = message; } unavailable_box.visible = true; } if (icon == null) { unavailable_icon.opacity = 0; } else { unavailable_icon.icon_name = icon; unavailable_icon.opacity = 1; } } public void set_input_state(Plugins.InputFieldStatus.MessageType message_type) { switch (message_type) { case Plugins.InputFieldStatus.MessageType.NONE: this.remove_css_class("dino-input-warning"); this.remove_css_class("dino-input-error"); break; case Plugins.InputFieldStatus.MessageType.INFO: this.remove_css_class("dino-input-warning"); this.remove_css_class("dino-input-error"); break; case Plugins.InputFieldStatus.MessageType.WARNING: this.add_css_class("dino-input-warning"); this.remove_css_class("dino-input-error"); break; case Plugins.InputFieldStatus.MessageType.ERROR: this.remove_css_class("dino-input-warning"); this.add_css_class("dino-input-error"); break; } } public void highlight_state_description() { chat_input_status.add_css_class("input-status-highlight-once"); Timeout.add(500, () => { chat_input_status.remove_css_class("input-status-highlight-once"); return false; }); } public void set_quoted_message(Widget quote_widget) { Widget? quote_box_child = quote_box.get_first_child(); if (quote_box_child != null) quote_box.remove(quote_box_child); quote_box.append(quote_widget); quote_box.visible = true; } public void unset_quoted_message() { Widget? quote_box_child = quote_box.get_first_child(); if (quote_box_child != null) quote_box.remove(quote_box_child); quote_box.visible = false; } public void do_focus() { chat_text_view.text_view.grab_focus(); } } }