server.js

/*
 * Copyright (c) 2014 - Copyright holders CIRSFID and Department of
 * Computer Science and Engineering of the University of Bologna
 *
 * Authors:
 * Monica Palmirani – CIRSFID of the University of Bologna
 * Fabio Vitali – Department of Computer Science and Engineering of the University of Bologna
 * Luca Cervone – CIRSFID of the University of Bologna
 *
 * Permission is hereby granted to any person obtaining a copy of this
 * software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the
 * rights to use, copy, modify, merge, publish, distribute, sublicense,
 * and/or sell copies of the Software, and to permit persons to whom the
 * Software is furnished to do so, subject to the following conditions:
 *
 * The Software can be used by anyone for purposes without commercial gain,
 * including scientific, individual, and charity purposes. If it is used
 * for purposes having commercial gains, an agreement with the copyright
 * holders is required. The above copyright notice and this permission
 * notice shall be included in all copies or substantial portions of the
 * Software.
 *
 * Except as contained in this notice, the name(s) of the above copyright
 * holders and authors shall not be used in advertising or otherwise to
 * promote the sale, use or other dealings in this Software without prior
 * written authorization.
 *
 * The end-user documentation included with the redistribution, if any,
 * must include the following acknowledgment: "This product includes
 * software developed by University of Bologna (CIRSFID and Department of
 * Computer Science and Engineering) and its authors (Monica Palmirani,
 * Fabio Vitali, Luca Cervone)", in the same place and form as other
 * third-party acknowledgments. Alternatively, this acknowledgment may
 * appear in the software itself, in the same form and location as other
 * such third-party acknowledgments.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
 * CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
 * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */


var cluster = require('cluster'),
    Boom = require('boom');

// We use cluster and domains for error management:
// on unhandled exception the child process is restarted.
if (cluster.isMaster) {
    startParentProcess();
} else {
    startChildProcess();
}

function startParentProcess () {
    cluster.fork();
    if (process.env.NODE_ENV !== 'development')
        cluster.on('disconnect', function () {
            console.info('Restarting service.');
            cluster.fork();
        });
}

function startChildProcess () {
    var app = require('express')();
    var config = require('./config.json');
    
    // Middleware
    app.use(require('express-domain-middleware'));
    app.use(require('cors')());
    app.use(require('body-parser').json({limit: '50mb'}));
    app.use(require('body-parser').urlencoded({ extended: true }));

    // Endpoints
    app.use('/xml', require('./xml/router.js'));
    app.use('/documentsdb', require('./documentsdb/router.js'));

    // Error Handling
    app.use(errorHandler);

    // Start https server
    if (config.https.enabled){
        var https = require('https');
        const fs = require('fs');

        console.log("https: enabled");
        const options = {
            key: fs.readFileSync(config.https.key),
            cert: fs.readFileSync(config.https.certificate),
            passphrase: config.https.passPhrase
        };
        module.server = https.createServer(options, app).listen(config.port, function() {
            console.log('Listening on port %d', module.server.address().port)            
        });

    }
    else{
    // Start server
        module.server = app.listen(config.port, function() {
            console.log('Listening on port %d', module.server.address().port)
        });
    }
    
}

function errorHandler (err, req, res, next) {
    err = Boom.wrap(err, err.status);

    // On server error, force restart.
    if (err.isServer) {
        console.error(err.stack);
        try {
            var killtimer = setTimeout(function() {
                process.exit(1);
            }, 5000);
            killtimer.unref();
            module.server.close();
            cluster.worker.disconnect();
        } catch (er2) {
            console.error('Error sending 500!', er2.stack);
        }
    }

    res.status(err.output.statusCode).end(err.output.payload.message);
}