cloudcmd/cloudcmd.js

(function() {
    'use strict';
    
    var DIR         = __dirname     + '/',
        main        = require(DIR   + 'lib/server/main'),
        
        LIBDIR      = main.LIBDIR,
        SRVDIR      = main.SRVDIR,
        CLIENTDIR   = LIBDIR + 'client',
        HTMLDIR     = main.HTMLDIR,
        JSONDIR     = main.JSONDIR,
        
        path        = main.path,
        fs          = main.fs,
        files       = main.files,
        CloudFunc   = main.cloudfunc,
        AppCache    = main.appcache,
        Util        = main.util,
        update      = main.update,
        
        server      = main.librequire('server'),
        Minify      = main.minify,
        Config      = main.config,
        
        INDEX_PATH  = HTMLDIR + 'index.html',
        CONFIG_PATH = JSONDIR + 'config.json',
        
        KEY         = DIR   + 'ssl/ssl.key',
        CERT        = DIR + 'ssl/ssl.crt',
        
        FILE_TMPL   = HTMLDIR + 'file.html',
        PANEL_TMPL  = HTMLDIR + 'panel.html',
        PATH_TMPL   = HTMLDIR + 'path.html',
        LINK_TMPL   = HTMLDIR + 'link.html',
        
        FileTemplate, PanelTemplate, PathTemplate, LinkTemplate,
        
        FS          = CloudFunc.FS;
        /* reinit main dir os if we on Win32 should be backslashes */
        DIR         = main.DIR;
    
    readConfig(init);
    
    
    /**
     * additional processing of index file
     */
    function indexProcessing(options) {
        var keysPanel, left, right,
            LEFT    = CloudFunc.PANEL_LEFT,
            RIGHT   = CloudFunc.PANEL_RIGHT,
            data    = options.data,
            panel   = options.panel;
        
        if (!Config.appCache)
            data = Util.removeStr(data, [
                /* min */
                ' manifest=/cloudcmd.appcache',
                /* normal */
                ' manifest="/cloudcmd.appcache"'
            ]);
        
        if (!Config.showKeysPanel) {
            lKeysPanel  = '<div class="keyspanel';
            data        = data.replace(keysPanel + '"', keysPanel +' hidden"');
        }
        
        left    = Util.render(PanelTemplate, {
            id      : LEFT,
            side    : 'left',
            content : panel
        });
        
        right    = Util.render(PanelTemplate, {
            id      : RIGHT,
            side    : 'right',
            content : panel
        });
        
        data = Util.render(data, {
            title   : CloudFunc.getTitle(),
            fm      : left + right
        });
        
        return data;
    }
    
    /**
     * init and process of appcache if it allowed in config
     */
    function appCacheProcessing() {
        var FONT_REMOTE         = '//themes.googleusercontent.com/static/fonts/droidsansmono/v4/ns-m2xQYezAtqh7ai59hJUYuTAAIFFn5GTWtryCmBQ4.woff',
            FONT_LOCAL          = './font/DroidSansMono.woff',
            JQUERY_REMOTE       = '//ajax.googleapis.com/ajax/libs/jquery/2.0.0/jquery.min.js',
            JQUERY_LOCAL        = './lib/client/jquery.js',
            files               = [{}, {}];
            
        files[0][FONT_REMOTE]   = FONT_LOCAL;
        files[1][JQUERY_REMOTE] = JQUERY_LOCAL;
        
        AppCache.addFiles(files);
        AppCache.createManifest();
    }
    
    
    function init() {
        var serverDir, params, filesList, isContain, argvFirst,
            argv = process.argv;
        
        if (update)
            update.get();
        
        /* Determining server.js directory
         * and chang current process directory
         * (usually /) to it.
         * argv[1] - is always script name
         */
        serverDir = path.dirname(argv[1]) + '/';
        
        if (DIR !== serverDir) {
            Util.log('current dir: ' + DIR);
            process.chdir(serverDir);
        }
        
        Util.log('server dir: ' + serverDir);
        
        /* if command line parameter testing resolved 
         * setting config to testing, so server
         * not created, just init and
         * all logs writed to screen */
        argvFirst    = argv[argv.length - 1];
        isContain   = Util.isContainStr(argvFirst, 'test');
        
        if (isContain) {
            Util.log(argv);
            Config.server  = false;
        }
        
        if (Config.logs) {
            Util.log('log param setted up in config.json\n' +
                'from now all logs will be writed to log.txt');
            
            writeLogsToFile();
        }
        
        params = {
            appcache    : appCacheProcessing,
            rest        : main.rest,
            route       : route
        };
        
        filesList = [FILE_TMPL, PANEL_TMPL, PATH_TMPL, LINK_TMPL];
        
        if (Config.ssl)
            filesList.push(KEY, CERT);
        
        files.read(filesList, 'utf-8', function(errors, files) {
            if (errors)
                Util.log(errors);
            else {
                FileTemplate    = files[FILE_TMPL];
                PanelTemplate   = files[PANEL_TMPL];
                PathTemplate    = files[PATH_TMPL];
                LinkTemplate    = files[LINK_TMPL];
                
                if (Config.ssl)
                    params.ssl = {
                        key     : files[KEY],
                        cert    : files[CERT]
                    };
                
                server.start(params);
            }
        });
    }
    
    function readConfig(callback) {
        fs.readFile(CONFIG_PATH, 'utf8', function(error, data) {
            var msg, status, readed;
            
            if (error) 
                status = 'error';
            else {
                status = 'ok';
                readed = Util.parseJSON(data);
                
                main.config = Config = readed;
            }
                
            msg = CloudFunc.formatMsg('read', 'config', status);
            Util.log(msg);
            
            Util.exec(callback);
        });
    }
    
    /**
     * routing of server queries
     */
    function route(request, response, callback) {
        var ret, name, params, isAuth, isFS, query;
        
        if (request && response) {
            ret     = true;
            name    = main.getPathName(request);
            isAuth  = Util.strCmp(name, ['/auth', '/auth/github']);
            isFS    = Util.strCmp(name, '/') || Util.isContainStrAtBegin(name, FS);
            
            params  = {
                request     : request,
                response    : response,
                name        : name
            };
            
            if (isAuth) {
                Util.log('* Routing' + '-> ' + name);
                
                params.name = main.HTMLDIR + name + '.html';
                main.sendFile(params);
            } else if (isFS) {
                query   = main.getQuery(params.request),
                sendContent(name, query, function(name, error, data, isFile) {
                    if (error)
                        main.sendError(params, error);
                    else if (isFile) {
                        params.name = name;
                        main.sendFile(params);
                    } else {
                        params.name = name;
                        main.sendResponse(params, data, true);
                    }
                });
            } else {
                ret = false;
                Util.exec(callback);
            }
        }
        
        return ret;
    }
    
    function sendContent(name, query, callback) {
        name  = Util.removeStrOneTime(name, CloudFunc.FS) || main.SLASH;
        
        fs.stat(name, function(error, stat) {
            var func = Util.retExec(callback, name);
            
            if (error)
                func(error);
            else
                if (!stat.isDirectory())
                    func(error, null, true);
                else {
                    processContent(name, query, callback);
                }
       });
    }
    
    function processContent(name, query, callback) {
        main.commander.getDirContent(name, function(error, json) {
            var data, name,
                isJSON  = Util.isContainStr(query, 'json');
                
                if (!isJSON && !error) 
                    readIndex(json, Util.retExec(callback, INDEX_PATH));
                else {
                    if (!error) {
                        data  = Util.stringifyJSON(json);
                        name +='.json';
                    }
                    
                    Util.exec(callback, name, error, data);
                }
        });
    }
    
    function readIndex(json, callback) {
        Util.ifExec(!Minify, function(params) {
            var name = params && params.name;
            
            fs.readFile(name || INDEX_PATH, 'utf8', function(error, template) {
                var panel, data,
                    config  = main.config,
                    minify  = config.minify;
                
                if (!error) {
                    panel   = CloudFunc.buildFromJSON(json, FileTemplate, PathTemplate, LinkTemplate),
                    data    = indexProcessing({
                        panel   : panel,
                        data    : template,
                    });
                }
                
                Util.exec(callback, error, data);
            });
        },  function(callback) {
                Minify.optimize(INDEX_PATH, {
                    callback    : callback,
                    returnName  : true
                });
        });
    }
    
    
    /* function sets stdout to file log.txt */
    function writeLogsToFile() {
        var stdout      = process.stdout,
            writeFile   = fs.createWriteStream('log.txt'),
            write       = writeFile.write.bind(writeFile);
        
        stdout.write    = write;
    }
})();