ezs-istex/lib/istex-fetch.js

'use strict';

Object.defineProperty(exports, "__esModule", {
    value: true
});

var _extends2 = require('babel-runtime/helpers/extends');

var _extends3 = _interopRequireDefault(_extends2);

var _url = require('url');

var _url2 = _interopRequireDefault(_url);

var _dotProp = require('dot-prop');

var _dotProp2 = _interopRequireDefault(_dotProp);

var _omniFetch = require('omni-fetch');

var _omniFetch2 = _interopRequireDefault(_omniFetch);

var _qs = require('qs');

var _qs2 = _interopRequireDefault(_qs);

var _utils = require('./utils');

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

/**
 * Take `Object` with `id` and returns the document's metadata
 *
 * @param {string} [source="id"]    Field to use to fetch documents
 * @param {string} target
 * @param {string} [id=data.id]     ISTEX Identifier of a document
 * @param {string} [sid="ezs-istex"]    User-agent identifier
 * @returns {Array<Object>}
 */
function ISTEXFetch(data, feed) {
    if (this.isLast()) {
        return feed.close();
    }
    var source = this.getParam('source', 'id');
    var target = this.getParam('target');
    var id = this.getParam('id', _dotProp2.default.get(data, source, data));
    var sid = this.getParam('sid', 'ezs-istex');
    var location = {
        protocol: 'https:',
        host: 'api.istex.fr'
    };
    if (id.length === 40) {
        location.pathname = '/document/'.concat(id);
    } else if (id.search(/^ark:/) === 0) {
        location.pathname = String(id).concat('/record.json');
    } else {
        throw new Error('Unexpected id.');
    }
    var parameters = {
        sid: sid
    };
    var urlObj = (0, _extends3.default)({}, location, {
        search: _qs2.default.stringify(parameters)
    });
    var urlStr = _url2.default.format(urlObj);
    (0, _omniFetch2.default)(urlStr).then(function (response) {
        return response.json();
    }).then(function (json) {
        if (json._error) {
            throw new Error(json._error);
        }
        return feed.send((0, _utils.newValue)(json, target, data));
    }).catch(function (err) {
        err.url = urlStr;
        err.input = data;
        err.target = target;
        feed.send(err);
    });
}

exports.default = {
    ISTEXFetch: ISTEXFetch
};