1 files changed, 126 insertions, 0 deletions
diff --git a/main/src/ui/conversation_content_view/chat_state_populator.vala b/main/src/ui/conversation_content_view/chat_state_populator.vala
new file mode 100644
index 00000000..54b41b7d
--- /dev/null
+++ b/main/src/ui/conversation_content_view/chat_state_populator.vala
@@ -0,0 +1,126 @@
+using Gee;
+using Gtk;
+
+using Dino.Entities;
+using Xmpp;
+
+namespace Dino.Ui.ConversationSummary {
+
+class ChatStatePopulator : Plugins.ConversationItemPopulator, Plugins.ConversationAdditionPopulator, Object {
+
+    public string id { get { return "chat_state"; } }
+
+    private StreamInteractor? stream_interactor;
+    private Conversation? current_conversation;
+    private Plugins.ConversationItemCollection? item_collection;
+
+    private MetaChatStateItem? meta_item;
+
+    public ChatStatePopulator(StreamInteractor stream_interactor) {
+        this.stream_interactor = stream_interactor;
+
+        stream_interactor.get_module(CounterpartInteractionManager.IDENTITY).received_state.connect((conversation, state) => {
+            if (current_conversation != null && current_conversation.equals(conversation)) {
+                update_chat_state();
+            }
+        });
+        stream_interactor.get_module(MessageProcessor.IDENTITY).message_sent.connect((message, conversation) => {
+            if (conversation.equals(current_conversation)) {
+                update_chat_state();
+            }
+        });
+    }
+
+    public void init(Conversation conversation, Plugins.ConversationItemCollection item_collection, Plugins.WidgetType type) {
+        current_conversation = conversation;
+        this.item_collection = item_collection;
+        this.meta_item = null;
+
+        update_chat_state();
+    }
+
+    public void close(Conversation conversation) { }
+
+    public void populate_timespan(Conversation conversation, DateTime from, DateTime to) { }
+
+    private void update_chat_state() {
+        Gee.List<Jid>? typing_jids = stream_interactor.get_module(CounterpartInteractionManager.IDENTITY).get_typing_jids(current_conversation);
+
+        if (meta_item != null && typing_jids == null) {
+            // Remove state (stoped typing)
+            item_collection.remove_item(meta_item);
+            meta_item = null;
+        } else if (meta_item != null && typing_jids != null) {
+            // Update state (other people typing in MUC)
+            meta_item.set_new(typing_jids);
+        } else if (typing_jids != null) {
+            // New state (started typing)
+            meta_item = new MetaChatStateItem(stream_interactor, current_conversation, typing_jids);
+            item_collection.insert_item(meta_item);
+        }
+    }
+}
+
+private class MetaChatStateItem : Plugins.MetaConversationItem {
+    public override bool dim { get; set; default=true; }
+    public override DateTime sort_time { get; set; default=new DateTime.now_utc().add_years(10); }
+
+    public override bool can_merge { get; set; default=false; }
+    public override bool requires_avatar { get; set; default=false; }
+    public override bool requires_header { get; set; default=false; }
+
+    private StreamInteractor stream_interactor;
+    private Conversation conversation;
+    private Gee.List<Jid> jids = new ArrayList<Jid>();
+    private Label label;
+    private AvatarImage image;
+
+    public MetaChatStateItem(StreamInteractor stream_interactor, Conversation conversation, Gee.List<Jid> jids) {
+        this.stream_interactor = stream_interactor;
+        this.conversation = conversation;
+        this.jids = jids;
+    }
+
+    public override Object? get_widget(Plugins.WidgetType widget_type) {
+        label = new Label("") { xalign=0, vexpand=true, visible=true };
+        label.get_style_context().add_class("dim-label");
+        image = new AvatarImage() { margin_top=2, valign=Align.START, visible=true };
+
+        Box image_content_box = new Box(Orientation.HORIZONTAL, 8) { visible=true };
+        image_content_box.add(image);
+        image_content_box.add(label);
+
+        update();
+        return image_content_box;
+    }
+
+    public void set_new(Gee.List<Jid> jids) {
+        this.jids = jids;
+        update();
+    }
+
+    private void update() {
+        if (image == null || label == null) return;
+
+        image.set_conversation_participants(stream_interactor, conversation, jids.to_array());
+
+        Gee.List<string> display_names = new ArrayList<string>();
+        foreach (Jid jid in jids) {
+            display_names.add(Util.get_participant_display_name(stream_interactor, conversation, jid));
+        }
+        string new_text = "";
+        if (jids.size > 3) {
+            new_text = _("%s, %s and %i others").printf(display_names[0], display_names[1], jids.size - 2);
+        } else if (jids.size == 3) {
+            new_text = _("%s, %s and %s are typing…").printf(display_names[0], display_names[1], display_names[2]);
+        } else if (jids.size == 2) {
+            new_text =_("%s and %s are typing…").printf(display_names[0], display_names[1]);
+        } else {
+            new_text = "%s is typing…".printf(display_names[0]);
+        }
+
+        label.label = new_text;
+    }
+}
+
+}