This repository has been archived by the owner on Mar 10, 2020. It is now read-only.
-
-
Notifications
You must be signed in to change notification settings - Fork 129
/
decorator_ascoltatore.js
152 lines (125 loc) · 3.6 KB
/
decorator_ascoltatore.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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
"use strict";
var async = require("async");
var AbstractAscoltatore = require("./abstract_ascoltatore");
/**
* Decorates totally another ascoltatore, doing nothing
* but forwarding the method calls, this should
* be a reference implementation for other decorators.
*
* @param {Object} decorated The decorated Ascoltatore
* @api public
*/
function DecoratorAscoltatore(decorated) {
this._ascoltatore = decorated;
AbstractAscoltatore.prototype._setPublish.call(this);
}
/**
* Translate the topic name in another
*
* @param String topic The topic name
* @param Function next The function that will be called
* @api public
*/
DecoratorAscoltatore.prototype.wrapTopic = function(topic, next) {
next(null, topic);
};
/**
* Translate the callback in another
*
* @param Function callback The callback to be translated
* @param Function next The function that will be called
* @api public
*/
DecoratorAscoltatore.prototype.wrapCallback = function(callback, next) {
next(null, callback);
};
/**
* Translate the payload in another
*
* @param String payload The payload
* @param Function next The function that will be called
* @api public
*/
DecoratorAscoltatore.prototype.wrapPayload = function(payload, next) {
next(null, payload);
};
/**
* Forwarding methods
*
* @api private
*/
DecoratorAscoltatore.prototype.on = function(event, callback) {
this._ascoltatore.on(event, callback);
return this;
};
DecoratorAscoltatore.prototype.once = function(event, callback) {
this._ascoltatore.once(event, callback);
return this;
};
DecoratorAscoltatore.prototype.removeListener = function(event, callback) {
this._ascoltatore.removeListener(event, callback);
};
DecoratorAscoltatore.prototype.subscribe = function(topic, callback, done) {
var that = this;
async.waterfall([
function(cb) {
that.wrapTopic(topic, cb);
},
function(newTopic, cb) {
that.wrapCallback(callback, function(err, newCallback) {
cb(err, newTopic, newCallback);
});
},
function(newTopic, newCallback, cb) {
that._ascoltatore.subscribe(newTopic, newCallback, cb);
}
], done);
};
DecoratorAscoltatore.prototype.unsubscribe = function(topic, callback, done) {
var that = this;
async.waterfall([
function(cb) {
that.wrapTopic(topic, cb);
},
function(newTopic, cb) {
that.wrapCallback(callback, function(err, newCallback) {
cb(err, newTopic, newCallback);
});
},
function(newTopic, newCallback, cb) {
that._ascoltatore.unsubscribe(newTopic, newCallback, cb);
}
], done);
};
DecoratorAscoltatore.prototype.publish = function(topic, payload, options, done) {
var that = this;
async.waterfall([
function(cb) {
that.wrapTopic(topic, cb);
},
function(newTopic, cb) {
that.wrapPayload(payload, function(err, newPayload) {
cb(err, newTopic, newPayload);
});
},
function(newTopic, newPayload, cb) {
that._ascoltatore.publish(newTopic, newPayload, options, cb);
}
], done);
};
DecoratorAscoltatore.prototype.close = function(done) {
this._ascoltatore.close(done);
};
DecoratorAscoltatore.prototype.registerDomain = function(domain) {
this._ascoltatore.registerDomain(domain);
};
DecoratorAscoltatore.prototype.unsub = function(topic, callback, done) {
this.unsubscribe(topic, callback, done);
};
DecoratorAscoltatore.prototype.sub = function(topic, callback, done) {
this.subscribe(topic, callback, done);
};
DecoratorAscoltatore.prototype.pub = function(topic, payload, options, done) {
this.publish(topic, payload, options, done);
};
module.exports = DecoratorAscoltatore;