lib/dist updates

Author: Mohit Tejani

dist/web/pubnub.js

@@ -9566,6 +9566,11 @@
 	        return subscriptionTimetokenFromReference(currentTimetoken, referenceTimetoken !== null && referenceTimetoken !== void 0 ? referenceTimetoken : '0');
 	    }
 	    subscribe({ channels, channelGroups, timetoken, withPresence, }) {
+	        var _a;
+	        // check if the channels and groups are already subscribed
+	        const hasNewChannels = channels === null || channels === void 0 ? void 0 : channels.some((channel) => !this.channels.includes(channel));
+	        const hasNewGroups = channelGroups === null || channelGroups === void 0 ? void 0 : channelGroups.some((group) => !this.groups.includes(group));
+	        const hasNewSubscriptions = hasNewChannels || hasNewGroups;
 	        this.channels = [...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])];
 	        this.groups = [...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])];
 	        if (withPresence) {
@@ -9576,7 +9581,29 @@
 	            this.engine.transition(restore(Array.from(new Set([...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])])), Array.from(new Set([...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])])), timetoken));
 	        }
 	        else {
-	            this.engine.transition(subscriptionChange(Array.from(new Set([...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])])), Array.from(new Set([...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])]))));
+	            if (hasNewSubscriptions) {
+	                this.engine.transition(subscriptionChange(Array.from(new Set([...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])])), Array.from(new Set([...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])]))));
+	            }
+	            else {
+	                this.dependencies.config
+	                    .logger()
+	                    .debug('EventEngine', 'Skipping state transition - all channels/groups already subscribed. Emitting SubscriptionChanged event.');
+	                // Get current timetoken from state context
+	                const currentState = this.engine.currentState;
+	                const currentContext = this.engine.currentContext;
+	                let currentTimetoken = '0';
+	                if ((currentState === null || currentState === void 0 ? void 0 : currentState.label) === ReceivingState.label && currentContext) {
+	                    const receivingContext = currentContext;
+	                    currentTimetoken = (_a = receivingContext.cursor) === null || _a === void 0 ? void 0 : _a.timetoken;
+	                }
+	                // Manually emit SubscriptionChanged status event
+	                this.dependencies.emitStatus({
+	                    category: StatusCategory$1.PNSubscriptionChangedCategory,
+	                    affectedChannels: Array.from(new Set(this.channels.filter((c) => !c.endsWith('-pnpres')))),
+	                    affectedChannelGroups: Array.from(new Set(this.groups.filter((g) => !g.endsWith('-pnpres')))),
+	                    currentTimetoken,
+	                });
+	            }
 	        }
 	        if (this.dependencies.join) {
 	            this.dependencies.join({

dist/web/pubnub.min.js

@@ -37,13 +37,17 @@ var __importStar = (this && this.__importStar) || (function () {
         return result;
     };
 })();
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.EventEngine = void 0;
 const receiving_1 = require("./states/receiving");
 const dispatcher_1 = require("./dispatcher");
 const utils_1 = require("../core/utils");
 const unsubscribed_1 = require("./states/unsubscribed");
 const core_1 = require("./core");
+const categories_1 = __importDefault(require("../core/constants/categories"));
 const utils = __importStar(require("../core/utils"));
 const events = __importStar(require("./events"));
 /**
@@ -88,6 +92,11 @@ class EventEngine {
         return (0, utils_1.subscriptionTimetokenFromReference)(currentTimetoken, referenceTimetoken !== null && referenceTimetoken !== void 0 ? referenceTimetoken : '0');
     }
     subscribe({ channels, channelGroups, timetoken, withPresence, }) {
+        var _a;
+        // check if the channels and groups are already subscribed
+        const hasNewChannels = channels === null || channels === void 0 ? void 0 : channels.some((channel) => !this.channels.includes(channel));
+        const hasNewGroups = channelGroups === null || channelGroups === void 0 ? void 0 : channelGroups.some((group) => !this.groups.includes(group));
+        const hasNewSubscriptions = hasNewChannels || hasNewGroups;
         this.channels = [...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])];
         this.groups = [...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])];
         if (withPresence) {
@@ -98,7 +107,29 @@ class EventEngine {
             this.engine.transition(events.restore(Array.from(new Set([...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])])), Array.from(new Set([...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])])), timetoken));
         }
         else {
-            this.engine.transition(events.subscriptionChange(Array.from(new Set([...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])])), Array.from(new Set([...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])]))));
+            if (hasNewSubscriptions) {
+                this.engine.transition(events.subscriptionChange(Array.from(new Set([...this.channels, ...(channels !== null && channels !== void 0 ? channels : [])])), Array.from(new Set([...this.groups, ...(channelGroups !== null && channelGroups !== void 0 ? channelGroups : [])]))));
+            }
+            else {
+                this.dependencies.config
+                    .logger()
+                    .debug('EventEngine', 'Skipping state transition - all channels/groups already subscribed. Emitting SubscriptionChanged event.');
+                // Get current timetoken from state context
+                const currentState = this.engine.currentState;
+                const currentContext = this.engine.currentContext;
+                let currentTimetoken = '0';
+                if ((currentState === null || currentState === void 0 ? void 0 : currentState.label) === receiving_1.ReceivingState.label && currentContext) {
+                    const receivingContext = currentContext;
+                    currentTimetoken = (_a = receivingContext.cursor) === null || _a === void 0 ? void 0 : _a.timetoken;
+                }
+                // Manually emit SubscriptionChanged status event
+                this.dependencies.emitStatus({
+                    category: categories_1.default.PNSubscriptionChangedCategory,
+                    affectedChannels: Array.from(new Set(this.channels.filter((c) => !c.endsWith('-pnpres')))),
+                    affectedChannelGroups: Array.from(new Set(this.groups.filter((g) => !g.endsWith('-pnpres')))),
+                    currentTimetoken,
+                });
+            }
         }
         if (this.dependencies.join) {
             this.dependencies.join({