diff options
author | Waqas Hussain <waqas20@gmail.com> | 2009-01-09 23:01:21 +0500 |
---|---|---|
committer | Waqas Hussain <waqas20@gmail.com> | 2009-01-09 23:01:21 +0500 |
commit | c8a52134628d2cbc0ded3e422e757579a6cd6c01 (patch) | |
tree | 171bb61a080d498f2bedbfd2ec9dafbf39c5aabb /core/modulemanager.lua | |
parent | 5d25f17e021ef01d4733f00edce4b3b6d5c06b82 (diff) | |
download | prosody-c8a52134628d2cbc0ded3e422e757579a6cd6c01.tar.gz prosody-c8a52134628d2cbc0ded3e422e757579a6cd6c01.zip |
modulemanager: Per-host event hooks for plugins - solves issue 41
Diffstat (limited to 'core/modulemanager.lua')
-rw-r--r-- | core/modulemanager.lua | 18 |
1 files changed, 17 insertions, 1 deletions
diff --git a/core/modulemanager.lua b/core/modulemanager.lua index 4d654ae0..7c1bc0d8 100644 --- a/core/modulemanager.lua +++ b/core/modulemanager.lua @@ -55,6 +55,9 @@ local modulehelpers = setmetatable({}, { __index = _G }); local features_table = multitable_new(); local handler_table = multitable_new(); +local hooked = multitable_new(); +local event_hooks = multitable_new(); + local NULL = {}; -- Load modules when a host is activated @@ -151,6 +154,7 @@ function unload(host, name, ...) handler_info[handlers[1]] = nil; stanza_handlers:remove(param[1], param[2], param[3], param[4]); end + event_hooks:remove(host, name); return true; end @@ -234,7 +238,19 @@ function api:add_feature(xmlns) features_table:set(self.host, self.name, xmlns, true); end -function api:add_event_hook (...) return eventmanager.add_event_hook(...); end +local event_hook = function(host, mod_name, event_name, ...) + if type((...)) == "table" and (...).host and (...).host ~= host then return; end + for handler in pairs(event_hooks:get(host, mod_name, event_name) or NULL) do + handler(...); + end +end; +function api:add_event_hook(name, handler) + if not hooked:get(self.host, self.name, name) then + eventmanager.add_event_hook(name, function(...) event_hook(self.host, self.name, name, ...); end); + hooked:set(self.host, self.name, name, true); + end + event_hooks:set(self.host, self.name, name, handler, true); +end -------------------------------------------------------------------- |