cloudcmd/lib/client/socket.js

var CloudCmd, Util, DOM, CloudFunc, io;

(function(CloudCmd, Util, DOM, CloudFunc) {
    'use strict';
    
    CloudCmd.Socket = SocketProto;
        
    function SocketProto(callback) {
        var Socket              = Util.exec.bind(Util),
            AllListeners        = {},
            socket,
            
            CONNECTED           = 'socket connected\n',
            DISCONNECTED        = 'socket disconnected\n',
            
            ERROR_MSG           = 'could not connect to socket.io\n'+
                              'npm i socket.io';
        
        Socket.on               = addListener;
        Socket.addListener      = addListener;
        Socket.removeListener   = removeListener;
        Socket.send             = send;
        Socket.emit             = emit;
        
        Socket.CONNECTED        = CONNECTED;
        Socket.DISCONNECTED     = DISCONNECTED;
        
        function init(callback) {
            DOM.load.js('/socket.io/socket.io.js', {
                onerror : Util.log.bind(Util, ERROR_MSG),
                onload  : function() {
                    Util.exec(callback);
                    
                    if (!socket)
                        connect();
                }
            });
        }
        
        function addListener(name, func) {
           CloudFunc.addListener(name, func, AllListeners, socket);
        }
        
        function removeListener(name, func) {
            CloudFunc.removeListener(name, func, AllListeners, socket);
        }
        
        function send(data) {
            if (socket)
                socket.send(data);
        }
        
        function emit(channel, data) {
            if (socket)
                socket.emit(channel, data);
        }
        
        function setListeners(all, socket) {
            var listeners;
            
            Object.keys(all).forEach(function(name) {
                listeners   = all[name];
                
                listeners.forEach(function(func) {
                    if (func)
                        socket.on(name, func);
                });
            });
        }
        
        function connect() {
            var FIVE_SECONDS = 5000;
            
            socket = io.connect(CloudCmd.HOST, {
                'max reconnection attempts' : Math.pow(2, 32),
                'reconnection limit'        : FIVE_SECONDS
            });
            
            socket.on('connect', function () {
                Util.log(CONNECTED);
            });
            
            setListeners(AllListeners, socket);
            
            socket.on('disconnect', function () {
                Util.log(DISCONNECTED);
            });
            
            socket.on('reconnect_failed', function () {
                Util.log('Could not reconnect. Reload page.');
            });
        }
        
        init(callback);
        
        return Socket;
    }
    
})(CloudCmd, Util, DOM, CloudFunc);