chat-service/lib/Room.js

'use strict';

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

var _regenerator2 = _interopRequireDefault(_regenerator);

var _getIterator2 = require('babel-runtime/core-js/get-iterator');

var _getIterator3 = _interopRequireDefault(_getIterator2);

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('es6-mixin');

var mixin = _require.mixin;

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

var asyncLimit = _require2.asyncLimit;
var run = _require2.run;

var RoomPermissions = function () {
  function RoomPermissions(roomName, roomState, emitFailure) {
    (0, _classCallCheck3.default)(this, RoomPermissions);

    this.roomName = roomName;
    this.roomState = roomState;
    this.emitFailure = emitFailure;
  }

  (0, _createClass3.default)(RoomPermissions, [{
    key: 'consistencyFailure',
    value: function consistencyFailure(error, operationInfo) {
      operationInfo.roomName = this.roomName;
      operationInfo.opType = 'roomUserlist';
      this.emitFailure('storeConsistencyFailure', error, operationInfo);
    }
  }, {
    key: 'isAdmin',
    value: function isAdmin(userName) {
      var _this = this;

      return this.roomState.ownerGet().then(function (owner) {
        if (owner === userName) {
          return true;
        }
        return _this.roomState.hasInList('adminlist', userName);
      });
    }
  }, {
    key: 'hasRemoveChangedCurrentAccess',
    value: function hasRemoveChangedCurrentAccess(userName, listName) {
      var _this2 = this;

      return this.roomState.hasInList('userlist', userName).then(function (hasUser) {
        if (!hasUser) {
          return false;
        }
        return _this2.isAdmin(userName).then(function (admin) {
          if (admin || listName !== 'whitelist') {
            return false;
          }
          return _this2.roomState.whitelistOnlyGet();
        });
      }).catch(function (e) {
        return _this2.consistencyFailure(e, { userName: userName });
      });
    }
  }, {
    key: 'hasAddChangedCurrentAccess',
    value: function hasAddChangedCurrentAccess(userName, listName) {
      var _this3 = this;

      return this.roomState.hasInList('userlist', userName).then(function (hasUser) {
        if (!hasUser) {
          return false;
        }
        return _this3.isAdmin(userName).then(function (admin) {
          return !(admin || listName !== 'blacklist');
        });
      }).catch(function (e) {
        return _this3.consistencyFailure(e, { userName: userName });
      });
    }
  }, {
    key: 'getModeChangedCurrentAccess',
    value: function getModeChangedCurrentAccess(value) {
      if (!value) {
        return [];
      } else {
        return this.roomState.getCommonUsers();
      }
    }
  }, {
    key: 'checkListChanges',
    value: function checkListChanges(author, listName, values, bypassPermissions) {
      var _this4 = this;

      if (listName === 'userlist') {
        return Promise.reject(new ChatServiceError('notAllowed'));
      }
      if (bypassPermissions) {
        return Promise.resolve();
      }
      return this.roomState.ownerGet().then(function (owner) {
        if (author === owner) {
          return Promise.resolve();
        }
        if (listName === 'adminlist') {
          return Promise.reject(new ChatServiceError('notAllowed'));
        }
        return _this4.roomState.hasInList('adminlist', author).then(function (admin) {
          if (!admin) {
            return Promise.reject(new ChatServiceError('notAllowed'));
          }
          var _iteratorNormalCompletion = true;
          var _didIteratorError = false;
          var _iteratorError = undefined;

          try {
            for (var _iterator = (0, _getIterator3.default)(values), _step; !(_iteratorNormalCompletion = (_step = _iterator.next()).done); _iteratorNormalCompletion = true) {
              var name = _step.value;

              if (name !== owner) {
                continue;
              }
              return Promise.reject(new ChatServiceError('notAllowed'));
            }
          } catch (err) {
            _didIteratorError = true;
            _iteratorError = err;
          } finally {
            try {
              if (!_iteratorNormalCompletion && _iterator.return) {
                _iterator.return();
              }
            } finally {
              if (_didIteratorError) {
                throw _iteratorError;
              }
            }
          }

          return Promise.resolve();
        });
      });
    }
  }, {
    key: 'checkModeChange',
    value: function checkModeChange(author, value, bypassPermissions) {
      return this.isAdmin(author).then(function (admin) {
        if (admin || bypassPermissions) {
          return Promise.resolve();
        }
        return Promise.reject(new ChatServiceError('notAllowed'));
      });
    }
  }, {
    key: 'checkAcess',
    value: function checkAcess(userName) {
      return run(this, _regenerator2.default.mark(function _callee() {
        var admin, blacklisted, whitelistOnly, whitelisted;
        return _regenerator2.default.wrap(function _callee$(_context) {
          while (1) {
            switch (_context.prev = _context.next) {
              case 0:
                _context.next = 2;
                return this.isAdmin(userName);

              case 2:
                admin = _context.sent;

                if (!admin) {
                  _context.next = 5;
                  break;
                }

                return _context.abrupt('return', Promise.resolve());

              case 5:
                _context.next = 7;
                return this.roomState.hasInList('blacklist', userName);

              case 7:
                blacklisted = _context.sent;

                if (!blacklisted) {
                  _context.next = 10;
                  break;
                }

                return _context.abrupt('return', Promise.reject(new ChatServiceError('notAllowed')));

              case 10:
                _context.next = 12;
                return this.roomState.whitelistOnlyGet();

              case 12:
                whitelistOnly = _context.sent;

                if (whitelistOnly) {
                  _context.next = 15;
                  break;
                }

                return _context.abrupt('return', Promise.resolve());

              case 15:
                _context.next = 17;
                return this.roomState.hasInList('whitelist', userName);

              case 17:
                whitelisted = _context.sent;

                if (!whitelisted) {
                  _context.next = 20;
                  break;
                }

                return _context.abrupt('return', Promise.resolve());

              case 20:
                return _context.abrupt('return', Promise.reject(new ChatServiceError('notAllowed')));

              case 21:
              case 'end':
                return _context.stop();
            }
          }
        }, _callee, this);
      }));
    }
  }, {
    key: 'checkRead',
    value: function checkRead(author, bypassPermissions) {
      if (bypassPermissions) {
        return Promise.resolve();
      }
      return run(this, _regenerator2.default.mark(function _callee2() {
        var hasAuthor, admin;
        return _regenerator2.default.wrap(function _callee2$(_context2) {
          while (1) {
            switch (_context2.prev = _context2.next) {
              case 0:
                _context2.next = 2;
                return this.roomState.hasInList('userlist', author);

              case 2:
                hasAuthor = _context2.sent;

                if (!hasAuthor) {
                  _context2.next = 5;
                  break;
                }

                return _context2.abrupt('return', Promise.resolve());

              case 5:
                _context2.next = 7;
                return this.isAdmin(author);

              case 7:
                admin = _context2.sent;

                if (!admin) {
                  _context2.next = 10;
                  break;
                }

                return _context2.abrupt('return', Promise.resolve());

              case 10:
                return _context2.abrupt('return', Promise.reject(new ChatServiceError('notJoined', this.roomName)));

              case 11:
              case 'end':
                return _context2.stop();
            }
          }
        }, _callee2, this);
      }));
    }
  }, {
    key: 'checkIsOwner',
    value: function checkIsOwner(author, bypassPermissions) {
      if (bypassPermissions) {
        return Promise.resolve();
      }
      return this.roomState.ownerGet().then(function (owner) {
        if (owner === author) {
          return Promise.resolve();
        }
        return Promise.reject(new ChatServiceError('notAllowed'));
      });
    }
  }]);
  return RoomPermissions;
}();

// Implements room messaging state manipulations with the respect to
// user's permissions.


var Room = function () {
  function Room(server, roomName) {
    (0, _classCallCheck3.default)(this, Room);

    this.server = server;
    this.roomName = roomName;
    this.listSizeLimit = this.server.roomListSizeLimit;
    var State = this.server.state.RoomState;
    this.roomState = new State(this.server, this.roomName);
    mixin(this, RoomPermissions, this.roomName, this.roomState, this.server.emit.bind(this.server));
  }

  (0, _createClass3.default)(Room, [{
    key: 'initState',
    value: function initState(state) {
      return this.roomState.initState(state);
    }
  }, {
    key: 'removeState',
    value: function removeState() {
      return this.roomState.removeState();
    }
  }, {
    key: 'startRemoving',
    value: function startRemoving() {
      return this.roomState.startRemoving();
    }
  }, {
    key: 'getUsers',
    value: function getUsers() {
      return this.roomState.getList('userlist');
    }
  }, {
    key: 'leave',
    value: function leave(author) {
      var _this5 = this;

      return this.roomState.hasInList('userlist', author).then(function (hasAuthor) {
        if (!hasAuthor) {
          return Promise.resolve();
        }
        return _this5.roomState.removeFromList('userlist', [author]).then(function () {
          return _this5.roomState.userSeenUpdate(author);
        });
      });
    }
  }, {
    key: 'join',
    value: function join(author) {
      var _this6 = this;

      return this.checkAcess(author).then(function () {
        return _this6.roomState.hasInList('userlist', author);
      }).then(function (hasAuthor) {
        if (hasAuthor) {
          return Promise.resolve();
        }
        return _this6.roomState.userSeenUpdate(author).then(function () {
          return _this6.roomState.addToList('userlist', [author]);
        });
      });
    }
  }, {
    key: 'message',
    value: function message(author, msg, bypassPermissions) {
      var _this7 = this;

      return Promise.try(function () {
        if (bypassPermissions) {
          return Promise.resolve();
        }
        return _this7.roomState.hasInList('userlist', author).then(function (hasAuthor) {
          if (hasAuthor) {
            return Promise.resolve();
          }
          return Promise.reject(new ChatServiceError('notJoined', _this7.roomName));
        });
      }).then(function () {
        return _this7.roomState.messageAdd(msg);
      });
    }
  }, {
    key: 'getList',
    value: function getList(author, listName, bypassPermissions) {
      var _this8 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return _this8.roomState.getList(listName);
      });
    }
  }, {
    key: 'getRecentMessages',
    value: function getRecentMessages(author, bypassPermissions) {
      var _this9 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return _this9.roomState.messagesGetRecent();
      });
    }
  }, {
    key: 'getHistoryInfo',
    value: function getHistoryInfo(author, bypassPermissions) {
      var _this10 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return _this10.roomState.historyInfo();
      });
    }
  }, {
    key: 'getNotificationsInfo',
    value: function getNotificationsInfo(author, bypassPermissions) {
      var _this11 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return Promise.join(_this11.roomState.userlistUpdatesGet(), _this11.roomState.accessListsUpdatesGet(), function (enableUserlistUpdates, enableAccessListsUpdates) {
          return { enableUserlistUpdates: enableUserlistUpdates, enableAccessListsUpdates: enableAccessListsUpdates };
        });
      });
    }
  }, {
    key: 'getMessages',
    value: function getMessages(author, id, limit, bypassPermissions) {
      var _this12 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        if (!bypassPermissions) {
          limit = _.min([limit, _this12.server.historyMaxGetMessages]);
        }
        return _this12.roomState.messagesGet(id, limit);
      });
    }
  }, {
    key: 'addToList',
    value: function addToList(author, listName, values, bypassPermissions) {
      var _this13 = this;

      return this.checkListChanges(author, listName, values, bypassPermissions).then(function () {
        return _this13.roomState.addToList(listName, values, _this13.listSizeLimit);
      }).then(function () {
        return Promise.filter(values, function (val) {
          return _this13.hasAddChangedCurrentAccess(val, listName);
        }, { concurrency: asyncLimit });
      });
    }
  }, {
    key: 'removeFromList',
    value: function removeFromList(author, listName, values, bypassPermissions) {
      var _this14 = this;

      return this.checkListChanges(author, listName, values, bypassPermissions).then(function () {
        return _this14.roomState.removeFromList(listName, values);
      }).then(function () {
        return Promise.filter(values, function (val) {
          return _this14.hasRemoveChangedCurrentAccess(val, listName);
        }, { concurrency: asyncLimit });
      });
    }
  }, {
    key: 'getMode',
    value: function getMode(author, bypassPermissions) {
      var _this15 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return _this15.roomState.whitelistOnlyGet();
      });
    }
  }, {
    key: 'getOwner',
    value: function getOwner(author, bypassPermissions) {
      var _this16 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return _this16.roomState.ownerGet();
      });
    }
  }, {
    key: 'changeMode',
    value: function changeMode(author, mode, bypassPermissions) {
      var _this17 = this;

      var whitelistOnly = mode;
      return this.checkModeChange(author, mode, bypassPermissions).then(function () {
        return _this17.roomState.whitelistOnlySet(whitelistOnly);
      }).then(function () {
        return _this17.getModeChangedCurrentAccess(whitelistOnly);
      }).then(function (usernames) {
        return [usernames, whitelistOnly];
      });
    }
  }, {
    key: 'userSeen',
    value: function userSeen(author, userName, bypassPermissions) {
      var _this18 = this;

      return this.checkRead(author, bypassPermissions).then(function () {
        return _this18.roomState.userSeenGet(userName);
      });
    }
  }]);
  return Room;
}();

module.exports = Room;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi4uL3NyYy9Sb29tLmpzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOzs7Ozs7Ozs7Ozs7Ozs7Ozs7OztBQUVBLElBQU0sbUJBQW1CLFFBQVEsb0JBQVIsQ0FBekI7QUFDQSxJQUFNLFVBQVUsUUFBUSxVQUFSLENBQWhCO0FBQ0EsSUFBTSxJQUFJLFFBQVEsUUFBUixDQUFWOztlQUNrQixRQUFRLFdBQVIsQzs7SUFBVixLLFlBQUEsSzs7Z0JBQ29CLFFBQVEsU0FBUixDOztJQUFwQixVLGFBQUEsVTtJQUFZLEcsYUFBQSxHOztJQUVkLGU7QUFFSiwyQkFBYSxRQUFiLEVBQXVCLFNBQXZCLEVBQWtDLFdBQWxDLEVBQStDO0FBQUE7O0FBQzdDLFNBQUssUUFBTCxHQUFnQixRQUFoQjtBQUNBLFNBQUssU0FBTCxHQUFpQixTQUFqQjtBQUNBLFNBQUssV0FBTCxHQUFtQixXQUFuQjtBQUNEOzs7O3VDQUVtQixLLEVBQU8sYSxFQUFlO0FBQ3hDLG9CQUFjLFFBQWQsR0FBeUIsS0FBSyxRQUE5QjtBQUNBLG9CQUFjLE1BQWQsR0FBdUIsY0FBdkI7QUFDQSxXQUFLLFdBQUwsQ0FBaUIseUJBQWpCLEVBQTRDLEtBQTVDLEVBQW1ELGFBQW5EO0FBQ0Q7Ozs0QkFFUSxRLEVBQVU7QUFBQTs7QUFDakIsYUFBTyxLQUFLLFNBQUwsQ0FBZSxRQUFmLEdBQTBCLElBQTFCLENBQStCLGlCQUFTO0FBQzdDLFlBQUksVUFBVSxRQUFkLEVBQXdCO0FBQUUsaUJBQU8sSUFBUDtBQUFhO0FBQ3ZDLGVBQU8sTUFBSyxTQUFMLENBQWUsU0FBZixDQUF5QixXQUF6QixFQUFzQyxRQUF0QyxDQUFQO0FBQ0QsT0FITSxDQUFQO0FBSUQ7OztrREFFOEIsUSxFQUFVLFEsRUFBVTtBQUFBOztBQUNqRCxhQUFPLEtBQUssU0FBTCxDQUFlLFNBQWYsQ0FBeUIsVUFBekIsRUFBcUMsUUFBckMsRUFBK0MsSUFBL0MsQ0FBb0QsbUJBQVc7QUFDcEUsWUFBSSxDQUFDLE9BQUwsRUFBYztBQUFFLGlCQUFPLEtBQVA7QUFBYztBQUM5QixlQUFPLE9BQUssT0FBTCxDQUFhLFFBQWIsRUFBdUIsSUFBdkIsQ0FBNEIsaUJBQVM7QUFDMUMsY0FBSSxTQUFTLGFBQWEsV0FBMUIsRUFBdUM7QUFBRSxtQkFBTyxLQUFQO0FBQWM7QUFDdkQsaUJBQU8sT0FBSyxTQUFMLENBQWUsZ0JBQWYsRUFBUDtBQUNELFNBSE0sQ0FBUDtBQUlELE9BTk0sRUFNSixLQU5JLENBTUU7QUFBQSxlQUFLLE9BQUssa0JBQUwsQ0FBd0IsQ0FBeEIsRUFBMkIsRUFBQyxrQkFBRCxFQUEzQixDQUFMO0FBQUEsT0FORixDQUFQO0FBT0Q7OzsrQ0FFMkIsUSxFQUFVLFEsRUFBVTtBQUFBOztBQUM5QyxhQUFPLEtBQUssU0FBTCxDQUFlLFNBQWYsQ0FBeUIsVUFBekIsRUFBcUMsUUFBckMsRUFBK0MsSUFBL0MsQ0FBb0QsbUJBQVc7QUFDcEUsWUFBSSxDQUFDLE9BQUwsRUFBYztBQUFFLGlCQUFPLEtBQVA7QUFBYztBQUM5QixlQUFPLE9BQUssT0FBTCxDQUFhLFFBQWIsRUFDSixJQURJLENBQ0M7QUFBQSxpQkFBUyxFQUFFLFNBQVMsYUFBYSxXQUF4QixDQUFUO0FBQUEsU0FERCxDQUFQO0FBRUQsT0FKTSxFQUlKLEtBSkksQ0FJRTtBQUFBLGVBQUssT0FBSyxrQkFBTCxDQUF3QixDQUF4QixFQUEyQixFQUFDLGtCQUFELEVBQTNCLENBQUw7QUFBQSxPQUpGLENBQVA7QUFLRDs7O2dEQUU0QixLLEVBQU87QUFDbEMsVUFBSSxDQUFDLEtBQUwsRUFBWTtBQUNWLGVBQU8sRUFBUDtBQUNELE9BRkQsTUFFTztBQUNMLGVBQU8sS0FBSyxTQUFMLENBQWUsY0FBZixFQUFQO0FBQ0Q7QUFDRjs7O3FDQUVpQixNLEVBQVEsUSxFQUFVLE0sRUFBUSxpQixFQUFtQjtBQUFBOztBQUM3RCxVQUFJLGFBQWEsVUFBakIsRUFBNkI7QUFDM0IsZUFBTyxRQUFRLE1BQVIsQ0FBZSxJQUFJLGdCQUFKLENBQXFCLFlBQXJCLENBQWYsQ0FBUDtBQUNEO0FBQ0QsVUFBSSxpQkFBSixFQUF1QjtBQUFFLGVBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDbkQsYUFBTyxLQUFLLFNBQUwsQ0FBZSxRQUFmLEdBQTBCLElBQTFCLENBQStCLGlCQUFTO0FBQzdDLFlBQUksV0FBVyxLQUFmLEVBQXNCO0FBQUUsaUJBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDbEQsWUFBSSxhQUFhLFdBQWpCLEVBQThCO0FBQzVCLGlCQUFPLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsWUFBckIsQ0FBZixDQUFQO0FBQ0Q7QUFDRCxlQUFPLE9BQUssU0FBTCxDQUFlLFNBQWYsQ0FBeUIsV0FBekIsRUFBc0MsTUFBdEMsRUFBOEMsSUFBOUMsQ0FBbUQsaUJBQVM7QUFDakUsY0FBSSxDQUFDLEtBQUwsRUFBWTtBQUNWLG1CQUFPLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsWUFBckIsQ0FBZixDQUFQO0FBQ0Q7QUFIZ0U7QUFBQTtBQUFBOztBQUFBO0FBSWpFLDREQUFpQixNQUFqQiw0R0FBeUI7QUFBQSxrQkFBaEIsSUFBZ0I7O0FBQ3ZCLGtCQUFJLFNBQVMsS0FBYixFQUFvQjtBQUFFO0FBQVU7QUFDaEMscUJBQU8sUUFBUSxNQUFSLENBQWUsSUFBSSxnQkFBSixDQUFxQixZQUFyQixDQUFmLENBQVA7QUFDRDtBQVBnRTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBOztBQVFqRSxpQkFBTyxRQUFRLE9BQVIsRUFBUDtBQUNELFNBVE0sQ0FBUDtBQVVELE9BZk0sQ0FBUDtBQWdCRDs7O29DQUVnQixNLEVBQVEsSyxFQUFPLGlCLEVBQW1CO0FBQ2pELGFBQU8sS0FBSyxPQUFMLENBQWEsTUFBYixFQUFxQixJQUFyQixDQUEwQixpQkFBUztBQUN4QyxZQUFJLFNBQVMsaUJBQWIsRUFBZ0M7QUFBRSxpQkFBTyxRQUFRLE9BQVIsRUFBUDtBQUEwQjtBQUM1RCxlQUFPLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsWUFBckIsQ0FBZixDQUFQO0FBQ0QsT0FITSxDQUFQO0FBSUQ7OzsrQkFFVyxRLEVBQVU7QUFDcEIsYUFBTyxJQUFJLElBQUosNkJBQVU7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQSx1QkFDRyxLQUFLLE9BQUwsQ0FBYSxRQUFiLENBREg7O0FBQUE7QUFDWCxxQkFEVzs7QUFBQSxxQkFFWCxLQUZXO0FBQUE7QUFBQTtBQUFBOztBQUFBLGlEQUVLLFFBQVEsT0FBUixFQUZMOztBQUFBO0FBQUE7QUFBQSx1QkFHUyxLQUFLLFNBQUwsQ0FBZSxTQUFmLENBQXlCLFdBQXpCLEVBQXNDLFFBQXRDLENBSFQ7O0FBQUE7QUFHWCwyQkFIVzs7QUFBQSxxQkFJWCxXQUpXO0FBQUE7QUFBQTtBQUFBOztBQUFBLGlEQUtOLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsWUFBckIsQ0FBZixDQUxNOztBQUFBO0FBQUE7QUFBQSx1QkFPVyxLQUFLLFNBQUwsQ0FBZSxnQkFBZixFQVBYOztBQUFBO0FBT1gsNkJBUFc7O0FBQUEsb0JBUVYsYUFSVTtBQUFBO0FBQUE7QUFBQTs7QUFBQSxpREFRYyxRQUFRLE9BQVIsRUFSZDs7QUFBQTtBQUFBO0FBQUEsdUJBU1MsS0FBSyxTQUFMLENBQWUsU0FBZixDQUF5QixXQUF6QixFQUFzQyxRQUF0QyxDQVRUOztBQUFBO0FBU1gsMkJBVFc7O0FBQUEscUJBVVgsV0FWVztBQUFBO0FBQUE7QUFBQTs7QUFBQSxpREFVVyxRQUFRLE9BQVIsRUFWWDs7QUFBQTtBQUFBLGlEQVdSLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsWUFBckIsQ0FBZixDQVhROztBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBLE9BQVYsRUFBUDtBQWFEOzs7OEJBRVUsTSxFQUFRLGlCLEVBQW1CO0FBQ3BDLFVBQUksaUJBQUosRUFBdUI7QUFBRSxlQUFPLFFBQVEsT0FBUixFQUFQO0FBQTBCO0FBQ25ELGFBQU8sSUFBSSxJQUFKLDZCQUFVO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUEsdUJBQ08sS0FBSyxTQUFMLENBQWUsU0FBZixDQUF5QixVQUF6QixFQUFxQyxNQUFyQyxDQURQOztBQUFBO0FBQ1gseUJBRFc7O0FBQUEscUJBRVgsU0FGVztBQUFBO0FBQUE7QUFBQTs7QUFBQSxrREFFUyxRQUFRLE9BQVIsRUFGVDs7QUFBQTtBQUFBO0FBQUEsdUJBR0csS0FBSyxPQUFMLENBQWEsTUFBYixDQUhIOztBQUFBO0FBR1gscUJBSFc7O0FBQUEscUJBSVgsS0FKVztBQUFBO0FBQUE7QUFBQTs7QUFBQSxrREFJSyxRQUFRLE9BQVIsRUFKTDs7QUFBQTtBQUFBLGtEQUtSLFFBQVEsTUFBUixDQUFlLElBQUksZ0JBQUosQ0FBcUIsV0FBckIsRUFBa0MsS0FBSyxRQUF2QyxDQUFmLENBTFE7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUEsT0FBVixFQUFQO0FBT0Q7OztpQ0FFYSxNLEVBQVEsaUIsRUFBbUI7QUFDdkMsVUFBSSxpQkFBSixFQUF1QjtBQUFFLGVBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDbkQsYUFBTyxLQUFLLFNBQUwsQ0FBZSxRQUFmLEdBQTBCLElBQTFCLENBQStCLGlCQUFTO0FBQzdDLFlBQUksVUFBVSxNQUFkLEVBQXNCO0FBQUUsaUJBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDbEQsZUFBTyxRQUFRLE1BQVIsQ0FBZSxJQUFJLGdCQUFKLENBQXFCLFlBQXJCLENBQWYsQ0FBUDtBQUNELE9BSE0sQ0FBUDtBQUlEOzs7OztBQUlIO0FBQ0E7OztJQUNNLEk7QUFFSixnQkFBYSxNQUFiLEVBQXFCLFFBQXJCLEVBQStCO0FBQUE7O0FBQzdCLFNBQUssTUFBTCxHQUFjLE1BQWQ7QUFDQSxTQUFLLFFBQUwsR0FBZ0IsUUFBaEI7QUFDQSxTQUFLLGFBQUwsR0FBcUIsS0FBSyxNQUFMLENBQVksaUJBQWpDO0FBQ0EsUUFBSSxRQUFRLEtBQUssTUFBTCxDQUFZLEtBQVosQ0FBa0IsU0FBOUI7QUFDQSxTQUFLLFNBQUwsR0FBaUIsSUFBSSxLQUFKLENBQVUsS0FBSyxNQUFmLEVBQXVCLEtBQUssUUFBNUIsQ0FBakI7QUFDQSxVQUFNLElBQU4sRUFBWSxlQUFaLEVBQTZCLEtBQUssUUFBbEMsRUFDTSxLQUFLLFNBRFgsRUFDc0IsS0FBSyxNQUFMLENBQVksSUFBWixDQUFpQixJQUFqQixDQUFzQixLQUFLLE1BQTNCLENBRHRCO0FBRUQ7Ozs7OEJBRVUsSyxFQUFPO0FBQ2hCLGFBQU8sS0FBSyxTQUFMLENBQWUsU0FBZixDQUF5QixLQUF6QixDQUFQO0FBQ0Q7OztrQ0FFYztBQUNiLGFBQU8sS0FBSyxTQUFMLENBQWUsV0FBZixFQUFQO0FBQ0Q7OztvQ0FFZ0I7QUFDZixhQUFPLEtBQUssU0FBTCxDQUFlLGFBQWYsRUFBUDtBQUNEOzs7K0JBRVc7QUFDVixhQUFPLEtBQUssU0FBTCxDQUFlLE9BQWYsQ0FBdUIsVUFBdkIsQ0FBUDtBQUNEOzs7MEJBRU0sTSxFQUFRO0FBQUE7O0FBQ2IsYUFBTyxLQUFLLFNBQUwsQ0FBZSxTQUFmLENBQXlCLFVBQXpCLEVBQXFDLE1BQXJDLEVBQTZDLElBQTdDLENBQWtELHFCQUFhO0FBQ3BFLFlBQUksQ0FBQyxTQUFMLEVBQWdCO0FBQUUsaUJBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDNUMsZUFBTyxPQUFLLFNBQUwsQ0FBZSxjQUFmLENBQThCLFVBQTlCLEVBQTBDLENBQUMsTUFBRCxDQUExQyxFQUNKLElBREksQ0FDQztBQUFBLGlCQUFNLE9BQUssU0FBTCxDQUFlLGNBQWYsQ0FBOEIsTUFBOUIsQ0FBTjtBQUFBLFNBREQsQ0FBUDtBQUVELE9BSk0sQ0FBUDtBQUtEOzs7eUJBRUssTSxFQUFRO0FBQUE7O0FBQ1osYUFBTyxLQUFLLFVBQUwsQ0FBZ0IsTUFBaEIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFNLE9BQUssU0FBTCxDQUFlLFNBQWYsQ0FBeUIsVUFBekIsRUFBcUMsTUFBckMsQ0FBTjtBQUFBLE9BREQsRUFFSixJQUZJLENBRUMscUJBQWE7QUFDakIsWUFBSSxTQUFKLEVBQWU7QUFBRSxpQkFBTyxRQUFRLE9BQVIsRUFBUDtBQUEwQjtBQUMzQyxlQUFPLE9BQUssU0FBTCxDQUFlLGNBQWYsQ0FBOEIsTUFBOUIsRUFDSixJQURJLENBQ0M7QUFBQSxpQkFBTSxPQUFLLFNBQUwsQ0FBZSxTQUFmLENBQXlCLFVBQXpCLEVBQXFDLENBQUMsTUFBRCxDQUFyQyxDQUFOO0FBQUEsU0FERCxDQUFQO0FBRUQsT0FOSSxDQUFQO0FBT0Q7Ozs0QkFFUSxNLEVBQVEsRyxFQUFLLGlCLEVBQW1CO0FBQUE7O0FBQ3ZDLGFBQU8sUUFBUSxHQUFSLENBQVksWUFBTTtBQUN2QixZQUFJLGlCQUFKLEVBQXVCO0FBQUUsaUJBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDbkQsZUFBTyxPQUFLLFNBQUwsQ0FBZSxTQUFmLENBQXlCLFVBQXpCLEVBQXFDLE1BQXJDLEVBQTZDLElBQTdDLENBQWtELHFCQUFhO0FBQ3BFLGNBQUksU0FBSixFQUFlO0FBQUUsbUJBQU8sUUFBUSxPQUFSLEVBQVA7QUFBMEI7QUFDM0MsaUJBQU8sUUFBUSxNQUFSLENBQWUsSUFBSSxnQkFBSixDQUFxQixXQUFyQixFQUFrQyxPQUFLLFFBQXZDLENBQWYsQ0FBUDtBQUNELFNBSE0sQ0FBUDtBQUlELE9BTk0sRUFNSixJQU5JLENBTUM7QUFBQSxlQUFNLE9BQUssU0FBTCxDQUFlLFVBQWYsQ0FBMEIsR0FBMUIsQ0FBTjtBQUFBLE9BTkQsQ0FBUDtBQU9EOzs7NEJBRVEsTSxFQUFRLFEsRUFBVSxpQixFQUFtQjtBQUFBOztBQUM1QyxhQUFPLEtBQUssU0FBTCxDQUFlLE1BQWYsRUFBdUIsaUJBQXZCLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBTSxPQUFLLFNBQUwsQ0FBZSxPQUFmLENBQXVCLFFBQXZCLENBQU47QUFBQSxPQURELENBQVA7QUFFRDs7O3NDQUVrQixNLEVBQVEsaUIsRUFBbUI7QUFBQTs7QUFDNUMsYUFBTyxLQUFLLFNBQUwsQ0FBZSxNQUFmLEVBQXVCLGlCQUF2QixFQUNKLElBREksQ0FDQztBQUFBLGVBQU0sT0FBSyxTQUFMLENBQWUsaUJBQWYsRUFBTjtBQUFBLE9BREQsQ0FBUDtBQUVEOzs7bUNBRWUsTSxFQUFRLGlCLEVBQW1CO0FBQUE7O0FBQ3pDLGFBQU8sS0FBSyxTQUFMLENBQWUsTUFBZixFQUF1QixpQkFBdkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFNLFFBQUssU0FBTCxDQUFlLFdBQWYsRUFBTjtBQUFBLE9BREQsQ0FBUDtBQUVEOzs7eUNBRXFCLE0sRUFBUSxpQixFQUFtQjtBQUFBOztBQUMvQyxhQUFPLEtBQUssU0FBTCxDQUFlLE1BQWYsRUFBdUIsaUJBQXZCLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBTSxRQUFRLElBQVIsQ0FDVixRQUFLLFNBQUwsQ0FBZSxrQkFBZixFQURVLEVBRVYsUUFBSyxTQUFMLENBQWUscUJBQWYsRUFGVSxFQUdWLFVBQUMscUJBQUQsRUFBd0Isd0JBQXhCO0FBQUEsaUJBQ0csRUFBRSw0Q0FBRixFQUF5QixrREFBekIsRUFESDtBQUFBLFNBSFUsQ0FBTjtBQUFBLE9BREQsQ0FBUDtBQU1EOzs7Z0NBRVksTSxFQUFRLEUsRUFBSSxLLEVBQU8saUIsRUFBbUI7QUFBQTs7QUFDakQsYUFBTyxLQUFLLFNBQUwsQ0FBZSxNQUFmLEVBQXVCLGlCQUF2QixFQUEwQyxJQUExQyxDQUErQyxZQUFNO0FBQzFELFlBQUksQ0FBQyxpQkFBTCxFQUF3QjtBQUN0QixrQkFBUSxFQUFFLEdBQUYsQ0FBTSxDQUFFLEtBQUYsRUFBUyxRQUFLLE1BQUwsQ0FBWSxxQkFBckIsQ0FBTixDQUFSO0FBQ0Q7QUFDRCxlQUFPLFFBQUssU0FBTCxDQUFlLFdBQWYsQ0FBMkIsRUFBM0IsRUFBK0IsS0FBL0IsQ0FBUDtBQUNELE9BTE0sQ0FBUDtBQU1EOzs7OEJBRVUsTSxFQUFRLFEsRUFBVSxNLEVBQVEsaUIsRUFBbUI7QUFBQTs7QUFDdEQsYUFBTyxLQUFLLGdCQUFMLENBQXNCLE1BQXRCLEVBQThCLFFBQTlCLEVBQXdDLE1BQXhDLEVBQWdELGlCQUFoRCxFQUNKLElBREksQ0FDQztBQUFBLGVBQU0sUUFBSyxTQUFMLENBQWUsU0FBZixDQUF5QixRQUF6QixFQUFtQyxNQUFuQyxFQUEyQyxRQUFLLGFBQWhELENBQU47QUFBQSxPQURELEVBRUosSUFGSSxDQUVDO0FBQUEsZUFBTSxRQUFRLE1BQVIsQ0FDVixNQURVLEVBRVY7QUFBQSxpQkFBTyxRQUFLLDBCQUFMLENBQWdDLEdBQWhDLEVBQXFDLFFBQXJDLENBQVA7QUFBQSxTQUZVLEVBR1YsRUFBRSxhQUFhLFVBQWYsRUFIVSxDQUFOO0FBQUEsT0FGRCxDQUFQO0FBTUQ7OzttQ0FFZSxNLEVBQVEsUSxFQUFVLE0sRUFBUSxpQixFQUFtQjtBQUFBOztBQUMzRCxhQUFPLEtBQUssZ0JBQUwsQ0FBc0IsTUFBdEIsRUFBOEIsUUFBOUIsRUFBd0MsTUFBeEMsRUFBZ0QsaUJBQWhELEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBTSxRQUFLLFNBQUwsQ0FBZSxjQUFmLENBQThCLFFBQTlCLEVBQXdDLE1BQXhDLENBQU47QUFBQSxPQURELEVBRUosSUFGSSxDQUVDO0FBQUEsZUFBTSxRQUFRLE1BQVIsQ0FDVixNQURVLEVBRVY7QUFBQSxpQkFBTyxRQUFLLDZCQUFMLENBQW1DLEdBQW5DLEVBQXdDLFFBQXhDLENBQVA7QUFBQSxTQUZVLEVBR1YsRUFBRSxhQUFhLFVBQWYsRUFIVSxDQUFOO0FBQUEsT0FGRCxDQUFQO0FBTUQ7Ozs0QkFFUSxNLEVBQVEsaUIsRUFBbUI7QUFBQTs7QUFDbEMsYUFBTyxLQUFLLFNBQUwsQ0FBZSxNQUFmLEVBQXVCLGlCQUF2QixFQUNKLElBREksQ0FDQztBQUFBLGVBQU0sUUFBSyxTQUFMLENBQWUsZ0JBQWYsRUFBTjtBQUFBLE9BREQsQ0FBUDtBQUVEOzs7NkJBRVMsTSxFQUFRLGlCLEVBQW1CO0FBQUE7O0FBQ25DLGFBQU8sS0FBSyxTQUFMLENBQWUsTUFBZixFQUF1QixpQkFBdkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFNLFFBQUssU0FBTCxDQUFlLFFBQWYsRUFBTjtBQUFBLE9BREQsQ0FBUDtBQUVEOzs7K0JBRVcsTSxFQUFRLEksRUFBTSxpQixFQUFtQjtBQUFBOztBQUMzQyxVQUFJLGdCQUFnQixJQUFwQjtBQUNBLGFBQU8sS0FBSyxlQUFMLENBQXFCLE1BQXJCLEVBQTZCLElBQTdCLEVBQW1DLGlCQUFuQyxFQUNKLElBREksQ0FDQztBQUFBLGVBQU0sUUFBSyxTQUFMLENBQWUsZ0JBQWYsQ0FBZ0MsYUFBaEMsQ0FBTjtBQUFBLE9BREQsRUFFSixJQUZJLENBRUM7QUFBQSxlQUFNLFFBQUssMkJBQUwsQ0FBaUMsYUFBakMsQ0FBTjtBQUFBLE9BRkQsRUFHSixJQUhJLENBR0M7QUFBQSxlQUFhLENBQUUsU0FBRixFQUFhLGFBQWIsQ0FBYjtBQUFBLE9BSEQsQ0FBUDtBQUlEOzs7NkJBRVMsTSxFQUFRLFEsRUFBVSxpQixFQUFtQjtBQUFBOztBQUM3QyxhQUFPLEtBQUssU0FBTCxDQUFlLE1BQWYsRUFBdUIsaUJBQXZCLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBTSxRQUFLLFNBQUwsQ0FBZSxXQUFmLENBQTJCLFFBQTNCLENBQU47QUFBQSxPQURELENBQVA7QUFFRDs7Ozs7QUFJSCxPQUFPLE9BQVAsR0FBaUIsSUFBakIiLCJmaWxlIjoiUm9vbS5qcyIsInNvdXJjZXNDb250ZW50IjpbIid1c2Ugc3RyaWN0J1xuXG5jb25zdCBDaGF0U2VydmljZUVycm9yID0gcmVxdWlyZSgnLi9DaGF0U2VydmljZUVycm9yJylcbmNvbnN0IFByb21pc2UgPSByZXF1aXJlKCdibHVlYmlyZCcpXG5jb25zdCBfID0gcmVxdWlyZSgnbG9kYXNoJylcbmNvbnN0IHsgbWl4aW4gfSA9IHJlcXVpcmUoJ2VzNi1taXhpbicpXG5jb25zdCB7IGFzeW5jTGltaXQsIHJ1biB9ID0gcmVxdWlyZSgnLi91dGlscycpXG5cbmNsYXNzIFJvb21QZXJtaXNzaW9ucyB7XG5cbiAgY29uc3RydWN0b3IgKHJvb21OYW1lLCByb29tU3RhdGUsIGVtaXRGYWlsdXJlKSB7XG4gICAgdGhpcy5yb29tTmFtZSA9IHJvb21OYW1lXG4gICAgdGhpcy5yb29tU3RhdGUgPSByb29tU3RhdGVcbiAgICB0aGlzLmVtaXRGYWlsdXJlID0gZW1pdEZhaWx1cmVcbiAgfVxuXG4gIGNvbnNpc3RlbmN5RmFpbHVyZSAoZXJyb3IsIG9wZXJhdGlvbkluZm8pIHtcbiAgICBvcGVyYXRpb25JbmZvLnJvb21OYW1lID0gdGhpcy5yb29tTmFtZVxuICAgIG9wZXJhdGlvbkluZm8ub3BUeXBlID0gJ3Jvb21Vc2VybGlzdCdcbiAgICB0aGlzLmVtaXRGYWlsdXJlKCdzdG9yZUNvbnNpc3RlbmN5RmFpbHVyZScsIGVycm9yLCBvcGVyYXRpb25JbmZvKVxuICB9XG5cbiAgaXNBZG1pbiAodXNlck5hbWUpIHtcbiAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUub3duZXJHZXQoKS50aGVuKG93bmVyID0+IHtcbiAgICAgIGlmIChvd25lciA9PT0gdXNlck5hbWUpIHsgcmV0dXJuIHRydWUgfVxuICAgICAgcmV0dXJuIHRoaXMucm9vbVN0YXRlLmhhc0luTGlzdCgnYWRtaW5saXN0JywgdXNlck5hbWUpXG4gICAgfSlcbiAgfVxuXG4gIGhhc1JlbW92ZUNoYW5nZWRDdXJyZW50QWNjZXNzICh1c2VyTmFtZSwgbGlzdE5hbWUpIHtcbiAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUuaGFzSW5MaXN0KCd1c2VybGlzdCcsIHVzZXJOYW1lKS50aGVuKGhhc1VzZXIgPT4ge1xuICAgICAgaWYgKCFoYXNVc2VyKSB7IHJldHVybiBmYWxzZSB9XG4gICAgICByZXR1cm4gdGhpcy5pc0FkbWluKHVzZXJOYW1lKS50aGVuKGFkbWluID0+IHtcbiAgICAgICAgaWYgKGFkbWluIHx8IGxpc3ROYW1lICE9PSAnd2hpdGVsaXN0JykgeyByZXR1cm4gZmFsc2UgfVxuICAgICAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUud2hpdGVsaXN0T25seUdldCgpXG4gICAgICB9KVxuICAgIH0pLmNhdGNoKGUgPT4gdGhpcy5jb25zaXN0ZW5jeUZhaWx1cmUoZSwge3VzZXJOYW1lfSkpXG4gIH1cblxuICBoYXNBZGRDaGFuZ2VkQ3VycmVudEFjY2VzcyAodXNlck5hbWUsIGxpc3ROYW1lKSB7XG4gICAgcmV0dXJuIHRoaXMucm9vbVN0YXRlLmhhc0luTGlzdCgndXNlcmxpc3QnLCB1c2VyTmFtZSkudGhlbihoYXNVc2VyID0+IHtcbiAgICAgIGlmICghaGFzVXNlcikgeyByZXR1cm4gZmFsc2UgfVxuICAgICAgcmV0dXJuIHRoaXMuaXNBZG1pbih1c2VyTmFtZSlcbiAgICAgICAgLnRoZW4oYWRtaW4gPT4gIShhZG1pbiB8fCBsaXN0TmFtZSAhPT0gJ2JsYWNrbGlzdCcpKVxuICAgIH0pLmNhdGNoKGUgPT4gdGhpcy5jb25zaXN0ZW5jeUZhaWx1cmUoZSwge3VzZXJOYW1lfSkpXG4gIH1cblxuICBnZXRNb2RlQ2hhbmdlZEN1cnJlbnRBY2Nlc3MgKHZhbHVlKSB7XG4gICAgaWYgKCF2YWx1ZSkge1xuICAgICAgcmV0dXJuIFtdXG4gICAgfSBlbHNlIHtcbiAgICAgIHJldHVybiB0aGlzLnJvb21TdGF0ZS5nZXRDb21tb25Vc2VycygpXG4gICAgfVxuICB9XG5cbiAgY2hlY2tMaXN0Q2hhbmdlcyAoYXV0aG9yLCBsaXN0TmFtZSwgdmFsdWVzLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIGlmIChsaXN0TmFtZSA9PT0gJ3VzZXJsaXN0Jykge1xuICAgICAgcmV0dXJuIFByb21pc2UucmVqZWN0KG5ldyBDaGF0U2VydmljZUVycm9yKCdub3RBbGxvd2VkJykpXG4gICAgfVxuICAgIGlmIChieXBhc3NQZXJtaXNzaW9ucykgeyByZXR1cm4gUHJvbWlzZS5yZXNvbHZlKCkgfVxuICAgIHJldHVybiB0aGlzLnJvb21TdGF0ZS5vd25lckdldCgpLnRoZW4ob3duZXIgPT4ge1xuICAgICAgaWYgKGF1dGhvciA9PT0gb3duZXIpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgIGlmIChsaXN0TmFtZSA9PT0gJ2FkbWlubGlzdCcpIHtcbiAgICAgICAgcmV0dXJuIFByb21pc2UucmVqZWN0KG5ldyBDaGF0U2VydmljZUVycm9yKCdub3RBbGxvd2VkJykpXG4gICAgICB9XG4gICAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUuaGFzSW5MaXN0KCdhZG1pbmxpc3QnLCBhdXRob3IpLnRoZW4oYWRtaW4gPT4ge1xuICAgICAgICBpZiAoIWFkbWluKSB7XG4gICAgICAgICAgcmV0dXJuIFByb21pc2UucmVqZWN0KG5ldyBDaGF0U2VydmljZUVycm9yKCdub3RBbGxvd2VkJykpXG4gICAgICAgIH1cbiAgICAgICAgZm9yIChsZXQgbmFtZSBvZiB2YWx1ZXMpIHtcbiAgICAgICAgICBpZiAobmFtZSAhPT0gb3duZXIpIHsgY29udGludWUgfVxuICAgICAgICAgIHJldHVybiBQcm9taXNlLnJlamVjdChuZXcgQ2hhdFNlcnZpY2VFcnJvcignbm90QWxsb3dlZCcpKVxuICAgICAgICB9XG4gICAgICAgIHJldHVybiBQcm9taXNlLnJlc29sdmUoKVxuICAgICAgfSlcbiAgICB9KVxuICB9XG5cbiAgY2hlY2tNb2RlQ2hhbmdlIChhdXRob3IsIHZhbHVlLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmlzQWRtaW4oYXV0aG9yKS50aGVuKGFkbWluID0+IHtcbiAgICAgIGlmIChhZG1pbiB8fCBieXBhc3NQZXJtaXNzaW9ucykgeyByZXR1cm4gUHJvbWlzZS5yZXNvbHZlKCkgfVxuICAgICAgcmV0dXJuIFByb21pc2UucmVqZWN0KG5ldyBDaGF0U2VydmljZUVycm9yKCdub3RBbGxvd2VkJykpXG4gICAgfSlcbiAgfVxuXG4gIGNoZWNrQWNlc3MgKHVzZXJOYW1lKSB7XG4gICAgcmV0dXJuIHJ1bih0aGlzLCBmdW5jdGlvbiAqICgpIHtcbiAgICAgIGxldCBhZG1pbiA9IHlpZWxkIHRoaXMuaXNBZG1pbih1c2VyTmFtZSlcbiAgICAgIGlmIChhZG1pbikgeyByZXR1cm4gUHJvbWlzZS5yZXNvbHZlKCkgfVxuICAgICAgbGV0IGJsYWNrbGlzdGVkID0geWllbGQgdGhpcy5yb29tU3RhdGUuaGFzSW5MaXN0KCdibGFja2xpc3QnLCB1c2VyTmFtZSlcbiAgICAgIGlmIChibGFja2xpc3RlZCkge1xuICAgICAgICByZXR1cm4gUHJvbWlzZS5yZWplY3QobmV3IENoYXRTZXJ2aWNlRXJyb3IoJ25vdEFsbG93ZWQnKSlcbiAgICAgIH1cbiAgICAgIGxldCB3aGl0ZWxpc3RPbmx5ID0geWllbGQgdGhpcy5yb29tU3RhdGUud2hpdGVsaXN0T25seUdldCgpXG4gICAgICBpZiAoIXdoaXRlbGlzdE9ubHkpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgIGxldCB3aGl0ZWxpc3RlZCA9IHlpZWxkIHRoaXMucm9vbVN0YXRlLmhhc0luTGlzdCgnd2hpdGVsaXN0JywgdXNlck5hbWUpXG4gICAgICBpZiAod2hpdGVsaXN0ZWQpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgIHJldHVybiBQcm9taXNlLnJlamVjdChuZXcgQ2hhdFNlcnZpY2VFcnJvcignbm90QWxsb3dlZCcpKVxuICAgIH0pXG4gIH1cblxuICBjaGVja1JlYWQgKGF1dGhvciwgYnlwYXNzUGVybWlzc2lvbnMpIHtcbiAgICBpZiAoYnlwYXNzUGVybWlzc2lvbnMpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICByZXR1cm4gcnVuKHRoaXMsIGZ1bmN0aW9uICogKCkge1xuICAgICAgbGV0IGhhc0F1dGhvciA9IHlpZWxkIHRoaXMucm9vbVN0YXRlLmhhc0luTGlzdCgndXNlcmxpc3QnLCBhdXRob3IpXG4gICAgICBpZiAoaGFzQXV0aG9yKSB7IHJldHVybiBQcm9taXNlLnJlc29sdmUoKSB9XG4gICAgICBsZXQgYWRtaW4gPSB5aWVsZCB0aGlzLmlzQWRtaW4oYXV0aG9yKVxuICAgICAgaWYgKGFkbWluKSB7IHJldHVybiBQcm9taXNlLnJlc29sdmUoKSB9XG4gICAgICByZXR1cm4gUHJvbWlzZS5yZWplY3QobmV3IENoYXRTZXJ2aWNlRXJyb3IoJ25vdEpvaW5lZCcsIHRoaXMucm9vbU5hbWUpKVxuICAgIH0pXG4gIH1cblxuICBjaGVja0lzT3duZXIgKGF1dGhvciwgYnlwYXNzUGVybWlzc2lvbnMpIHtcbiAgICBpZiAoYnlwYXNzUGVybWlzc2lvbnMpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUub3duZXJHZXQoKS50aGVuKG93bmVyID0+IHtcbiAgICAgIGlmIChvd25lciA9PT0gYXV0aG9yKSB7IHJldHVybiBQcm9taXNlLnJlc29sdmUoKSB9XG4gICAgICByZXR1cm4gUHJvbWlzZS5yZWplY3QobmV3IENoYXRTZXJ2aWNlRXJyb3IoJ25vdEFsbG93ZWQnKSlcbiAgICB9KVxuICB9XG5cbn1cblxuLy8gSW1wbGVtZW50cyByb29tIG1lc3NhZ2luZyBzdGF0ZSBtYW5pcHVsYXRpb25zIHdpdGggdGhlIHJlc3BlY3QgdG9cbi8vIHVzZXIncyBwZXJtaXNzaW9ucy5cbmNsYXNzIFJvb20ge1xuXG4gIGNvbnN0cnVjdG9yIChzZXJ2ZXIsIHJvb21OYW1lKSB7XG4gICAgdGhpcy5zZXJ2ZXIgPSBzZXJ2ZXJcbiAgICB0aGlzLnJvb21OYW1lID0gcm9vbU5hbWVcbiAgICB0aGlzLmxpc3RTaXplTGltaXQgPSB0aGlzLnNlcnZlci5yb29tTGlzdFNpemVMaW1pdFxuICAgIGxldCBTdGF0ZSA9IHRoaXMuc2VydmVyLnN0YXRlLlJvb21TdGF0ZVxuICAgIHRoaXMucm9vbVN0YXRlID0gbmV3IFN0YXRlKHRoaXMuc2VydmVyLCB0aGlzLnJvb21OYW1lKVxuICAgIG1peGluKHRoaXMsIFJvb21QZXJtaXNzaW9ucywgdGhpcy5yb29tTmFtZSxcbiAgICAgICAgICB0aGlzLnJvb21TdGF0ZSwgdGhpcy5zZXJ2ZXIuZW1pdC5iaW5kKHRoaXMuc2VydmVyKSlcbiAgfVxuXG4gIGluaXRTdGF0ZSAoc3RhdGUpIHtcbiAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUuaW5pdFN0YXRlKHN0YXRlKVxuICB9XG5cbiAgcmVtb3ZlU3RhdGUgKCkge1xuICAgIHJldHVybiB0aGlzLnJvb21TdGF0ZS5yZW1vdmVTdGF0ZSgpXG4gIH1cblxuICBzdGFydFJlbW92aW5nICgpIHtcbiAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUuc3RhcnRSZW1vdmluZygpXG4gIH1cblxuICBnZXRVc2VycyAoKSB7XG4gICAgcmV0dXJuIHRoaXMucm9vbVN0YXRlLmdldExpc3QoJ3VzZXJsaXN0JylcbiAgfVxuXG4gIGxlYXZlIChhdXRob3IpIHtcbiAgICByZXR1cm4gdGhpcy5yb29tU3RhdGUuaGFzSW5MaXN0KCd1c2VybGlzdCcsIGF1dGhvcikudGhlbihoYXNBdXRob3IgPT4ge1xuICAgICAgaWYgKCFoYXNBdXRob3IpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgIHJldHVybiB0aGlzLnJvb21TdGF0ZS5yZW1vdmVGcm9tTGlzdCgndXNlcmxpc3QnLCBbYXV0aG9yXSlcbiAgICAgICAgLnRoZW4oKCkgPT4gdGhpcy5yb29tU3RhdGUudXNlclNlZW5VcGRhdGUoYXV0aG9yKSlcbiAgICB9KVxuICB9XG5cbiAgam9pbiAoYXV0aG9yKSB7XG4gICAgcmV0dXJuIHRoaXMuY2hlY2tBY2VzcyhhdXRob3IpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLnJvb21TdGF0ZS5oYXNJbkxpc3QoJ3VzZXJsaXN0JywgYXV0aG9yKSlcbiAgICAgIC50aGVuKGhhc0F1dGhvciA9PiB7XG4gICAgICAgIGlmIChoYXNBdXRob3IpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgICAgcmV0dXJuIHRoaXMucm9vbVN0YXRlLnVzZXJTZWVuVXBkYXRlKGF1dGhvcilcbiAgICAgICAgICAudGhlbigoKSA9PiB0aGlzLnJvb21TdGF0ZS5hZGRUb0xpc3QoJ3VzZXJsaXN0JywgW2F1dGhvcl0pKVxuICAgICAgfSlcbiAgfVxuXG4gIG1lc3NhZ2UgKGF1dGhvciwgbXNnLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiBQcm9taXNlLnRyeSgoKSA9PiB7XG4gICAgICBpZiAoYnlwYXNzUGVybWlzc2lvbnMpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgIHJldHVybiB0aGlzLnJvb21TdGF0ZS5oYXNJbkxpc3QoJ3VzZXJsaXN0JywgYXV0aG9yKS50aGVuKGhhc0F1dGhvciA9PiB7XG4gICAgICAgIGlmIChoYXNBdXRob3IpIHsgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpIH1cbiAgICAgICAgcmV0dXJuIFByb21pc2UucmVqZWN0KG5ldyBDaGF0U2VydmljZUVycm9yKCdub3RKb2luZWQnLCB0aGlzLnJvb21OYW1lKSlcbiAgICAgIH0pXG4gICAgfSkudGhlbigoKSA9PiB0aGlzLnJvb21TdGF0ZS5tZXNzYWdlQWRkKG1zZykpXG4gIH1cblxuICBnZXRMaXN0IChhdXRob3IsIGxpc3ROYW1lLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmNoZWNrUmVhZChhdXRob3IsIGJ5cGFzc1Blcm1pc3Npb25zKVxuICAgICAgLnRoZW4oKCkgPT4gdGhpcy5yb29tU3RhdGUuZ2V0TGlzdChsaXN0TmFtZSkpXG4gIH1cblxuICBnZXRSZWNlbnRNZXNzYWdlcyAoYXV0aG9yLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmNoZWNrUmVhZChhdXRob3IsIGJ5cGFzc1Blcm1pc3Npb25zKVxuICAgICAgLnRoZW4oKCkgPT4gdGhpcy5yb29tU3RhdGUubWVzc2FnZXNHZXRSZWNlbnQoKSlcbiAgfVxuXG4gIGdldEhpc3RvcnlJbmZvIChhdXRob3IsIGJ5cGFzc1Blcm1pc3Npb25zKSB7XG4gICAgcmV0dXJuIHRoaXMuY2hlY2tSZWFkKGF1dGhvciwgYnlwYXNzUGVybWlzc2lvbnMpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLnJvb21TdGF0ZS5oaXN0b3J5SW5mbygpKVxuICB9XG5cbiAgZ2V0Tm90aWZpY2F0aW9uc0luZm8gKGF1dGhvciwgYnlwYXNzUGVybWlzc2lvbnMpIHtcbiAgICByZXR1cm4gdGhpcy5jaGVja1JlYWQoYXV0aG9yLCBieXBhc3NQZXJtaXNzaW9ucylcbiAgICAgIC50aGVuKCgpID0+IFByb21pc2Uuam9pbihcbiAgICAgICAgdGhpcy5yb29tU3RhdGUudXNlcmxpc3RVcGRhdGVzR2V0KCksXG4gICAgICAgIHRoaXMucm9vbVN0YXRlLmFjY2Vzc0xpc3RzVXBkYXRlc0dldCgpLFxuICAgICAgICAoZW5hYmxlVXNlcmxpc3RVcGRhdGVzLCBlbmFibGVBY2Nlc3NMaXN0c1VwZGF0ZXMpID0+XG4gICAgICAgICAgKHsgZW5hYmxlVXNlcmxpc3RVcGRhdGVzLCBlbmFibGVBY2Nlc3NMaXN0c1VwZGF0ZXMgfSkpKVxuICB9XG5cbiAgZ2V0TWVzc2FnZXMgKGF1dGhvciwgaWQsIGxpbWl0LCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmNoZWNrUmVhZChhdXRob3IsIGJ5cGFzc1Blcm1pc3Npb25zKS50aGVuKCgpID0+IHtcbiAgICAgIGlmICghYnlwYXNzUGVybWlzc2lvbnMpIHtcbiAgICAgICAgbGltaXQgPSBfLm1pbihbIGxpbWl0LCB0aGlzLnNlcnZlci5oaXN0b3J5TWF4R2V0TWVzc2FnZXMgXSlcbiAgICAgIH1cbiAgICAgIHJldHVybiB0aGlzLnJvb21TdGF0ZS5tZXNzYWdlc0dldChpZCwgbGltaXQpXG4gICAgfSlcbiAgfVxuXG4gIGFkZFRvTGlzdCAoYXV0aG9yLCBsaXN0TmFtZSwgdmFsdWVzLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmNoZWNrTGlzdENoYW5nZXMoYXV0aG9yLCBsaXN0TmFtZSwgdmFsdWVzLCBieXBhc3NQZXJtaXNzaW9ucylcbiAgICAgIC50aGVuKCgpID0+IHRoaXMucm9vbVN0YXRlLmFkZFRvTGlzdChsaXN0TmFtZSwgdmFsdWVzLCB0aGlzLmxpc3RTaXplTGltaXQpKVxuICAgICAgLnRoZW4oKCkgPT4gUHJvbWlzZS5maWx0ZXIoXG4gICAgICAgIHZhbHVlcyxcbiAgICAgICAgdmFsID0+IHRoaXMuaGFzQWRkQ2hhbmdlZEN1cnJlbnRBY2Nlc3ModmFsLCBsaXN0TmFtZSksXG4gICAgICAgIHsgY29uY3VycmVuY3k6IGFzeW5jTGltaXQgfSkpXG4gIH1cblxuICByZW1vdmVGcm9tTGlzdCAoYXV0aG9yLCBsaXN0TmFtZSwgdmFsdWVzLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmNoZWNrTGlzdENoYW5nZXMoYXV0aG9yLCBsaXN0TmFtZSwgdmFsdWVzLCBieXBhc3NQZXJtaXNzaW9ucylcbiAgICAgIC50aGVuKCgpID0+IHRoaXMucm9vbVN0YXRlLnJlbW92ZUZyb21MaXN0KGxpc3ROYW1lLCB2YWx1ZXMpKVxuICAgICAgLnRoZW4oKCkgPT4gUHJvbWlzZS5maWx0ZXIoXG4gICAgICAgIHZhbHVlcyxcbiAgICAgICAgdmFsID0+IHRoaXMuaGFzUmVtb3ZlQ2hhbmdlZEN1cnJlbnRBY2Nlc3ModmFsLCBsaXN0TmFtZSksXG4gICAgICAgIHsgY29uY3VycmVuY3k6IGFzeW5jTGltaXQgfSkpXG4gIH1cblxuICBnZXRNb2RlIChhdXRob3IsIGJ5cGFzc1Blcm1pc3Npb25zKSB7XG4gICAgcmV0dXJuIHRoaXMuY2hlY2tSZWFkKGF1dGhvciwgYnlwYXNzUGVybWlzc2lvbnMpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLnJvb21TdGF0ZS53aGl0ZWxpc3RPbmx5R2V0KCkpXG4gIH1cblxuICBnZXRPd25lciAoYXV0aG9yLCBieXBhc3NQZXJtaXNzaW9ucykge1xuICAgIHJldHVybiB0aGlzLmNoZWNrUmVhZChhdXRob3IsIGJ5cGFzc1Blcm1pc3Npb25zKVxuICAgICAgLnRoZW4oKCkgPT4gdGhpcy5yb29tU3RhdGUub3duZXJHZXQoKSlcbiAgfVxuXG4gIGNoYW5nZU1vZGUgKGF1dGhvciwgbW9kZSwgYnlwYXNzUGVybWlzc2lvbnMpIHtcbiAgICBsZXQgd2hpdGVsaXN0T25seSA9IG1vZGVcbiAgICByZXR1cm4gdGhpcy5jaGVja01vZGVDaGFuZ2UoYXV0aG9yLCBtb2RlLCBieXBhc3NQZXJtaXNzaW9ucylcbiAgICAgIC50aGVuKCgpID0+IHRoaXMucm9vbVN0YXRlLndoaXRlbGlzdE9ubHlTZXQod2hpdGVsaXN0T25seSkpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLmdldE1vZGVDaGFuZ2VkQ3VycmVudEFjY2Vzcyh3aGl0ZWxpc3RPbmx5KSlcbiAgICAgIC50aGVuKHVzZXJuYW1lcyA9PiBbIHVzZXJuYW1lcywgd2hpdGVsaXN0T25seSBdKVxuICB9XG5cbiAgdXNlclNlZW4gKGF1dGhvciwgdXNlck5hbWUsIGJ5cGFzc1Blcm1pc3Npb25zKSB7XG4gICAgcmV0dXJuIHRoaXMuY2hlY2tSZWFkKGF1dGhvciwgYnlwYXNzUGVybWlzc2lvbnMpXG4gICAgICAudGhlbigoKSA9PiB0aGlzLnJvb21TdGF0ZS51c2VyU2VlbkdldCh1c2VyTmFtZSkpXG4gIH1cblxufVxuXG5tb2R1bGUuZXhwb3J0cyA9IFJvb21cbiJdfQ==