Software /
code /
prosody
Annotate
plugins/mod_carbons.lua @ 13028:b2e6a175537d
mod_debug_reset: Don't delay operations until next tick
For some unknown reason, this was required with the old mock util.time
functions prior to 012d6e7b723a.
After 012d6e7b723a, it breaks. So I'm happy to revert to not delaying
anything. This makes tests pass again.
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Thu, 06 Apr 2023 14:17:50 +0100 |
parent | 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 |
12977
74b9e05af71e
plugins: Prefix module imports with prosody namespace
Kim Alvefur <zash@zash.se>
parents:
12308
diff
changeset
|
6 local st = require "prosody.util.stanza"; |
74b9e05af71e
plugins: Prefix module imports with prosody namespace
Kim Alvefur <zash@zash.se>
parents:
12308
diff
changeset
|
7 local jid_bare = require "prosody.util.jid".bare; |
74b9e05af71e
plugins: Prefix module imports with prosody namespace
Kim Alvefur <zash@zash.se>
parents:
12308
diff
changeset
|
8 local jid_resource = require "prosody.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); |