gfw-api/fw-alerts

const logger = require('logger');
const Router = require('koa-router');
const ConverterService = require('services/converter.service');
const AlertsValidator = require('validators/alerts.validator');
const AlertsService = require('services/alerts.service');
const ErrorSerializer = require('serializers/error.serializer');
const config = require('config');

const router = new Router({
    prefix: '/fw-alerts',
});

class AlertsRouter {

    static async getAlertsByGeostore(ctx) {
        logger.debug('Getting alerts by geostore');
        const { dataset } = ctx.params;
        const { range } = ctx.query;
        const { geostore } = ctx.params;
        const output = ctx.query.output || 'json';

        if (geostore) {
            let alerts = [];
            try {
                if (dataset === config.get('viirsDatasetSlug')) {
                    logger.debug('Requesting viirs alerts');
                    alerts = await AlertsService.getViirsByGeostore(geostore, range);
                } else if (dataset === config.get('gladDatasetSlug')) {
                    logger.debug('Requesting glad alerts');
                    alerts = await AlertsService.getGladByGeostore(geostore, range);
                }
            } catch (err) {
                logger.error(err);
                const statusCode = err.statusCode || 500;
                ctx.body = ErrorSerializer.serializeError(statusCode, err.message);
                ctx.status = statusCode;
            }
            logger.debug('Parsing data with output', output);
            if (output === 'csv') {
                ctx.set('Content-type', 'text/csv');
                ctx.statusCode = 200;
                logger.debug('Return csv data');
                if (alerts && alerts.length) {
                    const fields = ['lat', 'lon', 'date'];
                    ctx.body = ConverterService.json2csv(alerts, fields);
                } else {
                    ctx.body = '';
                }
            } else {
                // this is not being serialized as we need to minimify the size of the json
                logger.debug('Return json data');
                ctx.body = {
                    data: alerts
                };
            }
        } else {
            ctx.body = ErrorSerializer.serializeError(404, 'Geostore not found');
            ctx.status = 404;
        }
    }

}

router.get('/:dataset/:geostore', AlertsValidator.get, AlertsRouter.getAlertsByGeostore);

module.exports = router;