Fix socket reference bug. #196

This commit is contained in:
Michael Teeuw
2016-04-19 11:04:36 +02:00
parent 095f08d443
commit a3fedb47cb

View File

@@ -8,11 +8,11 @@ var MMSocket = function(moduleName) {
self.moduleName = moduleName; self.moduleName = moduleName;
// Private Methods // Private Methods
socket = io.connect("/" + self.moduleName); self.socket = io("/" + self.moduleName);
var notificationCallback = function() {}; var notificationCallback = function() {};
var onevent = socket.onevent; var onevent = self.socket.onevent;
socket.onevent = function(packet) { self.socket.onevent = function(packet) {
var args = packet.data || []; var args = packet.data || [];
onevent.call(this, packet); // original call onevent.call(this, packet); // original call
packet.data = ["*"].concat(args); packet.data = ["*"].concat(args);
@@ -20,7 +20,7 @@ var MMSocket = function(moduleName) {
}; };
// register catch all. // register catch all.
socket.on("*", function(notification, payload) { self.socket.on("*", function(notification, payload) {
if (notification !== "*") { if (notification !== "*") {
//console.log('Received notification: ' + notification +', payload: ' + payload); //console.log('Received notification: ' + notification +', payload: ' + payload);
notificationCallback(notification, payload); notificationCallback(notification, payload);
@@ -36,6 +36,6 @@ var MMSocket = function(moduleName) {
if (typeof payload === "undefined") { if (typeof payload === "undefined") {
payload = {}; payload = {};
} }
socket.emit(notification, payload); self.socket.emit(notification, payload);
}; };
}; };