1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
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 data = {};
local function publish(session, node, item)
local stanza = st.message({from=session.full_jid, type='headline'})
:tag('event', {xmlns='http://jabber.org/protocol/pubsub#event'})
:tag('items', {node=node})
:add_child(item)
:up()
:up();
local bare = session.username..'@'..session.host;
-- store for the future
local user_data = data[bare];
if not user_data then user_data = {}; data[bare] = user_data; end
user_data[node] = stanza;
-- 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:add_iq_handler("c2s", "http://jabber.org/protocol/pubsub", function (session, 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
payload = payload.tags[1];
if payload and payload.name == 'publish' and payload.attr.node then
local node = payload.attr.node;
payload = payload.tags[1];
if payload then
publish(session, node, payload);
return true;
end -- TODO else error
end -- TODO else error
end
end
session.send(st.error_reply(stanza, "cancel", "service-unavailable"));
end);
|
