mirror of https://github.com/bjc/prosody
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
93 lines
3.1 KiB
93 lines
3.1 KiB
|
|
local jid_bare = require "util.jid".bare;
|
|
local jid_split = require "util.jid".split;
|
|
local st = require "util.stanza";
|
|
local hosts = hosts;
|
|
local user_exists = require "core.usermanager".user_exists;
|
|
local is_contact_subscribed = require "core.rostermanager".is_contact_subscribed;
|
|
local pairs, ipairs = pairs, ipairs;
|
|
local next = next;
|
|
local load_roster = require "core.rostermanager".load_roster;
|
|
|
|
local data = {};
|
|
local recipients = {};
|
|
|
|
module:add_identity("pubsub", "pep");
|
|
module:add_feature("http://jabber.org/protocol/pubsub#publish");
|
|
|
|
local function publish(session, node, item)
|
|
local disable = #item.tags ~= 1 or #item.tags[1].tags == 0;
|
|
local bare = session.username..'@'..session.host;
|
|
local stanza = st.message({from=bare, type='headline'})
|
|
:tag('event', {xmlns='http://jabber.org/protocol/pubsub#event'})
|
|
:tag('items', {node=node})
|
|
:add_child(item)
|
|
:up()
|
|
:up();
|
|
|
|
-- store for the future
|
|
local user_data = data[bare];
|
|
if disable then
|
|
if user_data then user_data[node] = nil; end
|
|
if not next(user_data) then data[bare] = nil; end
|
|
else
|
|
if not user_data then user_data = {}; data[bare] = user_data; end
|
|
user_data[node] = stanza;
|
|
end
|
|
|
|
-- broadcast to resources
|
|
stanza.attr.to = bare;
|
|
core_route_stanza(session, stanza);
|
|
|
|
-- broadcast to contacts
|
|
for jid, item in pairs(session.roster) do
|
|
if jid and jid ~= "pending" and (item.subscription == 'from' or item.subscription == 'both') then
|
|
stanza.attr.to = jid;
|
|
core_route_stanza(session, stanza);
|
|
end
|
|
end
|
|
end
|
|
|
|
module:hook("presence/bare", function(event)
|
|
-- inbound presence to bare JID recieved
|
|
local origin, stanza = event.origin, event.stanza;
|
|
|
|
local user = stanza.attr.to or (origin.username..'@'..origin.host);
|
|
local bare = jid_bare(stanza.attr.from);
|
|
local item = load_roster(jid_split(user))[bare];
|
|
if not stanza.attr.to or (item and (item.subscription == 'from' or item.subscription == 'both')) then
|
|
local t = stanza.attr.type;
|
|
local recipient = stanza.attr.from;
|
|
if t == "unavailable" or t == "error" then
|
|
if recipients[user] then recipients[user][recipient] = nil; end
|
|
elseif not t then
|
|
recipients[user] = recipients[user] or {};
|
|
if not recipients[user][recipient] then
|
|
recipients[user][recipient] = true;
|
|
for node, message in pairs(data[user] or {}) do
|
|
message.attr.to = stanza.attr.from;
|
|
origin.send(message);
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end, 10);
|
|
|
|
module:hook("iq/bare/http://jabber.org/protocol/pubsub:pubsub", function(event)
|
|
local session, stanza = event.origin, event.stanza;
|
|
if stanza.attr.type == 'set' and (not stanza.attr.to or jid_bare(stanza.attr.from) == stanza.attr.to) then
|
|
local payload = stanza.tags[1];
|
|
if payload.name == 'pubsub' then -- <pubsub xmlns='http://jabber.org/protocol/pubsub'>
|
|
payload = payload.tags[1];
|
|
if payload and payload.name == 'publish' and payload.attr.node then -- <publish node='http://jabber.org/protocol/tune'>
|
|
local node = payload.attr.node;
|
|
payload = payload.tags[1];
|
|
if payload then -- <item>
|
|
publish(session, node, payload);
|
|
return true;
|
|
end -- TODO else error
|
|
end -- TODO else error
|
|
end
|
|
end
|
|
end);
|
|
|
|
|