@zambezi/ez-build/lib/pipeline.js

'use strict';

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

var _path = require('path');

var _file = require('./util/file');

function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; }

var keys = Object.keys;

function createPipeline(pkg, opts, build) {
  return function pipeline() {
    var _this = this;

    for (var _len = arguments.length, files = Array(_len), _key = 0; _key < _len; _key++) {
      files[_key] = arguments[_key];
    }

    return files.map(function () {
      var _ref = _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee(file) {
        var name, result, output;
        return regeneratorRuntime.wrap(function _callee$(_context) {
          while (1) {
            switch (_context.prev = _context.next) {
              case 0:
                name = (0, _path.basename)(file, (0, _path.extname)(file));
                result = { input: file }, output = void 0;
                _context.prev = 2;
                _context.next = 5;
                return build(name, file);

              case 5:
                output = _context.sent;
                _context.next = 12;
                break;

              case 8:
                _context.prev = 8;
                _context.t0 = _context['catch'](2);

                result.error = _context.t0;
                return _context.abrupt('return', result);

              case 12:

                result.messages = output.messages;
                result.files = keys(output.files).map(function (name) {
                  var path = (0, _path.join)(pkg.resolve(opts.lib), (0, _path.dirname)((0, _path.relative)(pkg.resolve(opts.src), (0, _path.resolve)(file))));
                  var outfile = (0, _path.join)(path, name);
                  return outfile;
                });

                _context.prev = 14;
                _context.next = 17;
                return Promise.all(keys(output.files).map(function (name, i) {
                  var outfile = result.files[i];
                  return (0, _file.put)(outfile, output.files[name]);
                }));

              case 17:
                _context.next = 22;
                break;

              case 19:
                _context.prev = 19;
                _context.t1 = _context['catch'](14);

                result.error = _context.t1;

              case 22:
                return _context.abrupt('return', result);

              case 23:
              case 'end':
                return _context.stop();
            }
          }
        }, _callee, _this, [[2, 8], [14, 19]]);
      }));

      return function (_x) {
        return _ref.apply(this, arguments);
      };
    }());
  };
}
//# sourceMappingURL=pipeline.js.map