resource-watch/webshot

const Koa = require('koa');
const logger = require('logger');
const koaLogger = require('koa-logger');
const koaSimpleHealthCheck = require('koa-simple-healthcheck');
const config = require('config');
const loader = require('loader');
const convert = require('koa-convert');
const { RWAPIMicroservice } = require('rw-api-microservice-node');
const ErrorSerializer = require('serializers/error.serializer');
require('dotenv').config();

async function init() {
    return new Promise((resolve) => {
        const app = new Koa();

        const koaBody = require('koa-body')({
            multipart: true,
            jsonLimit: '50mb',
            formLimit: '50mb',
            textLimit: '50mb'
        });

        app.use(convert(koaBody));

        app.use(async (ctx, next) => {
            try {
                await next();
            } catch (inErr) {
                let error = inErr;
                try {
                    error = JSON.parse(inErr);
                } catch (e) {
                    logger.debug('Could not parse error message - is it JSON?: ', inErr);
                    error = inErr;
                }
                ctx.status = error.status || ctx.status || 500;
                if (ctx.status >= 500) {
                    logger.error(error);
                } else {
                    logger.info(error);
                }

                ctx.body = ErrorSerializer.serializeError(ctx.status, error.message);
                if (process.env.NODE_ENV === 'prod' && ctx.status === 500) {
                    ctx.body = 'Unexpected error';
                }
                ctx.response.type = 'application/vnd.api+json';
            }
        });

        app.use(koaSimpleHealthCheck());
        app.use(koaLogger());

        app.use(RWAPIMicroservice.bootstrap({
            logger,
            gatewayURL: process.env.GATEWAY_URL,
            microserviceToken: process.env.MICROSERVICE_TOKEN,
            fastlyEnabled: process.env.FASTLY_ENABLED,
            fastlyServiceId: process.env.FASTLY_SERVICEID,
            fastlyAPIKey: process.env.FASTLY_APIKEY,
            requireAPIKey: process.env.REQUIRE_API_KEY || true,
            awsRegion: process.env.AWS_REGION,
            awsCloudWatchLogStreamName: config.get('service.name'),
        }));

        loader.loadRoutes(app);

        const port = config.get('service.port');
        const server = app.listen(port);

        logger.info('Server started in ', port);
        resolve({ app, server });
    });
}

module.exports = init;