Mercurial > prosody-modules

comparison mod_muc_moderation/mod_muc_moderation.lua @ 5169:1071a420ff6f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mod_muc_moderation: Refactor to prepare for new version of XEP-0425 Plan is to add support for both versions concurrently for a transition period while clients upgrade.
author Kim Alvefur <zash@zash.se>
date Sun, 19 Feb 2023 17:51:45 +0100
parents 5f12c75fd210
children 4d6af8950016
comparison
equal deleted inserted replaced
5168:e00dc913d965 5169:1071a420ff6f
32 -- Discovering support 32 -- Discovering support
33 module:hook("muc-disco#info", function (event) 33 module:hook("muc-disco#info", function (event)
34 event.reply:tag("feature", { var = xmlns_moderate }):up(); 34 event.reply:tag("feature", { var = xmlns_moderate }):up();
35 end); 35 end);
36 36
37 -- Main handling 37 -- TODO error registry, requires Prosody 0.12+
38 module:hook("iq-set/bare/" .. xmlns_fasten .. ":apply-to", function (event)
39 local stanza, origin = event.stanza, event.origin;
40 38
41 -- Collect info we need 39 -- moderate : function (string, string, string, boolean, string) : boolean, enum, enum, string
42 local apply_to = stanza.tags[1]; 40 local function moderate(actor, room_jid, stanza_id, retract, reason)
43 local moderate_tag = apply_to:get_child("moderate", xmlns_moderate);
44 if not moderate_tag then return end -- some other kind of fastening?
45
46 local reason = moderate_tag:get_child_text("reason");
47 local retract = moderate_tag:get_child("retract", xmlns_retract);
48
49 local room_jid = stanza.attr.to;
50 local room_node = jid.split(room_jid); 41 local room_node = jid.split(room_jid);
51 local room = mod_muc.get_room_from_jid(room_jid); 42 local room = mod_muc.get_room_from_jid(room_jid);
52 43
53 local stanza_id = apply_to.attr.id;
54
55 -- Permissions 44 -- Permissions
56 local actor = stanza.attr.from;
57 local actor_nick = room:get_occupant_jid(actor); 45 local actor_nick = room:get_occupant_jid(actor);
58 local affiliation = room:get_affiliation(actor); 46 local affiliation = room:get_affiliation(actor);
59 -- Retrieve their current role, iff they are in the room, otherwise what they 47 -- Retrieve their current role, iff they are in the room, otherwise what they
60 -- would have based on affiliation. 48 -- would have based on affiliation.
61 local role = room:get_role(actor_nick) or room:get_default_role(affiliation); 49 local role = room:get_role(actor_nick) or room:get_default_role(affiliation);
62 if valid_roles[role or "none"] < valid_roles.moderator then 50 if valid_roles[role or "none"] < valid_roles.moderator then
63 origin.send(st.error_reply(stanza, "auth", "forbidden", "You need a role of at least 'moderator'")); 51 return false, "auth", "forbidden", "You need a role of at least 'moderator'";
64 return true;
65 end 52 end
66 53
67 if not actor_nick then 54 if not actor_nick then
68 local reserved_nickname = room:get_affiliation_data(jid.bare(actor), "reserved_nickname"); 55 local reserved_nickname = room:get_affiliation_data(jid.bare(actor), "reserved_nickname");
69 if reserved_nickname then 56 if reserved_nickname then
82 if i == stanza_id then 69 if i == stanza_id then
83 original, err = item, nil; 70 original, err = item, nil;
84 end 71 end
85 end 72 end
86 end 73 end
74
87 if not original then 75 if not original then
88 if err == "item-not-found" then 76 if err == "item-not-found" then
89 origin.send(st.error_reply(stanza, "modify", "item-not-found")); 77 return false, "modify", "item-not-found";
90 else 78 else
91 origin.send(st.error_reply(stanza, "wait", "internal-server-error")); 79 return false, "wait", "internal-server-error";
92 end 80 end
93 return true;
94 end 81 end
95 82
96 83
97 local announcement = st.message({ from = room_jid, type = "groupchat", id = id.medium(), }) 84 local announcement = st.message({ from = room_jid, type = "groupchat", id = id.medium(), })
98 :tag("apply-to", { xmlns = xmlns_fasten, id = stanza_id }) 85 :tag("apply-to", { xmlns = xmlns_fasten, id = stanza_id })
112 :tag("retracted", { xmlns = xmlns_retract, stamp = dt.datetime() }):up(); 99 :tag("retracted", { xmlns = xmlns_retract, stamp = dt.datetime() }):up();
113 100
114 if reason then 101 if reason then
115 tombstone:text_tag("reason", reason); 102 tombstone:text_tag("reason", reason);
116 end 103 end
104 tombstone:reset();
117 105
118 local was_replaced = muc_log_archive:set(room_node, stanza_id, tombstone); 106 local was_replaced = muc_log_archive:set(room_node, stanza_id, tombstone);
119 if not was_replaced then 107 if not was_replaced then
120 origin.send(st.error_reply(stanza, "wait", "internal-server-error")); 108 return false, "wait", "internal-server-error";
121 return true;
122 end 109 end
123 end 110 end
124 111
125 -- Done, tell people about it 112 -- Done, tell people about it
126 module:log("info", "Message with id '%s' in room %s moderated by %s, reason: %s", stanza_id, room_jid, actor, reason); 113 module:log("info", "Message with id '%s' in room %s moderated by %s, reason: %s", stanza_id, room_jid, actor, reason);
127 room:broadcast_message(announcement); 114 room:broadcast_message(announcement);
115
116 return true;
117 end
118
119 -- Main handling
120 module:hook("iq-set/bare/" .. xmlns_fasten .. ":apply-to", function (event)
121 local stanza, origin = event.stanza, event.origin;
122
123 local actor = stanza.attr.from;
124 local room_jid = stanza.attr.to;
125
126 -- Collect info we need
127 local apply_to = stanza.tags[1];
128 local moderate_tag = apply_to:get_child("moderate", xmlns_moderate);
129 if not moderate_tag then return end -- some other kind of fastening?
130
131 local reason = moderate_tag:get_child_text("reason");
132 local retract = moderate_tag:get_child("retract", xmlns_retract);
133
134 local stanza_id = apply_to.attr.id;
135
136 local ok, error_type, error_condition, error_text = moderate(actor, room_jid, stanza_id, retract, reason);
137 if not ok then
138 origin.send(st.error_reply(stanza, error_type, error_condition, error_text));
139 return true;
140 end
128 141
129 origin.send(st.reply(stanza)); 142 origin.send(st.reply(stanza));
130 return true; 143 return true;
131 end); 144 end);
132 145