chat-service/lib/ServiceAPI.js

'use strict';

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

var _slicedToArray3 = _interopRequireDefault(_slicedToArray2);

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

var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);

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

var _createClass3 = _interopRequireDefault(_createClass2);

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

var ChatServiceError = require('./ChatServiceError');
var Promise = require('bluebird');
var _ = require('lodash');

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

var checkNameSymbols = _require.checkNameSymbols;
var possiblyCallback = _require.possiblyCallback;

/**
 * Server side operations.
 *
 * @mixin
 * @memberof chat-service
 * @see chat-service.ChatService
 */

var ServiceAPI = function () {
  function ServiceAPI(state, makeUser, clusterBus) {
    (0, _classCallCheck3.default)(this, ServiceAPI);

    this.state = state;
    this.makeUser = makeUser;
    this.clusterBus = clusterBus;
  }

  /**
   * Executes {@link rpc.clientRequests} handlers.
   *
   * @param {string|boolean|Object} context Is a `userName` if
   * `string`, or a `bypassPermissions` if `boolean`, or an options
   * object if `Object`.
   * @param {string} command Command name.
   * @param {...*} args Command arguments.
   * @param {callback} [cb] Optional callback.
   *
   * @property {string} [context.userName] User name.
   * @property {string} [context.id] Socket id, it is required for
   * {@link rpc.clientRequests.roomJoin} and {@link
   * rpc.clientRequests.roomLeave} commands.
   * @property {boolean} [context.bypassHooks=false] If `false`
   * executes command without before and after hooks.
   * @property {boolean} [context.bypassPermissions=false] If `true`
   * executes command (except {@link rpc.clientRequests.roomJoin})
   * bypassing built-in permissions checking.
   *
   * @return {Promise<Array>} Array of command results.
   *
   * @see rpc.clientRequests
   */


  (0, _createClass3.default)(ServiceAPI, [{
    key: 'execUserCommand',
    value: function execUserCommand(context, command) {
      var _this = this;

      if (_.isObject(context)) {
        var _context = context;
        var userName = _context.userName;

        context = _.clone(context);
      } else if (_.isBoolean(context)) {
        context = { bypassPermissions: context };
      } else {
        userName = context;
        context = {};
      }
      context.isLocalCall = true;

      for (var _len = arguments.length, args = Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) {
        args[_key - 2] = arguments[_key];
      }

      var _possiblyCallback = possiblyCallback(args);

      var _possiblyCallback2 = (0, _slicedToArray3.default)(_possiblyCallback, 2);

      var nargs = _possiblyCallback2[0];
      var cb = _possiblyCallback2[1];

      return Promise.try(function () {
        if (userName) {
          return _this.state.getUser(userName);
        } else {
          return _this.makeUser();
        }
      }).then(function (user) {
        return user.exec(command, context, nargs);
      }).asCallback(cb, { spread: true });
    }

    /**
     * Adds an user with a state.
     *
     * @param {string} userName User name.
     * @param {Object} [state] User state.
     * @param {callback} [cb] Optional callback.
     *
     * @property {Array<string>} [state.whitelist=[]] User direct messages
     * whitelist.
     * @property {Array<string>} [state.blacklist=[]] User direct messages
     * blacklist.
     * @property {boolean} [state.whitelistOnly=false] User direct
     * messages whitelistOnly mode.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'addUser',
    value: function addUser(userName, state, cb) {
      var _this2 = this;

      return checkNameSymbols(userName).then(function () {
        return _this2.state.addUser(userName, state);
      }).return().asCallback(cb);
    }

    /**
     * Deletes an offline user. Will raise an error if a user has online
     * sockets.
     *
     * @param {string} userName User name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'deleteUser',
    value: function deleteUser(userName, cb) {
      var _this3 = this;

      return this.state.getUser(userName).then(function (user) {
        return user.listOwnSockets().then(function (sockets) {
          if (sockets && _.size(sockets) > 0) {
            return Promise.reject(new ChatServiceError('userOnline', userName));
          } else {
            return Promise.all([user.removeState(), _this3.state.removeUser(userName)]);
          }
        });
      }).return().asCallback(cb);
    }

    /**
     * Checks for an user existence.
     *
     * @param {string} userName User name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<boolean>} Predicate result.
     */

  }, {
    key: 'hasUser',
    value: function hasUser(userName, cb) {
      return this.state.getUser(userName, true).then(function (user) {
        return Boolean(user);
      }).asCallback(cb);
    }

    /**
     * Checks for a name existence in a direct messaging list.
     *
     * @param {string} userName User name.
     * @param {string} listName List name.
     * @param {string} item List element.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<boolean>} Predicate result.
     */

  }, {
    key: 'userHasInList',
    value: function userHasInList(userName, listName, item, cb) {
      return this.state.getUser(userName).then(function (user) {
        return user.directMessaging.hasInList(listName, item);
      }).asCallback(cb);
    }

    /**
     * Checks for a direct messaging permission.
     *
     * @param {string} recipient Recipient name.
     * @param {string} sender Sender name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<boolean>} Predicate result.
     */

  }, {
    key: 'hasDirectAccess',
    value: function hasDirectAccess(recipient, sender, cb) {
      return this.state.getUser(recipient).then(function (user) {
        return user.directMessaging.checkAcess(sender);
      }).return(true).catchReturn(ChatServiceError, false).asCallback(cb);
    }

    /**
     * Disconnects user's sockets for all service instances. Method is
     * asynchronous, returns without waiting for the completion.
     *
     * @param {string} userName User name.
     *
     * @return {undefined} Returns no data.
     */

  }, {
    key: 'disconnectUserSockets',
    value: function disconnectUserSockets(userName) {
      this.clusterBus.emit('disconnectUserSockets', userName);
    }

    /**
     * Adds a room with a state.
     *
     * @param {string} roomName Room name.
     * @param {Object} [state] Room state.
     * @param {callback} [cb] Optional callback.
     *
     * @property {Array<string>} [state.whitelist=[]] Room whitelist.
     * @property {Array<string>} [state.blacklist=[]] Room blacklist
     * @property {Array<string>} [state.adminlist=[]] Room adminlist.
     * @property {boolean} [state.whitelistOnly=false] Room
     * whitelistOnly mode.
     * @property {string} [state.owner] Room owner.
     * @property {number} [state.historyMaxSize] Room history maximum
     * size. Defalut value is {@link chat-service.config.options}
     * `historyMaxSize`.
     * @property {boolean} [state.enableAccessListsUpdates] Room enable
     * access lists updates. Defalut value is {@link
     * chat-service.config.options} `enableAccessListsUpdates`.
     * @property {boolean} [state.enableUserlistUpdates] Room enable
     * userlist updates. Defalut value is {@link
     * chat-service.config.options} `enableUserlistUpdates`.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'addRoom',
    value: function addRoom(roomName, state, cb) {
      var _this4 = this;

      return checkNameSymbols(roomName).then(function () {
        return _this4.state.addRoom(roomName, state);
      }).return().asCallback(cb);
    }

    /**
     * Removes all joined users from the room and removes all room data.
     *
     * @param {string} roomName Room name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'deleteRoom',
    value: function deleteRoom(roomName, cb) {
      return this.execUserCommand(true, 'roomDelete', roomName).return().asCallback(cb);
    }

    /**
     * Checks for a room existence.
     *
     * @param {string} roomName Room name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<boolean>} Predicate result.
     */

  }, {
    key: 'hasRoom',
    value: function hasRoom(roomName, cb) {
      return this.state.getRoom(roomName, true).then(function (room) {
        return Boolean(room);
      }).asCallback(cb);
    }

    /**
     * Checks for a name existence in a room list.
     *
     * @param {string} roomName Room name.
     * @param {string} listName List name.
     * @param {string} item List element.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<boolean>} Predicate result.
     */

  }, {
    key: 'roomHasInList',
    value: function roomHasInList(roomName, listName, item, cb) {
      return this.state.getRoom(roomName).then(function (room) {
        return room.roomState.hasInList(listName, item);
      }).asCallback(cb);
    }

    /**
     * Checks for a room access permission.
     *
     * @param {string} roomName Room name.
     * @param {string} userName User name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<boolean>} Predicate result.
     */

  }, {
    key: 'hasRoomAccess',
    value: function hasRoomAccess(roomName, userName, cb) {
      return this.state.getRoom(roomName).then(function (room) {
        return room.checkAcess(userName);
      }).return(true).catchReturn(ChatServiceError, false).asCallback(cb);
    }

    /**
     * Changes the room owner.
     *
     * @param {string} roomName Room name.
     * @param {string} owner Owner user name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'changeRoomOwner',
    value: function changeRoomOwner(roomName, owner, cb) {
      return this.state.getRoom(roomName).then(function (room) {
        return room.roomState.ownerSet(owner);
      }).return().asCallback(cb);
    }

    /**
     * Changes the room history size.
     *
     * @param {string} roomName Room name.
     * @param {number} size Room history size.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'changeRoomHistoryMaxSize',
    value: function changeRoomHistoryMaxSize(roomName, size, cb) {
      return this.state.getRoom(roomName).then(function (room) {
        return room.roomState.historyMaxSizeSet(size);
      }).return().asCallback(cb);
    }

    /**
     * Enables or disables access lists updates for the room.
     *
     * @param {string} roomName Room name.
     * @param {boolean} mode Enable or disable.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     *
     * @see rpc.serverNotifications.roomAccessListAdded
     * @see rpc.serverNotifications.roomAccessListRemoved
     * @see rpc.serverNotifications.roomModeChanged
     */

  }, {
    key: 'changeAccessListsUpdates',
    value: function changeAccessListsUpdates(roomName, mode, cb) {
      return this.state.getRoom(roomName).then(function (room) {
        return room.roomState.accessListsUpdatesSet(mode);
      }).return().asCallback(cb);
    }

    /**
     * Enables or disables user list updates for the room.
     *
     * @param {string} roomName Room name.
     * @param {boolean} mode Enable or disable.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     *
     * @see rpc.serverNotifications.roomUserJoined
     * @see rpc.serverNotifications.roomUserLeft
     */

  }, {
    key: 'changeUserlistUpdates',
    value: function changeUserlistUpdates(roomName, mode, cb) {
      return this.state.getRoom(roomName).then(function (room) {
        return room.roomState.userlistUpdatesSet(mode);
      }).return().asCallback(cb);
    }
  }]);
  return ServiceAPI;
}();

module.exports = ServiceAPI;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi4uL3NyYy9TZXJ2aWNlQVBJLmpzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOzs7Ozs7Ozs7Ozs7Ozs7O0FBRUEsSUFBTSxtQkFBbUIsUUFBUSxvQkFBUixDQUF6QjtBQUNBLElBQU0sVUFBVSxRQUFRLFVBQVIsQ0FBaEI7QUFDQSxJQUFNLElBQUksUUFBUSxRQUFSLENBQVY7O2VBQytDLFFBQVEsU0FBUixDOztJQUF2QyxnQixZQUFBLGdCO0lBQWtCLGdCLFlBQUEsZ0I7O0FBRTFCOzs7Ozs7OztJQU9NLFU7QUFFSixzQkFBYSxLQUFiLEVBQW9CLFFBQXBCLEVBQThCLFVBQTlCLEVBQTBDO0FBQUE7O0FBQ3hDLFNBQUssS0FBTCxHQUFhLEtBQWI7QUFDQSxTQUFLLFFBQUwsR0FBZ0IsUUFBaEI7QUFDQSxTQUFLLFVBQUwsR0FBa0IsVUFBbEI7QUFDRDs7QUFFRDs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7OztvQ0F3QmlCLE8sRUFBUyxPLEVBQWtCO0FBQUE7O0FBQzFDLFVBQUksRUFBRSxRQUFGLENBQVcsT0FBWCxDQUFKLEVBQXlCO0FBQUEsdUJBQ0osT0FESTtBQUFBLFlBQ2pCLFFBRGlCLFlBQ2pCLFFBRGlCOztBQUV2QixrQkFBVSxFQUFFLEtBQUYsQ0FBUSxPQUFSLENBQVY7QUFDRCxPQUhELE1BR08sSUFBSSxFQUFFLFNBQUYsQ0FBWSxPQUFaLENBQUosRUFBMEI7QUFDL0Isa0JBQVUsRUFBQyxtQkFBbUIsT0FBcEIsRUFBVjtBQUNELE9BRk0sTUFFQTtBQUNMLG1CQUFXLE9BQVg7QUFDQSxrQkFBVSxFQUFWO0FBQ0Q7QUFDRCxjQUFRLFdBQVIsR0FBc0IsSUFBdEI7O0FBVjBDLHdDQUFOLElBQU07QUFBTixZQUFNO0FBQUE7O0FBQUEsOEJBV3hCLGlCQUFpQixJQUFqQixDQVh3Qjs7QUFBQTs7QUFBQSxVQVdyQyxLQVhxQztBQUFBLFVBVzlCLEVBWDhCOztBQVkxQyxhQUFPLFFBQVEsR0FBUixDQUFZLFlBQU07QUFDdkIsWUFBSSxRQUFKLEVBQWM7QUFDWixpQkFBTyxNQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLENBQVA7QUFDRCxTQUZELE1BRU87QUFDTCxpQkFBTyxNQUFLLFFBQUwsRUFBUDtBQUNEO0FBQ0YsT0FOTSxFQU1KLElBTkksQ0FNQztBQUFBLGVBQVEsS0FBSyxJQUFMLENBQVUsT0FBVixFQUFtQixPQUFuQixFQUE0QixLQUE1QixDQUFSO0FBQUEsT0FORCxFQU9KLFVBUEksQ0FPTyxFQVBQLEVBT1csRUFBRSxRQUFRLElBQVYsRUFQWCxDQUFQO0FBUUQ7O0FBRUQ7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7NEJBZ0JTLFEsRUFBVSxLLEVBQU8sRSxFQUFJO0FBQUE7O0FBQzVCLGFBQU8saUJBQWlCLFFBQWpCLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBTSxPQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLEVBQTZCLEtBQTdCLENBQU47QUFBQSxPQURELEVBRUosTUFGSSxHQUdKLFVBSEksQ0FHTyxFQUhQLENBQVA7QUFJRDs7QUFFRDs7Ozs7Ozs7Ozs7OytCQVNZLFEsRUFBVSxFLEVBQUk7QUFBQTs7QUFDeEIsYUFBTyxLQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLEVBQTZCLElBQTdCLENBQWtDLGdCQUFRO0FBQy9DLGVBQU8sS0FBSyxjQUFMLEdBQXNCLElBQXRCLENBQTJCLG1CQUFXO0FBQzNDLGNBQUksV0FBVyxFQUFFLElBQUYsQ0FBTyxPQUFQLElBQWtCLENBQWpDLEVBQW9DO0FBQ2xDLG1CQUFPLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsWUFBckIsRUFBbUMsUUFBbkMsQ0FBZixDQUFQO0FBQ0QsV0FGRCxNQUVPO0FBQ0wsbUJBQU8sUUFBUSxHQUFSLENBQVksQ0FDakIsS0FBSyxXQUFMLEVBRGlCLEVBRWpCLE9BQUssS0FBTCxDQUFXLFVBQVgsQ0FBc0IsUUFBdEIsQ0FGaUIsQ0FBWixDQUFQO0FBSUQ7QUFDRixTQVRNLENBQVA7QUFVRCxPQVhNLEVBV0osTUFYSSxHQVdLLFVBWEwsQ0FXZ0IsRUFYaEIsQ0FBUDtBQVlEOztBQUVEOzs7Ozs7Ozs7Ozs0QkFRUyxRLEVBQVUsRSxFQUFJO0FBQ3JCLGFBQU8sS0FBSyxLQUFMLENBQVcsT0FBWCxDQUFtQixRQUFuQixFQUE2QixJQUE3QixFQUNKLElBREksQ0FDQztBQUFBLGVBQVEsUUFBUSxJQUFSLENBQVI7QUFBQSxPQURELEVBRUosVUFGSSxDQUVPLEVBRlAsQ0FBUDtBQUdEOztBQUVEOzs7Ozs7Ozs7Ozs7O2tDQVVlLFEsRUFBVSxRLEVBQVUsSSxFQUFNLEUsRUFBSTtBQUMzQyxhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLEtBQUssZUFBTCxDQUFxQixTQUFyQixDQUErQixRQUEvQixFQUF5QyxJQUF6QyxDQUFSO0FBQUEsT0FERCxFQUVKLFVBRkksQ0FFTyxFQUZQLENBQVA7QUFHRDs7QUFFRDs7Ozs7Ozs7Ozs7O29DQVNpQixTLEVBQVcsTSxFQUFRLEUsRUFBSTtBQUN0QyxhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsU0FBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLEtBQUssZUFBTCxDQUFxQixVQUFyQixDQUFnQyxNQUFoQyxDQUFSO0FBQUEsT0FERCxFQUVKLE1BRkksQ0FFRyxJQUZILEVBR0osV0FISSxDQUdRLGdCQUhSLEVBRzBCLEtBSDFCLEVBSUosVUFKSSxDQUlPLEVBSlAsQ0FBUDtBQUtEOztBQUVEOzs7Ozs7Ozs7OzswQ0FRdUIsUSxFQUFVO0FBQy9CLFdBQUssVUFBTCxDQUFnQixJQUFoQixDQUFxQix1QkFBckIsRUFBOEMsUUFBOUM7QUFDRDs7QUFFRDs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs0QkF5QlMsUSxFQUFVLEssRUFBTyxFLEVBQUk7QUFBQTs7QUFDNUIsYUFBTyxpQkFBaUIsUUFBakIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFNLE9BQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFBNkIsS0FBN0IsQ0FBTjtBQUFBLE9BREQsRUFFSixNQUZJLEdBR0osVUFISSxDQUdPLEVBSFAsQ0FBUDtBQUlEOztBQUVEOzs7Ozs7Ozs7OzsrQkFRWSxRLEVBQVUsRSxFQUFJO0FBQ3hCLGFBQU8sS0FBSyxlQUFMLENBQXFCLElBQXJCLEVBQTJCLFlBQTNCLEVBQXlDLFFBQXpDLEVBQ0osTUFESSxHQUVKLFVBRkksQ0FFTyxFQUZQLENBQVA7QUFHRDs7QUFFRDs7Ozs7Ozs7Ozs7NEJBUVMsUSxFQUFVLEUsRUFBSTtBQUNyQixhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFBNkIsSUFBN0IsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLFFBQVEsSUFBUixDQUFSO0FBQUEsT0FERCxFQUVKLFVBRkksQ0FFTyxFQUZQLENBQVA7QUFHRDs7QUFFRDs7Ozs7Ozs7Ozs7OztrQ0FVZSxRLEVBQVUsUSxFQUFVLEksRUFBTSxFLEVBQUk7QUFDM0MsYUFBTyxLQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBUSxLQUFLLFNBQUwsQ0FBZSxTQUFmLENBQXlCLFFBQXpCLEVBQW1DLElBQW5DLENBQVI7QUFBQSxPQURELEVBRUosVUFGSSxDQUVPLEVBRlAsQ0FBUDtBQUdEOztBQUVEOzs7Ozs7Ozs7Ozs7a0NBU2UsUSxFQUFVLFEsRUFBVSxFLEVBQUk7QUFDckMsYUFBTyxLQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBUSxLQUFLLFVBQUwsQ0FBZ0IsUUFBaEIsQ0FBUjtBQUFBLE9BREQsRUFFSixNQUZJLENBRUcsSUFGSCxFQUdKLFdBSEksQ0FHUSxnQkFIUixFQUcwQixLQUgxQixFQUlKLFVBSkksQ0FJTyxFQUpQLENBQVA7QUFLRDs7QUFFRDs7Ozs7Ozs7Ozs7O29DQVNpQixRLEVBQVUsSyxFQUFPLEUsRUFBSTtBQUNwQyxhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLEtBQUssU0FBTCxDQUFlLFFBQWYsQ0FBd0IsS0FBeEIsQ0FBUjtBQUFBLE9BREQsRUFFSixNQUZJLEdBR0osVUFISSxDQUdPLEVBSFAsQ0FBUDtBQUlEOztBQUVEOzs7Ozs7Ozs7Ozs7NkNBUzBCLFEsRUFBVSxJLEVBQU0sRSxFQUFJO0FBQzVDLGFBQU8sS0FBSyxLQUFMLENBQVcsT0FBWCxDQUFtQixRQUFuQixFQUNKLElBREksQ0FDQztBQUFBLGVBQVEsS0FBSyxTQUFMLENBQWUsaUJBQWYsQ0FBaUMsSUFBakMsQ0FBUjtBQUFBLE9BREQsRUFFSixNQUZJLEdBR0osVUFISSxDQUdPLEVBSFAsQ0FBUDtBQUlEOztBQUVEOzs7Ozs7Ozs7Ozs7Ozs7OzZDQWEwQixRLEVBQVUsSSxFQUFNLEUsRUFBSTtBQUM1QyxhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLEtBQUssU0FBTCxDQUFlLHFCQUFmLENBQXFDLElBQXJDLENBQVI7QUFBQSxPQURELEVBRUosTUFGSSxHQUdKLFVBSEksQ0FHTyxFQUhQLENBQVA7QUFJRDs7QUFFRDs7Ozs7Ozs7Ozs7Ozs7OzBDQVl1QixRLEVBQVUsSSxFQUFNLEUsRUFBSTtBQUN6QyxhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLEtBQUssU0FBTCxDQUFlLGtCQUFmLENBQWtDLElBQWxDLENBQVI7QUFBQSxPQURELEVBRUosTUFGSSxHQUdKLFVBSEksQ0FHTyxFQUhQLENBQVA7QUFJRDs7Ozs7QUFJSCxPQUFPLE9BQVAsR0FBaUIsVUFBakIiLCJmaWxlIjoiU2VydmljZUFQSS5qcyIsInNvdXJjZXNDb250ZW50IjpbIid1c2Ugc3RyaWN0J1xuXG5jb25zdCBDaGF0U2VydmljZUVycm9yID0gcmVxdWlyZSgnLi9DaGF0U2VydmljZUVycm9yJylcbmNvbnN0IFByb21pc2UgPSByZXF1aXJlKCdibHVlYmlyZCcpXG5jb25zdCBfID0gcmVxdWlyZSgnbG9kYXNoJylcbmNvbnN0IHsgY2hlY2tOYW1lU3ltYm9scywgcG9zc2libHlDYWxsYmFjayB9ID0gcmVxdWlyZSgnLi91dGlscycpXG5cbi8qKlxuICogU2VydmVyIHNpZGUgb3BlcmF0aW9ucy5cbiAqXG4gKiBAbWl4aW5cbiAqIEBtZW1iZXJvZiBjaGF0LXNlcnZpY2VcbiAqIEBzZWUgY2hhdC1zZXJ2aWNlLkNoYXRTZXJ2aWNlXG4gKi9cbmNsYXNzIFNlcnZpY2VBUEkge1xuXG4gIGNvbnN0cnVjdG9yIChzdGF0ZSwgbWFrZVVzZXIsIGNsdXN0ZXJCdXMpIHtcbiAgICB0aGlzLnN0YXRlID0gc3RhdGVcbiAgICB0aGlzLm1ha2VVc2VyID0gbWFrZVVzZXJcbiAgICB0aGlzLmNsdXN0ZXJCdXMgPSBjbHVzdGVyQnVzXG4gIH1cblxuICAvKipcbiAgICogRXhlY3V0ZXMge0BsaW5rIHJwYy5jbGllbnRSZXF1ZXN0c30gaGFuZGxlcnMuXG4gICAqXG4gICAqIEBwYXJhbSB7c3RyaW5nfGJvb2xlYW58T2JqZWN0fSBjb250ZXh0IElzIGEgYHVzZXJOYW1lYCBpZlxuICAgKiBgc3RyaW5nYCwgb3IgYSBgYnlwYXNzUGVybWlzc2lvbnNgIGlmIGBib29sZWFuYCwgb3IgYW4gb3B0aW9uc1xuICAgKiBvYmplY3QgaWYgYE9iamVjdGAuXG4gICAqIEBwYXJhbSB7c3RyaW5nfSBjb21tYW5kIENvbW1hbmQgbmFtZS5cbiAgICogQHBhcmFtIHsuLi4qfSBhcmdzIENvbW1hbmQgYXJndW1lbnRzLlxuICAgKiBAcGFyYW0ge2NhbGxiYWNrfSBbY2JdIE9wdGlvbmFsIGNhbGxiYWNrLlxuICAgKlxuICAgKiBAcHJvcGVydHkge3N0cmluZ30gW2NvbnRleHQudXNlck5hbWVdIFVzZXIgbmFtZS5cbiAgICogQHByb3BlcnR5IHtzdHJpbmd9IFtjb250ZXh0LmlkXSBTb2NrZXQgaWQsIGl0IGlzIHJlcXVpcmVkIGZvclxuICAgKiB7QGxpbmsgcnBjLmNsaWVudFJlcXVlc3RzLnJvb21Kb2lufSBhbmQge0BsaW5rXG4gICAqIHJwYy5jbGllbnRSZXF1ZXN0cy5yb29tTGVhdmV9IGNvbW1hbmRzLlxuICAgKiBAcHJvcGVydHkge2Jvb2xlYW59IFtjb250ZXh0LmJ5cGFzc0hvb2tzPWZhbHNlXSBJZiBgZmFsc2VgXG4gICAqIGV4ZWN1dGVzIGNvbW1hbmQgd2l0aG91dCBiZWZvcmUgYW5kIGFmdGVyIGhvb2tzLlxuICAgKiBAcHJvcGVydHkge2Jvb2xlYW59IFtjb250ZXh0LmJ5cGFzc1Blcm1pc3Npb25zPWZhbHNlXSBJZiBgdHJ1ZWBcbiAgICogZXhlY3V0ZXMgY29tbWFuZCAoZXhjZXB0IHtAbGluayBycGMuY2xpZW50UmVxdWVzdHMucm9vbUpvaW59KVxuICAgKiBieXBhc3NpbmcgYnVpbHQtaW4gcGVybWlzc2lvbnMgY2hlY2tpbmcuXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8QXJyYXk+fSBBcnJheSBvZiBjb21tYW5kIHJlc3VsdHMuXG4gICAqXG4gICAqIEBzZWUgcnBjLmNsaWVudFJlcXVlc3RzXG4gICAqL1xuICBleGVjVXNlckNvbW1hbmQgKGNvbnRleHQsIGNvbW1hbmQsIC4uLmFyZ3MpIHtcbiAgICBpZiAoXy5pc09iamVjdChjb250ZXh0KSkge1xuICAgICAgdmFyIHsgdXNlck5hbWUgfSA9IGNvbnRleHRcbiAgICAgIGNvbnRleHQgPSBfLmNsb25lKGNvbnRleHQpXG4gICAgfSBlbHNlIGlmIChfLmlzQm9vbGVhbihjb250ZXh0KSkge1xuICAgICAgY29udGV4dCA9IHtieXBhc3NQZXJtaXNzaW9uczogY29udGV4dH1cbiAgICB9IGVsc2Uge1xuICAgICAgdXNlck5hbWUgPSBjb250ZXh0XG4gICAgICBjb250ZXh0ID0ge31cbiAgICB9XG4gICAgY29udGV4dC5pc0xvY2FsQ2FsbCA9IHRydWVcbiAgICBsZXQgW25hcmdzLCBjYl0gPSBwb3NzaWJseUNhbGxiYWNrKGFyZ3MpXG4gICAgcmV0dXJuIFByb21pc2UudHJ5KCgpID0+IHtcbiAgICAgIGlmICh1c2VyTmFtZSkge1xuICAgICAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRVc2VyKHVzZXJOYW1lKVxuICAgICAgfSBlbHNlIHtcbiAgICAgICAgcmV0dXJuIHRoaXMubWFrZVVzZXIoKVxuICAgICAgfVxuICAgIH0pLnRoZW4odXNlciA9PiB1c2VyLmV4ZWMoY29tbWFuZCwgY29udGV4dCwgbmFyZ3MpKVxuICAgICAgLmFzQ2FsbGJhY2soY2IsIHsgc3ByZWFkOiB0cnVlIH0pXG4gIH1cblxuICAvKipcbiAgICogQWRkcyBhbiB1c2VyIHdpdGggYSBzdGF0ZS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHVzZXJOYW1lIFVzZXIgbmFtZS5cbiAgICogQHBhcmFtIHtPYmplY3R9IFtzdGF0ZV0gVXNlciBzdGF0ZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHByb3BlcnR5IHtBcnJheTxzdHJpbmc+fSBbc3RhdGUud2hpdGVsaXN0PVtdXSBVc2VyIGRpcmVjdCBtZXNzYWdlc1xuICAgKiB3aGl0ZWxpc3QuXG4gICAqIEBwcm9wZXJ0eSB7QXJyYXk8c3RyaW5nPn0gW3N0YXRlLmJsYWNrbGlzdD1bXV0gVXNlciBkaXJlY3QgbWVzc2FnZXNcbiAgICogYmxhY2tsaXN0LlxuICAgKiBAcHJvcGVydHkge2Jvb2xlYW59IFtzdGF0ZS53aGl0ZWxpc3RPbmx5PWZhbHNlXSBVc2VyIGRpcmVjdFxuICAgKiBtZXNzYWdlcyB3aGl0ZWxpc3RPbmx5IG1vZGUuXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8dW5kZWZpbmVkPn0gUHJvbWlzZSB0aGF0IHJlc29sdmVzIHdpdGhvdXQgYW55IGRhdGEuXG4gICAqL1xuICBhZGRVc2VyICh1c2VyTmFtZSwgc3RhdGUsIGNiKSB7XG4gICAgcmV0dXJuIGNoZWNrTmFtZVN5bWJvbHModXNlck5hbWUpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLnN0YXRlLmFkZFVzZXIodXNlck5hbWUsIHN0YXRlKSlcbiAgICAgIC5yZXR1cm4oKVxuICAgICAgLmFzQ2FsbGJhY2soY2IpXG4gIH1cblxuICAvKipcbiAgICogRGVsZXRlcyBhbiBvZmZsaW5lIHVzZXIuIFdpbGwgcmFpc2UgYW4gZXJyb3IgaWYgYSB1c2VyIGhhcyBvbmxpbmVcbiAgICogc29ja2V0cy5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHVzZXJOYW1lIFVzZXIgbmFtZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTx1bmRlZmluZWQ+fSBQcm9taXNlIHRoYXQgcmVzb2x2ZXMgd2l0aG91dCBhbnkgZGF0YS5cbiAgICovXG4gIGRlbGV0ZVVzZXIgKHVzZXJOYW1lLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFVzZXIodXNlck5hbWUpLnRoZW4odXNlciA9PiB7XG4gICAgICByZXR1cm4gdXNlci5saXN0T3duU29ja2V0cygpLnRoZW4oc29ja2V0cyA9PiB7XG4gICAgICAgIGlmIChzb2NrZXRzICYmIF8uc2l6ZShzb2NrZXRzKSA+IDApIHtcbiAgICAgICAgICByZXR1cm4gUHJvbWlzZS5yZWplY3QobmV3IENoYXRTZXJ2aWNlRXJyb3IoJ3VzZXJPbmxpbmUnLCB1c2VyTmFtZSkpXG4gICAgICAgIH0gZWxzZSB7XG4gICAgICAgICAgcmV0dXJuIFByb21pc2UuYWxsKFtcbiAgICAgICAgICAgIHVzZXIucmVtb3ZlU3RhdGUoKSxcbiAgICAgICAgICAgIHRoaXMuc3RhdGUucmVtb3ZlVXNlcih1c2VyTmFtZSlcbiAgICAgICAgICBdKVxuICAgICAgICB9XG4gICAgICB9KVxuICAgIH0pLnJldHVybigpLmFzQ2FsbGJhY2soY2IpXG4gIH1cblxuICAvKipcbiAgICogQ2hlY2tzIGZvciBhbiB1c2VyIGV4aXN0ZW5jZS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHVzZXJOYW1lIFVzZXIgbmFtZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTxib29sZWFuPn0gUHJlZGljYXRlIHJlc3VsdC5cbiAgICovXG4gIGhhc1VzZXIgKHVzZXJOYW1lLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFVzZXIodXNlck5hbWUsIHRydWUpXG4gICAgICAudGhlbih1c2VyID0+IEJvb2xlYW4odXNlcikpXG4gICAgICAuYXNDYWxsYmFjayhjYilcbiAgfVxuXG4gIC8qKlxuICAgKiBDaGVja3MgZm9yIGEgbmFtZSBleGlzdGVuY2UgaW4gYSBkaXJlY3QgbWVzc2FnaW5nIGxpc3QuXG4gICAqXG4gICAqIEBwYXJhbSB7c3RyaW5nfSB1c2VyTmFtZSBVc2VyIG5hbWUuXG4gICAqIEBwYXJhbSB7c3RyaW5nfSBsaXN0TmFtZSBMaXN0IG5hbWUuXG4gICAqIEBwYXJhbSB7c3RyaW5nfSBpdGVtIExpc3QgZWxlbWVudC5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTxib29sZWFuPn0gUHJlZGljYXRlIHJlc3VsdC5cbiAgICovXG4gIHVzZXJIYXNJbkxpc3QgKHVzZXJOYW1lLCBsaXN0TmFtZSwgaXRlbSwgY2IpIHtcbiAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRVc2VyKHVzZXJOYW1lKVxuICAgICAgLnRoZW4odXNlciA9PiB1c2VyLmRpcmVjdE1lc3NhZ2luZy5oYXNJbkxpc3QobGlzdE5hbWUsIGl0ZW0pKVxuICAgICAgLmFzQ2FsbGJhY2soY2IpXG4gIH1cblxuICAvKipcbiAgICogQ2hlY2tzIGZvciBhIGRpcmVjdCBtZXNzYWdpbmcgcGVybWlzc2lvbi5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHJlY2lwaWVudCBSZWNpcGllbnQgbmFtZS5cbiAgICogQHBhcmFtIHtzdHJpbmd9IHNlbmRlciBTZW5kZXIgbmFtZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTxib29sZWFuPn0gUHJlZGljYXRlIHJlc3VsdC5cbiAgICovXG4gIGhhc0RpcmVjdEFjY2VzcyAocmVjaXBpZW50LCBzZW5kZXIsIGNiKSB7XG4gICAgcmV0dXJuIHRoaXMuc3RhdGUuZ2V0VXNlcihyZWNpcGllbnQpXG4gICAgICAudGhlbih1c2VyID0+IHVzZXIuZGlyZWN0TWVzc2FnaW5nLmNoZWNrQWNlc3Moc2VuZGVyKSlcbiAgICAgIC5yZXR1cm4odHJ1ZSlcbiAgICAgIC5jYXRjaFJldHVybihDaGF0U2VydmljZUVycm9yLCBmYWxzZSlcbiAgICAgIC5hc0NhbGxiYWNrKGNiKVxuICB9XG5cbiAgLyoqXG4gICAqIERpc2Nvbm5lY3RzIHVzZXIncyBzb2NrZXRzIGZvciBhbGwgc2VydmljZSBpbnN0YW5jZXMuIE1ldGhvZCBpc1xuICAgKiBhc3luY2hyb25vdXMsIHJldHVybnMgd2l0aG91dCB3YWl0aW5nIGZvciB0aGUgY29tcGxldGlvbi5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHVzZXJOYW1lIFVzZXIgbmFtZS5cbiAgICpcbiAgICogQHJldHVybiB7dW5kZWZpbmVkfSBSZXR1cm5zIG5vIGRhdGEuXG4gICAqL1xuICBkaXNjb25uZWN0VXNlclNvY2tldHMgKHVzZXJOYW1lKSB7XG4gICAgdGhpcy5jbHVzdGVyQnVzLmVtaXQoJ2Rpc2Nvbm5lY3RVc2VyU29ja2V0cycsIHVzZXJOYW1lKVxuICB9XG5cbiAgLyoqXG4gICAqIEFkZHMgYSByb29tIHdpdGggYSBzdGF0ZS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHJvb21OYW1lIFJvb20gbmFtZS5cbiAgICogQHBhcmFtIHtPYmplY3R9IFtzdGF0ZV0gUm9vbSBzdGF0ZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHByb3BlcnR5IHtBcnJheTxzdHJpbmc+fSBbc3RhdGUud2hpdGVsaXN0PVtdXSBSb29tIHdoaXRlbGlzdC5cbiAgICogQHByb3BlcnR5IHtBcnJheTxzdHJpbmc+fSBbc3RhdGUuYmxhY2tsaXN0PVtdXSBSb29tIGJsYWNrbGlzdFxuICAgKiBAcHJvcGVydHkge0FycmF5PHN0cmluZz59IFtzdGF0ZS5hZG1pbmxpc3Q9W11dIFJvb20gYWRtaW5saXN0LlxuICAgKiBAcHJvcGVydHkge2Jvb2xlYW59IFtzdGF0ZS53aGl0ZWxpc3RPbmx5PWZhbHNlXSBSb29tXG4gICAqIHdoaXRlbGlzdE9ubHkgbW9kZS5cbiAgICogQHByb3BlcnR5IHtzdHJpbmd9IFtzdGF0ZS5vd25lcl0gUm9vbSBvd25lci5cbiAgICogQHByb3BlcnR5IHtudW1iZXJ9IFtzdGF0ZS5oaXN0b3J5TWF4U2l6ZV0gUm9vbSBoaXN0b3J5IG1heGltdW1cbiAgICogc2l6ZS4gRGVmYWx1dCB2YWx1ZSBpcyB7QGxpbmsgY2hhdC1zZXJ2aWNlLmNvbmZpZy5vcHRpb25zfVxuICAgKiBgaGlzdG9yeU1heFNpemVgLlxuICAgKiBAcHJvcGVydHkge2Jvb2xlYW59IFtzdGF0ZS5lbmFibGVBY2Nlc3NMaXN0c1VwZGF0ZXNdIFJvb20gZW5hYmxlXG4gICAqIGFjY2VzcyBsaXN0cyB1cGRhdGVzLiBEZWZhbHV0IHZhbHVlIGlzIHtAbGlua1xuICAgKiBjaGF0LXNlcnZpY2UuY29uZmlnLm9wdGlvbnN9IGBlbmFibGVBY2Nlc3NMaXN0c1VwZGF0ZXNgLlxuICAgKiBAcHJvcGVydHkge2Jvb2xlYW59IFtzdGF0ZS5lbmFibGVVc2VybGlzdFVwZGF0ZXNdIFJvb20gZW5hYmxlXG4gICAqIHVzZXJsaXN0IHVwZGF0ZXMuIERlZmFsdXQgdmFsdWUgaXMge0BsaW5rXG4gICAqIGNoYXQtc2VydmljZS5jb25maWcub3B0aW9uc30gYGVuYWJsZVVzZXJsaXN0VXBkYXRlc2AuXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8dW5kZWZpbmVkPn0gUHJvbWlzZSB0aGF0IHJlc29sdmVzIHdpdGhvdXQgYW55IGRhdGEuXG4gICAqL1xuICBhZGRSb29tIChyb29tTmFtZSwgc3RhdGUsIGNiKSB7XG4gICAgcmV0dXJuIGNoZWNrTmFtZVN5bWJvbHMocm9vbU5hbWUpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLnN0YXRlLmFkZFJvb20ocm9vbU5hbWUsIHN0YXRlKSlcbiAgICAgIC5yZXR1cm4oKVxuICAgICAgLmFzQ2FsbGJhY2soY2IpXG4gIH1cblxuICAvKipcbiAgICogUmVtb3ZlcyBhbGwgam9pbmVkIHVzZXJzIGZyb20gdGhlIHJvb20gYW5kIHJlbW92ZXMgYWxsIHJvb20gZGF0YS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHJvb21OYW1lIFJvb20gbmFtZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTx1bmRlZmluZWQ+fSBQcm9taXNlIHRoYXQgcmVzb2x2ZXMgd2l0aG91dCBhbnkgZGF0YS5cbiAgICovXG4gIGRlbGV0ZVJvb20gKHJvb21OYW1lLCBjYikge1xuICAgIHJldHVybiB0aGlzLmV4ZWNVc2VyQ29tbWFuZCh0cnVlLCAncm9vbURlbGV0ZScsIHJvb21OYW1lKVxuICAgICAgLnJldHVybigpXG4gICAgICAuYXNDYWxsYmFjayhjYilcbiAgfVxuXG4gIC8qKlxuICAgKiBDaGVja3MgZm9yIGEgcm9vbSBleGlzdGVuY2UuXG4gICAqXG4gICAqIEBwYXJhbSB7c3RyaW5nfSByb29tTmFtZSBSb29tIG5hbWUuXG4gICAqIEBwYXJhbSB7Y2FsbGJhY2t9IFtjYl0gT3B0aW9uYWwgY2FsbGJhY2suXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8Ym9vbGVhbj59IFByZWRpY2F0ZSByZXN1bHQuXG4gICAqL1xuICBoYXNSb29tIChyb29tTmFtZSwgY2IpIHtcbiAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRSb29tKHJvb21OYW1lLCB0cnVlKVxuICAgICAgLnRoZW4ocm9vbSA9PiBCb29sZWFuKHJvb20pKVxuICAgICAgLmFzQ2FsbGJhY2soY2IpXG4gIH1cblxuICAvKipcbiAgICogQ2hlY2tzIGZvciBhIG5hbWUgZXhpc3RlbmNlIGluIGEgcm9vbSBsaXN0LlxuICAgKlxuICAgKiBAcGFyYW0ge3N0cmluZ30gcm9vbU5hbWUgUm9vbSBuYW1lLlxuICAgKiBAcGFyYW0ge3N0cmluZ30gbGlzdE5hbWUgTGlzdCBuYW1lLlxuICAgKiBAcGFyYW0ge3N0cmluZ30gaXRlbSBMaXN0IGVsZW1lbnQuXG4gICAqIEBwYXJhbSB7Y2FsbGJhY2t9IFtjYl0gT3B0aW9uYWwgY2FsbGJhY2suXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8Ym9vbGVhbj59IFByZWRpY2F0ZSByZXN1bHQuXG4gICAqL1xuICByb29tSGFzSW5MaXN0IChyb29tTmFtZSwgbGlzdE5hbWUsIGl0ZW0sIGNiKSB7XG4gICAgcmV0dXJuIHRoaXMuc3RhdGUuZ2V0Um9vbShyb29tTmFtZSlcbiAgICAgIC50aGVuKHJvb20gPT4gcm9vbS5yb29tU3RhdGUuaGFzSW5MaXN0KGxpc3ROYW1lLCBpdGVtKSlcbiAgICAgIC5hc0NhbGxiYWNrKGNiKVxuICB9XG5cbiAgLyoqXG4gICAqIENoZWNrcyBmb3IgYSByb29tIGFjY2VzcyBwZXJtaXNzaW9uLlxuICAgKlxuICAgKiBAcGFyYW0ge3N0cmluZ30gcm9vbU5hbWUgUm9vbSBuYW1lLlxuICAgKiBAcGFyYW0ge3N0cmluZ30gdXNlck5hbWUgVXNlciBuYW1lLlxuICAgKiBAcGFyYW0ge2NhbGxiYWNrfSBbY2JdIE9wdGlvbmFsIGNhbGxiYWNrLlxuICAgKlxuICAgKiBAcmV0dXJuIHtQcm9taXNlPGJvb2xlYW4+fSBQcmVkaWNhdGUgcmVzdWx0LlxuICAgKi9cbiAgaGFzUm9vbUFjY2VzcyAocm9vbU5hbWUsIHVzZXJOYW1lLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFJvb20ocm9vbU5hbWUpXG4gICAgICAudGhlbihyb29tID0+IHJvb20uY2hlY2tBY2Vzcyh1c2VyTmFtZSkpXG4gICAgICAucmV0dXJuKHRydWUpXG4gICAgICAuY2F0Y2hSZXR1cm4oQ2hhdFNlcnZpY2VFcnJvciwgZmFsc2UpXG4gICAgICAuYXNDYWxsYmFjayhjYilcbiAgfVxuXG4gIC8qKlxuICAgKiBDaGFuZ2VzIHRoZSByb29tIG93bmVyLlxuICAgKlxuICAgKiBAcGFyYW0ge3N0cmluZ30gcm9vbU5hbWUgUm9vbSBuYW1lLlxuICAgKiBAcGFyYW0ge3N0cmluZ30gb3duZXIgT3duZXIgdXNlciBuYW1lLlxuICAgKiBAcGFyYW0ge2NhbGxiYWNrfSBbY2JdIE9wdGlvbmFsIGNhbGxiYWNrLlxuICAgKlxuICAgKiBAcmV0dXJuIHtQcm9taXNlPHVuZGVmaW5lZD59IFByb21pc2UgdGhhdCByZXNvbHZlcyB3aXRob3V0IGFueSBkYXRhLlxuICAgKi9cbiAgY2hhbmdlUm9vbU93bmVyIChyb29tTmFtZSwgb3duZXIsIGNiKSB7XG4gICAgcmV0dXJuIHRoaXMuc3RhdGUuZ2V0Um9vbShyb29tTmFtZSlcbiAgICAgIC50aGVuKHJvb20gPT4gcm9vbS5yb29tU3RhdGUub3duZXJTZXQob3duZXIpKVxuICAgICAgLnJldHVybigpXG4gICAgICAuYXNDYWxsYmFjayhjYilcbiAgfVxuXG4gIC8qKlxuICAgKiBDaGFuZ2VzIHRoZSByb29tIGhpc3Rvcnkgc2l6ZS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHJvb21OYW1lIFJvb20gbmFtZS5cbiAgICogQHBhcmFtIHtudW1iZXJ9IHNpemUgUm9vbSBoaXN0b3J5IHNpemUuXG4gICAqIEBwYXJhbSB7Y2FsbGJhY2t9IFtjYl0gT3B0aW9uYWwgY2FsbGJhY2suXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8dW5kZWZpbmVkPn0gUHJvbWlzZSB0aGF0IHJlc29sdmVzIHdpdGhvdXQgYW55IGRhdGEuXG4gICAqL1xuICBjaGFuZ2VSb29tSGlzdG9yeU1heFNpemUgKHJvb21OYW1lLCBzaXplLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFJvb20ocm9vbU5hbWUpXG4gICAgICAudGhlbihyb29tID0+IHJvb20ucm9vbVN0YXRlLmhpc3RvcnlNYXhTaXplU2V0KHNpemUpKVxuICAgICAgLnJldHVybigpXG4gICAgICAuYXNDYWxsYmFjayhjYilcbiAgfVxuXG4gIC8qKlxuICAgKiBFbmFibGVzIG9yIGRpc2FibGVzIGFjY2VzcyBsaXN0cyB1cGRhdGVzIGZvciB0aGUgcm9vbS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHJvb21OYW1lIFJvb20gbmFtZS5cbiAgICogQHBhcmFtIHtib29sZWFufSBtb2RlIEVuYWJsZSBvciBkaXNhYmxlLlxuICAgKiBAcGFyYW0ge2NhbGxiYWNrfSBbY2JdIE9wdGlvbmFsIGNhbGxiYWNrLlxuICAgKlxuICAgKiBAcmV0dXJuIHtQcm9taXNlPHVuZGVmaW5lZD59IFByb21pc2UgdGhhdCByZXNvbHZlcyB3aXRob3V0IGFueSBkYXRhLlxuICAgKlxuICAgKiBAc2VlIHJwYy5zZXJ2ZXJOb3RpZmljYXRpb25zLnJvb21BY2Nlc3NMaXN0QWRkZWRcbiAgICogQHNlZSBycGMuc2VydmVyTm90aWZpY2F0aW9ucy5yb29tQWNjZXNzTGlzdFJlbW92ZWRcbiAgICogQHNlZSBycGMuc2VydmVyTm90aWZpY2F0aW9ucy5yb29tTW9kZUNoYW5nZWRcbiAgICovXG4gIGNoYW5nZUFjY2Vzc0xpc3RzVXBkYXRlcyAocm9vbU5hbWUsIG1vZGUsIGNiKSB7XG4gICAgcmV0dXJuIHRoaXMuc3RhdGUuZ2V0Um9vbShyb29tTmFtZSlcbiAgICAgIC50aGVuKHJvb20gPT4gcm9vbS5yb29tU3RhdGUuYWNjZXNzTGlzdHNVcGRhdGVzU2V0KG1vZGUpKVxuICAgICAgLnJldHVybigpXG4gICAgICAuYXNDYWxsYmFjayhjYilcbiAgfVxuXG4gIC8qKlxuICAgKiBFbmFibGVzIG9yIGRpc2FibGVzIHVzZXIgbGlzdCB1cGRhdGVzIGZvciB0aGUgcm9vbS5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHJvb21OYW1lIFJvb20gbmFtZS5cbiAgICogQHBhcmFtIHtib29sZWFufSBtb2RlIEVuYWJsZSBvciBkaXNhYmxlLlxuICAgKiBAcGFyYW0ge2NhbGxiYWNrfSBbY2JdIE9wdGlvbmFsIGNhbGxiYWNrLlxuICAgKlxuICAgKiBAcmV0dXJuIHtQcm9taXNlPHVuZGVmaW5lZD59IFByb21pc2UgdGhhdCByZXNvbHZlcyB3aXRob3V0IGFueSBkYXRhLlxuICAgKlxuICAgKiBAc2VlIHJwYy5zZXJ2ZXJOb3RpZmljYXRpb25zLnJvb21Vc2VySm9pbmVkXG4gICAqIEBzZWUgcnBjLnNlcnZlck5vdGlmaWNhdGlvbnMucm9vbVVzZXJMZWZ0XG4gICAqL1xuICBjaGFuZ2VVc2VybGlzdFVwZGF0ZXMgKHJvb21OYW1lLCBtb2RlLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFJvb20ocm9vbU5hbWUpXG4gICAgICAudGhlbihyb29tID0+IHJvb20ucm9vbVN0YXRlLnVzZXJsaXN0VXBkYXRlc1NldChtb2RlKSlcbiAgICAgIC5yZXR1cm4oKVxuICAgICAgLmFzQ2FsbGJhY2soY2IpXG4gIH1cblxufVxuXG5tb2R1bGUuZXhwb3J0cyA9IFNlcnZpY2VBUElcbiJdfQ==