Changeset fb2338d

Timestamp:

2015-10-30T10:28:32Z (9 years ago)

Author:

dequis <dx@…>

Branches:

master

Children:

884577f

Parents:

345577b

git-author:

dequis <dx@…> (13-09-15 04:45:43)

git-committer:

dequis <dx@…> (30-10-15 10:28:32)

Message:

jabber: Self message handling (echo removal) in MUCs

XMPP MUCs always echo own messages, and send messages from other
clients. So, we must display everything except the messages we just
sent.

This implementation uses the jabber stanza cache to add an ID to the
message and attach it to a callback which always returns XT_ABORT.
This way, if we do get the echo, the message packet handler can call
jabber_cache_handle_packet(), and if it returns XT_ABORT, it can skip
that particular message.

Every other message that looks like it comes from our own JID and wasn't
handled by the cache will be displayed, with the OPT_SELFMESSAGE flag

Stanza cache entries expire after some time, so it's not a problem if
the server doesn't echo messages for some reason.

I actually wrote this forever ago, for hipchat, but it works the same
way for standard XMPP MUCs.

File:

• protocols/jabber/conference.c (modified) (5 diffs)

protocols/jabber/conference.c

@@ -26 +26 @@
 
 static xt_status jabber_chat_join_failed(struct im_connection *ic, struct xt_node *node, struct xt_node *orig);
+static xt_status jabber_chat_self_message(struct im_connection *ic, struct xt_node *node, struct xt_node *orig);
 
 struct groupchat *jabber_chat_join(struct im_connection *ic, const char *room, const char *nick, const char *password)
@@ -127 +128 @@
 }
 
+static xt_status jabber_chat_self_message(struct im_connection *ic, struct xt_node *node, struct xt_node *orig)
+{
+        /* This is a self message sent by this bitlbee - just drop it */
+        return XT_ABORT;
+}
+
 struct groupchat *jabber_chat_by_jid(struct im_connection *ic, const char *name)
 {
@@ -171 +178 @@
         node = jabber_make_packet("message", "groupchat", jc->name, node);
 
-        if (!jabber_write_packet(ic, node)) {
-                xt_free_node(node);
-                return 0;
-        }
-        xt_free_node(node);
-
-        return 1;
+        jabber_cache_add(ic, node, jabber_chat_self_message);
+
+        return !jabber_write_packet(ic, node);
 }
 
@@ -403 +406 @@
         char *final_from = NULL;
         char *bare_jid = NULL;
+        guint32 flags = 0;
 
         from = (bud) ? bud->full_jid : xt_find_attr(node, "from");
@@ -466 +470 @@
                 imcb_chat_log(chat, "From conference server: %s", body->text);
                 return;
-        } else if (jc && jc->flags & JCFLAG_MESSAGE_SENT && bud == jc->me) {
-                /* exclude self-messages since they would get filtered out
-                 * but not the ones in the backlog */
+        } else if (jc && jc->flags & JCFLAG_MESSAGE_SENT && bud == jc->me &&
+                   (jabber_cache_handle_packet(ic, node) == XT_ABORT)) {
+                /* Self message marked by this bitlbee, don't show it */
                 return;
         }
 
-        if (bud && jc && bud != jc->me) {
+        if (bud) {
                 bare_jid = jabber_get_bare_jid(bud->ext_jid ? bud->ext_jid : bud->full_jid);
                 final_from = bare_jid;
+                flags = (bud == jc->me) ? OPT_SELFMESSAGE : 0;
         } else {
                 final_from = nick;
         }
 
-        imcb_chat_msg(chat, final_from, body->text, 0, jabber_get_timestamp(node));
+        imcb_chat_msg(chat, final_from, body->text, flags, jabber_get_timestamp(node));
 
         g_free(bare_jid);