Diff

util/pubsub.lua @ 10519:641e3b7a6a39 0.11

util.pubsub: Pass subscribers trough a filter callback
author Kim Alvefur <zash@zash.se>
date Thu, 06 Jun 2019 18:13:46 +0200
parent 10518:9f50489c2033
child 10521:cbb2c3f8bb1d
child 11565:087b275a9aee
line wrap: on
line diff
--- a/util/pubsub.lua	Thu Jun 06 17:37:15 2019 +0200
+++ b/util/pubsub.lua	Thu Jun 06 18:13:46 2019 +0200
@@ -6,6 +6,7 @@
 local default_config = {
 	itemstore = function (config, _) return cache.new(config["max_items"]) end;
 	broadcaster = function () end;
+	subscriber_filter = function (subs) return subs end;
 	itemcheck = function () return true; end;
 	get_affiliation = function () end;
 	normalize_jid = function (jid) return jid; end;
@@ -567,6 +568,7 @@
 end
 
 function service:broadcast(event, node, subscribers, item, actor, node_obj)
+	subscribers = self.config.subscriber_filter(subscribers, node, event);
 	return self.config.broadcaster(event, node, subscribers, item, actor, node_obj, self);
 end