eventEngine

.eslintrc.js

@@ -17,6 +17,8 @@ module.exports = {
     'class-methods-use-this': 0,
     'no-prototype-builtins': 1,
     'prefer-destructuring': 0,
+    'no-unused-vars': 0,
+    '@typescript-eslint/no-unused-vars': 0,
     '@typescript-eslint/explicit-module-boundary-types': 'off',
   },
 };

.gitignore

@@ -15,6 +15,7 @@ dist/titanium/stats.json
 dist/contract
 dist/cucumber
 upload
+test/specs
 
 # GitHub Actions #
 ##################

cucumber.js

@@ -0,0 +1,12 @@
+module.exports = {
+  default: [
+    'test/specs/features/**/*.feature',
+    '--require test/contract/setup.js',
+    '--require test/contract/definitions/**/*.ts',
+    '--require test/contract/shared/**/*.ts',
+    '--format summary',
+    '--format progress-bar',
+    // '--format @cucumber/pretty-formatter',
+    '--publish-quiet',
+  ].join(' '),
+};

lib/core/components/_endpoint.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

lib/core/components/config.js

@@ -12,7 +12,7 @@ var makeDefaultOrigins = function () { return Array.from({ length: 20 }, functio
 var default_1 = /** @class */ (function () {
     function default_1(_a) {
         var setup = _a.setup;
-        var _b, _c, _d;
+        var _b, _c, _d, _e;
         this._PNSDKSuffix = {};
         this.instanceId = "pn-".concat(uuid_1.default.createUUID());
         this.secretKey = setup.secretKey || setup.secret_key;
@@ -40,8 +40,8 @@ var default_1 = /** @class */ (function () {
         this.customDecrypt = setup.customDecrypt;
         this.fileUploadPublishRetryLimit = (_b = setup.fileUploadPublishRetryLimit) !== null && _b !== void 0 ? _b : 5;
         this.useRandomIVs = (_c = setup.useRandomIVs) !== null && _c !== void 0 ? _c : true;
-        // flag for beta subscribe feature enablement
-        this.enableSubscribeBeta = (_d = setup.enableSubscribeBeta) !== null && _d !== void 0 ? _d : false;
+        this.enableEventEngine = (_d = setup.enableEventEngine) !== null && _d !== void 0 ? _d : false;
+        this.maintainPresenceState = (_e = setup.maintainPresenceState) !== null && _e !== void 0 ? _e : true;
         // if location config exist and we are in https, force secure to true.
         if (typeof location !== 'undefined' && location.protocol === 'https:') {
             this.secure = true;
@@ -53,6 +53,9 @@ var default_1 = /** @class */ (function () {
         this.useInstanceId = setup.useInstanceId || false;
         this.useRequestId = setup.useRequestId || false;
         this.requestMessageCountThreshold = setup.requestMessageCountThreshold;
+        if (setup.retryConfiguration) {
+            this._setRetryConfiguration(setup.retryConfiguration);
+        }
         // set timeout to how long a transaction request will wait for the server (default 15 seconds)
         this.setTransactionTimeout(setup.transactionalRequestTimeout || 15 * 1000);
         // set timeout to how long a subscribe event loop will run (default 310 seconds)
@@ -179,6 +182,21 @@ var default_1 = /** @class */ (function () {
     default_1.prototype.getVersion = function () {
         return '7.4.5';
     };
+    default_1.prototype._setRetryConfiguration = function (configuration) {
+        if (configuration.minimumdelay < 2) {
+            throw new Error('Minimum delay can not be set less than 2 seconds for retry');
+        }
+        if (configuration.maximumDelay > 150) {
+            throw new Error('Maximum delay can not be set more than 150 seconds for retry');
+        }
+        if (configuration.maximumDelay && maximumRetry > 6) {
+            throw new Error('Maximum retry for exponential retry policy can not be more than 6');
+        }
+        else if (configuration.maximumRetry > 10) {
+            throw new Error('Maximum retry for linear retry policy can not be more than 10');
+        }
+        this.retryConfiguration = configuration;
+    };
     default_1.prototype._addPnsdkSuffix = function (name, suffix) {
         this._PNSDKSuffix[name] = suffix;
     };

lib/core/components/eventEmitter.js

@@ -0,0 +1,212 @@
+"use strict";
+var __assign = (this && this.__assign) || function () {
+    __assign = Object.assign || function(t) {
+        for (var s, i = 1, n = arguments.length; i < n; i++) {
+            s = arguments[i];
+            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+                t[p] = s[p];
+        }
+        return t;
+    };
+    return __assign.apply(this, arguments);
+};
+var __rest = (this && this.__rest) || function (s, e) {
+    var t = {};
+    for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p) && e.indexOf(p) < 0)
+        t[p] = s[p];
+    if (s != null && typeof Object.getOwnPropertySymbols === "function")
+        for (var i = 0, p = Object.getOwnPropertySymbols(s); i < p.length; i++) {
+            if (e.indexOf(p[i]) < 0 && Object.prototype.propertyIsEnumerable.call(s, p[i]))
+                t[p[i]] = s[p[i]];
+        }
+    return t;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+var EventEmitter = /** @class */ (function () {
+    function EventEmitter(_a) {
+        var modules = _a.modules, listenerManager = _a.listenerManager, getFileUrl = _a.getFileUrl;
+        this.modules = modules;
+        this.listenerManager = listenerManager;
+        this.getFileUrl = getFileUrl;
+        if (modules.cryptoModule)
+            this._decoder = new TextDecoder();
+    }
+    EventEmitter.prototype.emitEvent = function (e) {
+        var channel = e.channel, publishMetaData = e.publishMetaData;
+        var subscriptionMatch = e.subscriptionMatch;
+        if (channel === subscriptionMatch) {
+            subscriptionMatch = null;
+        }
+        if (e.channel.endsWith('-pnpres')) {
+            var announce = {};
+            announce.channel = null;
+            announce.subscription = null;
+            if (channel) {
+                announce.channel = channel.substring(0, channel.lastIndexOf('-pnpres'));
+            }
+            if (subscriptionMatch) {
+                announce.subscription = subscriptionMatch.substring(0, subscriptionMatch.lastIndexOf('-pnpres'));
+            }
+            announce.action = e.payload.action;
+            announce.state = e.payload.data;
+            announce.timetoken = publishMetaData.publishTimetoken;
+            announce.occupancy = e.payload.occupancy;
+            announce.uuid = e.payload.uuid;
+            announce.timestamp = e.payload.timestamp;
+            if (e.payload.join) {
+                announce.join = e.payload.join;
+            }
+            if (e.payload.leave) {
+                announce.leave = e.payload.leave;
+            }
+            if (e.payload.timeout) {
+                announce.timeout = e.payload.timeout;
+            }
+            this.listenerManager.announcePresence(announce);
+        }
+        else if (e.messageType === 1) {
+            var announce = {};
+            announce.channel = null;
+            announce.subscription = null;
+            announce.channel = channel;
+            announce.subscription = subscriptionMatch;
+            announce.timetoken = publishMetaData.publishTimetoken;
+            announce.publisher = e.issuingClientId;
+            if (e.userMetadata) {
+                announce.userMetadata = e.userMetadata;
+            }
+            announce.message = e.payload;
+            this.listenerManager.announceSignal(announce);
+        }
+        else if (e.messageType === 2) {
+            var announce = {};
+            announce.channel = null;
+            announce.subscription = null;
+            announce.channel = channel;
+            announce.subscription = subscriptionMatch;
+            announce.timetoken = publishMetaData.publishTimetoken;
+            announce.publisher = e.issuingClientId;
+            if (e.userMetadata) {
+                announce.userMetadata = e.userMetadata;
+            }
+            announce.message = {
+                event: e.payload.event,
+                type: e.payload.type,
+                data: e.payload.data,
+            };
+            this.listenerManager.announceObjects(announce);
+            if (e.payload.type === 'uuid') {
+                var eventData = this._renameChannelField(announce);
+                this.listenerManager.announceUser(__assign(__assign({}, eventData), { message: __assign(__assign({}, eventData.message), { event: this._renameEvent(eventData.message.event), type: 'user' }) }));
+            }
+            else if (message.payload.type === 'channel') {
+                var eventData = this._renameChannelField(announce);
+                this.listenerManager.announceSpace(__assign(__assign({}, eventData), { message: __assign(__assign({}, eventData.message), { event: this._renameEvent(eventData.message.event), type: 'space' }) }));
+            }
+            else if (message.payload.type === 'membership') {
+                var eventData = this._renameChannelField(announce);
+                var _a = eventData.message.data, user = _a.uuid, space = _a.channel, membershipData = __rest(_a, ["uuid", "channel"]);
+                membershipData.user = user;
+                membershipData.space = space;
+                this.listenerManager.announceMembership(__assign(__assign({}, eventData), { message: __assign(__assign({}, eventData.message), { event: this._renameEvent(eventData.message.event), data: membershipData }) }));
+            }
+        }
+        else if (e.messageType === 3) {
+            var announce = {};
+            announce.channel = channel;
+            announce.subscription = subscriptionMatch;
+            announce.timetoken = publishMetaData.publishTimetoken;
+            announce.publisher = e.issuingClientId;
+            announce.data = {
+                messageTimetoken: e.payload.data.messageTimetoken,
+                actionTimetoken: e.payload.data.actionTimetoken,
+                type: e.payload.data.type,
+                uuid: e.issuingClientId,
+                value: e.payload.data.value,
+            };
+            announce.event = e.payload.event;
+            this.listenerManager.announceMessageAction(announce);
+        }
+        else if (e.messageType === 4) {
+            var announce = {};
+            announce.channel = channel;
+            announce.subscription = subscriptionMatch;
+            announce.timetoken = publishMetaData.publishTimetoken;
+            announce.publisher = e.issuingClientId;
+            var msgPayload = e.payload;
+            if (this.modules.cryptoModule) {
+                var decryptedPayload = void 0;
+                try {
+                    var decryptedData = this.modules.cryptoModule.decrypt(e.payload);
+                    decryptedPayload =
+                        decryptedData instanceof ArrayBuffer ? JSON.parse(this._decoder.decode(decryptedData)) : decryptedData;
+                }
+                catch (e) {
+                    decryptedPayload = null;
+                    announce.error = "Error while decrypting message content: ".concat(e.message);
+                }
+                if (decryptedPayload !== null) {
+                    msgPayload = decryptedPayload;
+                }
+            }
+            if (e.userMetadata) {
+                announce.userMetadata = e.userMetadata;
+            }
+            announce.message = msgPayload.message;
+            announce.file = {
+                id: msgPayload.file.id,
+                name: msgPayload.file.name,
+                url: this.getFileUrl({
+                    id: msgPayload.file.id,
+                    name: msgPayload.file.name,
+                    channel: channel,
+                }),
+            };
+            this.listenerManager.announceFile(announce);
+        }
+        else {
+            var announce = {};
+            announce.channel = null;
+            announce.subscription = null;
+            announce.channel = channel;
+            announce.subscription = subscriptionMatch;
+            announce.timetoken = publishMetaData.publishTimetoken;
+            announce.publisher = e.issuingClientId;
+            if (e.userMetadata) {
+                announce.userMetadata = e.userMetadata;
+            }
+            if (this.modules.cryptoModule) {
+                var decryptedPayload = void 0;
+                try {
+                    var decryptedData = this.modules.cryptoModule.decrypt(e.payload);
+                    decryptedPayload =
+                        decryptedData instanceof ArrayBuffer ? JSON.parse(this._decoder.decode(decryptedData)) : decryptedData;
+                }
+                catch (e) {
+                    decryptedPayload = null;
+                    announce.error = "Error while decrypting message content: ".concat(e.message);
+                }
+                if (decryptedPayload != null) {
+                    announce.message = decryptedPayload;
+                }
+                else {
+                    announce.message = e.payload;
+                }
+            }
+            else {
+                announce.message = e.payload;
+            }
+            this.listenerManager.announceMessage(announce);
+        }
+    };
+    EventEmitter.prototype._renameEvent = function (e) {
+        return e === 'set' ? 'updated' : 'removed';
+    };
+    EventEmitter.prototype._renameChannelField = function (announce) {
+        var channel = announce.channel, eventData = __rest(announce, ["channel"]);
+        eventData.spaceId = channel;
+        return eventData;
+    };
+    return EventEmitter;
+}());
+exports.default = EventEmitter;

lib/core/components/listener_manager.js

@@ -8,8 +8,11 @@ var default_1 = /** @class */ (function () {
     function default_1() {
         this._listeners = [];
     }
-    default_1.prototype.addListener = function (newListeners) {
-        this._listeners.push(newListeners);
+    default_1.prototype.addListener = function (newListener) {
+        if (this._listeners.includes(newListener)) {
+            return;
+        }
+        this._listeners.push(newListener);
     };
     default_1.prototype.removeListener = function (deprecatedListener) {
         var newListeners = [];

lib/core/constants/categories.js

@@ -20,4 +20,7 @@ exports.default = {
     PNReconnectedCategory: 'PNReconnectedCategory',
     PNConnectedCategory: 'PNConnectedCategory',
     PNRequestMessageCountExceededCategory: 'PNRequestMessageCountExceededCategory',
+    PNDisconnectedCategory: 'PNDisconnectedCategory',
+    PNConnectionErrorCategory: 'PNConnectionErrorCategory',
+    PNDisconnectedUnexpectedlyCategory: 'PNDisconnectedUnexpectedlyCategory',
 };