fix: telemetry condition to add query param

pubnub · Feb 5, 2024 · 2fd360e · 2fd360e
1 parent 9c6462f
commit 2fd360e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 15 deletions.
diff --git a/src/core/components/telemetry_manager.js b/src/core/components/telemetry_manager.js
@@ -33,23 +33,15 @@ export default class {
   }
 
   startLatencyMeasure(operationType, identifier) {
-    if (
-      operationType === operationConstants.PNSubscribeOperation ||
-      operationConstants.PNReceiveMessagesOperation ||
-      !identifier
-    ) {
+    if (operationType === operationConstants.PNSubscribeOperation || !identifier) {
       return;
     }
 
     this._trackedLatencies[identifier] = Date.now();
   }
 
   stopLatencyMeasure(operationType, identifier) {
-    if (
-      operationType === operationConstants.PNSubscribeOperation ||
-      operationConstants.PNReceiveMessagesOperation ||
-      !identifier
-    ) {
+    if (operationType === operationConstants.PNSubscribeOperation || !identifier) {
       return;
     }
 

diff --git a/src/core/constants/operations.js b/src/core/constants/operations.js
@@ -86,7 +86,4 @@ export default {
   PNAccessManagerRevokeToken: 'PNAccessManagerRevokeToken',
   //
 
-  // subscription utilities
-  PNHandshakeOperation: 'PNHandshakeOperation',
-  PNReceiveMessagesOperation: 'PNReceiveMessagesOperation',
 };
diff --git a/src/core/endpoints/subscriptionUtils/handshake.js b/src/core/endpoints/subscriptionUtils/handshake.js
@@ -2,7 +2,7 @@ import operationConstants from '../../constants/operations';
 import utils from '../../utils';
 
 const endpoint = {
-  getOperation: () => operationConstants.PNHandshakeOperation,
+  getOperation: () => operationConstants.PNSubscribeOperation,
 
   validateParams: (_, params) => {
     if (!params?.channels && !params?.channelGroups) {

diff --git a/src/core/endpoints/subscriptionUtils/receiveMessages.js b/src/core/endpoints/subscriptionUtils/receiveMessages.js
@@ -2,7 +2,7 @@ import operationConstants from '../../constants/operations';
 import utils from '../../utils';
 
 const endpoint = {
-  getOperation: () => operationConstants.PNReceiveMessagesOperation,
+  getOperation: () => operationConstants.PNSubscribeOperation,
 
   validateParams: (_, params) => {
     if (!params?.channels && !params?.channelGroups) {