prosody-modules: mod_pubsub_subscription/mod_pubsub

annotate mod_pubsub_subscription/mod_pubsub_subscription.lua @ 5252:85f0c6c1c24f

mod_http_oauth2: Fix attempt to index a boolean value _This_ function signature strikes again It returns true, payload, but only passed the boolean on in place of the client, tripping up client_subset()

author	Kim Alvefur <zash@zash.se>
date	Thu, 16 Mar 2023 00:06:43 +0100
parents	97fac0ba0469
children	b40750891bee

rev	line source
4511 97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	1 local st = require "util.stanza";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	2 local uuid = require "util.uuid";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	3 local mt = require "util.multitable";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	4 local cache = require "util.cache";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	5
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	6 local xmlns_pubsub = "http://jabber.org/protocol/pubsub";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	7 local xmlns_pubsub_event = "http://jabber.org/protocol/pubsub#event";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	8
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	9 -- TODO persist
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	10 -- TODO query known pubsub nodes to sync current subscriptions
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	11 -- TODO subscription ids per 'item' would be handy
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	12
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	13 local pending_subscription = cache.new(256); -- uuid → node
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	14 local pending_unsubscription = cache.new(256); -- uuid → node
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	15 local active_subscriptions = mt.new() -- service \| node \| uuid \| { item }
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	16 function module.save()
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	17 return { active_subscriptions = active_subscriptions.data }
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	18 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	19 function module.restore(data)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	20 if data and data.active_subscriptions then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	21 active_subscriptions.data = data.active_subscriptions
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	22 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	23 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	24
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	25 local valid_events = {"subscribed"; "unsubscribed"; "error"; "item"; "retract"; "purge"; "delete"}
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	26
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	27 local function subscription_added(item_event)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	28 local item = item_event.item;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	29 assert(item.service, "pubsub subscription item MUST have a 'service' field.");
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	30 assert(item.node, "pubsub subscription item MUST have a 'node' field.");
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	31
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	32 local already_subscibed = false;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	33 for _ in active_subscriptions:iter(item.service, item.node, nil) do -- luacheck: ignore 512
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	34 already_subscibed = true;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	35 break
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	36 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	37
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	38 item._id = uuid.generate();
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	39 local iq_id = uuid.generate();
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	40 pending_subscription:set(iq_id, item._id);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	41 active_subscriptions:set(item.service, item.node, item._id, item);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	42
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	43 if not already_subscibed then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	44 module:send(st.iq({ type = "set", id = iq_id, from = module.host, to = item.service })
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	45 :tag("pubsub", { xmlns = xmlns_pubsub })
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	46 :tag("subscribe", { jid = module.host, node = item.node }));
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	47 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	48 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	49
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	50 for _, event_name in ipairs(valid_events) do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	51 module:hook("pubsub-event/host/"..event_name, function (event)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	52 for _, _, _, _, cb in active_subscriptions:iter(event.service, event.node, nil, "on_"..event_name) do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	53 pcall(cb, event);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	54 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	55 end);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	56 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	57
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	58 module:hook("iq/host", function (event)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	59 local stanza = event.stanza;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	60 local service = stanza.attr.from;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	61
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	62 if not stanza.attr.id then return end -- shouldn't be possible
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	63
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	64 local subscribed_node = pending_subscription:get(stanza.attr.id);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	65 pending_subscription:set(stanza.attr.id, nil);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	66 local unsubscribed_node = pending_unsubscription:get(stanza.attr.id);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	67 pending_unsubscription:set(stanza.attr.id, nil);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	68
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	69 if stanza.attr.type == "result" then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	70 local pubsub_wrapper = stanza:get_child("pubsub", xmlns_pubsub);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	71 local subscription = pubsub_wrapper and pubsub_wrapper:get_child("subscription");
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	72 if not subscription then return end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	73 local node = subscription.attr.node;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	74
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	75 local what;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	76 if subscription.attr.subscription == "subscribed" then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	77 what = "on_subscribed";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	78 elseif subscription.attr.subscription == "none" then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	79 what = "on_unsubscribed";
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	80 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	81 if not what then return end -- there are other states but we don't handle them
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	82 for _, _, _, _, cb in active_subscriptions:iter(service, node, nil, what) do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	83 cb(event);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	84 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	85 return true;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	86
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	87 elseif stanza.attr.type == "error" then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	88 local node = subscribed_node or unsubscribed_node;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	89 local error_type, error_condition, reason, pubsub_error = stanza:get_error();
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	90 local err = { type = error_type, condition = error_condition, text = reason, extra = pubsub_error };
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	91 if active_subscriptions:get(service) then
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	92 for _, _, _, _, cb in active_subscriptions:iter(service, node, nil, "on_error") do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	93 cb(err);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	94 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	95 return true;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	96 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	97 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	98 end, 1);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	99
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	100 local function subscription_removed(item_event)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	101 local item = item_event.item;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	102 active_subscriptions:set(item.service, item.node, item._id, nil);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	103 local node_subs = active_subscriptions:get(item.service, item.node);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	104 if node_subs and next(node_subs) then return end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	105
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	106 local iq_id = uuid.generate();
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	107 pending_unsubscription:set(iq_id, item._id);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	108
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	109 module:send(st.iq({ type = "set", id = iq_id, from = module.host, to = item.service })
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	110 :tag("pubsub", { xmlns = xmlns_pubsub })
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	111 :tag("unsubscribe", { jid = module.host, node = item.node }))
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	112 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	113
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	114 module:handle_items("pubsub-subscription", subscription_added, subscription_removed, true);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	115
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	116 module:hook("message/host", function(event)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	117 local origin, stanza = event.origin, event.stanza;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	118 local ret = nil;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	119 local service = stanza.attr.from;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	120 module:log("debug", "Got message/host: %s", stanza:top_tag());
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	121 for event_container in stanza:childtags("event", xmlns_pubsub_event) do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	122 for pubsub_event in event_container:childtags() do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	123 module:log("debug", "Got pubsub event %s", pubsub_event:top_tag());
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	124 local node = pubsub_event.attr.node;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	125 module:fire_event("pubsub-event/host/"..pubsub_event.name, {
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	126 stanza = stanza;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	127 origin = origin;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	128 event = pubsub_event;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	129 service = service;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	130 node = node;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	131 });
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	132 ret = true;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	133 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	134 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	135 return ret;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	136 end);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	137
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	138 module:hook("pubsub-event/host/items", function (event)
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	139 for item in event.event:childtags() do
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	140 module:log("debug", "Got pubsub item event %s", item:top_tag());
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	141 event.item = item;
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	142 event.payload = item.tags[1];
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	143 module:fire_event("pubsub-event/host/"..item.name, event);
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	144 end
97fac0ba0469 mod_pubsub_subscription: New module providing an API for pubsub subscriptions Kim Alvefur <zash@zash.se> parents: diff changeset	145 end);

Mercurial > prosody-modules

annotate mod_pubsub_subscription/mod_pubsub_subscription.lua @ 5252:85f0c6c1c24f