cli-engine/lib/updater.js

'use strict';

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

var _promise = require('babel-runtime/core-js/promise');

var _promise2 = _interopRequireDefault(_promise);

var _regenerator = require('babel-runtime/regenerator');

var _regenerator2 = _interopRequireDefault(_regenerator);

var _asyncToGenerator2 = require('babel-runtime/helpers/asyncToGenerator');

var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2);

var _getPrototypeOf = require('babel-runtime/core-js/object/get-prototype-of');

var _getPrototypeOf2 = _interopRequireDefault(_getPrototypeOf);

var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');

var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);

var _createClass2 = require('babel-runtime/helpers/createClass');

var _createClass3 = _interopRequireDefault(_createClass2);

var _possibleConstructorReturn2 = require('babel-runtime/helpers/possibleConstructorReturn');

var _possibleConstructorReturn3 = _interopRequireDefault(_possibleConstructorReturn2);

var _inherits2 = require('babel-runtime/helpers/inherits');

var _inherits3 = _interopRequireDefault(_inherits2);

var _cliEngineCommand = require('cli-engine-command');

var _path = require('path');

var _path2 = _interopRequireDefault(_path);

var _rwlockfile = require('rwlockfile');

var _rwlockfile2 = _interopRequireDefault(_rwlockfile);

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

var _class = function (_Base) {
  (0, _inherits3.default)(_class, _Base);

  function _class() {
    (0, _classCallCheck3.default)(this, _class);
    return (0, _possibleConstructorReturn3.default)(this, (_class.__proto__ || (0, _getPrototypeOf2.default)(_class)).apply(this, arguments));
  }

  (0, _createClass3.default)(_class, [{
    key: 'fetchManifest',
    value: function () {
      var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(channel) {
        var url, manifest;
        return _regenerator2.default.wrap(function _callee$(_context) {
          while (1) {
            switch (_context.prev = _context.next) {
              case 0:
                if (this.config.s3.host) {
                  _context.next = 2;
                  break;
                }

                throw new Error('S3 host not defined');

              case 2:
                _context.prev = 2;
                url = 'https://' + this.config.s3.host + '/' + this.config.name + '/channels/' + channel + '/' + process.platform + '-' + process.arch;
                _context.next = 6;
                return this.http.get(url);

              case 6:
                manifest = _context.sent;
                return _context.abrupt('return', manifest);

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

                if (!(_context.t0.statusCode === 403)) {
                  _context.next = 14;
                  break;
                }

                throw new Error('HTTP 403: Invalid channel ' + channel);

              case 14:
                throw _context.t0;

              case 15:
              case 'end':
                return _context.stop();
            }
          }
        }, _callee, this, [[2, 10]]);
      }));

      function fetchManifest(_x) {
        return _ref.apply(this, arguments);
      }

      return fetchManifest;
    }()
  }, {
    key: 'update',
    value: function () {
      var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(manifest) {
        var url, stream, dir, tmp;
        return _regenerator2.default.wrap(function _callee2$(_context2) {
          while (1) {
            switch (_context2.prev = _context2.next) {
              case 0:
                if (this.config.s3.host) {
                  _context2.next = 2;
                  break;
                }

                throw new Error('S3 host not defined');

              case 2:
                url = 'https://' + this.config.s3.host + '/' + this.config.name + '/channels/' + manifest.channel + '/' + this.base(manifest) + '.tar.gz';
                _context2.next = 5;
                return this.http.stream(url);

              case 5:
                stream = _context2.sent;
                dir = _path2.default.join(this.config.dirs.data, 'cli');
                tmp = _path2.default.join(this.config.dirs.data, 'cli_tmp');
                _context2.next = 10;
                return this.extract(stream, tmp);

              case 10:
                _context2.next = 12;
                return _rwlockfile2.default.write(this.updatelockfile, { skipOwnPid: true });

              case 12:
                this.fs.removeSync(dir);
                this.fs.renameSync(_path2.default.join(tmp, this.base(manifest)), dir);
                this.fs.removeSync(tmp);

              case 15:
              case 'end':
                return _context2.stop();
            }
          }
        }, _callee2, this);
      }));

      function update(_x2) {
        return _ref2.apply(this, arguments);
      }

      return update;
    }()
  }, {
    key: 'extract',
    value: function extract(stream, dir) {
      var _this2 = this;

      var zlib = require('zlib');
      var tar = require('tar-stream');

      return new _promise2.default(function (resolve) {
        _this2.fs.removeSync(dir);
        var extract = tar.extract();
        extract.on('entry', function (header, stream, next) {
          var p = _path2.default.join(dir, header.name);
          var opts = { mode: header.mode };
          switch (header.type) {
            case 'directory':
              _this2.fs.mkdirpSync(p, opts);
              next();
              break;
            case 'file':
              stream.pipe(_this2.fs.createWriteStream(p, opts));
              break;
            case 'symlink':
              // ignore symlinks since they will not work on windows
              next();
              break;
            default:
              throw new Error(header.type);
          }
          stream.resume();
          stream.on('end', next);
        });
        extract.on('finish', resolve);
        stream.pipe(zlib.createGunzip()).pipe(extract);
      });
    }
  }, {
    key: 'base',
    value: function base(manifest) {
      return this.config.name + '-v' + manifest.version + '-' + process.platform + '-' + process.arch;
    }
  }, {
    key: 'restartCLI',
    value: function () {
      var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
        var _require, spawnSync, _spawnSync, status;

        return _regenerator2.default.wrap(function _callee3$(_context3) {
          while (1) {
            switch (_context3.prev = _context3.next) {
              case 0:
                _context3.next = 2;
                return _rwlockfile2.default.read(this.updatelockfile);

              case 2:
                _rwlockfile2.default.unreadSync(this.updatelockfile);
                _require = require('child_process'), spawnSync = _require.spawnSync;

                if (this.binPath) {
                  _context3.next = 6;
                  break;
                }

                return _context3.abrupt('return');

              case 6:
                _spawnSync = spawnSync(this.binPath, process.argv.slice(2), { stdio: 'inherit', shell: true }), status = _spawnSync.status;

                this.exit(status);

              case 8:
              case 'end':
                return _context3.stop();
            }
          }
        }, _callee3, this);
      }));

      function restartCLI() {
        return _ref3.apply(this, arguments);
      }

      return restartCLI;
    }()
  }, {
    key: 'autoupdate',
    value: function () {
      var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
        var _this3 = this;

        var fd, _require2, spawn;

        return _regenerator2.default.wrap(function _callee4$(_context4) {
          while (1) {
            switch (_context4.prev = _context4.next) {
              case 0:
                _context4.prev = 0;

                if (this.autoupdateNeeded) {
                  _context4.next = 3;
                  break;
                }

                return _context4.abrupt('return');

              case 3:
                this.fs.writeFileSync(this.autoupdatefile, '');

                if (!this.config.updateDisabled) {
                  _context4.next = 7;
                  break;
                }

                _context4.next = 7;
                return this.warnIfUpdateAvailable();

              case 7:
                _context4.next = 9;
                return this.checkIfUpdating();

              case 9:
                fd = this.fs.openSync(this.autoupdatelogfile, 'a');

                if (this.binPath) {
                  _context4.next = 12;
                  break;
                }

                return _context4.abrupt('return');

              case 12:
                _require2 = require('child_process'), spawn = _require2.spawn;

                spawn(this.binPath, ['update'], { stdio: [null, fd, fd], detached: true }).on('error', function (e) {
                  return _this3.warn(e, 'autoupdate:');
                });
                _context4.next = 19;
                break;

              case 16:
                _context4.prev = 16;
                _context4.t0 = _context4['catch'](0);
                this.warn(_context4.t0, 'autoupdate:');
              case 19:
              case 'end':
                return _context4.stop();
            }
          }
        }, _callee4, this, [[0, 16]]);
      }));

      function autoupdate() {
        return _ref4.apply(this, arguments);
      }

      return autoupdate;
    }()
  }, {
    key: 'warnIfUpdateAvailable',
    value: function () {
      var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5() {
        var manifest, local, remote;
        return _regenerator2.default.wrap(function _callee5$(_context5) {
          while (1) {
            switch (_context5.prev = _context5.next) {
              case 0:
                _context5.next = 2;
                return this.fetchManifest(this.config.channel);

              case 2:
                manifest = _context5.sent;
                local = this.config.version.split('.');
                remote = manifest.version.split('.');

                if (local[0] !== remote[0] || local[1] !== remote[1]) {
                  this.stderr.log(this.config.name + ': update available from ' + this.config.version + ' to ' + manifest.version);
                }

              case 6:
              case 'end':
                return _context5.stop();
            }
          }
        }, _callee5, this);
      }));

      function warnIfUpdateAvailable() {
        return _ref5.apply(this, arguments);
      }

      return warnIfUpdateAvailable;
    }()
  }, {
    key: 'checkIfUpdating',
    value: function () {
      var _ref6 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6() {
        var lock;
        return _regenerator2.default.wrap(function _callee6$(_context6) {
          while (1) {
            switch (_context6.prev = _context6.next) {
              case 0:
                lock = require('rwlockfile');
                _context6.next = 3;
                return lock.hasWriter(this.updatelockfile);

              case 3:
                if (!_context6.sent) {
                  _context6.next = 9;
                  break;
                }

                this.warn(this.config.name + ': warning: update in process');
                _context6.next = 7;
                return this.restartCLI();

              case 7:
                _context6.next = 11;
                break;

              case 9:
                _context6.next = 11;
                return lock.read(this.updatelockfile);

              case 11:
              case 'end':
                return _context6.stop();
            }
          }
        }, _callee6, this);
      }));

      function checkIfUpdating() {
        return _ref6.apply(this, arguments);
      }

      return checkIfUpdating;
    }()
  }, {
    key: 'autoupdatefile',
    get: function get() {
      return _path2.default.join(this.config.dirs.cache, 'autoupdate');
    }
  }, {
    key: 'autoupdatelogfile',
    get: function get() {
      return _path2.default.join(this.config.dirs.cache, 'autoupdate.log');
    }
  }, {
    key: 'updatelockfile',
    get: function get() {
      return _path2.default.join(this.config.dirs.cache, 'update.lock');
    }
  }, {
    key: 'binPath',
    get: function get() {
      return process.env.CLI_BINPATH;
    }
  }, {
    key: 'autoupdateNeeded',
    get: function get() {
      try {
        var moment = require('moment');
        var stat = this.fs.statSync(this.autoupdatefile);
        return moment(stat.mtime).isBefore(moment().subtract(4, 'hours'));
      } catch (err) {
        if (err.code !== 'ENOENT') console.error(err.stack);
        return true;
      }
    }
  }]);
  return _class;
}(_cliEngineCommand.Base);
/* globals
   stream$Readable
*/

exports.default = _class;
//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi4uL3NyYy91cGRhdGVyLmpzIl0sIm5hbWVzIjpbImNoYW5uZWwiLCJjb25maWciLCJzMyIsImhvc3QiLCJFcnJvciIsInVybCIsIm5hbWUiLCJwcm9jZXNzIiwicGxhdGZvcm0iLCJhcmNoIiwiaHR0cCIsImdldCIsIm1hbmlmZXN0Iiwic3RhdHVzQ29kZSIsImJhc2UiLCJzdHJlYW0iLCJkaXIiLCJqb2luIiwiZGlycyIsImRhdGEiLCJ0bXAiLCJleHRyYWN0Iiwid3JpdGUiLCJ1cGRhdGVsb2NrZmlsZSIsInNraXBPd25QaWQiLCJmcyIsInJlbW92ZVN5bmMiLCJyZW5hbWVTeW5jIiwiemxpYiIsInJlcXVpcmUiLCJ0YXIiLCJvbiIsImhlYWRlciIsIm5leHQiLCJwIiwib3B0cyIsIm1vZGUiLCJ0eXBlIiwibWtkaXJwU3luYyIsInBpcGUiLCJjcmVhdGVXcml0ZVN0cmVhbSIsInJlc3VtZSIsInJlc29sdmUiLCJjcmVhdGVHdW56aXAiLCJ2ZXJzaW9uIiwicmVhZCIsInVucmVhZFN5bmMiLCJzcGF3blN5bmMiLCJiaW5QYXRoIiwiYXJndiIsInNsaWNlIiwic3RkaW8iLCJzaGVsbCIsInN0YXR1cyIsImV4aXQiLCJhdXRvdXBkYXRlTmVlZGVkIiwid3JpdGVGaWxlU3luYyIsImF1dG91cGRhdGVmaWxlIiwidXBkYXRlRGlzYWJsZWQiLCJ3YXJuSWZVcGRhdGVBdmFpbGFibGUiLCJjaGVja0lmVXBkYXRpbmciLCJmZCIsIm9wZW5TeW5jIiwiYXV0b3VwZGF0ZWxvZ2ZpbGUiLCJzcGF3biIsImRldGFjaGVkIiwid2FybiIsImUiLCJmZXRjaE1hbmlmZXN0IiwibG9jYWwiLCJzcGxpdCIsInJlbW90ZSIsInN0ZGVyciIsImxvZyIsImxvY2siLCJoYXNXcml0ZXIiLCJyZXN0YXJ0Q0xJIiwiY2FjaGUiLCJlbnYiLCJDTElfQklOUEFUSCIsIm1vbWVudCIsInN0YXQiLCJzdGF0U3luYyIsIm10aW1lIiwiaXNCZWZvcmUiLCJzdWJ0cmFjdCIsImVyciIsImNvZGUiLCJjb25zb2xlIiwiZXJyb3IiLCJzdGFjayJdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFLQTs7QUFDQTs7OztBQUNBOzs7Ozs7Ozs7Ozs7Ozs7Ozs2RkFjdUJBLE87Ozs7OztvQkFDZCxLQUFLQyxNQUFMLENBQVlDLEVBQVosQ0FBZUMsSTs7Ozs7c0JBQVksSUFBSUMsS0FBSixDQUFVLHFCQUFWLEM7Ozs7QUFFMUJDLG1CLGdCQUFpQixLQUFLSixNQUFMLENBQVlDLEVBQVosQ0FBZUMsSSxTQUFRLEtBQUtGLE1BQUwsQ0FBWUssSSxrQkFBaUJOLE8sU0FBV08sUUFBUUMsUSxTQUFZRCxRQUFRRSxJOzt1QkFDM0YsS0FBS0MsSUFBTCxDQUFVQyxHQUFWLENBQWNOLEdBQWQsQzs7O0FBQWpCTyx3QjtpREFDS0EsUTs7Ozs7O3NCQUVMLFlBQUlDLFVBQUosS0FBbUIsRzs7Ozs7c0JBQVcsSUFBSVQsS0FBSixnQ0FBdUNKLE9BQXZDLEM7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7K0ZBS3hCWSxROzs7Ozs7b0JBQ1AsS0FBS1gsTUFBTCxDQUFZQyxFQUFaLENBQWVDLEk7Ozs7O3NCQUFZLElBQUlDLEtBQUosQ0FBVSxxQkFBVixDOzs7QUFDNUJDLG1CLGdCQUFpQixLQUFLSixNQUFMLENBQVlDLEVBQVosQ0FBZUMsSSxTQUFRLEtBQUtGLE1BQUwsQ0FBWUssSSxrQkFBaUJNLFNBQVNaLE8sU0FBVyxLQUFLYyxJQUFMLENBQVVGLFFBQVYsQzs7dUJBQzFFLEtBQUtGLElBQUwsQ0FBVUssTUFBVixDQUFpQlYsR0FBakIsQzs7O0FBQWZVLHNCO0FBQ0FDLG1CLEdBQU0sZUFBS0MsSUFBTCxDQUFVLEtBQUtoQixNQUFMLENBQVlpQixJQUFaLENBQWlCQyxJQUEzQixFQUFpQyxLQUFqQyxDO0FBQ05DLG1CLEdBQU0sZUFBS0gsSUFBTCxDQUFVLEtBQUtoQixNQUFMLENBQVlpQixJQUFaLENBQWlCQyxJQUEzQixFQUFpQyxTQUFqQyxDOzt1QkFDSixLQUFLRSxPQUFMLENBQWFOLE1BQWIsRUFBcUJLLEdBQXJCLEM7Ozs7dUJBQ0EscUJBQUtFLEtBQUwsQ0FBVyxLQUFLQyxjQUFoQixFQUFnQyxFQUFDQyxZQUFZLElBQWIsRUFBaEMsQzs7O0FBQ04scUJBQUtDLEVBQUwsQ0FBUUMsVUFBUixDQUFtQlYsR0FBbkI7QUFDQSxxQkFBS1MsRUFBTCxDQUFRRSxVQUFSLENBQW1CLGVBQUtWLElBQUwsQ0FBVUcsR0FBVixFQUFlLEtBQUtOLElBQUwsQ0FBVUYsUUFBVixDQUFmLENBQW5CLEVBQXdESSxHQUF4RDtBQUNBLHFCQUFLUyxFQUFMLENBQVFDLFVBQVIsQ0FBbUJOLEdBQW5COzs7Ozs7Ozs7Ozs7Ozs7Ozs7NEJBR09MLE0sRUFBeUJDLEcsRUFBYTtBQUFBOztBQUM3QyxVQUFNWSxPQUFPQyxRQUFRLE1BQVIsQ0FBYjtBQUNBLFVBQU1DLE1BQU1ELFFBQVEsWUFBUixDQUFaOztBQUVBLGFBQU8sc0JBQVksbUJBQVc7QUFDNUIsZUFBS0osRUFBTCxDQUFRQyxVQUFSLENBQW1CVixHQUFuQjtBQUNBLFlBQUlLLFVBQVVTLElBQUlULE9BQUosRUFBZDtBQUNBQSxnQkFBUVUsRUFBUixDQUFXLE9BQVgsRUFBb0IsVUFBQ0MsTUFBRCxFQUFTakIsTUFBVCxFQUFpQmtCLElBQWpCLEVBQTBCO0FBQzVDLGNBQUlDLElBQUksZUFBS2pCLElBQUwsQ0FBVUQsR0FBVixFQUFlZ0IsT0FBTzFCLElBQXRCLENBQVI7QUFDQSxjQUFJNkIsT0FBTyxFQUFDQyxNQUFNSixPQUFPSSxJQUFkLEVBQVg7QUFDQSxrQkFBUUosT0FBT0ssSUFBZjtBQUNFLGlCQUFLLFdBQUw7QUFDRSxxQkFBS1osRUFBTCxDQUFRYSxVQUFSLENBQW1CSixDQUFuQixFQUFzQkMsSUFBdEI7QUFDQUY7QUFDQTtBQUNGLGlCQUFLLE1BQUw7QUFDRWxCLHFCQUFPd0IsSUFBUCxDQUFZLE9BQUtkLEVBQUwsQ0FBUWUsaUJBQVIsQ0FBMEJOLENBQTFCLEVBQTZCQyxJQUE3QixDQUFaO0FBQ0E7QUFDRixpQkFBSyxTQUFMO0FBQ0U7QUFDQUY7QUFDQTtBQUNGO0FBQVMsb0JBQU0sSUFBSTdCLEtBQUosQ0FBVTRCLE9BQU9LLElBQWpCLENBQU47QUFaWDtBQWNBdEIsaUJBQU8wQixNQUFQO0FBQ0ExQixpQkFBT2dCLEVBQVAsQ0FBVSxLQUFWLEVBQWlCRSxJQUFqQjtBQUNELFNBbkJEO0FBb0JBWixnQkFBUVUsRUFBUixDQUFXLFFBQVgsRUFBcUJXLE9BQXJCO0FBQ0EzQixlQUNDd0IsSUFERCxDQUNNWCxLQUFLZSxZQUFMLEVBRE4sRUFFQ0osSUFGRCxDQUVNbEIsT0FGTjtBQUdELE9BM0JNLENBQVA7QUE0QkQ7Ozt5QkFFS1QsUSxFQUE0QjtBQUNoQyxhQUFVLEtBQUtYLE1BQUwsQ0FBWUssSUFBdEIsVUFBK0JNLFNBQVNnQyxPQUF4QyxTQUFtRHJDLFFBQVFDLFFBQTNELFNBQXVFRCxRQUFRRSxJQUEvRTtBQUNEOzs7Ozs7Ozs7Ozs7dUJBR08scUJBQUtvQyxJQUFMLENBQVUsS0FBS3RCLGNBQWYsQzs7O0FBQ04scUNBQUt1QixVQUFMLENBQWdCLEtBQUt2QixjQUFyQjsyQkFDb0JNLFFBQVEsZUFBUixDLEVBQWJrQixTLFlBQUFBLFM7O29CQUNGLEtBQUtDLE87Ozs7Ozs7OzZCQUNPRCxVQUFVLEtBQUtDLE9BQWYsRUFBd0J6QyxRQUFRMEMsSUFBUixDQUFhQyxLQUFiLENBQW1CLENBQW5CLENBQXhCLEVBQStDLEVBQUNDLE9BQU8sU0FBUixFQUFtQkMsT0FBTyxJQUExQixFQUEvQyxDLEVBQVZDLE0sY0FBQUEsTTs7QUFDUCxxQkFBS0MsSUFBTCxDQUFVRCxNQUFWOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7b0JBZ0JPLEtBQUtFLGdCOzs7Ozs7OztBQUNWLHFCQUFLOUIsRUFBTCxDQUFRK0IsYUFBUixDQUFzQixLQUFLQyxjQUEzQixFQUEyQyxFQUEzQzs7cUJBQ0ksS0FBS3hELE1BQUwsQ0FBWXlELGM7Ozs7Ozt1QkFBc0IsS0FBS0MscUJBQUwsRTs7Ozt1QkFDaEMsS0FBS0MsZUFBTCxFOzs7QUFDRkMsa0IsR0FBSyxLQUFLcEMsRUFBTCxDQUFRcUMsUUFBUixDQUFpQixLQUFLQyxpQkFBdEIsRUFBeUMsR0FBekMsQzs7b0JBQ0osS0FBS2YsTzs7Ozs7Ozs7NEJBQ01uQixRQUFRLGVBQVIsQyxFQUFUbUMsSyxhQUFBQSxLOztBQUNQQSxzQkFBTSxLQUFLaEIsT0FBWCxFQUFvQixDQUFDLFFBQUQsQ0FBcEIsRUFBZ0MsRUFBQ0csT0FBTyxDQUFDLElBQUQsRUFBT1UsRUFBUCxFQUFXQSxFQUFYLENBQVIsRUFBd0JJLFVBQVUsSUFBbEMsRUFBaEMsRUFDQ2xDLEVBREQsQ0FDSSxPQURKLEVBQ2E7QUFBQSx5QkFBSyxPQUFLbUMsSUFBTCxDQUFVQyxDQUFWLEVBQWEsYUFBYixDQUFMO0FBQUEsaUJBRGI7Ozs7Ozs7QUFFWSxxQkFBS0QsSUFBTCxlQUFhLGFBQWI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7dUJBSVMsS0FBS0UsYUFBTCxDQUFtQixLQUFLbkUsTUFBTCxDQUFZRCxPQUEvQixDOzs7QUFBakJZLHdCO0FBQ0Z5RCxxQixHQUFRLEtBQUtwRSxNQUFMLENBQVkyQyxPQUFaLENBQW9CMEIsS0FBcEIsQ0FBMEIsR0FBMUIsQztBQUNSQyxzQixHQUFTM0QsU0FBU2dDLE9BQVQsQ0FBaUIwQixLQUFqQixDQUF1QixHQUF2QixDOztBQUNiLG9CQUFJRCxNQUFNLENBQU4sTUFBYUUsT0FBTyxDQUFQLENBQWIsSUFBMEJGLE1BQU0sQ0FBTixNQUFhRSxPQUFPLENBQVAsQ0FBM0MsRUFBc0Q7QUFDcEQsdUJBQUtDLE1BQUwsQ0FBWUMsR0FBWixDQUFtQixLQUFLeEUsTUFBTCxDQUFZSyxJQUEvQixnQ0FBOEQsS0FBS0wsTUFBTCxDQUFZMkMsT0FBMUUsWUFBd0ZoQyxTQUFTZ0MsT0FBakc7QUFDRDs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7OztBQUlLOEIsb0IsR0FBTzdDLFFBQVEsWUFBUixDOzt1QkFDSDZDLEtBQUtDLFNBQUwsQ0FBZSxLQUFLcEQsY0FBcEIsQzs7Ozs7Ozs7QUFDUixxQkFBSzJDLElBQUwsQ0FBYSxLQUFLakUsTUFBTCxDQUFZSyxJQUF6Qjs7dUJBQ00sS0FBS3NFLFVBQUwsRTs7Ozs7Ozs7dUJBQ0tGLEtBQUs3QixJQUFMLENBQVUsS0FBS3RCLGNBQWYsQzs7Ozs7Ozs7Ozs7Ozs7Ozs7O3dCQXBIZTtBQUFFLGFBQU8sZUFBS04sSUFBTCxDQUFVLEtBQUtoQixNQUFMLENBQVlpQixJQUFaLENBQWlCMkQsS0FBM0IsRUFBa0MsWUFBbEMsQ0FBUDtBQUF3RDs7O3dCQUN2RDtBQUFFLGFBQU8sZUFBSzVELElBQUwsQ0FBVSxLQUFLaEIsTUFBTCxDQUFZaUIsSUFBWixDQUFpQjJELEtBQTNCLEVBQWtDLGdCQUFsQyxDQUFQO0FBQTREOzs7d0JBQ2pFO0FBQUUsYUFBTyxlQUFLNUQsSUFBTCxDQUFVLEtBQUtoQixNQUFMLENBQVlpQixJQUFaLENBQWlCMkQsS0FBM0IsRUFBa0MsYUFBbEMsQ0FBUDtBQUF5RDs7O3dCQUNqRTtBQUFFLGFBQU90RSxRQUFRdUUsR0FBUixDQUFZQyxXQUFuQjtBQUFnQzs7O3dCQTBFbEM7QUFDdEIsVUFBSTtBQUNGLFlBQU1DLFNBQVNuRCxRQUFRLFFBQVIsQ0FBZjtBQUNBLFlBQU1vRCxPQUFPLEtBQUt4RCxFQUFMLENBQVF5RCxRQUFSLENBQWlCLEtBQUt6QixjQUF0QixDQUFiO0FBQ0EsZUFBT3VCLE9BQU9DLEtBQUtFLEtBQVosRUFBbUJDLFFBQW5CLENBQTRCSixTQUFTSyxRQUFULENBQWtCLENBQWxCLEVBQXFCLE9BQXJCLENBQTVCLENBQVA7QUFDRCxPQUpELENBSUUsT0FBT0MsR0FBUCxFQUFZO0FBQ1osWUFBSUEsSUFBSUMsSUFBSixLQUFhLFFBQWpCLEVBQTJCQyxRQUFRQyxLQUFSLENBQWNILElBQUlJLEtBQWxCO0FBQzNCLGVBQU8sSUFBUDtBQUNEO0FBQ0Y7Ozs7QUFyR0giLCJmaWxlIjoidXBkYXRlci5qcyIsInNvdXJjZXNDb250ZW50IjpbIi8vIEBmbG93XG4vKiBnbG9iYWxzXG4gICBzdHJlYW0kUmVhZGFibGVcbiovXG5cbmltcG9ydCB7QmFzZX0gZnJvbSAnY2xpLWVuZ2luZS1jb21tYW5kJ1xuaW1wb3J0IHBhdGggZnJvbSAncGF0aCdcbmltcG9ydCBsb2NrIGZyb20gJ3J3bG9ja2ZpbGUnXG5cbnR5cGUgTWFuaWZlc3QgPSB7XG4gIHZlcnNpb246IHN0cmluZyxcbiAgY2hhbm5lbDogc3RyaW5nLFxuICBzaGEyNTY6IHN0cmluZ1xufVxuXG5leHBvcnQgZGVmYXVsdCBjbGFzcyBleHRlbmRzIEJhc2Uge1xuICBnZXQgYXV0b3VwZGF0ZWZpbGUgKCk6IHN0cmluZyB7IHJldHVybiBwYXRoLmpvaW4odGhpcy5jb25maWcuZGlycy5jYWNoZSwgJ2F1dG91cGRhdGUnKSB9XG4gIGdldCBhdXRvdXBkYXRlbG9nZmlsZSAoKTogc3RyaW5nIHsgcmV0dXJuIHBhdGguam9pbih0aGlzLmNvbmZpZy5kaXJzLmNhY2hlLCAnYXV0b3VwZGF0ZS5sb2cnKSB9XG4gIGdldCB1cGRhdGVsb2NrZmlsZSAoKTogc3RyaW5nIHsgcmV0dXJuIHBhdGguam9pbih0aGlzLmNvbmZpZy5kaXJzLmNhY2hlLCAndXBkYXRlLmxvY2snKSB9XG4gIGdldCBiaW5QYXRoICgpOiA/c3RyaW5nIHsgcmV0dXJuIHByb2Nlc3MuZW52LkNMSV9CSU5QQVRIIH1cblxuICBhc3luYyBmZXRjaE1hbmlmZXN0IChjaGFubmVsOiBzdHJpbmcpOiBQcm9taXNlPE1hbmlmZXN0PiB7XG4gICAgaWYgKCF0aGlzLmNvbmZpZy5zMy5ob3N0KSB0aHJvdyBuZXcgRXJyb3IoJ1MzIGhvc3Qgbm90IGRlZmluZWQnKVxuICAgIHRyeSB7XG4gICAgICBsZXQgdXJsID0gYGh0dHBzOi8vJHt0aGlzLmNvbmZpZy5zMy5ob3N0fS8ke3RoaXMuY29uZmlnLm5hbWV9L2NoYW5uZWxzLyR7Y2hhbm5lbH0vJHtwcm9jZXNzLnBsYXRmb3JtfS0ke3Byb2Nlc3MuYXJjaH1gXG4gICAgICBsZXQgbWFuaWZlc3QgPSBhd2FpdCB0aGlzLmh0dHAuZ2V0KHVybClcbiAgICAgIHJldHVybiAoKG1hbmlmZXN0OiBhbnkpOiBQcm9taXNlPE1hbmlmZXN0PilcbiAgICB9IGNhdGNoIChlcnIpIHtcbiAgICAgIGlmIChlcnIuc3RhdHVzQ29kZSA9PT0gNDAzKSB0aHJvdyBuZXcgRXJyb3IoYEhUVFAgNDAzOiBJbnZhbGlkIGNoYW5uZWwgJHtjaGFubmVsfWApXG4gICAgICB0aHJvdyBlcnJcbiAgICB9XG4gIH1cblxuICBhc3luYyB1cGRhdGUgKG1hbmlmZXN0OiBNYW5pZmVzdCkge1xuICAgIGlmICghdGhpcy5jb25maWcuczMuaG9zdCkgdGhyb3cgbmV3IEVycm9yKCdTMyBob3N0IG5vdCBkZWZpbmVkJylcbiAgICBsZXQgdXJsID0gYGh0dHBzOi8vJHt0aGlzLmNvbmZpZy5zMy5ob3N0fS8ke3RoaXMuY29uZmlnLm5hbWV9L2NoYW5uZWxzLyR7bWFuaWZlc3QuY2hhbm5lbH0vJHt0aGlzLmJhc2UobWFuaWZlc3QpfS50YXIuZ3pgXG4gICAgbGV0IHN0cmVhbSA9IGF3YWl0IHRoaXMuaHR0cC5zdHJlYW0odXJsKVxuICAgIGxldCBkaXIgPSBwYXRoLmpvaW4odGhpcy5jb25maWcuZGlycy5kYXRhLCAnY2xpJylcbiAgICBsZXQgdG1wID0gcGF0aC5qb2luKHRoaXMuY29uZmlnLmRpcnMuZGF0YSwgJ2NsaV90bXAnKVxuICAgIGF3YWl0IHRoaXMuZXh0cmFjdChzdHJlYW0sIHRtcClcbiAgICBhd2FpdCBsb2NrLndyaXRlKHRoaXMudXBkYXRlbG9ja2ZpbGUsIHtza2lwT3duUGlkOiB0cnVlfSlcbiAgICB0aGlzLmZzLnJlbW92ZVN5bmMoZGlyKVxuICAgIHRoaXMuZnMucmVuYW1lU3luYyhwYXRoLmpvaW4odG1wLCB0aGlzLmJhc2UobWFuaWZlc3QpKSwgZGlyKVxuICAgIHRoaXMuZnMucmVtb3ZlU3luYyh0bXApXG4gIH1cblxuICBleHRyYWN0IChzdHJlYW06IHN0cmVhbSRSZWFkYWJsZSwgZGlyOiBzdHJpbmcpIHtcbiAgICBjb25zdCB6bGliID0gcmVxdWlyZSgnemxpYicpXG4gICAgY29uc3QgdGFyID0gcmVxdWlyZSgndGFyLXN0cmVhbScpXG5cbiAgICByZXR1cm4gbmV3IFByb21pc2UocmVzb2x2ZSA9PiB7XG4gICAgICB0aGlzLmZzLnJlbW92ZVN5bmMoZGlyKVxuICAgICAgbGV0IGV4dHJhY3QgPSB0YXIuZXh0cmFjdCgpXG4gICAgICBleHRyYWN0Lm9uKCdlbnRyeScsIChoZWFkZXIsIHN0cmVhbSwgbmV4dCkgPT4ge1xuICAgICAgICBsZXQgcCA9IHBhdGguam9pbihkaXIsIGhlYWRlci5uYW1lKVxuICAgICAgICBsZXQgb3B0cyA9IHttb2RlOiBoZWFkZXIubW9kZX1cbiAgICAgICAgc3dpdGNoIChoZWFkZXIudHlwZSkge1xuICAgICAgICAgIGNhc2UgJ2RpcmVjdG9yeSc6XG4gICAgICAgICAgICB0aGlzLmZzLm1rZGlycFN5bmMocCwgb3B0cylcbiAgICAgICAgICAgIG5leHQoKVxuICAgICAgICAgICAgYnJlYWtcbiAgICAgICAgICBjYXNlICdmaWxlJzpcbiAgICAgICAgICAgIHN0cmVhbS5waXBlKHRoaXMuZnMuY3JlYXRlV3JpdGVTdHJlYW0ocCwgb3B0cykpXG4gICAgICAgICAgICBicmVha1xuICAgICAgICAgIGNhc2UgJ3N5bWxpbmsnOlxuICAgICAgICAgICAgLy8gaWdub3JlIHN5bWxpbmtzIHNpbmNlIHRoZXkgd2lsbCBub3Qgd29yayBvbiB3aW5kb3dzXG4gICAgICAgICAgICBuZXh0KClcbiAgICAgICAgICAgIGJyZWFrXG4gICAgICAgICAgZGVmYXVsdDogdGhyb3cgbmV3IEVycm9yKGhlYWRlci50eXBlKVxuICAgICAgICB9XG4gICAgICAgIHN0cmVhbS5yZXN1bWUoKVxuICAgICAgICBzdHJlYW0ub24oJ2VuZCcsIG5leHQpXG4gICAgICB9KVxuICAgICAgZXh0cmFjdC5vbignZmluaXNoJywgcmVzb2x2ZSlcbiAgICAgIHN0cmVhbVxuICAgICAgLnBpcGUoemxpYi5jcmVhdGVHdW56aXAoKSlcbiAgICAgIC5waXBlKGV4dHJhY3QpXG4gICAgfSlcbiAgfVxuXG4gIGJhc2UgKG1hbmlmZXN0OiBNYW5pZmVzdCk6IHN0cmluZyB7XG4gICAgcmV0dXJuIGAke3RoaXMuY29uZmlnLm5hbWV9LXYke21hbmlmZXN0LnZlcnNpb259LSR7cHJvY2Vzcy5wbGF0Zm9ybX0tJHtwcm9jZXNzLmFyY2h9YFxuICB9XG5cbiAgYXN5bmMgcmVzdGFydENMSSAoKSB7XG4gICAgYXdhaXQgbG9jay5yZWFkKHRoaXMudXBkYXRlbG9ja2ZpbGUpXG4gICAgbG9jay51bnJlYWRTeW5jKHRoaXMudXBkYXRlbG9ja2ZpbGUpXG4gICAgY29uc3Qge3NwYXduU3luY30gPSByZXF1aXJlKCdjaGlsZF9wcm9jZXNzJylcbiAgICBpZiAoIXRoaXMuYmluUGF0aCkgcmV0dXJuXG4gICAgY29uc3Qge3N0YXR1c30gPSBzcGF3blN5bmModGhpcy5iaW5QYXRoLCBwcm9jZXNzLmFyZ3Yuc2xpY2UoMiksIHtzdGRpbzogJ2luaGVyaXQnLCBzaGVsbDogdHJ1ZX0pXG4gICAgdGhpcy5leGl0KHN0YXR1cylcbiAgfVxuXG4gIGdldCBhdXRvdXBkYXRlTmVlZGVkICgpIHtcbiAgICB0cnkge1xuICAgICAgY29uc3QgbW9tZW50ID0gcmVxdWlyZSgnbW9tZW50JylcbiAgICAgIGNvbnN0IHN0YXQgPSB0aGlzLmZzLnN0YXRTeW5jKHRoaXMuYXV0b3VwZGF0ZWZpbGUpXG4gICAgICByZXR1cm4gbW9tZW50KHN0YXQubXRpbWUpLmlzQmVmb3JlKG1vbWVudCgpLnN1YnRyYWN0KDQsICdob3VycycpKVxuICAgIH0gY2F0Y2ggKGVycikge1xuICAgICAgaWYgKGVyci5jb2RlICE9PSAnRU5PRU5UJykgY29uc29sZS5lcnJvcihlcnIuc3RhY2spXG4gICAgICByZXR1cm4gdHJ1ZVxuICAgIH1cbiAgfVxuXG4gIGFzeW5jIGF1dG91cGRhdGUgKCkge1xuICAgIHRyeSB7XG4gICAgICBpZiAoIXRoaXMuYXV0b3VwZGF0ZU5lZWRlZCkgcmV0dXJuXG4gICAgICB0aGlzLmZzLndyaXRlRmlsZVN5bmModGhpcy5hdXRvdXBkYXRlZmlsZSwgJycpXG4gICAgICBpZiAodGhpcy5jb25maWcudXBkYXRlRGlzYWJsZWQpIGF3YWl0IHRoaXMud2FybklmVXBkYXRlQXZhaWxhYmxlKClcbiAgICAgIGF3YWl0IHRoaXMuY2hlY2tJZlVwZGF0aW5nKClcbiAgICAgIGxldCBmZCA9IHRoaXMuZnMub3BlblN5bmModGhpcy5hdXRvdXBkYXRlbG9nZmlsZSwgJ2EnKVxuICAgICAgaWYgKCF0aGlzLmJpblBhdGgpIHJldHVyblxuICAgICAgY29uc3Qge3NwYXdufSA9IHJlcXVpcmUoJ2NoaWxkX3Byb2Nlc3MnKVxuICAgICAgc3Bhd24odGhpcy5iaW5QYXRoLCBbJ3VwZGF0ZSddLCB7c3RkaW86IFtudWxsLCBmZCwgZmRdLCBkZXRhY2hlZDogdHJ1ZX0pXG4gICAgICAub24oJ2Vycm9yJywgZSA9PiB0aGlzLndhcm4oZSwgJ2F1dG91cGRhdGU6JykpXG4gICAgfSBjYXRjaCAoZSkgeyB0aGlzLndhcm4oZSwgJ2F1dG91cGRhdGU6JykgfVxuICB9XG5cbiAgYXN5bmMgd2FybklmVXBkYXRlQXZhaWxhYmxlICgpIHtcbiAgICBjb25zdCBtYW5pZmVzdCA9IGF3YWl0IHRoaXMuZmV0Y2hNYW5pZmVzdCh0aGlzLmNvbmZpZy5jaGFubmVsKVxuICAgIGxldCBsb2NhbCA9IHRoaXMuY29uZmlnLnZlcnNpb24uc3BsaXQoJy4nKVxuICAgIGxldCByZW1vdGUgPSBtYW5pZmVzdC52ZXJzaW9uLnNwbGl0KCcuJylcbiAgICBpZiAobG9jYWxbMF0gIT09IHJlbW90ZVswXSB8fCBsb2NhbFsxXSAhPT0gcmVtb3RlWzFdKSB7XG4gICAgICB0aGlzLnN0ZGVyci5sb2coYCR7dGhpcy5jb25maWcubmFtZX06IHVwZGF0ZSBhdmFpbGFibGUgZnJvbSAke3RoaXMuY29uZmlnLnZlcnNpb259IHRvICR7bWFuaWZlc3QudmVyc2lvbn1gKVxuICAgIH1cbiAgfVxuXG4gIGFzeW5jIGNoZWNrSWZVcGRhdGluZyAoKSB7XG4gICAgY29uc3QgbG9jayA9IHJlcXVpcmUoJ3J3bG9ja2ZpbGUnKVxuICAgIGlmIChhd2FpdCBsb2NrLmhhc1dyaXRlcih0aGlzLnVwZGF0ZWxvY2tmaWxlKSkge1xuICAgICAgdGhpcy53YXJuKGAke3RoaXMuY29uZmlnLm5hbWV9OiB3YXJuaW5nOiB1cGRhdGUgaW4gcHJvY2Vzc2ApXG4gICAgICBhd2FpdCB0aGlzLnJlc3RhcnRDTEkoKVxuICAgIH0gZWxzZSBhd2FpdCBsb2NrLnJlYWQodGhpcy51cGRhdGVsb2NrZmlsZSlcbiAgfVxufVxuIl19