aboutsummaryrefslogtreecommitdiffstats
path: root/util/events.lua
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2009-07-09 22:57:32 +0100
committerMatthew Wild <mwild1@gmail.com>2009-07-09 22:57:32 +0100
commitb5dd5312123638261e020e7c11e4c0739255817a (patch)
treeef178fcb55fab651f8bb5014ddfc1879482505f5 /util/events.lua
parent7fcac49c78dcb09aa2774768f02ad1bb2388bf13 (diff)
downloadprosody-b5dd5312123638261e020e7c11e4c0739255817a.tar.gz
prosody-b5dd5312123638261e020e7c11e4c0739255817a.zip
util.events: Convert from Windows line endings
Diffstat (limited to 'util/events.lua')
-rw-r--r--util/events.lua198
1 files changed, 99 insertions, 99 deletions
diff --git a/util/events.lua b/util/events.lua
index 6d69c95d..1d07fe09 100644
--- a/util/events.lua
+++ b/util/events.lua
@@ -1,99 +1,99 @@
-
-local ipairs = ipairs;
-local pairs = pairs;
-local t_insert = table.insert;
-local t_sort = table.sort;
-local select = select;
-
-module "events"
-
-function new()
- local dispatchers = {};
- local handlers = {};
- local event_map = {};
- local function _rebuild_index(event) -- TODO optimize index rebuilding
- local _handlers = event_map[event];
- local index = handlers[event];
- if index then
- for i=#index,1,-1 do index[i] = nil; end
- else index = {}; handlers[event] = index; end
- for handler in pairs(_handlers) do
- t_insert(index, handler);
- end
- t_sort(index, function(a, b) return _handlers[a] > _handlers[b]; end);
- end;
- local function add_handler(event, handler, priority)
- local map = event_map[event];
- if map then
- map[handler] = priority or 0;
- else
- map = {[handler] = priority or 0};
- event_map[event] = map;
- end
- _rebuild_index(event);
- end;
- local function remove_handler(event, handler)
- local map = event_map[event];
- if map then
- map[handler] = nil;
- _rebuild_index(event);
- end
- end;
- local function add_plugin(plugin)
- for event, handler in pairs(plugin) do
- add_handler(event, handler);
- end
- end;
- local function remove_plugin(plugin)
- for event, handler in pairs(plugin) do
- remove_handler(event, handler);
- end
- end;
- local function _create_dispatcher(event) -- FIXME duplicate code in fire_event
- local h = handlers[event];
- if not h then h = {}; handlers[event] = h; end
- local dispatcher = function(...)
- for i=1,#h do
- local ret = h[i](...);
- if ret ~= nil then return ret; end
- end
- end;
- dispatchers[event] = dispatcher;
- return dispatcher;
- end;
- local function get_dispatcher(event)
- return dispatchers[event] or _create_dispatcher(event);
- end;
- local function fire_event(event, ...) -- FIXME duplicates dispatcher code
- local h = handlers[event];
- if h then
- for i=1,#h do
- local ret = h[i](...);
- if ret ~= nil then return ret; end
- end
- end
- end;
- local function get_named_arg_dispatcher(event, ...)
- local dispatcher = get_dispatcher(event);
- local keys = {...};
- local data = {};
- return function(...)
- for i, key in ipairs(keys) do data[key] = select(i, ...); end
- dispatcher(data);
- end;
- end;
- return {
- add_handler = add_handler;
- remove_handler = remove_handler;
- add_plugin = add_plugin;
- remove_plugin = remove_plugin;
- get_dispatcher = get_dispatcher;
- fire_event = fire_event;
- get_named_arg_dispatcher = get_named_arg_dispatcher;
- _dispatchers = dispatchers;
- _handlers = handlers;
- _event_map = event_map;
- };
-end
-
-return _M;
+
+local ipairs = ipairs;
+local pairs = pairs;
+local t_insert = table.insert;
+local t_sort = table.sort;
+local select = select;
+
+module "events"
+
+function new()
+ local dispatchers = {};
+ local handlers = {};
+ local event_map = {};
+ local function _rebuild_index(event) -- TODO optimize index rebuilding
+ local _handlers = event_map[event];
+ local index = handlers[event];
+ if index then
+ for i=#index,1,-1 do index[i] = nil; end
+ else index = {}; handlers[event] = index; end
+ for handler in pairs(_handlers) do
+ t_insert(index, handler);
+ end
+ t_sort(index, function(a, b) return _handlers[a] > _handlers[b]; end);
+ end;
+ local function add_handler(event, handler, priority)
+ local map = event_map[event];
+ if map then
+ map[handler] = priority or 0;
+ else
+ map = {[handler] = priority or 0};
+ event_map[event] = map;
+ end
+ _rebuild_index(event);
+ end;
+ local function remove_handler(event, handler)
+ local map = event_map[event];
+ if map then
+ map[handler] = nil;
+ _rebuild_index(event);
+ end
+ end;
+ local function add_plugin(plugin)
+ for event, handler in pairs(plugin) do
+ add_handler(event, handler);
+ end
+ end;
+ local function remove_plugin(plugin)
+ for event, handler in pairs(plugin) do
+ remove_handler(event, handler);
+ end
+ end;
+ local function _create_dispatcher(event) -- FIXME duplicate code in fire_event
+ local h = handlers[event];
+ if not h then h = {}; handlers[event] = h; end
+ local dispatcher = function(...)
+ for i=1,#h do
+ local ret = h[i](...);
+ if ret ~= nil then return ret; end
+ end
+ end;
+ dispatchers[event] = dispatcher;
+ return dispatcher;
+ end;
+ local function get_dispatcher(event)
+ return dispatchers[event] or _create_dispatcher(event);
+ end;
+ local function fire_event(event, ...) -- FIXME duplicates dispatcher code
+ local h = handlers[event];
+ if h then
+ for i=1,#h do
+ local ret = h[i](...);
+ if ret ~= nil then return ret; end
+ end
+ end
+ end;
+ local function get_named_arg_dispatcher(event, ...)
+ local dispatcher = get_dispatcher(event);
+ local keys = {...};
+ local data = {};
+ return function(...)
+ for i, key in ipairs(keys) do data[key] = select(i, ...); end
+ dispatcher(data);
+ end;
+ end;
+ return {
+ add_handler = add_handler;
+ remove_handler = remove_handler;
+ add_plugin = add_plugin;
+ remove_plugin = remove_plugin;
+ get_dispatcher = get_dispatcher;
+ fire_event = fire_event;
+ get_named_arg_dispatcher = get_named_arg_dispatcher;
+ _dispatchers = dispatchers;
+ _handlers = handlers;
+ _event_map = event_map;
+ };
+end
+
+return _M;