prosody-modules: mod_pubsub_subscription/mod_pubsub

annotate mod_pubsub_subscription/mod_pubsub_subscription.lua @ 5571:ca3c2d11823c

mod_pubsub_feeds: Track latest timestamp seen in feeds instead of last poll This should ensure that an entry that has a publish timestmap after the previously oldest post, but before the time of the last poll check, is published to the node. Previously if an entry would be skipped if it was published at 13:00 with a timestamp of 12:30, where the last poll was at 12:45. For feeds that lack a timestamp, it now looks for the first post that is not published, assuming that the feed is in reverse chronological order, then iterates back up from there.

author	Kim Alvefur <zash@zash.se>
date	Sun, 25 Jun 2023 16:27:55 +0200
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 @ 5571:ca3c2d11823c