chat-service/lib/UserAssociations.js

'use strict';

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

var _slicedToArray3 = _interopRequireDefault(_slicedToArray2);

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

var _regenerator2 = _interopRequireDefault(_regenerator);

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');
var eventToPromise = require('event-to-promise');

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

var asyncLimit = _require.asyncLimit;


var co = Promise.coroutine;

// Associations for user class.

var UserAssociations = function () {
  function UserAssociations(props) {
    (0, _classCallCheck3.default)(this, UserAssociations);

    _.defaults(this, props);
  }

  (0, _createClass3.default)(UserAssociations, [{
    key: 'userJoinRoomReport',
    value: function userJoinRoomReport(userName, roomName) {
      this.transport.emitToChannel(roomName, 'roomUserJoined', roomName, userName);
    }
  }, {
    key: 'userLeftRoomReport',
    value: function userLeftRoomReport(userName, roomName, enableUserlistUpdates) {
      if (enableUserlistUpdates) {
        this.transport.emitToChannel(roomName, 'roomUserLeft', roomName, userName);
      }
    }
  }, {
    key: 'userRemovedReport',
    value: function userRemovedReport(userName, roomName, enableUserlistUpdates) {
      var cn = this.echoChannel;
      this.transport.emitToChannel(cn, 'roomAccessRemoved', roomName);
      this.userLeftRoomReport(userName, roomName, enableUserlistUpdates);
    }
  }, {
    key: 'socketJoinEcho',
    value: function socketJoinEcho(id, roomName, njoined, isLocalCall) {
      if (isLocalCall) {
        this.transport.emitToChannel(this.echoChannel, 'roomJoinedEcho', roomName, id, njoined);
      } else {
        this.transport.sendToChannel(id, this.echoChannel, 'roomJoinedEcho', roomName, id, njoined);
      }
    }
  }, {
    key: 'socketLeftEcho',
    value: function socketLeftEcho(id, roomName, njoined, isLocalCall) {
      if (isLocalCall) {
        this.transport.emitToChannel(this.echoChannel, 'roomLeftEcho', roomName, id, njoined);
      } else {
        this.transport.sendToChannel(id, this.echoChannel, 'roomLeftEcho', roomName, id, njoined);
      }
    }
  }, {
    key: 'socketConnectEcho',
    value: function socketConnectEcho(id, nconnected) {
      this.transport.sendToChannel(id, this.echoChannel, 'socketConnectEcho', id, nconnected);
    }
  }, {
    key: 'socketDisconnectEcho',
    value: function socketDisconnectEcho(id, nconnected) {
      this.transport.sendToChannel(id, this.echoChannel, 'socketDisconnectEcho', id, nconnected);
    }
  }, {
    key: 'leaveChannel',
    value: function leaveChannel(id, channel) {
      var _this = this;

      return this.transport.leaveChannel(id, channel).catch(function (e) {
        var info = { roomName: channel, id: id, opType: 'transportChannel' };
        return _this.consistencyFailure(e, info);
      });
    }
  }, {
    key: 'socketLeaveChannels',
    value: function socketLeaveChannels(id, channels) {
      var _this2 = this;

      return Promise.map(channels, function (channel) {
        return _this2.leaveChannel(id, channel);
      }, { concurrency: asyncLimit });
    }
  }, {
    key: 'leaveChannelMessage',
    value: function leaveChannelMessage(id, channel) {
      var bus = this.clusterBus;
      return Promise.try(function () {
        bus.emit('roomLeaveSocket', id, channel);
        return eventToPromise(bus, bus.makeSocketRoomLeftName(id, channel));
      }).timeout(this.busAckTimeout).catchReturn();
    }
  }, {
    key: 'channelLeaveSockets',
    value: function channelLeaveSockets(channel, ids) {
      var _this3 = this;

      return Promise.map(ids, function (id) {
        return _this3.leaveChannelMessage(id, channel);
      }, { concurrency: asyncLimit });
    }
  }, {
    key: 'rollbackRoomJoin',
    value: function rollbackRoomJoin(error, roomName, id) {
      var _this4 = this;

      return this.userState.removeSocketFromRoom(id, roomName).catch(function (e) {
        _this4.consistencyFailure(e, { roomName: roomName, opType: 'userRooms' });
        return [1];
      }).spread(function (njoined) {
        if (!njoined) {
          return _this4.leaveRoom(roomName);
        } else {
          return Promise.resolve();
        }
      }).thenThrow(error);
    }
  }, {
    key: 'leaveRoom',
    value: function leaveRoom(roomName) {
      var _this5 = this;

      return Promise.try(function () {
        return _this5.state.getRoom(roomName);
      }).then(function (room) {
        return room.leave(_this5.userName).catch(function (error) {
          return _this5.consistencyFailure(error, { roomName: roomName, opType: 'roomUserlist' });
        });
      }).catchReturn();
    }
  }, {
    key: 'getNotifySettings',
    value: function getNotifySettings(roomName) {
      var _this6 = this;

      return Promise.try(function () {
        return _this6.state.getRoom(roomName);
      }).then(function (room) {
        return room.getNotificationsInfo(null, true);
      }).catchReturn({});
    }
  }, {
    key: 'joinSocketToRoom',
    value: function joinSocketToRoom(id, roomName, isLocalCall) {
      var lock = this.userState.lockToRoom(roomName, this.lockTTL);
      return Promise.using(lock, co(_regenerator2.default.mark(function _callee() {
        var _this7 = this;

        var room, enableUserlistUpdates;
        return _regenerator2.default.wrap(function _callee$(_context) {
          while (1) {
            switch (_context.prev = _context.next) {
              case 0:
                _context.next = 2;
                return this.state.getRoom(roomName);

              case 2:
                room = _context.sent;
                _context.next = 5;
                return room.join(this.userName);

              case 5:
                _context.next = 7;
                return room.roomState.userlistUpdatesGet();

              case 7:
                enableUserlistUpdates = _context.sent;
                return _context.abrupt('return', this.userState.addSocketToRoom(id, roomName).then(function (njoined) {
                  return _this7.transport.joinChannel(id, roomName).then(function () {
                    if (njoined === 1 && enableUserlistUpdates) {
                      _this7.userJoinRoomReport(_this7.userName, roomName);
                    }
                    return _this7.socketJoinEcho(id, roomName, njoined, isLocalCall);
                  }).return(njoined);
                }).catch(function (e) {
                  return _this7.rollbackRoomJoin(e, roomName, id);
                }));

              case 9:
              case 'end':
                return _context.stop();
            }
          }
        }, _callee, this);
      })).bind(this));
    }
  }, {
    key: 'leaveSocketFromRoom',
    value: function leaveSocketFromRoom(id, roomName, isLocalCall) {
      var lock = this.userState.lockToRoom(roomName, this.lockTTL);
      return Promise.using(lock, co(_regenerator2.default.mark(function _callee2() {
        var _ref, _ref2, njoined, hasChanged, _ref3, enableUserlistUpdates;

        return _regenerator2.default.wrap(function _callee2$(_context2) {
          while (1) {
            switch (_context2.prev = _context2.next) {
              case 0:
                _context2.next = 2;
                return this.userState.removeSocketFromRoom(id, roomName);

              case 2:
                _ref = _context2.sent;
                _ref2 = (0, _slicedToArray3.default)(_ref, 2);
                njoined = _ref2[0];
                hasChanged = _ref2[1];
                _context2.next = 8;
                return this.leaveChannel(id, roomName);

              case 8:
                if (!(njoined === 0)) {
                  _context2.next = 11;
                  break;
                }

                _context2.next = 11;
                return this.leaveRoom(roomName);

              case 11:
                if (!hasChanged) {
                  _context2.next = 18;
                  break;
                }

                _context2.next = 14;
                return this.getNotifySettings(roomName);

              case 14:
                _ref3 = _context2.sent;
                enableUserlistUpdates = _ref3.enableUserlistUpdates;

                this.socketLeftEcho(id, roomName, njoined, isLocalCall);
                this.userLeftRoomReport(this.userName, roomName, enableUserlistUpdates);

              case 18:
                return _context2.abrupt('return', Promise.resolve(njoined));

              case 19:
              case 'end':
                return _context2.stop();
            }
          }
        }, _callee2, this);
      })).bind(this));
    }
  }, {
    key: 'removeUserSocket',
    value: function removeUserSocket(id) {
      var _this8 = this;

      return this.userState.removeSocket(id).spread(function (roomsRemoved, joinedSockets, nconnected) {
        roomsRemoved = roomsRemoved || [];
        joinedSockets = joinedSockets || [];
        nconnected = nconnected || 0;
        return _this8.socketLeaveChannels(id, roomsRemoved).then(function () {
          return Promise.map(roomsRemoved, function (roomName, idx) {
            var njoined = joinedSockets[idx];
            _this8.socketLeftEcho(id, roomName, njoined);
            if (njoined) {
              return Promise.resolve();
            }
            return _this8.leaveRoom(roomName).then(function () {
              return _this8.getNotifySettings(roomName);
            }).then(function (_ref4) {
              var enableUserlistUpdates = _ref4.enableUserlistUpdates;
              return _this8.userLeftRoomReport(_this8.userName, roomName, enableUserlistUpdates);
            });
          }, { concurrency: asyncLimit }).then(function () {
            return _this8.socketDisconnectEcho(id, nconnected);
          });
        });
      }).then(function () {
        return _this8.state.removeSocket(id);
      });
    }
  }, {
    key: 'removeSocketFromServer',
    value: function removeSocketFromServer(id) {
      var _this9 = this;

      return this.removeUserSocket(id).catch(function (e) {
        var info = { id: id, opType: 'userSockets' };
        return _this9.consistencyFailure(e, info);
      });
    }
  }, {
    key: 'removeUserSocketsFromRoom',
    value: function removeUserSocketsFromRoom(roomName) {
      var _this10 = this;

      return this.userState.removeAllSocketsFromRoom(roomName).catch(function (e) {
        var info = { roomName: roomName, opType: 'roomUserlist' };
        return _this10.consistencyFailure(e, info);
      });
    }
  }, {
    key: 'removeFromRoom',
    value: function removeFromRoom(roomName) {
      var lock = this.userState.lockToRoom(roomName, this.lockTTL);
      return Promise.using(lock, co(_regenerator2.default.mark(function _callee3() {
        var removedSockets, _ref5, enableUserlistUpdates;

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

              case 2:
                removedSockets = _context3.sent;

                removedSockets = removedSockets || [];
                _context3.next = 6;
                return this.channelLeaveSockets(roomName, removedSockets);

              case 6:
                if (!removedSockets.length) {
                  _context3.next = 12;
                  break;
                }

                _context3.next = 9;
                return this.getNotifySettings(roomName);

              case 9:
                _ref5 = _context3.sent;
                enableUserlistUpdates = _ref5.enableUserlistUpdates;

                this.userRemovedReport(this.userName, roomName, enableUserlistUpdates);

              case 12:
                return _context3.abrupt('return', this.leaveRoom(roomName));

              case 13:
              case 'end':
                return _context3.stop();
            }
          }
        }, _callee3, this);
      })).bind(this));
    }
  }, {
    key: 'removeRoomUsers',
    value: function removeRoomUsers(roomName, userNames) {
      var _this11 = this;

      userNames = userNames || [];
      return Promise.map(userNames, function (userName) {
        return _this11.state.getUser(userName).then(function (user) {
          return user.removeFromRoom(roomName);
        }).catchReturn();
      }, { concurrency: asyncLimit });
    }
  }]);
  return UserAssociations;
}();

module.exports = UserAssociations;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi4uL3NyYy9Vc2VyQXNzb2NpYXRpb25zLmpzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBOzs7Ozs7Ozs7Ozs7Ozs7Ozs7OztBQUVBLElBQU0sVUFBVSxRQUFRLFVBQVIsQ0FBaEI7QUFDQSxJQUFNLElBQUksUUFBUSxRQUFSLENBQVY7QUFDQSxJQUFNLGlCQUFpQixRQUFRLGtCQUFSLENBQXZCOztlQUN1QixRQUFRLFNBQVIsQzs7SUFBZixVLFlBQUEsVTs7O0FBRVIsSUFBTSxLQUFLLFFBQVEsU0FBbkI7O0FBRUE7O0lBQ00sZ0I7QUFFSiw0QkFBYSxLQUFiLEVBQW9CO0FBQUE7O0FBQ2xCLE1BQUUsUUFBRixDQUFXLElBQVgsRUFBaUIsS0FBakI7QUFDRDs7Ozt1Q0FFbUIsUSxFQUFVLFEsRUFBVTtBQUN0QyxXQUFLLFNBQUwsQ0FBZSxhQUFmLENBQTZCLFFBQTdCLEVBQXVDLGdCQUF2QyxFQUF5RCxRQUF6RCxFQUFtRSxRQUFuRTtBQUNEOzs7dUNBRW1CLFEsRUFBVSxRLEVBQVUscUIsRUFBdUI7QUFDN0QsVUFBSSxxQkFBSixFQUEyQjtBQUN6QixhQUFLLFNBQUwsQ0FBZSxhQUFmLENBQTZCLFFBQTdCLEVBQXVDLGNBQXZDLEVBQXVELFFBQXZELEVBQWlFLFFBQWpFO0FBQ0Q7QUFDRjs7O3NDQUVrQixRLEVBQVUsUSxFQUFVLHFCLEVBQXVCO0FBQzVELFVBQUksS0FBSyxLQUFLLFdBQWQ7QUFDQSxXQUFLLFNBQUwsQ0FBZSxhQUFmLENBQTZCLEVBQTdCLEVBQWlDLG1CQUFqQyxFQUFzRCxRQUF0RDtBQUNBLFdBQUssa0JBQUwsQ0FBd0IsUUFBeEIsRUFBa0MsUUFBbEMsRUFBNEMscUJBQTVDO0FBQ0Q7OzttQ0FFZSxFLEVBQUksUSxFQUFVLE8sRUFBUyxXLEVBQWE7QUFDbEQsVUFBSSxXQUFKLEVBQWlCO0FBQ2YsYUFBSyxTQUFMLENBQWUsYUFBZixDQUNFLEtBQUssV0FEUCxFQUNvQixnQkFEcEIsRUFDc0MsUUFEdEMsRUFDZ0QsRUFEaEQsRUFDb0QsT0FEcEQ7QUFFRCxPQUhELE1BR087QUFDTCxhQUFLLFNBQUwsQ0FBZSxhQUFmLENBQ0UsRUFERixFQUNNLEtBQUssV0FEWCxFQUN3QixnQkFEeEIsRUFDMEMsUUFEMUMsRUFDb0QsRUFEcEQsRUFDd0QsT0FEeEQ7QUFFRDtBQUNGOzs7bUNBRWUsRSxFQUFJLFEsRUFBVSxPLEVBQVMsVyxFQUFhO0FBQ2xELFVBQUksV0FBSixFQUFpQjtBQUNmLGFBQUssU0FBTCxDQUFlLGFBQWYsQ0FDRSxLQUFLLFdBRFAsRUFDb0IsY0FEcEIsRUFDb0MsUUFEcEMsRUFDOEMsRUFEOUMsRUFDa0QsT0FEbEQ7QUFFRCxPQUhELE1BR087QUFDTCxhQUFLLFNBQUwsQ0FBZSxhQUFmLENBQ0UsRUFERixFQUNNLEtBQUssV0FEWCxFQUN3QixjQUR4QixFQUN3QyxRQUR4QyxFQUNrRCxFQURsRCxFQUNzRCxPQUR0RDtBQUVEO0FBQ0Y7OztzQ0FFa0IsRSxFQUFJLFUsRUFBWTtBQUNqQyxXQUFLLFNBQUwsQ0FBZSxhQUFmLENBQ0UsRUFERixFQUNNLEtBQUssV0FEWCxFQUN3QixtQkFEeEIsRUFDNkMsRUFEN0MsRUFDaUQsVUFEakQ7QUFFRDs7O3lDQUVxQixFLEVBQUksVSxFQUFZO0FBQ3BDLFdBQUssU0FBTCxDQUFlLGFBQWYsQ0FDRSxFQURGLEVBQ00sS0FBSyxXQURYLEVBQ3dCLHNCQUR4QixFQUNnRCxFQURoRCxFQUNvRCxVQURwRDtBQUVEOzs7aUNBRWEsRSxFQUFJLE8sRUFBUztBQUFBOztBQUN6QixhQUFPLEtBQUssU0FBTCxDQUFlLFlBQWYsQ0FBNEIsRUFBNUIsRUFBZ0MsT0FBaEMsRUFBeUMsS0FBekMsQ0FBK0MsYUFBSztBQUN6RCxZQUFJLE9BQU8sRUFBRSxVQUFVLE9BQVosRUFBcUIsTUFBckIsRUFBeUIsUUFBUSxrQkFBakMsRUFBWDtBQUNBLGVBQU8sTUFBSyxrQkFBTCxDQUF3QixDQUF4QixFQUEyQixJQUEzQixDQUFQO0FBQ0QsT0FITSxDQUFQO0FBSUQ7Ozt3Q0FFb0IsRSxFQUFJLFEsRUFBVTtBQUFBOztBQUNqQyxhQUFPLFFBQVEsR0FBUixDQUNMLFFBREssRUFFTDtBQUFBLGVBQVcsT0FBSyxZQUFMLENBQWtCLEVBQWxCLEVBQXNCLE9BQXRCLENBQVg7QUFBQSxPQUZLLEVBR0wsRUFBRSxhQUFhLFVBQWYsRUFISyxDQUFQO0FBSUQ7Ozt3Q0FFb0IsRSxFQUFJLE8sRUFBUztBQUNoQyxVQUFJLE1BQU0sS0FBSyxVQUFmO0FBQ0EsYUFBTyxRQUFRLEdBQVIsQ0FBWSxZQUFNO0FBQ3ZCLFlBQUksSUFBSixDQUFTLGlCQUFULEVBQTRCLEVBQTVCLEVBQWdDLE9BQWhDO0FBQ0EsZUFBTyxlQUFlLEdBQWYsRUFBb0IsSUFBSSxzQkFBSixDQUEyQixFQUEzQixFQUErQixPQUEvQixDQUFwQixDQUFQO0FBQ0QsT0FITSxFQUdKLE9BSEksQ0FHSSxLQUFLLGFBSFQsRUFHd0IsV0FIeEIsRUFBUDtBQUlEOzs7d0NBRW9CLE8sRUFBUyxHLEVBQUs7QUFBQTs7QUFDakMsYUFBTyxRQUFRLEdBQVIsQ0FDTCxHQURLLEVBRUw7QUFBQSxlQUFNLE9BQUssbUJBQUwsQ0FBeUIsRUFBekIsRUFBNkIsT0FBN0IsQ0FBTjtBQUFBLE9BRkssRUFHTCxFQUFFLGFBQWEsVUFBZixFQUhLLENBQVA7QUFJRDs7O3FDQUVpQixLLEVBQU8sUSxFQUFVLEUsRUFBSTtBQUFBOztBQUNyQyxhQUFPLEtBQUssU0FBTCxDQUFlLG9CQUFmLENBQW9DLEVBQXBDLEVBQXdDLFFBQXhDLEVBQWtELEtBQWxELENBQXdELGFBQUs7QUFDbEUsZUFBSyxrQkFBTCxDQUF3QixDQUF4QixFQUEyQixFQUFFLGtCQUFGLEVBQVksUUFBUSxXQUFwQixFQUEzQjtBQUNBLGVBQU8sQ0FBQyxDQUFELENBQVA7QUFDRCxPQUhNLEVBR0osTUFISSxDQUdHLG1CQUFXO0FBQ25CLFlBQUksQ0FBQyxPQUFMLEVBQWM7QUFDWixpQkFBTyxPQUFLLFNBQUwsQ0FBZSxRQUFmLENBQVA7QUFDRCxTQUZELE1BRU87QUFDTCxpQkFBTyxRQUFRLE9BQVIsRUFBUDtBQUNEO0FBQ0YsT0FUTSxFQVNKLFNBVEksQ0FTTSxLQVROLENBQVA7QUFVRDs7OzhCQUVVLFEsRUFBVTtBQUFBOztBQUNuQixhQUFPLFFBQ0osR0FESSxDQUNBO0FBQUEsZUFBTSxPQUFLLEtBQUwsQ0FBVyxPQUFYLENBQW1CLFFBQW5CLENBQU47QUFBQSxPQURBLEVBRUosSUFGSSxDQUVDO0FBQUEsZUFBUSxLQUFLLEtBQUwsQ0FBVyxPQUFLLFFBQWhCLEVBQ1AsS0FETyxDQUNEO0FBQUEsaUJBQVMsT0FBSyxrQkFBTCxDQUNkLEtBRGMsRUFDUCxFQUFDLGtCQUFELEVBQVcsUUFBUSxjQUFuQixFQURPLENBQVQ7QUFBQSxTQURDLENBQVI7QUFBQSxPQUZELEVBS0osV0FMSSxFQUFQO0FBTUQ7OztzQ0FFa0IsUSxFQUFVO0FBQUE7O0FBQzNCLGFBQU8sUUFDSixHQURJLENBQ0E7QUFBQSxlQUFNLE9BQUssS0FBTCxDQUFXLE9BQVgsQ0FBbUIsUUFBbkIsQ0FBTjtBQUFBLE9BREEsRUFFSixJQUZJLENBRUM7QUFBQSxlQUFRLEtBQUssb0JBQUwsQ0FBMEIsSUFBMUIsRUFBZ0MsSUFBaEMsQ0FBUjtBQUFBLE9BRkQsRUFHSixXQUhJLENBR1EsRUFIUixDQUFQO0FBSUQ7OztxQ0FFaUIsRSxFQUFJLFEsRUFBVSxXLEVBQWE7QUFDM0MsVUFBSSxPQUFPLEtBQUssU0FBTCxDQUFlLFVBQWYsQ0FBMEIsUUFBMUIsRUFBb0MsS0FBSyxPQUF6QyxDQUFYO0FBQ0EsYUFBTyxRQUFRLEtBQVIsQ0FBYyxJQUFkLEVBQW9CLDhCQUFHO0FBQUE7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUEsdUJBQ1gsS0FBSyxLQUFMLENBQVcsT0FBWCxDQUFtQixRQUFuQixDQURXOztBQUFBO0FBQ3hCLG9CQUR3QjtBQUFBO0FBQUEsdUJBRXRCLEtBQUssSUFBTCxDQUFVLEtBQUssUUFBZixDQUZzQjs7QUFBQTtBQUFBO0FBQUEsdUJBR00sS0FBSyxTQUFMLENBQWUsa0JBQWYsRUFITjs7QUFBQTtBQUd4QixxQ0FId0I7QUFBQSxpREFJckIsS0FBSyxTQUFMLENBQWUsZUFBZixDQUErQixFQUEvQixFQUFtQyxRQUFuQyxFQUE2QyxJQUE3QyxDQUFrRCxtQkFBVztBQUNsRSx5QkFBTyxPQUFLLFNBQUwsQ0FBZSxXQUFmLENBQTJCLEVBQTNCLEVBQStCLFFBQS9CLEVBQXlDLElBQXpDLENBQThDLFlBQU07QUFDekQsd0JBQUksWUFBWSxDQUFaLElBQWlCLHFCQUFyQixFQUE0QztBQUMxQyw2QkFBSyxrQkFBTCxDQUF3QixPQUFLLFFBQTdCLEVBQXVDLFFBQXZDO0FBQ0Q7QUFDRCwyQkFBTyxPQUFLLGNBQUwsQ0FBb0IsRUFBcEIsRUFBd0IsUUFBeEIsRUFBa0MsT0FBbEMsRUFBMkMsV0FBM0MsQ0FBUDtBQUNELG1CQUxNLEVBS0osTUFMSSxDQUtHLE9BTEgsQ0FBUDtBQU1ELGlCQVBNLEVBT0osS0FQSSxDQU9FO0FBQUEseUJBQUssT0FBSyxnQkFBTCxDQUFzQixDQUF0QixFQUF5QixRQUF6QixFQUFtQyxFQUFuQyxDQUFMO0FBQUEsaUJBUEYsQ0FKcUI7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUEsT0FBSCxHQVl4QixJQVp3QixDQVluQixJQVptQixDQUFwQixDQUFQO0FBYUQ7Ozt3Q0FFb0IsRSxFQUFJLFEsRUFBVSxXLEVBQWE7QUFDOUMsVUFBSSxPQUFPLEtBQUssU0FBTCxDQUFlLFVBQWYsQ0FBMEIsUUFBMUIsRUFBb0MsS0FBSyxPQUF6QyxDQUFYO0FBQ0EsYUFBTyxRQUFRLEtBQVIsQ0FBYyxJQUFkLEVBQW9CLDhCQUFHO0FBQUE7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBLHVCQUVoQixLQUFLLFNBQUwsQ0FBZSxvQkFBZixDQUFvQyxFQUFwQyxFQUF3QyxRQUF4QyxDQUZnQjs7QUFBQTtBQUFBO0FBQUE7QUFDdkIsdUJBRHVCO0FBQ2QsMEJBRGM7QUFBQTtBQUFBLHVCQUd0QixLQUFLLFlBQUwsQ0FBa0IsRUFBbEIsRUFBc0IsUUFBdEIsQ0FIc0I7O0FBQUE7QUFBQSxzQkFJeEIsWUFBWSxDQUpZO0FBQUE7QUFBQTtBQUFBOztBQUFBO0FBQUEsdUJBS3BCLEtBQUssU0FBTCxDQUFlLFFBQWYsQ0FMb0I7O0FBQUE7QUFBQSxxQkFPeEIsVUFQd0I7QUFBQTtBQUFBO0FBQUE7O0FBQUE7QUFBQSx1QkFRWSxLQUFLLGlCQUFMLENBQXVCLFFBQXZCLENBUlo7O0FBQUE7QUFBQTtBQVFwQixxQ0FSb0IsU0FRcEIscUJBUm9COztBQVMxQixxQkFBSyxjQUFMLENBQW9CLEVBQXBCLEVBQXdCLFFBQXhCLEVBQWtDLE9BQWxDLEVBQTJDLFdBQTNDO0FBQ0EscUJBQUssa0JBQUwsQ0FBd0IsS0FBSyxRQUE3QixFQUF1QyxRQUF2QyxFQUFpRCxxQkFBakQ7O0FBVjBCO0FBQUEsa0RBWXJCLFFBQVEsT0FBUixDQUFnQixPQUFoQixDQVpxQjs7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQSxPQUFILEdBYXhCLElBYndCLENBYW5CLElBYm1CLENBQXBCLENBQVA7QUFjRDs7O3FDQUVpQixFLEVBQUk7QUFBQTs7QUFDcEIsYUFBTyxLQUFLLFNBQUwsQ0FBZSxZQUFmLENBQTRCLEVBQTVCLEVBQ0osTUFESSxDQUNHLFVBQUMsWUFBRCxFQUFlLGFBQWYsRUFBOEIsVUFBOUIsRUFBNkM7QUFDbkQsdUJBQWUsZ0JBQWdCLEVBQS9CO0FBQ0Esd0JBQWdCLGlCQUFpQixFQUFqQztBQUNBLHFCQUFhLGNBQWMsQ0FBM0I7QUFDQSxlQUFPLE9BQUssbUJBQUwsQ0FBeUIsRUFBekIsRUFBNkIsWUFBN0IsRUFBMkMsSUFBM0MsQ0FBZ0QsWUFBTTtBQUMzRCxpQkFBTyxRQUFRLEdBQVIsQ0FDTCxZQURLLEVBRUwsVUFBQyxRQUFELEVBQVcsR0FBWCxFQUFtQjtBQUNqQixnQkFBSSxVQUFVLGNBQWMsR0FBZCxDQUFkO0FBQ0EsbUJBQUssY0FBTCxDQUFvQixFQUFwQixFQUF3QixRQUF4QixFQUFrQyxPQUFsQztBQUNBLGdCQUFJLE9BQUosRUFBYTtBQUFFLHFCQUFPLFFBQVEsT0FBUixFQUFQO0FBQTBCO0FBQ3pDLG1CQUFPLE9BQUssU0FBTCxDQUFlLFFBQWYsRUFDSixJQURJLENBQ0M7QUFBQSxxQkFBTSxPQUFLLGlCQUFMLENBQXVCLFFBQXZCLENBQU47QUFBQSxhQURELEVBRUosSUFGSSxDQUVDO0FBQUEsa0JBQUUscUJBQUYsU0FBRSxxQkFBRjtBQUFBLHFCQUE2QixPQUFLLGtCQUFMLENBQ2pDLE9BQUssUUFENEIsRUFDbEIsUUFEa0IsRUFDUixxQkFEUSxDQUE3QjtBQUFBLGFBRkQsQ0FBUDtBQUlELFdBVkksRUFXTCxFQUFFLGFBQWEsVUFBZixFQVhLLEVBWUosSUFaSSxDQVlDO0FBQUEsbUJBQU0sT0FBSyxvQkFBTCxDQUEwQixFQUExQixFQUE4QixVQUE5QixDQUFOO0FBQUEsV0FaRCxDQUFQO0FBYUQsU0FkTSxDQUFQO0FBZUQsT0FwQkksRUFvQkYsSUFwQkUsQ0FvQkc7QUFBQSxlQUFNLE9BQUssS0FBTCxDQUFXLFlBQVgsQ0FBd0IsRUFBeEIsQ0FBTjtBQUFBLE9BcEJILENBQVA7QUFxQkQ7OzsyQ0FFdUIsRSxFQUFJO0FBQUE7O0FBQzFCLGFBQU8sS0FBSyxnQkFBTCxDQUFzQixFQUF0QixFQUEwQixLQUExQixDQUFnQyxhQUFLO0FBQzFDLFlBQUksT0FBTyxFQUFFLE1BQUYsRUFBTSxRQUFRLGFBQWQsRUFBWDtBQUNBLGVBQU8sT0FBSyxrQkFBTCxDQUF3QixDQUF4QixFQUEyQixJQUEzQixDQUFQO0FBQ0QsT0FITSxDQUFQO0FBSUQ7Ozs4Q0FFMEIsUSxFQUFVO0FBQUE7O0FBQ25DLGFBQU8sS0FBSyxTQUFMLENBQWUsd0JBQWYsQ0FBd0MsUUFBeEMsRUFBa0QsS0FBbEQsQ0FBd0QsYUFBSztBQUNsRSxZQUFJLE9BQU8sRUFBRSxrQkFBRixFQUFZLFFBQVEsY0FBcEIsRUFBWDtBQUNBLGVBQU8sUUFBSyxrQkFBTCxDQUF3QixDQUF4QixFQUEyQixJQUEzQixDQUFQO0FBQ0QsT0FITSxDQUFQO0FBSUQ7OzttQ0FFZSxRLEVBQVU7QUFDeEIsVUFBSSxPQUFPLEtBQUssU0FBTCxDQUFlLFVBQWYsQ0FBMEIsUUFBMUIsRUFBb0MsS0FBSyxPQUF6QyxDQUFYO0FBQ0EsYUFBTyxRQUFRLEtBQVIsQ0FBYyxJQUFkLEVBQW9CLDhCQUFHO0FBQUE7O0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBLHVCQUNELEtBQUsseUJBQUwsQ0FBK0IsUUFBL0IsQ0FEQzs7QUFBQTtBQUN4Qiw4QkFEd0I7O0FBRTVCLGlDQUFpQixrQkFBa0IsRUFBbkM7QUFGNEI7QUFBQSx1QkFHdEIsS0FBSyxtQkFBTCxDQUF5QixRQUF6QixFQUFtQyxjQUFuQyxDQUhzQjs7QUFBQTtBQUFBLHFCQUl4QixlQUFlLE1BSlM7QUFBQTtBQUFBO0FBQUE7O0FBQUE7QUFBQSx1QkFLWSxLQUFLLGlCQUFMLENBQXVCLFFBQXZCLENBTFo7O0FBQUE7QUFBQTtBQUtwQixxQ0FMb0IsU0FLcEIscUJBTG9COztBQU0xQixxQkFBSyxpQkFBTCxDQUF1QixLQUFLLFFBQTVCLEVBQXNDLFFBQXRDLEVBQWdELHFCQUFoRDs7QUFOMEI7QUFBQSxrREFRckIsS0FBSyxTQUFMLENBQWUsUUFBZixDQVJxQjs7QUFBQTtBQUFBO0FBQUE7QUFBQTtBQUFBO0FBQUE7QUFBQSxPQUFILEdBU3hCLElBVHdCLENBU25CLElBVG1CLENBQXBCLENBQVA7QUFVRDs7O29DQUVnQixRLEVBQVUsUyxFQUFXO0FBQUE7O0FBQ3BDLGtCQUFZLGFBQWEsRUFBekI7QUFDQSxhQUFPLFFBQVEsR0FBUixDQUNMLFNBREssRUFFTCxvQkFBWTtBQUNWLGVBQU8sUUFBSyxLQUFMLENBQVcsT0FBWCxDQUFtQixRQUFuQixFQUNKLElBREksQ0FDQztBQUFBLGlCQUFRLEtBQUssY0FBTCxDQUFvQixRQUFwQixDQUFSO0FBQUEsU0FERCxFQUVKLFdBRkksRUFBUDtBQUdELE9BTkksRUFPTCxFQUFFLGFBQWEsVUFBZixFQVBLLENBQVA7QUFRRDs7Ozs7QUFJSCxPQUFPLE9BQVAsR0FBaUIsZ0JBQWpCIiwiZmlsZSI6IlVzZXJBc3NvY2lhdGlvbnMuanMiLCJzb3VyY2VzQ29udGVudCI6WyIndXNlIHN0cmljdCdcblxuY29uc3QgUHJvbWlzZSA9IHJlcXVpcmUoJ2JsdWViaXJkJylcbmNvbnN0IF8gPSByZXF1aXJlKCdsb2Rhc2gnKVxuY29uc3QgZXZlbnRUb1Byb21pc2UgPSByZXF1aXJlKCdldmVudC10by1wcm9taXNlJylcbmNvbnN0IHsgYXN5bmNMaW1pdCB9ID0gcmVxdWlyZSgnLi91dGlscycpXG5cbmNvbnN0IGNvID0gUHJvbWlzZS5jb3JvdXRpbmVcblxuLy8gQXNzb2NpYXRpb25zIGZvciB1c2VyIGNsYXNzLlxuY2xhc3MgVXNlckFzc29jaWF0aW9ucyB7XG5cbiAgY29uc3RydWN0b3IgKHByb3BzKSB7XG4gICAgXy5kZWZhdWx0cyh0aGlzLCBwcm9wcylcbiAgfVxuXG4gIHVzZXJKb2luUm9vbVJlcG9ydCAodXNlck5hbWUsIHJvb21OYW1lKSB7XG4gICAgdGhpcy50cmFuc3BvcnQuZW1pdFRvQ2hhbm5lbChyb29tTmFtZSwgJ3Jvb21Vc2VySm9pbmVkJywgcm9vbU5hbWUsIHVzZXJOYW1lKVxuICB9XG5cbiAgdXNlckxlZnRSb29tUmVwb3J0ICh1c2VyTmFtZSwgcm9vbU5hbWUsIGVuYWJsZVVzZXJsaXN0VXBkYXRlcykge1xuICAgIGlmIChlbmFibGVVc2VybGlzdFVwZGF0ZXMpIHtcbiAgICAgIHRoaXMudHJhbnNwb3J0LmVtaXRUb0NoYW5uZWwocm9vbU5hbWUsICdyb29tVXNlckxlZnQnLCByb29tTmFtZSwgdXNlck5hbWUpXG4gICAgfVxuICB9XG5cbiAgdXNlclJlbW92ZWRSZXBvcnQgKHVzZXJOYW1lLCByb29tTmFtZSwgZW5hYmxlVXNlcmxpc3RVcGRhdGVzKSB7XG4gICAgbGV0IGNuID0gdGhpcy5lY2hvQ2hhbm5lbFxuICAgIHRoaXMudHJhbnNwb3J0LmVtaXRUb0NoYW5uZWwoY24sICdyb29tQWNjZXNzUmVtb3ZlZCcsIHJvb21OYW1lKVxuICAgIHRoaXMudXNlckxlZnRSb29tUmVwb3J0KHVzZXJOYW1lLCByb29tTmFtZSwgZW5hYmxlVXNlcmxpc3RVcGRhdGVzKVxuICB9XG5cbiAgc29ja2V0Sm9pbkVjaG8gKGlkLCByb29tTmFtZSwgbmpvaW5lZCwgaXNMb2NhbENhbGwpIHtcbiAgICBpZiAoaXNMb2NhbENhbGwpIHtcbiAgICAgIHRoaXMudHJhbnNwb3J0LmVtaXRUb0NoYW5uZWwoXG4gICAgICAgIHRoaXMuZWNob0NoYW5uZWwsICdyb29tSm9pbmVkRWNobycsIHJvb21OYW1lLCBpZCwgbmpvaW5lZClcbiAgICB9IGVsc2Uge1xuICAgICAgdGhpcy50cmFuc3BvcnQuc2VuZFRvQ2hhbm5lbChcbiAgICAgICAgaWQsIHRoaXMuZWNob0NoYW5uZWwsICdyb29tSm9pbmVkRWNobycsIHJvb21OYW1lLCBpZCwgbmpvaW5lZClcbiAgICB9XG4gIH1cblxuICBzb2NrZXRMZWZ0RWNobyAoaWQsIHJvb21OYW1lLCBuam9pbmVkLCBpc0xvY2FsQ2FsbCkge1xuICAgIGlmIChpc0xvY2FsQ2FsbCkge1xuICAgICAgdGhpcy50cmFuc3BvcnQuZW1pdFRvQ2hhbm5lbChcbiAgICAgICAgdGhpcy5lY2hvQ2hhbm5lbCwgJ3Jvb21MZWZ0RWNobycsIHJvb21OYW1lLCBpZCwgbmpvaW5lZClcbiAgICB9IGVsc2Uge1xuICAgICAgdGhpcy50cmFuc3BvcnQuc2VuZFRvQ2hhbm5lbChcbiAgICAgICAgaWQsIHRoaXMuZWNob0NoYW5uZWwsICdyb29tTGVmdEVjaG8nLCByb29tTmFtZSwgaWQsIG5qb2luZWQpXG4gICAgfVxuICB9XG5cbiAgc29ja2V0Q29ubmVjdEVjaG8gKGlkLCBuY29ubmVjdGVkKSB7XG4gICAgdGhpcy50cmFuc3BvcnQuc2VuZFRvQ2hhbm5lbChcbiAgICAgIGlkLCB0aGlzLmVjaG9DaGFubmVsLCAnc29ja2V0Q29ubmVjdEVjaG8nLCBpZCwgbmNvbm5lY3RlZClcbiAgfVxuXG4gIHNvY2tldERpc2Nvbm5lY3RFY2hvIChpZCwgbmNvbm5lY3RlZCkge1xuICAgIHRoaXMudHJhbnNwb3J0LnNlbmRUb0NoYW5uZWwoXG4gICAgICBpZCwgdGhpcy5lY2hvQ2hhbm5lbCwgJ3NvY2tldERpc2Nvbm5lY3RFY2hvJywgaWQsIG5jb25uZWN0ZWQpXG4gIH1cblxuICBsZWF2ZUNoYW5uZWwgKGlkLCBjaGFubmVsKSB7XG4gICAgcmV0dXJuIHRoaXMudHJhbnNwb3J0LmxlYXZlQ2hhbm5lbChpZCwgY2hhbm5lbCkuY2F0Y2goZSA9PiB7XG4gICAgICBsZXQgaW5mbyA9IHsgcm9vbU5hbWU6IGNoYW5uZWwsIGlkLCBvcFR5cGU6ICd0cmFuc3BvcnRDaGFubmVsJyB9XG4gICAgICByZXR1cm4gdGhpcy5jb25zaXN0ZW5jeUZhaWx1cmUoZSwgaW5mbylcbiAgICB9KVxuICB9XG5cbiAgc29ja2V0TGVhdmVDaGFubmVscyAoaWQsIGNoYW5uZWxzKSB7XG4gICAgcmV0dXJuIFByb21pc2UubWFwKFxuICAgICAgY2hhbm5lbHMsXG4gICAgICBjaGFubmVsID0+IHRoaXMubGVhdmVDaGFubmVsKGlkLCBjaGFubmVsKSxcbiAgICAgIHsgY29uY3VycmVuY3k6IGFzeW5jTGltaXQgfSlcbiAgfVxuXG4gIGxlYXZlQ2hhbm5lbE1lc3NhZ2UgKGlkLCBjaGFubmVsKSB7XG4gICAgbGV0IGJ1cyA9IHRoaXMuY2x1c3RlckJ1c1xuICAgIHJldHVybiBQcm9taXNlLnRyeSgoKSA9PiB7XG4gICAgICBidXMuZW1pdCgncm9vbUxlYXZlU29ja2V0JywgaWQsIGNoYW5uZWwpXG4gICAgICByZXR1cm4gZXZlbnRUb1Byb21pc2UoYnVzLCBidXMubWFrZVNvY2tldFJvb21MZWZ0TmFtZShpZCwgY2hhbm5lbCkpXG4gICAgfSkudGltZW91dCh0aGlzLmJ1c0Fja1RpbWVvdXQpLmNhdGNoUmV0dXJuKClcbiAgfVxuXG4gIGNoYW5uZWxMZWF2ZVNvY2tldHMgKGNoYW5uZWwsIGlkcykge1xuICAgIHJldHVybiBQcm9taXNlLm1hcChcbiAgICAgIGlkcyxcbiAgICAgIGlkID0+IHRoaXMubGVhdmVDaGFubmVsTWVzc2FnZShpZCwgY2hhbm5lbCksXG4gICAgICB7IGNvbmN1cnJlbmN5OiBhc3luY0xpbWl0IH0pXG4gIH1cblxuICByb2xsYmFja1Jvb21Kb2luIChlcnJvciwgcm9vbU5hbWUsIGlkKSB7XG4gICAgcmV0dXJuIHRoaXMudXNlclN0YXRlLnJlbW92ZVNvY2tldEZyb21Sb29tKGlkLCByb29tTmFtZSkuY2F0Y2goZSA9PiB7XG4gICAgICB0aGlzLmNvbnNpc3RlbmN5RmFpbHVyZShlLCB7IHJvb21OYW1lLCBvcFR5cGU6ICd1c2VyUm9vbXMnIH0pXG4gICAgICByZXR1cm4gWzFdXG4gICAgfSkuc3ByZWFkKG5qb2luZWQgPT4ge1xuICAgICAgaWYgKCFuam9pbmVkKSB7XG4gICAgICAgIHJldHVybiB0aGlzLmxlYXZlUm9vbShyb29tTmFtZSlcbiAgICAgIH0gZWxzZSB7XG4gICAgICAgIHJldHVybiBQcm9taXNlLnJlc29sdmUoKVxuICAgICAgfVxuICAgIH0pLnRoZW5UaHJvdyhlcnJvcilcbiAgfVxuXG4gIGxlYXZlUm9vbSAocm9vbU5hbWUpIHtcbiAgICByZXR1cm4gUHJvbWlzZVxuICAgICAgLnRyeSgoKSA9PiB0aGlzLnN0YXRlLmdldFJvb20ocm9vbU5hbWUpKVxuICAgICAgLnRoZW4ocm9vbSA9PiByb29tLmxlYXZlKHRoaXMudXNlck5hbWUpXG4gICAgICAgICAgICAuY2F0Y2goZXJyb3IgPT4gdGhpcy5jb25zaXN0ZW5jeUZhaWx1cmUoXG4gICAgICAgICAgICAgIGVycm9yLCB7cm9vbU5hbWUsIG9wVHlwZTogJ3Jvb21Vc2VybGlzdCd9KSkpXG4gICAgICAuY2F0Y2hSZXR1cm4oKVxuICB9XG5cbiAgZ2V0Tm90aWZ5U2V0dGluZ3MgKHJvb21OYW1lKSB7XG4gICAgcmV0dXJuIFByb21pc2VcbiAgICAgIC50cnkoKCkgPT4gdGhpcy5zdGF0ZS5nZXRSb29tKHJvb21OYW1lKSlcbiAgICAgIC50aGVuKHJvb20gPT4gcm9vbS5nZXROb3RpZmljYXRpb25zSW5mbyhudWxsLCB0cnVlKSlcbiAgICAgIC5jYXRjaFJldHVybih7fSlcbiAgfVxuXG4gIGpvaW5Tb2NrZXRUb1Jvb20gKGlkLCByb29tTmFtZSwgaXNMb2NhbENhbGwpIHtcbiAgICBsZXQgbG9jayA9IHRoaXMudXNlclN0YXRlLmxvY2tUb1Jvb20ocm9vbU5hbWUsIHRoaXMubG9ja1RUTClcbiAgICByZXR1cm4gUHJvbWlzZS51c2luZyhsb2NrLCBjbyhmdW5jdGlvbiAqICgpIHtcbiAgICAgIGxldCByb29tID0geWllbGQgdGhpcy5zdGF0ZS5nZXRSb29tKHJvb21OYW1lKVxuICAgICAgeWllbGQgcm9vbS5qb2luKHRoaXMudXNlck5hbWUpXG4gICAgICBsZXQgZW5hYmxlVXNlcmxpc3RVcGRhdGVzID0geWllbGQgcm9vbS5yb29tU3RhdGUudXNlcmxpc3RVcGRhdGVzR2V0KClcbiAgICAgIHJldHVybiB0aGlzLnVzZXJTdGF0ZS5hZGRTb2NrZXRUb1Jvb20oaWQsIHJvb21OYW1lKS50aGVuKG5qb2luZWQgPT4ge1xuICAgICAgICByZXR1cm4gdGhpcy50cmFuc3BvcnQuam9pbkNoYW5uZWwoaWQsIHJvb21OYW1lKS50aGVuKCgpID0+IHtcbiAgICAgICAgICBpZiAobmpvaW5lZCA9PT0gMSAmJiBlbmFibGVVc2VybGlzdFVwZGF0ZXMpIHtcbiAgICAgICAgICAgIHRoaXMudXNlckpvaW5Sb29tUmVwb3J0KHRoaXMudXNlck5hbWUsIHJvb21OYW1lKVxuICAgICAgICAgIH1cbiAgICAgICAgICByZXR1cm4gdGhpcy5zb2NrZXRKb2luRWNobyhpZCwgcm9vbU5hbWUsIG5qb2luZWQsIGlzTG9jYWxDYWxsKVxuICAgICAgICB9KS5yZXR1cm4obmpvaW5lZClcbiAgICAgIH0pLmNhdGNoKGUgPT4gdGhpcy5yb2xsYmFja1Jvb21Kb2luKGUsIHJvb21OYW1lLCBpZCkpXG4gICAgfSkuYmluZCh0aGlzKSlcbiAgfVxuXG4gIGxlYXZlU29ja2V0RnJvbVJvb20gKGlkLCByb29tTmFtZSwgaXNMb2NhbENhbGwpIHtcbiAgICBsZXQgbG9jayA9IHRoaXMudXNlclN0YXRlLmxvY2tUb1Jvb20ocm9vbU5hbWUsIHRoaXMubG9ja1RUTClcbiAgICByZXR1cm4gUHJvbWlzZS51c2luZyhsb2NrLCBjbyhmdW5jdGlvbiAqICgpIHtcbiAgICAgIGxldCBbbmpvaW5lZCwgaGFzQ2hhbmdlZF0gPVxuICAgICAgICAgICAgeWllbGQgdGhpcy51c2VyU3RhdGUucmVtb3ZlU29ja2V0RnJvbVJvb20oaWQsIHJvb21OYW1lKVxuICAgICAgeWllbGQgdGhpcy5sZWF2ZUNoYW5uZWwoaWQsIHJvb21OYW1lKVxuICAgICAgaWYgKG5qb2luZWQgPT09IDApIHtcbiAgICAgICAgeWllbGQgdGhpcy5sZWF2ZVJvb20ocm9vbU5hbWUpXG4gICAgICB9XG4gICAgICBpZiAoaGFzQ2hhbmdlZCkge1xuICAgICAgICBsZXQgeyBlbmFibGVVc2VybGlzdFVwZGF0ZXMgfSA9IHlpZWxkIHRoaXMuZ2V0Tm90aWZ5U2V0dGluZ3Mocm9vbU5hbWUpXG4gICAgICAgIHRoaXMuc29ja2V0TGVmdEVjaG8oaWQsIHJvb21OYW1lLCBuam9pbmVkLCBpc0xvY2FsQ2FsbClcbiAgICAgICAgdGhpcy51c2VyTGVmdFJvb21SZXBvcnQodGhpcy51c2VyTmFtZSwgcm9vbU5hbWUsIGVuYWJsZVVzZXJsaXN0VXBkYXRlcylcbiAgICAgIH1cbiAgICAgIHJldHVybiBQcm9taXNlLnJlc29sdmUobmpvaW5lZClcbiAgICB9KS5iaW5kKHRoaXMpKVxuICB9XG5cbiAgcmVtb3ZlVXNlclNvY2tldCAoaWQpIHtcbiAgICByZXR1cm4gdGhpcy51c2VyU3RhdGUucmVtb3ZlU29ja2V0KGlkKVxuICAgICAgLnNwcmVhZCgocm9vbXNSZW1vdmVkLCBqb2luZWRTb2NrZXRzLCBuY29ubmVjdGVkKSA9PiB7XG4gICAgICAgIHJvb21zUmVtb3ZlZCA9IHJvb21zUmVtb3ZlZCB8fCBbXVxuICAgICAgICBqb2luZWRTb2NrZXRzID0gam9pbmVkU29ja2V0cyB8fCBbXVxuICAgICAgICBuY29ubmVjdGVkID0gbmNvbm5lY3RlZCB8fCAwXG4gICAgICAgIHJldHVybiB0aGlzLnNvY2tldExlYXZlQ2hhbm5lbHMoaWQsIHJvb21zUmVtb3ZlZCkudGhlbigoKSA9PiB7XG4gICAgICAgICAgcmV0dXJuIFByb21pc2UubWFwKFxuICAgICAgICAgICAgcm9vbXNSZW1vdmVkLFxuICAgICAgICAgICAgKHJvb21OYW1lLCBpZHgpID0+IHtcbiAgICAgICAgICAgICAgbGV0IG5qb2luZWQgPSBqb2luZWRTb2NrZXRzW2lkeF1cbiAgICAgICAgICAgICAgdGhpcy5zb2NrZXRMZWZ0RWNobyhpZCwgcm9vbU5hbWUsIG5qb2luZWQpXG4gICAgICAgICAgICAgIGlmIChuam9pbmVkKSB7IHJldHVybiBQcm9taXNlLnJlc29sdmUoKSB9XG4gICAgICAgICAgICAgIHJldHVybiB0aGlzLmxlYXZlUm9vbShyb29tTmFtZSlcbiAgICAgICAgICAgICAgICAudGhlbigoKSA9PiB0aGlzLmdldE5vdGlmeVNldHRpbmdzKHJvb21OYW1lKSlcbiAgICAgICAgICAgICAgICAudGhlbigoe2VuYWJsZVVzZXJsaXN0VXBkYXRlc30pID0+IHRoaXMudXNlckxlZnRSb29tUmVwb3J0KFxuICAgICAgICAgICAgICAgICAgdGhpcy51c2VyTmFtZSwgcm9vbU5hbWUsIGVuYWJsZVVzZXJsaXN0VXBkYXRlcykpXG4gICAgICAgICAgICB9LFxuICAgICAgICAgICAgeyBjb25jdXJyZW5jeTogYXN5bmNMaW1pdCB9KVxuICAgICAgICAgICAgLnRoZW4oKCkgPT4gdGhpcy5zb2NrZXREaXNjb25uZWN0RWNobyhpZCwgbmNvbm5lY3RlZCkpXG4gICAgICAgIH0pXG4gICAgICB9KS50aGVuKCgpID0+IHRoaXMuc3RhdGUucmVtb3ZlU29ja2V0KGlkKSlcbiAgfVxuXG4gIHJlbW92ZVNvY2tldEZyb21TZXJ2ZXIgKGlkKSB7XG4gICAgcmV0dXJuIHRoaXMucmVtb3ZlVXNlclNvY2tldChpZCkuY2F0Y2goZSA9PiB7XG4gICAgICBsZXQgaW5mbyA9IHsgaWQsIG9wVHlwZTogJ3VzZXJTb2NrZXRzJyB9XG4gICAgICByZXR1cm4gdGhpcy5jb25zaXN0ZW5jeUZhaWx1cmUoZSwgaW5mbylcbiAgICB9KVxuICB9XG5cbiAgcmVtb3ZlVXNlclNvY2tldHNGcm9tUm9vbSAocm9vbU5hbWUpIHtcbiAgICByZXR1cm4gdGhpcy51c2VyU3RhdGUucmVtb3ZlQWxsU29ja2V0c0Zyb21Sb29tKHJvb21OYW1lKS5jYXRjaChlID0+IHtcbiAgICAgIGxldCBpbmZvID0geyByb29tTmFtZSwgb3BUeXBlOiAncm9vbVVzZXJsaXN0JyB9XG4gICAgICByZXR1cm4gdGhpcy5jb25zaXN0ZW5jeUZhaWx1cmUoZSwgaW5mbylcbiAgICB9KVxuICB9XG5cbiAgcmVtb3ZlRnJvbVJvb20gKHJvb21OYW1lKSB7XG4gICAgbGV0IGxvY2sgPSB0aGlzLnVzZXJTdGF0ZS5sb2NrVG9Sb29tKHJvb21OYW1lLCB0aGlzLmxvY2tUVEwpXG4gICAgcmV0dXJuIFByb21pc2UudXNpbmcobG9jaywgY28oZnVuY3Rpb24gKiAoKSB7XG4gICAgICBsZXQgcmVtb3ZlZFNvY2tldHMgPSB5aWVsZCB0aGlzLnJlbW92ZVVzZXJTb2NrZXRzRnJvbVJvb20ocm9vbU5hbWUpXG4gICAgICByZW1vdmVkU29ja2V0cyA9IHJlbW92ZWRTb2NrZXRzIHx8IFtdXG4gICAgICB5aWVsZCB0aGlzLmNoYW5uZWxMZWF2ZVNvY2tldHMocm9vbU5hbWUsIHJlbW92ZWRTb2NrZXRzKVxuICAgICAgaWYgKHJlbW92ZWRTb2NrZXRzLmxlbmd0aCkge1xuICAgICAgICBsZXQgeyBlbmFibGVVc2VybGlzdFVwZGF0ZXMgfSA9IHlpZWxkIHRoaXMuZ2V0Tm90aWZ5U2V0dGluZ3Mocm9vbU5hbWUpXG4gICAgICAgIHRoaXMudXNlclJlbW92ZWRSZXBvcnQodGhpcy51c2VyTmFtZSwgcm9vbU5hbWUsIGVuYWJsZVVzZXJsaXN0VXBkYXRlcylcbiAgICAgIH1cbiAgICAgIHJldHVybiB0aGlzLmxlYXZlUm9vbShyb29tTmFtZSlcbiAgICB9KS5iaW5kKHRoaXMpKVxuICB9XG5cbiAgcmVtb3ZlUm9vbVVzZXJzIChyb29tTmFtZSwgdXNlck5hbWVzKSB7XG4gICAgdXNlck5hbWVzID0gdXNlck5hbWVzIHx8IFtdXG4gICAgcmV0dXJuIFByb21pc2UubWFwKFxuICAgICAgdXNlck5hbWVzLFxuICAgICAgdXNlck5hbWUgPT4ge1xuICAgICAgICByZXR1cm4gdGhpcy5zdGF0ZS5nZXRVc2VyKHVzZXJOYW1lKVxuICAgICAgICAgIC50aGVuKHVzZXIgPT4gdXNlci5yZW1vdmVGcm9tUm9vbShyb29tTmFtZSkpXG4gICAgICAgICAgLmNhdGNoUmV0dXJuKClcbiAgICAgIH0sXG4gICAgICB7IGNvbmN1cnJlbmN5OiBhc3luY0xpbWl0IH0pXG4gIH1cblxufVxuXG5tb2R1bGUuZXhwb3J0cyA9IFVzZXJBc3NvY2lhdGlvbnNcbiJdfQ==