Software `/` code `/` prosody

Annotate

plugins/mod_carbons.lua @ 12480:7e9ebdc75ce4

net: isolate LuaSec-specifics For this, various accessor functions are now provided directly on the sockets, which reach down into the LuaSec implementation to obtain the information. While this may seem of little gain at first, it hides the implementation detail of the LuaSec+LuaSocket combination that the actual socket and the TLS layer are separate objects. The net gain here is that an alternative implementation does not have to emulate that specific implementation detail and "only" has to expose LuaSec-compatible data structures on the new functions.

author	Jonas Schäfer <jonas@wielicki.name>
date	Wed, 27 Apr 2022 17:44:14 +0200
parent	12308:063ce658c181
child	12977:74b9e05af71e

rev	line source
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	1 -- XEP-0280: Message Carbons implementation for Prosody
7670 2be85cb3bc66 mod_carbons: Make the conditions for ignoring MUC PMs more specific (fixes #744) Kim Alvefur <zash@zash.se> parents: 6841 diff changeset	2 -- Copyright (C) 2011-2016 Kim Alvefur
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	3 --
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	4 -- This file is MIT/X11 licensed.
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	5
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	6 local st = require "util.stanza";
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	7 local jid_bare = require "util.jid".bare;
10802 c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	8 local jid_resource = require "util.jid".resource;
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	9 local xmlns_carbons = "urn:xmpp:carbons:2";
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	10 local xmlns_forward = "urn:xmpp:forward:0";
6804 9f40ae38f0de mod_carbons: Get full_ and bare_sessions from the prosody global [luacheck] Kim Alvefur <zash@zash.se> parents: 6803 diff changeset	11 local full_sessions, bare_sessions = prosody.full_sessions, prosody.bare_sessions;
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	12
11836 8ccb22c0fa56 mod_carbons: Advertise following of recommended rules (closes #1486) Kim Alvefur <zash@zash.se> parents: 11796 diff changeset	13 module:add_feature("urn:xmpp:carbons:rules:0");
8ccb22c0fa56 mod_carbons: Advertise following of recommended rules (closes #1486) Kim Alvefur <zash@zash.se> parents: 11796 diff changeset	14
10802 c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	15 local function is_bare(jid)
c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	16 return not jid_resource(jid);
c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	17 end
c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	18
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	19 local function toggle_carbons(event)
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	20 local origin, stanza = event.origin, event.stanza;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	21 local state = stanza.tags[1].name;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	22 module:log("debug", "%s %sd carbons", origin.full_jid, state);
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	23 origin.want_carbons = state == "enable" and stanza.tags[1].attr.xmlns;
6841 be87ab2d611c plugins: Explicitly return to halt event propagation (session.send sometimes does not return true) Kim Alvefur <zash@zash.se> parents: 6804 diff changeset	24 origin.send(st.reply(stanza));
be87ab2d611c plugins: Explicitly return to halt event propagation (session.send sometimes does not return true) Kim Alvefur <zash@zash.se> parents: 6804 diff changeset	25 return true;
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	26 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	27 module:hook("iq-set/self/"..xmlns_carbons..":disable", toggle_carbons);
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	28 module:hook("iq-set/self/"..xmlns_carbons..":enable", toggle_carbons);
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	29
10818 04a0aa6d7e72 mod_carbons: Describe return types in a comment Kim Alvefur <zash@zash.se> parents: 10802 diff changeset	30 local function should_copy(stanza, c2s, user_bare) --> boolean, reason: string
10779 d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	31 local st_type = stanza.attr.type or "normal";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	32 if stanza:get_child("private", xmlns_carbons) then
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	33 return false, "private";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	34 end
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	35
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	36 if stanza:get_child("no-copy", "urn:xmpp:hints") then
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	37 return false, "hint";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	38 end
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	39
10780 22bbc644c5eb mod_carbons: Fix syntax error [luacheck] Kim Alvefur <zash@zash.se> parents: 10779 diff changeset	40 if not c2s and stanza.attr.to ~= user_bare and stanza:get_child("x", "http://jabber.org/protocol/muc#user") then
10779 d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	41 -- MUC PMs are normally sent to full JIDs
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	42 return false, "muc-pm";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	43 end
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	44
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	45 if st_type == "chat" then
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	46 return true, "type";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	47 end
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	48
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	49 if st_type == "normal" and stanza:get_child("body") then
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	50 return true, "type";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	51 end
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	52
10802 c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	53 -- Normal outgoing chat messages are sent to=bare JID. This clause should
c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	54 -- match the error bounces from those, which would have from=bare JID and
c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	55 -- be incoming (not c2s).
c11f9cd6c761 mod_carbons: Clarify handling of error bounces Kim Alvefur <zash@zash.se> parents: 10786 diff changeset	56 if st_type == "error" and not c2s and is_bare(stanza.attr.from) then
10781 f7e8d299513f mod_carbons: Carbon incoming message delivery failure reports Kim Alvefur <zash@zash.se> parents: 10780 diff changeset	57 return true, "bounce";
f7e8d299513f mod_carbons: Carbon incoming message delivery failure reports Kim Alvefur <zash@zash.se> parents: 10780 diff changeset	58 end
f7e8d299513f mod_carbons: Carbon incoming message delivery failure reports Kim Alvefur <zash@zash.se> parents: 10780 diff changeset	59
12234 1c47162dd965 plugins: Update for namespace bump in XEP-0353 v0.4.0 Kim Alvefur <zash@zash.se> parents: 11836 diff changeset	60 if stanza:get_child(nil, "urn:xmpp:jingle-message:0") or stanza:get_child(nil, "urn:xmpp:jingle-message:1") then
11260 08b397c21805 mod_csi_simple,mod_carbons,mod_mam: Update comment about XEP-0353 Kim Alvefur <zash@zash.se> parents: 10820 diff changeset	61 -- XXX Experimental XEP
10820 e0a09d3af563 mod_carbons: Explicitly carbon XEP-0353: Jingle Message Initiation Kim Alvefur <zash@zash.se> parents: 10818 diff changeset	62 return true, "jingle call";
e0a09d3af563 mod_carbons: Explicitly carbon XEP-0353: Jingle Message Initiation Kim Alvefur <zash@zash.se> parents: 10818 diff changeset	63 end
e0a09d3af563 mod_carbons: Explicitly carbon XEP-0353: Jingle Message Initiation Kim Alvefur <zash@zash.se> parents: 10818 diff changeset	64
11796 71c20650a0b4 mod_carbons: Reduce line count using new util.stanza attr method Kim Alvefur <zash@zash.se> parents: 11260 diff changeset	65 if stanza:get_child_with_attr("stanza-id", "urn:xmpp:sid:0", "by", user_bare) then
71c20650a0b4 mod_carbons: Reduce line count using new util.stanza attr method Kim Alvefur <zash@zash.se> parents: 11260 diff changeset	66 return true, "archived";
10782 6b776f80b96e mod_carbons: Carbon anything that has been archived by the current user Kim Alvefur <zash@zash.se> parents: 10781 diff changeset	67 end
6b776f80b96e mod_carbons: Carbon anything that has been archived by the current user Kim Alvefur <zash@zash.se> parents: 10781 diff changeset	68
10779 d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	69 return false, "default";
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	70 end
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	71
12308 063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	72 module:hook("carbons-should-copy", function (event)
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	73 local should, why = should_copy(event.stanza);
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	74 event.reason = why;
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	75 return should;
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	76 end, -1)
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	77
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	78 local function message_handler(event, c2s)
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	79 local origin, stanza = event.origin, event.stanza;
6803 7ed87299dbf9 mod_carbons: Carbon chat messages or normal messages that have a body Kim Alvefur <zash@zash.se> parents: 6546 diff changeset	80 local orig_type = stanza.attr.type or "normal";
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	81 local orig_from = stanza.attr.from;
7776 63f50a84318f mod_carbons: Rename some variables for clarity Kim Alvefur <zash@zash.se> parents: 7718 diff changeset	82 local bare_from = jid_bare(orig_from);
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	83 local orig_to = stanza.attr.to;
7776 63f50a84318f mod_carbons: Rename some variables for clarity Kim Alvefur <zash@zash.se> parents: 7718 diff changeset	84 local bare_to = jid_bare(orig_to);
63f50a84318f mod_carbons: Rename some variables for clarity Kim Alvefur <zash@zash.se> parents: 7718 diff changeset	85
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	86 -- Stanza sent by a local client
7776 63f50a84318f mod_carbons: Rename some variables for clarity Kim Alvefur <zash@zash.se> parents: 7718 diff changeset	87 local bare_jid = bare_from; -- JID of the local user
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	88 local target_session = origin;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	89 local top_priority = false;
7776 63f50a84318f mod_carbons: Rename some variables for clarity Kim Alvefur <zash@zash.se> parents: 7718 diff changeset	90 local user_sessions = bare_sessions[bare_from];
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	91
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	92 -- Stanza about to be delivered to a local client
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	93 if not c2s then
7776 63f50a84318f mod_carbons: Rename some variables for clarity Kim Alvefur <zash@zash.se> parents: 7718 diff changeset	94 bare_jid = bare_to;
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	95 target_session = full_sessions[orig_to];
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	96 user_sessions = bare_sessions[bare_jid];
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	97 if not target_session and user_sessions then
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	98 -- The top resources will already receive this message per normal routing rules,
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	99 -- so we are going to skip them in order to avoid sending duplicated messages.
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	100 local top_resources = user_sessions.top_resources;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	101 top_priority = top_resources and top_resources[1].priority
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	102 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	103 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	104
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	105 if not user_sessions then
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	106 module:log("debug", "Skip carbons for offline user");
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	107 return -- No use in sending carbons to an offline user
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	108 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	109
12308 063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	110 local event_payload = { stanza = stanza; session = origin };
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	111 local should = module:fire_event("carbons-should-copy", event_payload);
063ce658c181 mod_carbons: Allow plugging into decision of whether to carbon-copy Kim Alvefur <zash@zash.se> parents: 12234 diff changeset	112 local why = event_payload.reason;
10779 d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	113
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	114 if not should then
d95e083931d1 mod_carbons: Refactor in new style (mod_mam/csi) Kim Alvefur <zash@zash.se> parents: 10778 diff changeset	115 module:log("debug", "Not copying stanza: %s (%s)", stanza:top_tag(), why);
10786 a1b633ba9bd9 mod_carbons: Check for and strip 'private' tag before stopping Kim Alvefur <zash@zash.se> parents: 10785 diff changeset	116 if why == "private" and not c2s then
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	117 stanza:maptags(function(tag)
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	118 if not ( tag.attr.xmlns == xmlns_carbons and tag.name == "private" ) then
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	119 return tag;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	120 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	121 end);
10786 a1b633ba9bd9 mod_carbons: Check for and strip 'private' tag before stopping Kim Alvefur <zash@zash.se> parents: 10785 diff changeset	122 end
a1b633ba9bd9 mod_carbons: Check for and strip 'private' tag before stopping Kim Alvefur <zash@zash.se> parents: 10785 diff changeset	123 return;
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	124 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	125
10469 658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	126 local carbon;
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	127 user_sessions = user_sessions and user_sessions.sessions;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	128 for _, session in pairs(user_sessions) do
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	129 -- Carbons are sent to resources that have enabled it
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	130 if session.want_carbons
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	131 -- but not the resource that sent the message, or the one that it's directed to
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	132 and session ~= target_session
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	133 -- and isn't among the top resources that would receive the message per standard routing rules
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	134 and (c2s or session.priority ~= top_priority) then
10469 658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	135 if not carbon then
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	136 -- Create the carbon copy and wrap it as per the Stanza Forwarding XEP
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	137 local copy = st.clone(stanza);
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	138 if c2s and not orig_to then
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	139 stanza.attr.to = bare_from;
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	140 end
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	141 copy.attr.xmlns = "jabber:client";
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	142 carbon = st.message{ from = bare_jid, type = orig_type, }
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	143 :tag(c2s and "sent" or "received", { xmlns = xmlns_carbons })
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	144 :tag("forwarded", { xmlns = xmlns_forward })
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	145 :add_child(copy):reset();
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	146
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	147 end
658b759a1f7a mod_carbons: Improve performance by delaying creation of carbon payload Kim Alvefur <zash@zash.se> parents: 8354 diff changeset	148
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	149 carbon.attr.to = session.full_jid;
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	150 module:log("debug", "Sending carbon to %s", session.full_jid);
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	151 session.send(carbon);
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	152 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	153 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	154 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	155
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	156 local function c2s_message_handler(event)
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	157 return message_handler(event, true)
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	158 end
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	159
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	160 -- Stanzas sent by local clients
7718 c58075c4d375 mod_message, mod_carbons: Adjust event hook priorities to negative (core modules should do this to make overriding from other modules easier) Kim Alvefur <zash@zash.se> parents: 7698 diff changeset	161 module:hook("pre-message/host", c2s_message_handler, -0.5);
c58075c4d375 mod_message, mod_carbons: Adjust event hook priorities to negative (core modules should do this to make overriding from other modules easier) Kim Alvefur <zash@zash.se> parents: 7698 diff changeset	162 module:hook("pre-message/bare", c2s_message_handler, -0.5);
c58075c4d375 mod_message, mod_carbons: Adjust event hook priorities to negative (core modules should do this to make overriding from other modules easier) Kim Alvefur <zash@zash.se> parents: 7698 diff changeset	163 module:hook("pre-message/full", c2s_message_handler, -0.5);
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	164 -- Stanzas to local clients
7718 c58075c4d375 mod_message, mod_carbons: Adjust event hook priorities to negative (core modules should do this to make overriding from other modules easier) Kim Alvefur <zash@zash.se> parents: 7698 diff changeset	165 module:hook("message/bare", message_handler, -0.5);
c58075c4d375 mod_message, mod_carbons: Adjust event hook priorities to negative (core modules should do this to make overriding from other modules easier) Kim Alvefur <zash@zash.se> parents: 7698 diff changeset	166 module:hook("message/full", message_handler, -0.5);
6546 3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	167
3426e903c48d mod_carbons: Import XEP-0280 implementation from prosody-modules (sans compat with older versions of the protocol) Kim Alvefur <zash@zash.se> parents: diff changeset	168 module:add_feature(xmlns_carbons);

prosody

7e9ebdc75ce4

plugins/mod_carbons.lua

Software / code / prosody

Annotate

plugins/mod_carbons.lua @ 12480:7e9ebdc75ce4

Software `/` code `/` prosody