cloudcmd/lib/client/socket.js

var CloudCmd, Util, DOM, io;

(function(CloudCmd, Util, DOM) {
    'use strict';
    
    CloudCmd.Socket = new SocketProto(CloudCmd, Util, DOM);
        
    function SocketProto(CloudCmd, Util, DOM) {
        var Messages        = [],
            socket,
            Terminal,
            
            ERROR_MSG       = 'could not connect to socket.io\n'+
                              'npm i socket.io';
        
        DOM.jsload('/socket.io/lib/socket.io.js', {
            onerror : Util.retFunc(Util.log, ERROR_MSG),
            onload  : connect
        });
        
        function connect() {
            var FIVE_SECONDS = 5000;
            
            socket = io.connect(CloudCmd.HOST, {
                'max reconnection attempts' : Math.pow(2, 32),
                'reconnection limit'        : FIVE_SECONDS
            });
            
            CloudCmd.Socket = socket;
            
            socket.on('connect', function () {
                outToTerminal({stdout: 'socket connected\n'});
            });
            
            socket.on('message', function (msg) {
                var lMsg = Util.parseJSON(msg);
                
                outToTerminal(lMsg);
            });
            
            socket.on('disconnect', function () {
                outToTerminal({stderr: 'socket disconected\n'});
            });
            
            socket.on('reconnect_failed', function () {
                Util.log('Could not reconnect. Reload page.');
            });
        }
            
        function outToTerminal(pMsg) {
            var i, n, lResult, lStdout, lStderr,
                lConsole = CloudCmd.Console;
            
            DOM.Images.hideLoad();
            
            if (Util.isObject(lConsole)) {
                if (Messages.length) {
                    /* show oll msg from buffer */
                    for (i = 0, n = Messages.length; i < n; i++) {
                        lStdout = Messages[i].stdout;
                        lStderr = Messages[i].stderr;
                        
                        if (lStdout)
                            lConsole.log(lStdout);
                        
                        if (lStderr) {
                            /* if it's object - convert is to string' */
                            if (Util.isObject(lStderr))
                                lStderr =  Util.stringifyJSON(lStderr);
                                
                            lConsole.error(lStderr);
                        }
                    }
                    Messages = [];
                }
                
                lStdout = pMsg.stdout;
                lStderr = pMsg.stderr;
                
                if (lStdout)
                    lResult = lConsole.log(lStdout);
                            
                if (lStderr)
                    lResult = lConsole.error(lStderr);
            }
            else
                Messages.push(pMsg);
            
            Util.log(pMsg);
            
            return lResult;
        }
    }
    
})(CloudCmd, Util, DOM);