npm/remotedev-server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Let the app know when the monitor is disconnected

Browse Source 
Related to https://github.com/zalmoxisus/remote-redux-devtools/pull/20
This commit is contained in:
Zalmoxisus 2016-04-20 15:57:13 +03:00
parent b1a4bb662d
commit a78072ade8
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
bin/worker.js
View File

@ -31,17 +31,25 @@ module.exports.run = function(worker) {
}); });
scServer.on('connection', function(socket) { scServer.on('connection', function(socket) {
var channelToWatch, channelToEmit;
socket.on('login', function (credentials, respond) { socket.on('login', function (credentials, respond) {
var channelName = credentials === 'master' ? 'respond' : 'log'; if (credentials === 'master') {
channelToWatch = 'respond'; channelToEmit = 'log';
} else {
channelToWatch = 'log'; channelToEmit = 'respond';
}
worker.exchange.subscribe('sc-' + socket.id).watch(function(msg) { worker.exchange.subscribe('sc-' + socket.id).watch(function(msg) {
socket.emit(channelName, msg); socket.emit(channelToWatch, msg);
}); });
respond(null, channelName); respond(null, channelToWatch);
}); });
socket.on('disconnect', function() { socket.on('disconnect', function() {
var channel = worker.exchange.channel('sc-' + socket.id); var channel = worker.exchange.channel('sc-' + socket.id);
channel.unsubscribe(); channel.destroy(); channel.unsubscribe(); channel.destroy();
scServer.exchange.publish('log', { id: socket.id, type: 'DISCONNECTED' }); scServer.exchange.publish(
channelToEmit,
{ id: socket.id, type: 'DISCONNECTED' }
);
}); });
}); });
}; };