chat-service/lib/RecoveryAPI.js

'use strict';

var _toConsumableArray2 = require('babel-runtime/helpers/toConsumableArray');

var _toConsumableArray3 = _interopRequireDefault(_toConsumableArray2);

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 Promise = require('bluebird');
var _ = require('lodash');

/**
 * Service infrastructure failures recovery.
 *
 * @mixin
 * @memberof chat-service
 * @see chat-service.ChatService.event:storeConsistencyFailure
 */

var RecoveryAPI = function () {
  function RecoveryAPI(state, transport, execUserCommand, instanceUID) {
    (0, _classCallCheck3.default)(this, RecoveryAPI);

    this.state = state;
    this.transport = transport;
    this.instanceUID = instanceUID;
    this.execUserCommand = execUserCommand;
  }

  (0, _createClass3.default)(RecoveryAPI, [{
    key: 'checkUserSockets',
    value: function checkUserSockets(user) {
      var _this = this;

      var userName = user.userName;

      return user.userState.getSocketsToInstance().then(function (sockets) {
        return Promise.each(_.toPairs(sockets), function (_ref) {
          var _ref2 = (0, _slicedToArray3.default)(_ref, 2);

          var socket = _ref2[0];
          var instance = _ref2[1];

          if (instance === _this.instanceUID) {
            if (!_this.transport.getSocket(socket)) {
              return user.userState.removeSocket(socket);
            }
          }
          return Promise.resolve();
        });
      }).then(function () {
        return user.userState.getSocketsToRooms();
      }).then(function (data) {
        var args = _.values(data);
        return _.intersection.apply(_, (0, _toConsumableArray3.default)(args));
      }).then(function (rooms) {
        return Promise.each(rooms, function (roomName) {
          return _this.state.getRoom(roomName).then(function (room) {
            return room.roomState.hasInList('userlist', userName);
          }).then(function (isPresent) {
            return isPresent ? Promise.resolve() : user.removeFromRoom(roomName);
          }).catchReturn();
        });
      });
    }
  }, {
    key: 'checkRoomJoined',
    value: function checkRoomJoined(room) {
      var _this2 = this;

      var roomName = room.roomName;

      return room.getList(null, 'userlist', true).then(function (userlist) {
        return Promise.each(userlist, function (userName) {
          return _this2.state.getUser(userName).then(function (user) {
            return user.userState.getRoomToSockets(roomName).then(function (sockets) {
              if (!sockets || !sockets.length) {
                return user.removeFromRoom(roomName);
              } else {
                return Promise.resolve();
              }
            }).catchReturn().then(function () {
              return room.checkAcess(userName);
            }).catch(function () {
              return user.removeFromRoom(roomName);
            });
          }).catchReturn();
        });
      });
    }

    /**
     * Sync user to sockets associations.
     *
     * @param {string} userName User name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

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

      return this.state.getUser(userName).then(function (user) {
        return _this3.checkUserSockets(user);
      }).asCallback(cb);
    }

    /**
     * Sync room to users associations.
     *
     * @param {string} roomName Room name.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

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

      return this.state.getRoom(roomName).then(function (room) {
        return _this4.checkRoomJoined(room);
      }).asCallback(cb);
    }

    /**
     * Fixes an instance data after an incorrect service shutdown.
     *
     * @param {string} id Instance id.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<undefined>} Promise that resolves without any data.
     */

  }, {
    key: 'instanceRecovery',
    value: function instanceRecovery(id, cb) {
      var _this5 = this;

      return this.state.getInstanceSockets(id).then(function (sockets) {
        return Promise.each(_.toPairs(sockets), function (_ref3) {
          var _ref4 = (0, _slicedToArray3.default)(_ref3, 2);

          var id = _ref4[0];
          var userName = _ref4[1];

          return _this5.state.getUser(userName).then(function (user) {
            return user.removeSocket(id);
          }).catchReturn();
        });
      }).asCallback(cb);
    }

    /**
     * Gets an instance heartbeat.
     *
     * @param {string} id Instance id.
     * @param {callback} [cb] Optional callback.
     *
     * @return {Promise<number>} Heartbeat timestamp.
     */

  }, {
    key: 'getInstanceHeartbeat',
    value: function getInstanceHeartbeat(id, cb) {
      return this.state.getInstanceHeartbeat(id).asCallback(cb);
    }
  }]);
  return RecoveryAPI;
}();

module.exports = RecoveryAPI;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi4uL3NyYy9SZWNvdmVyeUFQSS5qcyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQTs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFFQSxJQUFNLFVBQVUsUUFBUSxVQUFSLENBQWhCO0FBQ0EsSUFBTSxJQUFJLFFBQVEsUUFBUixDQUFWOztBQUVBOzs7Ozs7OztJQU9NLFc7QUFFSix1QkFBYSxLQUFiLEVBQW9CLFNBQXBCLEVBQStCLGVBQS9CLEVBQWdELFdBQWhELEVBQTZEO0FBQUE7O0FBQzNELFNBQUssS0FBTCxHQUFhLEtBQWI7QUFDQSxTQUFLLFNBQUwsR0FBaUIsU0FBakI7QUFDQSxTQUFLLFdBQUwsR0FBbUIsV0FBbkI7QUFDQSxTQUFLLGVBQUwsR0FBdUIsZUFBdkI7QUFDRDs7OztxQ0FFaUIsSSxFQUFNO0FBQUE7O0FBQUEsVUFDaEIsUUFEZ0IsR0FDSCxJQURHLENBQ2hCLFFBRGdCOztBQUV0QixhQUFPLEtBQUssU0FBTCxDQUFlLG9CQUFmLEdBQXNDLElBQXRDLENBQTJDLG1CQUFXO0FBQzNELGVBQU8sUUFBUSxJQUFSLENBQWEsRUFBRSxPQUFGLENBQVUsT0FBVixDQUFiLEVBQWlDLGdCQUF3QjtBQUFBOztBQUFBLGNBQXRCLE1BQXNCO0FBQUEsY0FBZCxRQUFjOztBQUM5RCxjQUFJLGFBQWEsTUFBSyxXQUF0QixFQUFtQztBQUNqQyxnQkFBSSxDQUFDLE1BQUssU0FBTCxDQUFlLFNBQWYsQ0FBeUIsTUFBekIsQ0FBTCxFQUF1QztBQUNyQyxxQkFBTyxLQUFLLFNBQUwsQ0FBZSxZQUFmLENBQTRCLE1BQTVCLENBQVA7QUFDRDtBQUNGO0FBQ0QsaUJBQU8sUUFBUSxPQUFSLEVBQVA7QUFDRCxTQVBNLENBQVA7QUFRRCxPQVRNLEVBU0osSUFUSSxDQVNDLFlBQU07QUFDWixlQUFPLEtBQUssU0FBTCxDQUFlLGlCQUFmLEVBQVA7QUFDRCxPQVhNLEVBV0osSUFYSSxDQVdDLGdCQUFRO0FBQ2QsWUFBSSxPQUFPLEVBQUUsTUFBRixDQUFTLElBQVQsQ0FBWDtBQUNBLGVBQU8sRUFBRSxZQUFGLDJDQUFrQixJQUFsQixFQUFQO0FBQ0QsT0FkTSxFQWNKLElBZEksQ0FjQyxpQkFBUztBQUNmLGVBQU8sUUFBUSxJQUFSLENBQWEsS0FBYixFQUFvQixvQkFBWTtBQUNyQyxpQkFBTyxNQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLEVBQ0osSUFESSxDQUNDO0FBQUEsbUJBQVEsS0FBSyxTQUFMLENBQWUsU0FBZixDQUF5QixVQUF6QixFQUFxQyxRQUFyQyxDQUFSO0FBQUEsV0FERCxFQUVKLElBRkksQ0FFQztBQUFBLG1CQUNBLFlBQVksUUFBUSxPQUFSLEVBQVosR0FBZ0MsS0FBSyxjQUFMLENBQW9CLFFBQXBCLENBRGhDO0FBQUEsV0FGRCxFQUlKLFdBSkksRUFBUDtBQUtELFNBTk0sQ0FBUDtBQU9ELE9BdEJNLENBQVA7QUF1QkQ7OztvQ0FFZ0IsSSxFQUFNO0FBQUE7O0FBQUEsVUFDZixRQURlLEdBQ0YsSUFERSxDQUNmLFFBRGU7O0FBRXJCLGFBQU8sS0FBSyxPQUFMLENBQWEsSUFBYixFQUFtQixVQUFuQixFQUErQixJQUEvQixFQUFxQyxJQUFyQyxDQUEwQyxvQkFBWTtBQUMzRCxlQUFPLFFBQVEsSUFBUixDQUFhLFFBQWIsRUFBdUIsb0JBQVk7QUFDeEMsaUJBQU8sT0FBSyxLQUFMLENBQVcsT0FBWCxDQUFtQixRQUFuQixFQUE2QixJQUE3QixDQUFrQyxnQkFBUTtBQUMvQyxtQkFBTyxLQUFLLFNBQUwsQ0FBZSxnQkFBZixDQUFnQyxRQUFoQyxFQUEwQyxJQUExQyxDQUErQyxtQkFBVztBQUMvRCxrQkFBSSxDQUFDLE9BQUQsSUFBWSxDQUFDLFFBQVEsTUFBekIsRUFBaUM7QUFDL0IsdUJBQU8sS0FBSyxjQUFMLENBQW9CLFFBQXBCLENBQVA7QUFDRCxlQUZELE1BRU87QUFDTCx1QkFBTyxRQUFRLE9BQVIsRUFBUDtBQUNEO0FBQ0YsYUFOTSxFQU1KLFdBTkksR0FPSixJQVBJLENBT0M7QUFBQSxxQkFBTSxLQUFLLFVBQUwsQ0FBZ0IsUUFBaEIsQ0FBTjtBQUFBLGFBUEQsRUFRSixLQVJJLENBUUU7QUFBQSxxQkFBTSxLQUFLLGNBQUwsQ0FBb0IsUUFBcEIsQ0FBTjtBQUFBLGFBUkYsQ0FBUDtBQVNELFdBVk0sRUFVSixXQVZJLEVBQVA7QUFXRCxTQVpNLENBQVA7QUFhRCxPQWRNLENBQVA7QUFlRDs7QUFFRDs7Ozs7Ozs7Ozs7a0NBUWUsUSxFQUFVLEUsRUFBSTtBQUFBOztBQUMzQixhQUFPLEtBQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxlQUFRLE9BQUssZ0JBQUwsQ0FBc0IsSUFBdEIsQ0FBUjtBQUFBLE9BREQsRUFFSixVQUZJLENBRU8sRUFGUCxDQUFQO0FBR0Q7O0FBRUQ7Ozs7Ozs7Ozs7O2tDQVFlLFEsRUFBVSxFLEVBQUk7QUFBQTs7QUFDM0IsYUFBTyxLQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLEVBQ0osSUFESSxDQUNDO0FBQUEsZUFBUSxPQUFLLGVBQUwsQ0FBcUIsSUFBckIsQ0FBUjtBQUFBLE9BREQsRUFFSixVQUZJLENBRU8sRUFGUCxDQUFQO0FBR0Q7O0FBRUQ7Ozs7Ozs7Ozs7O3FDQVFrQixFLEVBQUksRSxFQUFJO0FBQUE7O0FBQ3hCLGFBQU8sS0FBSyxLQUFMLENBQVcsa0JBQVgsQ0FBOEIsRUFBOUIsRUFBa0MsSUFBbEMsQ0FBdUMsbUJBQVc7QUFDdkQsZUFBTyxRQUFRLElBQVIsQ0FBYSxFQUFFLE9BQUYsQ0FBVSxPQUFWLENBQWIsRUFBaUMsaUJBQW9CO0FBQUE7O0FBQUEsY0FBbEIsRUFBa0I7QUFBQSxjQUFkLFFBQWM7O0FBQzFELGlCQUFPLE9BQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsRUFDSixJQURJLENBQ0M7QUFBQSxtQkFBUSxLQUFLLFlBQUwsQ0FBa0IsRUFBbEIsQ0FBUjtBQUFBLFdBREQsRUFFSixXQUZJLEVBQVA7QUFHRCxTQUpNLENBQVA7QUFLRCxPQU5NLEVBTUosVUFOSSxDQU1PLEVBTlAsQ0FBUDtBQU9EOztBQUVEOzs7Ozs7Ozs7Ozt5Q0FRc0IsRSxFQUFJLEUsRUFBSTtBQUM1QixhQUFPLEtBQUssS0FBTCxDQUFXLG9CQUFYLENBQWdDLEVBQWhDLEVBQW9DLFVBQXBDLENBQStDLEVBQS9DLENBQVA7QUFDRDs7Ozs7QUFJSCxPQUFPLE9BQVAsR0FBaUIsV0FBakIiLCJmaWxlIjoiUmVjb3ZlcnlBUEkuanMiLCJzb3VyY2VzQ29udGVudCI6WyIndXNlIHN0cmljdCdcblxuY29uc3QgUHJvbWlzZSA9IHJlcXVpcmUoJ2JsdWViaXJkJylcbmNvbnN0IF8gPSByZXF1aXJlKCdsb2Rhc2gnKVxuXG4vKipcbiAqIFNlcnZpY2UgaW5mcmFzdHJ1Y3R1cmUgZmFpbHVyZXMgcmVjb3ZlcnkuXG4gKlxuICogQG1peGluXG4gKiBAbWVtYmVyb2YgY2hhdC1zZXJ2aWNlXG4gKiBAc2VlIGNoYXQtc2VydmljZS5DaGF0U2VydmljZS5ldmVudDpzdG9yZUNvbnNpc3RlbmN5RmFpbHVyZVxuICovXG5jbGFzcyBSZWNvdmVyeUFQSSB7XG5cbiAgY29uc3RydWN0b3IgKHN0YXRlLCB0cmFuc3BvcnQsIGV4ZWNVc2VyQ29tbWFuZCwgaW5zdGFuY2VVSUQpIHtcbiAgICB0aGlzLnN0YXRlID0gc3RhdGVcbiAgICB0aGlzLnRyYW5zcG9ydCA9IHRyYW5zcG9ydFxuICAgIHRoaXMuaW5zdGFuY2VVSUQgPSBpbnN0YW5jZVVJRFxuICAgIHRoaXMuZXhlY1VzZXJDb21tYW5kID0gZXhlY1VzZXJDb21tYW5kXG4gIH1cblxuICBjaGVja1VzZXJTb2NrZXRzICh1c2VyKSB7XG4gICAgbGV0IHsgdXNlck5hbWUgfSA9IHVzZXJcbiAgICByZXR1cm4gdXNlci51c2VyU3RhdGUuZ2V0U29ja2V0c1RvSW5zdGFuY2UoKS50aGVuKHNvY2tldHMgPT4ge1xuICAgICAgcmV0dXJuIFByb21pc2UuZWFjaChfLnRvUGFpcnMoc29ja2V0cyksIChbc29ja2V0LCBpbnN0YW5jZV0pID0+IHtcbiAgICAgICAgaWYgKGluc3RhbmNlID09PSB0aGlzLmluc3RhbmNlVUlEKSB7XG4gICAgICAgICAgaWYgKCF0aGlzLnRyYW5zcG9ydC5nZXRTb2NrZXQoc29ja2V0KSkge1xuICAgICAgICAgICAgcmV0dXJuIHVzZXIudXNlclN0YXRlLnJlbW92ZVNvY2tldChzb2NrZXQpXG4gICAgICAgICAgfVxuICAgICAgICB9XG4gICAgICAgIHJldHVybiBQcm9taXNlLnJlc29sdmUoKVxuICAgICAgfSlcbiAgICB9KS50aGVuKCgpID0+IHtcbiAgICAgIHJldHVybiB1c2VyLnVzZXJTdGF0ZS5nZXRTb2NrZXRzVG9Sb29tcygpXG4gICAgfSkudGhlbihkYXRhID0+IHtcbiAgICAgIGxldCBhcmdzID0gXy52YWx1ZXMoZGF0YSlcbiAgICAgIHJldHVybiBfLmludGVyc2VjdGlvbiguLi5hcmdzKVxuICAgIH0pLnRoZW4ocm9vbXMgPT4ge1xuICAgICAgcmV0dXJuIFByb21pc2UuZWFjaChyb29tcywgcm9vbU5hbWUgPT4ge1xuICAgICAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRSb29tKHJvb21OYW1lKVxuICAgICAgICAgIC50aGVuKHJvb20gPT4gcm9vbS5yb29tU3RhdGUuaGFzSW5MaXN0KCd1c2VybGlzdCcsIHVzZXJOYW1lKSlcbiAgICAgICAgICAudGhlbihpc1ByZXNlbnQgPT5cbiAgICAgICAgICAgICAgICBpc1ByZXNlbnQgPyBQcm9taXNlLnJlc29sdmUoKSA6IHVzZXIucmVtb3ZlRnJvbVJvb20ocm9vbU5hbWUpKVxuICAgICAgICAgIC5jYXRjaFJldHVybigpXG4gICAgICB9KVxuICAgIH0pXG4gIH1cblxuICBjaGVja1Jvb21Kb2luZWQgKHJvb20pIHtcbiAgICBsZXQgeyByb29tTmFtZSB9ID0gcm9vbVxuICAgIHJldHVybiByb29tLmdldExpc3QobnVsbCwgJ3VzZXJsaXN0JywgdHJ1ZSkudGhlbih1c2VybGlzdCA9PiB7XG4gICAgICByZXR1cm4gUHJvbWlzZS5lYWNoKHVzZXJsaXN0LCB1c2VyTmFtZSA9PiB7XG4gICAgICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFVzZXIodXNlck5hbWUpLnRoZW4odXNlciA9PiB7XG4gICAgICAgICAgcmV0dXJuIHVzZXIudXNlclN0YXRlLmdldFJvb21Ub1NvY2tldHMocm9vbU5hbWUpLnRoZW4oc29ja2V0cyA9PiB7XG4gICAgICAgICAgICBpZiAoIXNvY2tldHMgfHwgIXNvY2tldHMubGVuZ3RoKSB7XG4gICAgICAgICAgICAgIHJldHVybiB1c2VyLnJlbW92ZUZyb21Sb29tKHJvb21OYW1lKVxuICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgcmV0dXJuIFByb21pc2UucmVzb2x2ZSgpXG4gICAgICAgICAgICB9XG4gICAgICAgICAgfSkuY2F0Y2hSZXR1cm4oKVxuICAgICAgICAgICAgLnRoZW4oKCkgPT4gcm9vbS5jaGVja0FjZXNzKHVzZXJOYW1lKSlcbiAgICAgICAgICAgIC5jYXRjaCgoKSA9PiB1c2VyLnJlbW92ZUZyb21Sb29tKHJvb21OYW1lKSlcbiAgICAgICAgfSkuY2F0Y2hSZXR1cm4oKVxuICAgICAgfSlcbiAgICB9KVxuICB9XG5cbiAgLyoqXG4gICAqIFN5bmMgdXNlciB0byBzb2NrZXRzIGFzc29jaWF0aW9ucy5cbiAgICpcbiAgICogQHBhcmFtIHtzdHJpbmd9IHVzZXJOYW1lIFVzZXIgbmFtZS5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTx1bmRlZmluZWQ+fSBQcm9taXNlIHRoYXQgcmVzb2x2ZXMgd2l0aG91dCBhbnkgZGF0YS5cbiAgICovXG4gIHVzZXJTdGF0ZVN5bmMgKHVzZXJOYW1lLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldFVzZXIodXNlck5hbWUpXG4gICAgICAudGhlbih1c2VyID0+IHRoaXMuY2hlY2tVc2VyU29ja2V0cyh1c2VyKSlcbiAgICAgIC5hc0NhbGxiYWNrKGNiKVxuICB9XG5cbiAgLyoqXG4gICAqIFN5bmMgcm9vbSB0byB1c2VycyBhc3NvY2lhdGlvbnMuXG4gICAqXG4gICAqIEBwYXJhbSB7c3RyaW5nfSByb29tTmFtZSBSb29tIG5hbWUuXG4gICAqIEBwYXJhbSB7Y2FsbGJhY2t9IFtjYl0gT3B0aW9uYWwgY2FsbGJhY2suXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8dW5kZWZpbmVkPn0gUHJvbWlzZSB0aGF0IHJlc29sdmVzIHdpdGhvdXQgYW55IGRhdGEuXG4gICAqL1xuICByb29tU3RhdGVTeW5jIChyb29tTmFtZSwgY2IpIHtcbiAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRSb29tKHJvb21OYW1lKVxuICAgICAgLnRoZW4ocm9vbSA9PiB0aGlzLmNoZWNrUm9vbUpvaW5lZChyb29tKSlcbiAgICAgIC5hc0NhbGxiYWNrKGNiKVxuICB9XG5cbiAgLyoqXG4gICAqIEZpeGVzIGFuIGluc3RhbmNlIGRhdGEgYWZ0ZXIgYW4gaW5jb3JyZWN0IHNlcnZpY2Ugc2h1dGRvd24uXG4gICAqXG4gICAqIEBwYXJhbSB7c3RyaW5nfSBpZCBJbnN0YW5jZSBpZC5cbiAgICogQHBhcmFtIHtjYWxsYmFja30gW2NiXSBPcHRpb25hbCBjYWxsYmFjay5cbiAgICpcbiAgICogQHJldHVybiB7UHJvbWlzZTx1bmRlZmluZWQ+fSBQcm9taXNlIHRoYXQgcmVzb2x2ZXMgd2l0aG91dCBhbnkgZGF0YS5cbiAgICovXG4gIGluc3RhbmNlUmVjb3ZlcnkgKGlkLCBjYikge1xuICAgIHJldHVybiB0aGlzLnN0YXRlLmdldEluc3RhbmNlU29ja2V0cyhpZCkudGhlbihzb2NrZXRzID0+IHtcbiAgICAgIHJldHVybiBQcm9taXNlLmVhY2goXy50b1BhaXJzKHNvY2tldHMpLCAoW2lkLCB1c2VyTmFtZV0pID0+IHtcbiAgICAgICAgcmV0dXJuIHRoaXMuc3RhdGUuZ2V0VXNlcih1c2VyTmFtZSlcbiAgICAgICAgICAudGhlbih1c2VyID0+IHVzZXIucmVtb3ZlU29ja2V0KGlkKSlcbiAgICAgICAgICAuY2F0Y2hSZXR1cm4oKVxuICAgICAgfSlcbiAgICB9KS5hc0NhbGxiYWNrKGNiKVxuICB9XG5cbiAgLyoqXG4gICAqIEdldHMgYW4gaW5zdGFuY2UgaGVhcnRiZWF0LlxuICAgKlxuICAgKiBAcGFyYW0ge3N0cmluZ30gaWQgSW5zdGFuY2UgaWQuXG4gICAqIEBwYXJhbSB7Y2FsbGJhY2t9IFtjYl0gT3B0aW9uYWwgY2FsbGJhY2suXG4gICAqXG4gICAqIEByZXR1cm4ge1Byb21pc2U8bnVtYmVyPn0gSGVhcnRiZWF0IHRpbWVzdGFtcC5cbiAgICovXG4gIGdldEluc3RhbmNlSGVhcnRiZWF0IChpZCwgY2IpIHtcbiAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRJbnN0YW5jZUhlYXJ0YmVhdChpZCkuYXNDYWxsYmFjayhjYilcbiAgfVxuXG59XG5cbm1vZHVsZS5leHBvcnRzID0gUmVjb3ZlcnlBUElcbiJdfQ==