thegameofcode/cipherlayer

'use strict';

const restify = require('restify');
const _ = require('lodash');

const log = require('./logger/service');
const bodyParserWrapper = require('./middlewares/bodyParserWrapper');

const routes = require('./routes_internal/routes');

module.exports = function () {
    const service = {};

    let server;
    service.start = function (internalPort, done) {
        if (!internalPort) {
            log.info('INTERNAL SERVICE not started because there is no internal_port in config');
            return done();
        }

        log.info(`INTERNAL SERVICE starting on PORT ${internalPort}`);

        server = restify.createServer({
            name: 'cipherlayer-internal-server',
            log
        });

        server.on('after', function (req, res) {
            const logInfo = {
                request: {
                    method: req.method,
                    headers: req.headers,
                    url: req.url,
                    path: req._url.pathname,
                    query: req._url.query,
                    params: req.params,
                    time: req._time
                },
                response: {
                    statusCode: res.statusCode,
                    hasBody: res.hasBody,
                    bodySize: _.size(res.body),
                    time: Date.now()
                },
                user: req.user,
                tokenInfo: req.tokenInfo
            };

            if (logInfo.request.params && logInfo.request.params.password) {
                delete(logInfo.request.params.password);
            }

            req.log.info(logInfo, 'response');
        });

        server.use(restify.queryParser());
        server.use(bodyParserWrapper(restify.bodyParser({maxBodySize: 1024 * 1024 * 3})));

        routes(server);

        server.listen(internalPort, function () {
            log.info(`INTERNAL SERVICE listening on PORT ${internalPort}`);
            return done();
        });
    };

    service.stop = function (done) {
        if (!server) {
            return done();
        }
        server.close(function () {
            return done();
        });
    };

    return service;
}();