"use strict";
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
function _defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } }
function _createClass(Constructor, protoProps, staticProps) { if (protoProps) _defineProperties(Constructor.prototype, protoProps); if (staticProps) _defineProperties(Constructor, staticProps); return Constructor; }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function"); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, writable: true, configurable: true } }); if (superClass) _setPrototypeOf(subClass, superClass); }
function _setPrototypeOf(o, p) { _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { o.__proto__ = p; return o; }; return _setPrototypeOf(o, p); }
function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = _getPrototypeOf(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = _getPrototypeOf(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return _possibleConstructorReturn(this, result); }; }
function _possibleConstructorReturn(self, call) { if (call && (_typeof(call) === "object" || typeof call === "function")) { return call; } return _assertThisInitialized(self); }
function _assertThisInitialized(self) { if (self === void 0) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return self; }
function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Date.prototype.toString.call(Reflect.construct(Date, [], function () {})); return true; } catch (e) { return false; } }
function _getPrototypeOf(o) { _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { return o.__proto__ || Object.getPrototypeOf(o); }; return _getPrototypeOf(o); }
(function () {
var root = typeof window !== "undefined" ? window : typeof global !== "undefined" ? global : typeof self !== "undefined" ? self : {};
var ice = root.ice || {};
root.IceStorm = root.IceStorm || {};
ice.IceStorm = root.IceStorm;
var Slice = Ice.Slice;
(function () {
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
//
// Ice version 3.7.5
//
//
//
// Generated from file `Metrics.ice'
//
// Warning: do not edit this file.
//
//
//
/* eslint-disable */
/* jshint ignore: start */
(function (module, require, exports) {
var _ModuleRegistry = Ice._ModuleRegistry;
var Slice = Ice.Slice;
var iceC_IceMX_TopicMetrics_ids = ["::Ice::Object", "::IceMX::Metrics", "::IceMX::TopicMetrics"];
/**
* Provides information on IceStorm topics.
*
**/
IceMX.TopicMetrics = /*#__PURE__*/function (_IceMX$Metrics) {
_inherits(_class, _IceMX$Metrics);
var _super = _createSuper(_class);
function _class(id, total, current, totalLifetime, failures) {
var _this;
var published = arguments.length > 5 && arguments[5] !== undefined ? arguments[5] : new Ice.Long(0, 0);
var forwarded = arguments.length > 6 && arguments[6] !== undefined ? arguments[6] : new Ice.Long(0, 0);
_classCallCheck(this, _class);
_this = _super.call(this, id, total, current, totalLifetime, failures);
_this.published = published;
_this.forwarded = forwarded;
return _this;
}
_createClass(_class, [{
key: "_iceWriteMemberImpl",
value: function _iceWriteMemberImpl(ostr) {
ostr.writeLong(this.published);
ostr.writeLong(this.forwarded);
}
}, {
key: "_iceReadMemberImpl",
value: function _iceReadMemberImpl(istr) {
this.published = istr.readLong();
this.forwarded = istr.readLong();
}
}]);
return _class;
}(IceMX.Metrics);
Slice.defineValue(IceMX.TopicMetrics, iceC_IceMX_TopicMetrics_ids[2], false);
var iceC_IceMX_SubscriberMetrics_ids = ["::Ice::Object", "::IceMX::Metrics", "::IceMX::SubscriberMetrics"];
/**
* Provides information on IceStorm subscribers.
*
**/
IceMX.SubscriberMetrics = /*#__PURE__*/function (_IceMX$Metrics2) {
_inherits(_class2, _IceMX$Metrics2);
var _super2 = _createSuper(_class2);
function _class2(id, total, current, totalLifetime, failures) {
var _this2;
var queued = arguments.length > 5 && arguments[5] !== undefined ? arguments[5] : 0;
var outstanding = arguments.length > 6 && arguments[6] !== undefined ? arguments[6] : 0;
var delivered = arguments.length > 7 && arguments[7] !== undefined ? arguments[7] : new Ice.Long(0, 0);
_classCallCheck(this, _class2);
_this2 = _super2.call(this, id, total, current, totalLifetime, failures);
_this2.queued = queued;
_this2.outstanding = outstanding;
_this2.delivered = delivered;
return _this2;
}
_createClass(_class2, [{
key: "_iceWriteMemberImpl",
value: function _iceWriteMemberImpl(ostr) {
ostr.writeInt(this.queued);
ostr.writeInt(this.outstanding);
ostr.writeLong(this.delivered);
}
}, {
key: "_iceReadMemberImpl",
value: function _iceReadMemberImpl(istr) {
this.queued = istr.readInt();
this.outstanding = istr.readInt();
this.delivered = istr.readLong();
}
}]);
return _class2;
}(IceMX.Metrics);
Slice.defineValue(IceMX.SubscriberMetrics, iceC_IceMX_SubscriberMetrics_ids[2], false);
})(typeof global !== "undefined" && typeof global.process !== "undefined" ? module : undefined, typeof global !== "undefined" && typeof global.process !== "undefined" ? require : typeof WorkerGlobalScope !== "undefined" && self instanceof WorkerGlobalScope ? self.Ice._require : window.Ice._require, typeof global !== "undefined" && typeof global.process !== "undefined" ? exports : typeof WorkerGlobalScope !== "undefined" && self instanceof WorkerGlobalScope ? self : window);
})();
(function () {
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
//
// Ice version 3.7.5
//
//
//
// Generated from file `IceStorm.ice'
//
// Warning: do not edit this file.
//
//
//
/* eslint-disable */
/* jshint ignore: start */
/**
* Information on the topic links.
*
**/
IceStorm.LinkInfo = /*#__PURE__*/function () {
function _class3() {
var theTopic = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : null;
var name = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
var cost = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : 0;
_classCallCheck(this, _class3);
this.theTopic = theTopic;
this.name = name;
this.cost = cost;
}
_createClass(_class3, [{
key: "_write",
value: function _write(ostr) {
IceStorm.TopicPrx.write(ostr, this.theTopic);
ostr.writeString(this.name);
ostr.writeInt(this.cost);
}
}, {
key: "_read",
value: function _read(istr) {
this.theTopic = IceStorm.TopicPrx.read(istr, this.theTopic);
this.name = istr.readString();
this.cost = istr.readInt();
}
}], [{
key: "minWireSize",
get: function get() {
return 7;
}
}]);
return _class3;
}();
Slice.defineStruct(IceStorm.LinkInfo, false, true);
Slice.defineSequence(IceStorm, "LinkInfoSeqHelper", "IceStorm.LinkInfo", false);
Slice.defineDictionary(IceStorm, "QoS", "QoSHelper", "Ice.StringHelper", "Ice.StringHelper", false, undefined, undefined);
/**
* This exception indicates that an attempt was made to create a link
* that already exists.
*
**/
IceStorm.LinkExists = /*#__PURE__*/function (_Ice$UserException) {
_inherits(_class4, _Ice$UserException);
var _super3 = _createSuper(_class4);
function _class4() {
var _this3;
var name = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
var _cause = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
_classCallCheck(this, _class4);
_this3 = _super3.call(this, _cause);
_this3.name = name;
return _this3;
}
_createClass(_class4, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.LinkExists;
}
}, {
key: "_writeMemberImpl",
value: function _writeMemberImpl(ostr) {
ostr.writeString(this.name);
}
}, {
key: "_readMemberImpl",
value: function _readMemberImpl(istr) {
this.name = istr.readString();
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::LinkExists";
}
}]);
return _class4;
}(Ice.UserException);
/**
* This exception indicates that an attempt was made to remove a
* link that does not exist.
*
**/
IceStorm.NoSuchLink = /*#__PURE__*/function (_Ice$UserException2) {
_inherits(_class5, _Ice$UserException2);
var _super4 = _createSuper(_class5);
function _class5() {
var _this4;
var name = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
var _cause = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
_classCallCheck(this, _class5);
_this4 = _super4.call(this, _cause);
_this4.name = name;
return _this4;
}
_createClass(_class5, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.NoSuchLink;
}
}, {
key: "_writeMemberImpl",
value: function _writeMemberImpl(ostr) {
ostr.writeString(this.name);
}
}, {
key: "_readMemberImpl",
value: function _readMemberImpl(istr) {
this.name = istr.readString();
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::NoSuchLink";
}
}]);
return _class5;
}(Ice.UserException);
/**
* This exception indicates that an attempt was made to subscribe
* a proxy for which a subscription already exists.
*
**/
IceStorm.AlreadySubscribed = /*#__PURE__*/function (_Ice$UserException3) {
_inherits(_class6, _Ice$UserException3);
var _super5 = _createSuper(_class6);
function _class6() {
var _cause = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
_classCallCheck(this, _class6);
return _super5.call(this, _cause);
}
_createClass(_class6, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.AlreadySubscribed;
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::AlreadySubscribed";
}
}]);
return _class6;
}(Ice.UserException);
/**
* This exception indicates that an attempt was made to subscribe
* a proxy that is null.
*
**/
IceStorm.InvalidSubscriber = /*#__PURE__*/function (_Ice$UserException4) {
_inherits(_class7, _Ice$UserException4);
var _super6 = _createSuper(_class7);
function _class7() {
var _this5;
var reason = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
var _cause = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
_classCallCheck(this, _class7);
_this5 = _super6.call(this, _cause);
_this5.reason = reason;
return _this5;
}
_createClass(_class7, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.InvalidSubscriber;
}
}, {
key: "_writeMemberImpl",
value: function _writeMemberImpl(ostr) {
ostr.writeString(this.reason);
}
}, {
key: "_readMemberImpl",
value: function _readMemberImpl(istr) {
this.reason = istr.readString();
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::InvalidSubscriber";
}
}]);
return _class7;
}(Ice.UserException);
/**
* This exception indicates that a subscription failed due to an
* invalid QoS.
*
**/
IceStorm.BadQoS = /*#__PURE__*/function (_Ice$UserException5) {
_inherits(_class8, _Ice$UserException5);
var _super7 = _createSuper(_class8);
function _class8() {
var _this6;
var reason = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
var _cause = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
_classCallCheck(this, _class8);
_this6 = _super7.call(this, _cause);
_this6.reason = reason;
return _this6;
}
_createClass(_class8, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.BadQoS;
}
}, {
key: "_writeMemberImpl",
value: function _writeMemberImpl(ostr) {
ostr.writeString(this.reason);
}
}, {
key: "_readMemberImpl",
value: function _readMemberImpl(istr) {
this.reason = istr.readString();
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::BadQoS";
}
}]);
return _class8;
}(Ice.UserException);
var iceC_IceStorm_Topic_ids = ["::Ice::Object", "::IceStorm::Topic"];
/**
* Publishers publish information on a particular topic. A topic
* logically represents a type.
*
* @see TopicManager
*
**/
IceStorm.Topic = /*#__PURE__*/function (_Ice$Object) {
_inherits(_class9, _Ice$Object);
var _super8 = _createSuper(_class9);
function _class9() {
_classCallCheck(this, _class9);
return _super8.apply(this, arguments);
}
return _class9;
}(Ice.Object);
IceStorm.TopicPrx = /*#__PURE__*/function (_Ice$ObjectPrx) {
_inherits(_class10, _Ice$ObjectPrx);
var _super9 = _createSuper(_class10);
function _class10() {
_classCallCheck(this, _class10);
return _super9.apply(this, arguments);
}
return _class10;
}(Ice.ObjectPrx);
Slice.defineOperations(IceStorm.Topic, IceStorm.TopicPrx, iceC_IceStorm_Topic_ids, 1, {
"getName": [, 2, 1,, [7],,,,,],
"getPublisher": [, 2, 1,, [9],,,,,],
"getNonReplicatedPublisher": [, 2, 1,, [9],,,,,],
"subscribeAndGetPublisher": [,,,, [9], [["IceStorm.QoSHelper"], [9]],, [IceStorm.AlreadySubscribed, IceStorm.BadQoS, IceStorm.InvalidSubscriber],,],
"unsubscribe": [, 2, 2,,, [[9]],,,,],
"link": [,,,,, [["IceStorm.TopicPrx"], [3]],, [IceStorm.LinkExists],,],
"unlink": [,,,,, [["IceStorm.TopicPrx"]],, [IceStorm.NoSuchLink],,],
"getLinkInfoSeq": [, 2, 1,, ["IceStorm.LinkInfoSeqHelper"],,,,,],
"getSubscribers": [,,,, ["Ice.IdentitySeqHelper"],,,,,],
"destroy": [,,,,,,,,,]
});
Slice.defineDictionary(IceStorm, "TopicDict", "TopicDictHelper", "Ice.StringHelper", "IceStorm.TopicPrx", false, undefined, undefined);
/**
* This exception indicates that an attempt was made to create a topic
* that already exists.
*
**/
IceStorm.TopicExists = /*#__PURE__*/function (_Ice$UserException6) {
_inherits(_class11, _Ice$UserException6);
var _super10 = _createSuper(_class11);
function _class11() {
var _this7;
var name = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
var _cause = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
_classCallCheck(this, _class11);
_this7 = _super10.call(this, _cause);
_this7.name = name;
return _this7;
}
_createClass(_class11, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.TopicExists;
}
}, {
key: "_writeMemberImpl",
value: function _writeMemberImpl(ostr) {
ostr.writeString(this.name);
}
}, {
key: "_readMemberImpl",
value: function _readMemberImpl(istr) {
this.name = istr.readString();
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::TopicExists";
}
}]);
return _class11;
}(Ice.UserException);
/**
* This exception indicates that an attempt was made to retrieve a
* topic that does not exist.
*
**/
IceStorm.NoSuchTopic = /*#__PURE__*/function (_Ice$UserException7) {
_inherits(_class12, _Ice$UserException7);
var _super11 = _createSuper(_class12);
function _class12() {
var _this8;
var name = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : "";
var _cause = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : "";
_classCallCheck(this, _class12);
_this8 = _super11.call(this, _cause);
_this8.name = name;
return _this8;
}
_createClass(_class12, [{
key: "_mostDerivedType",
value: function _mostDerivedType() {
return IceStorm.NoSuchTopic;
}
}, {
key: "_writeMemberImpl",
value: function _writeMemberImpl(ostr) {
ostr.writeString(this.name);
}
}, {
key: "_readMemberImpl",
value: function _readMemberImpl(istr) {
this.name = istr.readString();
}
}], [{
key: "_parent",
get: function get() {
return Ice.UserException;
}
}, {
key: "_id",
get: function get() {
return "::IceStorm::NoSuchTopic";
}
}]);
return _class12;
}(Ice.UserException);
var iceC_IceStorm_TopicManager_ids = ["::Ice::Object", "::IceStorm::TopicManager"];
/**
* A topic manager manages topics, and subscribers to topics.
*
* @see Topic
*
**/
IceStorm.TopicManager = /*#__PURE__*/function (_Ice$Object2) {
_inherits(_class13, _Ice$Object2);
var _super12 = _createSuper(_class13);
function _class13() {
_classCallCheck(this, _class13);
return _super12.apply(this, arguments);
}
return _class13;
}(Ice.Object);
IceStorm.TopicManagerPrx = /*#__PURE__*/function (_Ice$ObjectPrx2) {
_inherits(_class14, _Ice$ObjectPrx2);
var _super13 = _createSuper(_class14);
function _class14() {
_classCallCheck(this, _class14);
return _super13.apply(this, arguments);
}
return _class14;
}(Ice.ObjectPrx);
Slice.defineOperations(IceStorm.TopicManager, IceStorm.TopicManagerPrx, iceC_IceStorm_TopicManager_ids, 1, {
"create": [,,,, ["IceStorm.TopicPrx"], [[7]],, [IceStorm.TopicExists],,],
"retrieve": [, 2, 1,, ["IceStorm.TopicPrx"], [[7]],, [IceStorm.NoSuchTopic],,],
"retrieveAll": [, 2, 1,, ["IceStorm.TopicDictHelper"],,,,,],
"getSliceChecksums": [, 2, 1,, ["Ice.SliceChecksumDictHelper"],,,,,]
});
var iceC_IceStorm_Finder_ids = ["::Ice::Object", "::IceStorm::Finder"];
/**
* This inferface is advertised by the IceStorm service through the
* Ice object with the identity `IceStorm/Finder'. This allows clients
* to retrieve the topic manager with just the endpoint information of
* the IceStorm service.
*
**/
IceStorm.Finder = /*#__PURE__*/function (_Ice$Object3) {
_inherits(_class15, _Ice$Object3);
var _super14 = _createSuper(_class15);
function _class15() {
_classCallCheck(this, _class15);
return _super14.apply(this, arguments);
}
return _class15;
}(Ice.Object);
IceStorm.FinderPrx = /*#__PURE__*/function (_Ice$ObjectPrx3) {
_inherits(_class16, _Ice$ObjectPrx3);
var _super15 = _createSuper(_class16);
function _class16() {
_classCallCheck(this, _class16);
return _super15.apply(this, arguments);
}
return _class16;
}(Ice.ObjectPrx);
Slice.defineOperations(IceStorm.Finder, IceStorm.FinderPrx, iceC_IceStorm_Finder_ids, 1, {
"getTopicManager": [,,,, ["IceStorm.TopicManagerPrx"],,,,,]
});
})();
root.IceStorm = IceStorm;
root.ice = ice;
})();
//# sourceMappingURL=IceStorm.js.map