yoanm / async-response-aggregator-server

"use strict";

const logger = require('../logger/taskLogger')('Routing');

const transformers = require('./transformers');

module.exports = (name, handler) => (request, reply) => {

    const promise = new Promise(resolve => {

        request = transformers.in(request);

        logger.info(`[${name.toUpperCase()}][Request]`, {request});

        resolve(handler(request));

    })

        .then(response => {

            logger.info(`[${name.toUpperCase()}][Response]`, {response});

            return response;

        })

    ;

    return promise.then(response => {

        reply({result: transformers.out(response)}).type('application/json');

    })

        .catch(error => {

            // Reply with an error

            logger.error(error.stack);

            reply({error: error.message}).type('application/json').code(500);

            return Promise.resolve();

        })

    ;

};