2016-03-30 12:20:46 +02:00
|
|
|
var MMSocket = function(moduleName) {
|
|
|
|
var self = this;
|
|
|
|
|
|
|
|
if (typeof moduleName !== 'string') {
|
|
|
|
throw new Error('Please set the module name for the MMSocket.');
|
|
|
|
}
|
|
|
|
|
|
|
|
self.moduleName = moduleName;
|
|
|
|
|
|
|
|
// Private Methods
|
2016-03-30 17:22:30 +02:00
|
|
|
socket = io.connect('/' + self.moduleName);
|
2016-03-30 12:20:46 +02:00
|
|
|
var notificationCallback = function() {};
|
|
|
|
|
2016-03-30 17:22:30 +02:00
|
|
|
var onevent = socket.onevent;
|
|
|
|
socket.onevent = function (packet) {
|
|
|
|
var args = packet.data || [];
|
|
|
|
onevent.call (this, packet); // original call
|
|
|
|
packet.data = ["*"].concat(args);
|
|
|
|
onevent.call(this, packet); // additional call to catch-all
|
|
|
|
};
|
2016-03-30 12:20:46 +02:00
|
|
|
|
2016-03-30 17:22:30 +02:00
|
|
|
// register catch all.
|
|
|
|
socket.on('*', function (notification, payload) {
|
|
|
|
if (notification !== '*') {
|
|
|
|
//console.log('Received notification: ' + notification +', payload: ' + payload);
|
|
|
|
notificationCallback(notification, payload);
|
|
|
|
}
|
2016-03-30 12:20:46 +02:00
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
// Public Methods
|
|
|
|
this.setNotificationCallback = function(callback) {
|
|
|
|
notificationCallback = callback;
|
|
|
|
};
|
|
|
|
|
|
|
|
this.sendNotification = function(notification, payload) {
|
|
|
|
if (typeof payload === 'undefined') {
|
|
|
|
payload = {};
|
|
|
|
}
|
2016-03-30 17:22:30 +02:00
|
|
|
socket.emit(notification, payload);
|
2016-03-30 12:20:46 +02:00
|
|
|
};
|
2016-03-30 16:25:24 +02:00
|
|
|
};
|