next-ft-api-client/src/content.js

'use strict';

var fetchres = require('fetchres');
var logger = require('@financial-times/n-logger').default;
var elasticAgent = require('./utils/elastic-agent');
var signedFetch = require('signed-aws-es-fetch');

module.exports = function(opts) {
	var uuid = [].concat(opts.uuid);
	var returnMany = Array.isArray(opts.uuid);
	var source = 'source' in opts ? opts.source : true;

	if (uuid.length === 0) {
		return Promise.resolve([]);
	}

	const query = {
		docs: uuid.map(function (uuid) {
			return { _id: uuid, _source: source };
		})
	};

	return signedFetch(`https://next-elastic.ft.com/v3_api_v2/item/_mget`, {
			method: 'POST',
			body: JSON.stringify(query),
			timeout: 3000,
			agent: elasticAgent
		})
		.then(function(response) {
			if (!response.ok) {
				logger.warn('Failed getting ElasticSearch content', {
					uuid: uuid,
					status: response.status
				});
			}
			return response;
		})
		.then(fetchres.json)
		.then(function(data) {
			var foundCount = 0;
			var docs = data.docs

				// Filter out any that haven't been found
				.filter(function(item) {
					if (item.found) {
						foundCount++;
						return true;
					}
				})
				.map(function(item) {
					return item._source;
				});
			if (returnMany) {
				return docs;
			}
			if (foundCount === 0) {
				throw new fetchres.BadServerResponseError(404);
			}
			return docs[0];
		});
};