Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-01-23 18:55:26 +00:00
Code Issues Projects Releases Wiki Activity

refactor(socket)add onConnection

Browse source
This commit is contained in:
coderaiser 2014-01-27 08:32:45 -05:00
parent a5a4ad98c1
commit 9463f861fb
1 changed files with 35 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

71
lib/server/socket.js
View file

@ -24,6 +24,7 @@
INFO_LOG_LEVEL = 2,
ENV = process.env,
WIN32 = main.WIN32,
ConNum = 0,
HELP = {
stdout : CLOUDCMD + ' exit \n' +
CLOUDCMD + ' update \n',
@ -51,11 +52,10 @@
* @pServer {Object} started server object
*/
exports.listen = function(pServer) {
var lRet, lConnNum, lMsg;
var ret;
if (io) {
io = io.listen(pServer);
lConnNum = 0;
io.set('log level', INFO_LOG_LEVEL);
@ -79,45 +79,44 @@
'jsonp-polling'
]);
lRet = io.sockets.on('connection', function (socket) {
var onDisconect, onConnect;
++lConnNum;
if (!Clients[lConnNum]) {
lMsg = log(lConnNum, 'connected\n');
jsonSend(socket, {
stdout : lMsg
});
Clients[lConnNum] = true;
onConnect = onMessage(lConnNum, socket);
onDisconect = Util.retFunc(disconnect, lConnNum);
socket.on('message', onConnect);
socket.on('disconnect', function() {
socket.removeListener('message', onConnect);
socket.removeListener('disconnect', onDisconect);
socket = null;
});
} else {
lMsg = log(lConnNum, ' in use. Reconnecting...');
jsonSend(socket, {
stdout: lMsg
});
socket.disconnect();
}
});
ret = io.sockets.on('connection', onConnection);
}
return lRet;
};
function onConnection(socket) {
var msg, onDisconect, onConnect;
++ConNum;
if (!Clients[ConNum]) {
msg = log(ConNum, 'connected\n');
jsonSend(socket, {
stdout : msg
});
Clients[ConNum] = true;
onConnect = onMessage(ConNum, socket);
onDisconect = Util.retFunc(disconnect, ConNum);
socket.on('message', onConnect);
socket.on('disconnect', function() {
socket.removeListener('message', onConnect);
socket.removeListener('disconnect', onDisconect);
});
} else {
msg = log(ConNum, ' in use. Reconnecting...');
jsonSend(socket, {
stdout: msg
});
socket.disconnect();
}
}
function disconnect(connNum) {
OnMessageFuncs [connNum] =
ClientFuncs [connNum] = null;