/
events.js
88 lines (68 loc) · 2 KB
/
events.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
var events = require('events');
var util = require('util');
var Q = require('q');
var helper = require('./helper');
var bindAllEvents = function(object, context) {
context = context || this;
var bindMethod = function(method) {
context.on(helper.camelToSnake(method.substr(2)), function() {
var args = Array.prototype.slice.call(arguments, 0);
args.push(context);
object[method].apply(object, args);
});
}
for (var method in object) {
if (helper.isFunction(object[method]) && method.substr(0, 2) === 'on') {
bindMethod(method);
}
}
};
var bufferEvents = function(emitter, eventsToBuffer) {
var listeners = [];
var eventsToReply = [];
var genericListener = function() {
eventsToReply.push(Array.prototype.slice.call(arguments));
};
eventsToBuffer.forEach(function(eventName) {
var listener = genericListener.bind(null, eventName);
listeners.push(listener);
emitter.on(eventName, listener);
});
return function() {
if (!eventsToReply) {
return;
}
// remove all buffering listeners
listeners.forEach(function(listener, i) {
emitter.removeListener(eventsToBuffer[i], listener);
});
// reply
eventsToReply.forEach(function(args) {
events.EventEmitter.prototype.emit.apply(emitter, args);
});
// free-up
listeners = eventsToReply = null;
};
};
// TODO(vojta): log.debug all events
var EventEmitter = function() {
this.bind = bindAllEvents;
this.emitAsync = function(name) {
// TODO(vojta): allow passing args
// TODO(vojta): ignore/throw if listener call done() multiple times
var pending = this.listeners(name).length;
var deferred = Q.defer();
var done = function() {
if (!--pending) {
deferred.resolve();
}
};
this.emit(name, done);
return deferred.promise;
};
};
util.inherits(EventEmitter, events.EventEmitter);
// PUBLISH
exports.EventEmitter = EventEmitter;
exports.bindAll = bindAllEvents;
exports.bufferEvents = bufferEvents;