server.js

#!/usr/bin/env node
/*
 * ----------------------------------------------------------------------------
 * "THE BEER-WARE LICENSE" (Revision 42):
 * <varga.daniel@gmx.de> wrote this file. As long as you retain this notice you
 * can do whatever you want with this stuff. If we meet some day, and you think
 * this stuff is worth it, you can buy me a beer in return Daniel Varga
 * ----------------------------------------------------------------------------
 */

/**
 * Module dependencies
 */

var nodefs = require("node-fs");

var homePath = process.env.HOME || process.env.HOMEPATH || process.env.USERPROFILE;
var appHome = homePath+'/.slingxdcc/';


nodefs.mkdir(appHome+"config",0775,true,function(){


    var logger = require("./lib/xdcclogger"),
        downloadHandler = require("./lib/downloadHandler"),
        express = require('express'),
        morgan = require('morgan'),
        bodyParser = require('body-parser'),
        methodOverride = require('method-override'),
        auth = require("./lib/auth"),
        https = require('https'),
        http = require('http'),
        path = require('path'),
        fs = require('fs'),
        io = require('socket.io'),
        nconf = require('nconf'),
    	log4js = require("log4js"),
    	appLogger = log4js.getLogger('app'),
    	httpLogger = log4js.getLogger('http'),
    	errors = require('common-errors');
        
    log4js.configure('logging/logging-' + (process.env.NODE_ENV || 'Development') + '.json');

    nconf.add('settings', {type: 'file', file: appHome+'/config/settings.json'});

    nconf.defaults({
        "webserver": {
            "port": 3000,
            "ssl": true,
            "ssl.crt": appHome+"ssl/server.crt",
            "ssl.key": appHome+"ssl/server.key"
        }
    });

    nconf.set('webserver',nconf.get('webserver'));
    nconf.save();

    process.on('SIGINT', function () {
        appLogger.info('Shuting down');
        downloadHandler.exit();
        logger.exit();
        io.close(); // Close current server
        process.exit();
    });

    nconf.load(function(){

        var routes = require('./routes'),
            api = require('./routes/api');

        var app = module.exports = express();


        /**
         * Configuration
         */

            // all environments
        app.set('port', nconf.get('webserver:port'));
        app.set('views', __dirname + '/views');
        app.set('view engine', 'jade');

//        app.use(morgan('dev'));
        app.use(bodyParser.json());
        app.use(bodyParser.urlencoded({extended:false}));
        app.use(errors.middleware.crashProtector());
        app.use(methodOverride());
        app.use(express.static(path.join(__dirname, 'public')));
        app.use(log4js.connectLogger(httpLogger, { level: 'auto', format: ':remote-addr - :method :url HTTP/:http-version :status - :response-time ms',nolog: '\\.gif|\\.jpg$' }));
        
        auth.middleware(app);

        /**
         * Routes
         */

        app.get('/', routes.index);
        app.get('/partials/*', routes.partials);

        // JSON API

        app.get('/api/packet/', api.getNumPackets);

        app.get('/api/packet/get/:id', api.packet);
        app.get('/api/packet/search/:string/', api.packetSearch);
        app.get('/api/packet/search/:string/:page', api.packetSearchPaged);
        app.get('/api/packet/list/', api.packetList);
        app.get('/api/packet/list/:page', api.packetListPaged);

        app.get('/api/packet/sorting/', api.getSorting);
        app.get('/api/packet/filter/', api.getFilter);
        app.get('/api/packet/pagelimit/', api.getPageLimit);

        app.get('/api/server/', api.getServer);

        app.get('/api/db/compacting/', api.getNextCompacting);
        app.get('/api/db/compactingfilter/', api.getCompactingFilter);
        app.get('/api/downloads/', auth.authenticate, api.getDownloads);
        app.get('/api/downloads/notifications/', api.getDlNotifications);
        app.get('/api/downloads/notifications/count/', api.getDlNotificationCount);

        app.put('/api/packet/sorting/', api.setSorting);
        app.put('/api/packet/filter/', api.setFilter);
        app.put('/api/packet/pagelimit/', api.setPageLimit);
        app.put('/api/db/compacting/', auth.authenticate, api.compactDb);
        app.put('/api/db/compactingfilter/', auth.authenticate, api.setCompactingFilter);
        app.put('/api/channel/', auth.authenticate, api.channels);
        app.put('/api/downloads/upqueue/', auth.authenticate, api.upQueueDownload);
        app.put('/api/downloads/downqueue/', auth.authenticate, api.downQueueDownload);
        app.put('/api/downloads/cancel', auth.authenticate, api.cancelDownload);



        app.post('/api/server/', auth.authenticate, api.addServer);
        app.post('/api/downloads/', auth.authenticate, api.startDownload);
        app.post('/api/db/compacting/', auth.authenticate, api.startCompactCronjob);

        app.delete('/api/server/:key', auth.authenticate, api.removeServer);
        app.delete('/api/downloads/notifications/', api.clearDlNotifications);
        app.delete('/api/downloads/notifications/count/', api.clearDlNotificationCount);
        app.delete('/api/db/compacting', auth.authenticate, api.stopCompactCronjob);
        
        app.get('/api/user/', auth.authenticate, api.getUsers);
        app.post('/api/user/', auth.authenticate, api.addUser);
        app.put('/api/user/:key', auth.authenticate, api.editUser);
        app.get('/api/user/:key', auth.authenticate, api.getUser);
        app.delete('/api/user/:key', auth.authenticate, api.removeUser);

        app.get('*', routes.index);

        app.use(errors.middleware.errorHandler);


        /**
         * Create server
         */


        fs.readFile(nconf.get('webserver:ssl.key'), function (errorkey, key){
            fs.readFile(nconf.get('webserver:ssl.crt'), function (errorcrt, crt){
                var server;
                if ((errorcrt || errorkey) && nconf.get('webserver:ssl')){
                    server = http.createServer(app);
                    appLogger.info('No key or cert found, !!!Fallback!!! to Http');
                }else if(nconf.get('webserver:ssl')){
                    server = https.createServer({key: key, cert: crt}, app);
                }else{
                    server = http.createServer(app);
                }
                // Hook Socket.io into Express
                io = io.listen(server);
                
                const ioHandler = require('./routes/socket'); 
                // Socket.io Communication
                io.sockets.on('connection', ioHandler);

                /**
                 * Start Server
                 */

                server.listen(app.get('port'), function (){
                	appLogger.info('Server listening on port ' + app.get('port'));
                });
            });
        });

    });
});