Changeset fa8f57b for protocols/jabber/message.c

Timestamp:

2015-11-21T03:01:05Z (8 years ago)

Author:

dequis <dx@…>

Branches:

master

Children:

2f8e3ca

Parents:

8fdeaa5

git-author:

dequis <dx@…> (21-11-15 02:04:06)

git-committer:

dequis <dx@…> (21-11-15 03:01:05)

Message:

jabber: Implement carbons (XEP-0280)

"Message carbons" (XEP-0280) is a server feature to get copies of
outgoing messages sent from other clients connected to the same account.
It's not widely supported by most public XMPP servers (easier if you
host your own), but this will probably change in the next few years.

This is enabled by default if the server supports it. It can also be
disabled with the "carbons" account setting.

Loosely based on a patch by kormat from trac ticket 1021. (Thanks!)
I moved stuff around, simplified things, fixed a few bugs, and used the
new self-messages feature.

File:

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

protocols/jabber/message.c

@@ -24 +24 @@
 #include "jabber.h"
 
-xt_status jabber_pkt_message(struct xt_node *node, gpointer data)
+static xt_status jabber_pkt_message_normal(struct xt_node *node, gpointer data, gboolean carbons_sent)
 {
         struct im_connection *ic = data;
-        char *from = xt_find_attr(node, "from");
+        char *from = xt_find_attr(node, carbons_sent ? "to" : "from");
         char *type = xt_find_attr(node, "type");
         char *id = xt_find_attr(node, "id");
@@ -39 +39 @@
         }
 
-        if (request && id && g_strcmp0(type, "groupchat") != 0) {
+        if (request && id && g_strcmp0(type, "groupchat") != 0 && !carbons_sent) {
                 /* Send a message receipt (XEP-0184), looking like this:
                  * <message from='...' id='...' to='...'>
@@ -128 +128 @@
                 if (fullmsg->len > 0) {
                         imcb_buddy_msg(ic, from, fullmsg->str,
-                                       0, jabber_get_timestamp(node));
+                                       carbons_sent ? OPT_SELFMESSAGE : 0, jabber_get_timestamp(node));
                 }
                 if (room) {
@@ -137 +137 @@
 
                 /* Handling of incoming typing notifications. */
-                if (bud == NULL) {
-                        /* Can't handle these for unknown buddies. */
+                if (bud == NULL || carbons_sent) {
+                        /* Can't handle these for unknown buddies.
+                           And ignore them if it's just carbons */
                 } else if (xt_find_node(node->children, "composing")) {
                         bud->flags |= JBFLAG_DOES_XEP85;
@@ -162 +163 @@
         return XT_HANDLED;
 }
+
+static xt_status jabber_carbons_message(struct xt_node *node, gpointer data)
+{
+        struct im_connection *ic = data;
+        struct xt_node *wrap, *fwd, *msg;
+        gboolean carbons_sent;
+
+        if ((wrap = xt_find_node(node->children, "received"))) {
+                carbons_sent = FALSE;
+        } else if ((wrap = xt_find_node(node->children, "sent"))) {
+                carbons_sent = TRUE;
+        }
+
+        if (wrap == NULL || g_strcmp0(xt_find_attr(wrap, "xmlns"), XMLNS_CARBONS) != 0) {
+                return XT_NEXT;
+        }
+
+        if (!(fwd = xt_find_node(wrap->children, "forwarded")) ||
+             (g_strcmp0(xt_find_attr(fwd, "xmlns"), XMLNS_FORWARDING) != 0) ||
+            !(msg = xt_find_node(fwd->children, "message"))) {
+                imcb_log(ic, "Error: Invalid carbons message received");
+                return XT_ABORT;
+        }
+
+        return jabber_pkt_message_normal(msg, data, carbons_sent);
+}
+
+xt_status jabber_pkt_message(struct xt_node *node, gpointer data)
+{
+        struct im_connection *ic = data;
+        struct jabber_data *jd = ic->proto_data;
+        char *from = xt_find_attr(node, "from");
+
+        if (jabber_compare_jid(jd->me, from)) {    /* Probably a Carbons message */
+                xt_status st = jabber_carbons_message(node, data);
+                if (st == XT_HANDLED || st == XT_ABORT) {
+                        return st;
+                }
+        }
+        return jabber_pkt_message_normal(node, data, FALSE);
+}