Mercurial > prosody-modules
view mod_muc_batched_probe/mod_muc_batched_probe.lua @ 5536:96dec7681af8
mod_firewall: Update user marks to store instantly via map store
The original approach was to keep marks in memory only, and persist them at
shutdown. That saves I/O, at the cost of potentially losing marks on an
unclean shutdown.
This change persists marks instantly, which may have some performance overhead
but should be more "correct".
It also splits the marking/unmarking into an event which may be watched or
even fired by other modules.
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Thu, 08 Jun 2023 16:20:42 +0100 |
parents | e06258fc6cf1 |
children |
line wrap: on
line source
-- This module allows you to probe the MUC presences for multiple occupants. -- Copyright (C) 2020 JC Brand local st = require "util.stanza"; local mod_muc = module:depends"muc"; local get_room_from_jid = rawget(mod_muc, "get_room_from_jid") or function (jid) local rooms = rawget(mod_muc, "rooms"); return rooms[jid]; end module:log("debug", "Module loaded"); local function respondToBatchedProbe(event) local stanza = event.stanza; if stanza.attr.type ~= "get" then return; end local query = stanza:get_child("query", "http://jabber.org/protocol/muc#user"); if not query then return; end; local origin = event.origin; local room = get_room_from_jid(stanza.attr.to); local probing_occupant = room:get_occupant_by_real_jid(stanza.attr.from); if probing_occupant == nil then origin.send(st.error_reply(stanza, "cancel", "not-acceptable", "You are not currently connected to this chat", room.jid)); return true; end for item in query:children() do local probed_jid = item.attr.jid; local probed_occupant = room:get_occupant_by_nick(probed_jid); if probed_occupant == nil then local pr = room:build_unavailable_presence(probed_jid, stanza.attr.from); if pr then room:route_stanza(pr); end else local x = st.stanza("x", {xmlns = "http://jabber.org/protocol/muc#user"}); room:publicise_occupant_status(probed_occupant, x, nil, nil, nil, nil, false, probing_occupant); end end origin.send(st.reply(stanza)); return true; end module:hook("iq/bare", respondToBatchedProbe, 1);