2016-03-30 12:20:46 +02:00
|
|
|
var MMSocket = function(moduleName) {
|
|
|
|
var self = this;
|
|
|
|
|
2016-04-05 14:35:11 -04:00
|
|
|
if (typeof moduleName !== "string") {
|
|
|
|
throw new Error("Please set the module name for the MMSocket.");
|
2016-03-30 12:20:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
self.moduleName = moduleName;
|
|
|
|
|
|
|
|
// Private Methods
|
2020-02-18 17:09:25 +01:00
|
|
|
self.socket = io("/" + self.moduleName, {
|
2020-04-05 23:00:38 +02:00
|
|
|
path: config.basename + "socket.io"
|
2020-02-18 17:09:25 +01:00
|
|
|
});
|
2016-03-30 12:20:46 +02:00
|
|
|
var notificationCallback = function() {};
|
|
|
|
|
2016-04-19 11:04:36 +02:00
|
|
|
var onevent = self.socket.onevent;
|
|
|
|
self.socket.onevent = function(packet) {
|
2016-03-30 17:22:30 +02:00
|
|
|
var args = packet.data || [];
|
2020-03-15 15:49:34 +01:00
|
|
|
onevent.call(this, packet); // original call
|
2016-03-30 17:22:30 +02:00
|
|
|
packet.data = ["*"].concat(args);
|
2020-03-15 15:49:34 +01:00
|
|
|
onevent.call(this, packet); // additional call to catch-all
|
2016-03-30 17:22:30 +02:00
|
|
|
};
|
2016-03-30 12:20:46 +02:00
|
|
|
|
2016-03-30 17:22:30 +02:00
|
|
|
// register catch all.
|
2016-04-19 11:04:36 +02:00
|
|
|
self.socket.on("*", function(notification, payload) {
|
2016-04-05 14:35:11 -04:00
|
|
|
if (notification !== "*") {
|
2016-03-30 17:22:30 +02:00
|
|
|
notificationCallback(notification, payload);
|
|
|
|
}
|
2016-03-30 12:20:46 +02:00
|
|
|
});
|
|
|
|
|
|
|
|
// Public Methods
|
|
|
|
this.setNotificationCallback = function(callback) {
|
|
|
|
notificationCallback = callback;
|
|
|
|
};
|
|
|
|
|
|
|
|
this.sendNotification = function(notification, payload) {
|
2016-04-05 14:35:11 -04:00
|
|
|
if (typeof payload === "undefined") {
|
2016-03-30 12:20:46 +02:00
|
|
|
payload = {};
|
|
|
|
}
|
2016-04-19 11:04:36 +02:00
|
|
|
self.socket.emit(notification, payload);
|
2016-03-30 12:20:46 +02:00
|
|
|
};
|
2016-04-03 19:52:13 +02:00
|
|
|
};
|