doushio/hooks.js

var async = require('async');

var HOOKS = {}, SYNC_HOOKS = {};

exports.hook = function (key, func) {
	var hs = HOOKS[key];
	if (hs)
		hs.push(func);
	else
		HOOKS[key] = [func];
};

exports.trigger = function (key, arg, cb) {
	var hs = HOOKS[key] || [];
	async.forEachSeries(hs, function (hook, next) {
		hook(arg, next);
	}, function (err) {
		if (err)
			cb(err);
		else
			cb(null, arg);
	});
};

exports.hook_sync = function (key, func) {
	var hs = SYNC_HOOKS[key];
	if (hs)
		hs.push(func);
	else
		SYNC_HOOKS[key] = [func];
};

exports.trigger_sync = function (key, arg) {
	var hs = SYNC_HOOKS[key] || [];
	hs.forEach(function (func) {
		func(arg);
	});
};