resource-watch/query

const { RWAPIMicroservice } = require('rw-api-microservice-node');
const logger = require('logger');
const DatasetNotFound = require('errors/datasetNotFound.error');

class DatasetService {

    static async getDatasetById(datasetId, apiKey) {
        logger.info(`[DatasetService - getDatasetById] Validating presence of dataset with id: ${datasetId}`);

        try {
            const dataset = await RWAPIMicroservice.requestToMicroservice({
                uri: `/v1/dataset/${datasetId}`,
                method: 'GET',
                json: true,
                headers: {
                    'x-api-key': apiKey,
                }
            });
            return dataset.data;
        } catch (err) {
            if (err.statusCode === 404) {
                logger.info(`[DatasetService - getDatasetById] There was an error obtaining a dataset: ${err}`);
                throw new DatasetNotFound(err.error.errors[0].detail);
            }
            logger.warn(`[DatasetService - getDatasetById] There was an error obtaining a dataset: ${err}`);
            throw err;
        }
    }

}

module.exports = DatasetService;