ezs-istex/lib/utils.js

'use strict';

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

var _slicedToArray2 = require('babel-runtime/helpers/slicedToArray');

var _slicedToArray3 = _interopRequireDefault(_slicedToArray2);

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

var _extends3 = _interopRequireDefault(_extends2);

var _typeof2 = require('babel-runtime/helpers/typeof');

var _typeof3 = _interopRequireDefault(_typeof2);

exports.writeTo = writeTo;
exports.newValue = newValue;
exports.getSubject = getSubject;

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

var _dotProp2 = _interopRequireDefault(_dotProp);

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

function writeTo(stream, data, cb) {
    if (!stream.write(data)) {
        stream.once('drain', cb);
    } else {
        process.nextTick(cb);
    }
}

function newValue(value, path, data) {
    if (path === undefined) {
        return value;
    }
    if ((typeof data === 'undefined' ? 'undefined' : (0, _typeof3.default)(data)) === 'object') {
        var _out = (0, _extends3.default)({}, data);
        _dotProp2.default.set(_out, path, value);
        return _out;
    }
    var out = {};
    _dotProp2.default.set(out, path, value);
    return out;
}

function getSubject(line) {
    var _line$split = line.split('>', 1),
        _line$split2 = (0, _slicedToArray3.default)(_line$split, 1),
        subject = _line$split2[0];

    subject += '>';
    return subject;
}