dist/lib

pubnub · Feb 5, 2024 · f3cab86 · f3cab86
1 parent 528fab0
commit f3cab86
Show file tree

Hide file tree

Showing 6 changed files with 25 additions and 9 deletions.
diff --git a/dist/web/pubnub.js b/dist/web/pubnub.js
@@ -2534,6 +2534,9 @@
         PNAccessManagerAudit: 'PNAccessManagerAudit',
         PNAccessManagerRevokeToken: 'PNAccessManagerRevokeToken',
         //
+        // subscription utilities
+        PNHandshakeOperation: 'PNHandshakeOperation',
+        PNReceiveMessagesOperation: 'PNReceiveMessagesOperation',
     };
 
     /*       */
@@ -2542,6 +2545,11 @@
             this._maximumSamplesCount = 100;
             this._trackedLatencies = {};
             this._latencies = {};
+            this._telemetryExcludeOperations = [
+                OPERATIONS.PNSubscribeOperation,
+                OPERATIONS.PNReceiveMessagesOperation,
+                OPERATIONS.PNHandshakeOperation,
+            ];
             this._maximumSamplesCount = configuration.maximumSamplesCount || this._maximumSamplesCount;
         }
         /**
@@ -2562,13 +2570,13 @@
             return latencies;
         };
         default_1.prototype.startLatencyMeasure = function (operationType, identifier) {
-            if (operationType === OPERATIONS.PNSubscribeOperation || !identifier) {
+            if (this._telemetryExcludeOperations.includes(operationType) || !identifier) {
                 return;
             }
             this._trackedLatencies[identifier] = Date.now();
         };
         default_1.prototype.stopLatencyMeasure = function (operationType, identifier) {
-            if (operationType === OPERATIONS.PNSubscribeOperation || !identifier) {
+            if (this._telemetryExcludeOperations.includes(operationType) || !identifier) {
                 return;
             }
             var endpointName = this._endpointName(operationType);
@@ -6720,7 +6728,7 @@
     });
 
     var endpoint$1 = {
-        getOperation: function () { return OPERATIONS.PNSubscribeOperation; },
+        getOperation: function () { return OPERATIONS.PNHandshakeOperation; },
         validateParams: function (_, params) {
             if (!(params === null || params === void 0 ? void 0 : params.channels) && !(params === null || params === void 0 ? void 0 : params.channelGroups)) {
                 return 'channels and channleGroups both should not be empty';
@@ -6759,7 +6767,7 @@
     };
 
     var endpoint = {
-        getOperation: function () { return OPERATIONS.PNSubscribeOperation; },
+        getOperation: function () { return OPERATIONS.PNReceiveMessagesOperation; },
         validateParams: function (_, params) {
             if (!(params === null || params === void 0 ? void 0 : params.channels) && !(params === null || params === void 0 ? void 0 : params.channelGroups)) {
                 return 'channels and channleGroups both should not be empty';

diff --git a/dist/web/pubnub.min.js b/dist/web/pubnub.min.js
diff --git a/lib/core/components/telemetry_manager.js b/lib/core/components/telemetry_manager.js
@@ -10,6 +10,11 @@ var default_1 = /** @class */ (function () {
         this._maximumSamplesCount = 100;
         this._trackedLatencies = {};
         this._latencies = {};
+        this._telemetryExcludeOperations = [
+            operations_1.default.PNSubscribeOperation,
+            operations_1.default.PNReceiveMessagesOperation,
+            operations_1.default.PNHandshakeOperation,
+        ];
         this._maximumSamplesCount = configuration.maximumSamplesCount || this._maximumSamplesCount;
     }
     /**
@@ -30,13 +35,13 @@ var default_1 = /** @class */ (function () {
         return latencies;
     };
     default_1.prototype.startLatencyMeasure = function (operationType, identifier) {
-        if (operationType === operations_1.default.PNSubscribeOperation || !identifier) {
+        if (this._telemetryExcludeOperations.includes(operationType) || !identifier) {
             return;
         }
         this._trackedLatencies[identifier] = Date.now();
     };
     default_1.prototype.stopLatencyMeasure = function (operationType, identifier) {
-        if (operationType === operations_1.default.PNSubscribeOperation || !identifier) {
+        if (this._telemetryExcludeOperations.includes(operationType) || !identifier) {
             return;
         }
         var endpointName = this._endpointName(operationType);

diff --git a/lib/core/constants/operations.js b/lib/core/constants/operations.js
@@ -77,4 +77,7 @@ exports.default = {
     PNAccessManagerAudit: 'PNAccessManagerAudit',
     PNAccessManagerRevokeToken: 'PNAccessManagerRevokeToken',
     //
+    // subscription utilities
+    PNHandshakeOperation: 'PNHandshakeOperation',
+    PNReceiveMessagesOperation: 'PNReceiveMessagesOperation',
 };
diff --git a/lib/core/endpoints/subscriptionUtils/handshake.js b/lib/core/endpoints/subscriptionUtils/handshake.js
@@ -6,7 +6,7 @@ Object.defineProperty(exports, "__esModule", { value: true });
 var operations_1 = __importDefault(require("../../constants/operations"));
 var utils_1 = __importDefault(require("../../utils"));
 var endpoint = {
-    getOperation: function () { return operations_1.default.PNSubscribeOperation; },
+    getOperation: function () { return operations_1.default.PNHandshakeOperation; },
     validateParams: function (_, params) {
         if (!(params === null || params === void 0 ? void 0 : params.channels) && !(params === null || params === void 0 ? void 0 : params.channelGroups)) {
             return 'channels and channleGroups both should not be empty';

diff --git a/lib/core/endpoints/subscriptionUtils/receiveMessages.js b/lib/core/endpoints/subscriptionUtils/receiveMessages.js
@@ -6,7 +6,7 @@ Object.defineProperty(exports, "__esModule", { value: true });
 var operations_1 = __importDefault(require("../../constants/operations"));
 var utils_1 = __importDefault(require("../../utils"));
 var endpoint = {
-    getOperation: function () { return operations_1.default.PNSubscribeOperation; },
+    getOperation: function () { return operations_1.default.PNReceiveMessagesOperation; },
     validateParams: function (_, params) {
         if (!(params === null || params === void 0 ? void 0 : params.channels) && !(params === null || params === void 0 ? void 0 : params.channelGroups)) {
             return 'channels and channleGroups both should not be empty';