Fix missing heartbeat query parameter

.pubnub.yml

@@ -1,5 +1,10 @@
 ---
 changelog:
+  - date: 2026-10-13
+    version: v13.1.1
+    changes:
+      - type: bug
+        text: "Fix the missing `heartbeat` query parameter for the new subscription flow on `handshake` and `receive messages` state."
   - date: 2026-10-12
     version: v13.1.0
     changes:
@@ -1508,7 +1513,7 @@ supported-platforms:
       - 'Ubuntu 14.04 and up'
       - 'Windows 7 and up'
     version: 'Pubnub Javascript for Node'
-version: '13.1.0'
+version: '13.1.1'
 sdks:
   - full-name: PubNub Javascript SDK
     short-name: Javascript
@@ -1524,7 +1529,7 @@ sdks:
           - distribution-type: source
             distribution-repository: GitHub release
             package-name: pubnub.js
-            location: https://github.com/pubnub/javascript/archive/refs/tags/v13.1.0.zip
+            location: https://github.com/pubnub/javascript/archive/refs/tags/v13.1.1.zip
             requires:
               - name: 'agentkeepalive'
                 min-version: '3.5.2'
@@ -2195,7 +2200,7 @@ sdks:
           - distribution-type: library
             distribution-repository: GitHub release
             package-name: pubnub.js
-            location: https://github.com/pubnub/javascript/releases/download/v13.1.0/pubnub.13.1.0.js
+            location: https://github.com/pubnub/javascript/releases/download/v13.1.1/pubnub.13.1.1.js
             requires:
               - name: 'agentkeepalive'
                 min-version: '3.5.2'

CHANGELOG.md

@@ -1,3 +1,9 @@
+## v13.1.1
+October 13 2026
+
+#### Fixed
+- Fix the missing `heartbeat` query parameter for the new subscription flow on `handshake` and `receive messages` state.
+
 ## v13.1.0
 October 12 2026
 

README.md

@@ -29,8 +29,8 @@ Watch [Getting Started with PubNub JS SDK](https://app.dashcam.io/replay/64ee0d2
      npm install pubnub
      ```
    * or download one of our builds from our CDN: 
-     * https://cdn.pubnub.com/sdk/javascript/pubnub.13.1.0.js
-     * https://cdn.pubnub.com/sdk/javascript/pubnub.13.1.0.min.js
+     * https://cdn.pubnub.com/sdk/javascript/pubnub.13.1.1.js
+     * https://cdn.pubnub.com/sdk/javascript/pubnub.13.1.1.min.js
 
    > **React Native:** the SDK relies on a global `URL` implementation, which React Native does not
    > provide, so it depends on [`react-native-url-polyfill`](https://www.npmjs.com/package/react-native-url-polyfill).

dist/web/pubnub.js

@@ -5613,7 +5613,7 @@
 	            return base.PubNubFile;
 	        },
 	        get version() {
-	            return '13.1.0';
+	            return '13.1.1';
 	        },
 	        getVersion() {
 	            return this.version;
@@ -10386,7 +10386,7 @@
 	        return `/v2/subscribe/${subscribeKey}/${encodeNames(channels.sort(), ',')}/0`;
 	    }
 	    get queryParameters() {
-	        const { channelGroups, filterExpression, timetoken, region, onDemand } = this
+	        const { channelGroups, filterExpression, timetoken, region, heartbeat, onDemand } = this
 	            .parameters;
 	        const query = { ee: '' };
 	        if (onDemand)
@@ -10403,6 +10403,8 @@
 	            query['tt'] = timetoken;
 	        if (region)
 	            query['tr'] = region;
+	        if (heartbeat)
+	            query.heartbeat = heartbeat;
 	        return query;
 	    }
 	}
@@ -10428,7 +10430,7 @@
 	        return `/v2/subscribe/${subscribeKey}/${encodeNames(channels.sort(), ',')}/0`;
 	    }
 	    get queryParameters() {
-	        const { channelGroups, filterExpression, state, onDemand } = this
+	        const { channelGroups, heartbeat, filterExpression, state, onDemand } = this
 	            .parameters;
 	        const query = { ee: '' };
 	        if (onDemand)
@@ -10439,6 +10441,8 @@
 	            query['filter-expr'] = filterExpression;
 	        if (state && Object.keys(state).length > 0)
 	            query['state'] = JSON.stringify(state);
+	        if (heartbeat)
+	            query.heartbeat = heartbeat;
 	        return query;
 	    }
 	}
@@ -19797,6 +19801,8 @@
 	                // `on-demand` query parameter not required for non-SharedWorker environment.
 	                if (!this._configuration.isSharedWorkerEnabled())
 	                    parameters.onDemand = false;
+	                if (!parameters.heartbeat)
+	                    parameters.heartbeat = this._configuration.getPresenceTimeout();
 	                const request = new HandshakeSubscribeRequest(Object.assign(Object.assign({}, parameters), { keySet: this._configuration.keySet, crypto: this._configuration.getCryptoModule(), getFileUrl: this.getFileUrl.bind(this) }));
 	                const abortUnsubscribe = parameters.abortSignal.subscribe((err) => {
 	                    request.abort('Cancel subscribe handshake request');
@@ -19828,6 +19834,8 @@
 	                // `on-demand` query parameter not required for non-SharedWorker environment.
 	                if (!this._configuration.isSharedWorkerEnabled())
 	                    parameters.onDemand = false;
+	                if (!parameters.heartbeat)
+	                    parameters.heartbeat = this._configuration.getPresenceTimeout();
 	                const request = new ReceiveMessagesSubscribeRequest(Object.assign(Object.assign({}, parameters), { keySet: this._configuration.keySet, crypto: this._configuration.getCryptoModule(), getFileUrl: this.getFileUrl.bind(this) }));
 	                const abortUnsubscribe = parameters.abortSignal.subscribe((err) => {
 	                    request.abort('Cancel long-poll subscribe request');

lib/core/components/configuration.js

@@ -174,7 +174,7 @@ const makeConfiguration = (base, setupCryptoModule) => {
             return base.PubNubFile;
         },
         get version() {
-            return '13.1.0';
+            return '13.1.1';
         },
         getVersion() {
             return this.version;

lib/core/endpoints/subscriptionUtils/handshake.js

@@ -28,7 +28,7 @@ class HandshakeSubscribeRequest extends subscribe_1.BaseSubscribeRequest {
         return `/v2/subscribe/${subscribeKey}/${(0, utils_1.encodeNames)(channels.sort(), ',')}/0`;
     }
     get queryParameters() {
-        const { channelGroups, filterExpression, state, onDemand } = this
+        const { channelGroups, heartbeat, filterExpression, state, onDemand } = this
             .parameters;
         const query = { ee: '' };
         if (onDemand)
@@ -39,6 +39,8 @@ class HandshakeSubscribeRequest extends subscribe_1.BaseSubscribeRequest {
             query['filter-expr'] = filterExpression;
         if (state && Object.keys(state).length > 0)
             query['state'] = JSON.stringify(state);
+        if (heartbeat)
+            query.heartbeat = heartbeat;
         return query;
     }
 }

lib/core/endpoints/subscriptionUtils/receiveMessages.js

@@ -35,7 +35,7 @@ class ReceiveMessagesSubscribeRequest extends subscribe_1.BaseSubscribeRequest {
         return `/v2/subscribe/${subscribeKey}/${(0, utils_1.encodeNames)(channels.sort(), ',')}/0`;
     }
     get queryParameters() {
-        const { channelGroups, filterExpression, timetoken, region, onDemand } = this
+        const { channelGroups, filterExpression, timetoken, region, heartbeat, onDemand } = this
             .parameters;
         const query = { ee: '' };
         if (onDemand)
@@ -52,6 +52,8 @@ class ReceiveMessagesSubscribeRequest extends subscribe_1.BaseSubscribeRequest {
             query['tt'] = timetoken;
         if (region)
             query['tr'] = region;
+        if (heartbeat)
+            query.heartbeat = heartbeat;
         return query;
     }
 }

lib/core/pubnub-common.js

@@ -1466,6 +1466,8 @@ class PubNubCore {
                 // `on-demand` query parameter not required for non-SharedWorker environment.
                 if (!this._configuration.isSharedWorkerEnabled())
                     parameters.onDemand = false;
+                if (!parameters.heartbeat)
+                    parameters.heartbeat = this._configuration.getPresenceTimeout();
                 const request = new handshake_1.HandshakeSubscribeRequest(Object.assign(Object.assign({}, parameters), { keySet: this._configuration.keySet, crypto: this._configuration.getCryptoModule(), getFileUrl: this.getFileUrl.bind(this) }));
                 const abortUnsubscribe = parameters.abortSignal.subscribe((err) => {
                     request.abort('Cancel subscribe handshake request');
@@ -1499,6 +1501,8 @@ class PubNubCore {
                 // `on-demand` query parameter not required for non-SharedWorker environment.
                 if (!this._configuration.isSharedWorkerEnabled())
                     parameters.onDemand = false;
+                if (!parameters.heartbeat)
+                    parameters.heartbeat = this._configuration.getPresenceTimeout();
                 const request = new receiveMessages_1.ReceiveMessagesSubscribeRequest(Object.assign(Object.assign({}, parameters), { keySet: this._configuration.keySet, crypto: this._configuration.getCryptoModule(), getFileUrl: this.getFileUrl.bind(this) }));
                 const abortUnsubscribe = parameters.abortSignal.subscribe((err) => {
                     request.abort('Cancel long-poll subscribe request');

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pubnub",
-  "version": "13.1.0",
+  "version": "13.1.1",
   "author": "PubNub <support@pubnub.com>",
   "description": "PubNub SDK for JavaScript. Publish/subscribe messaging over HTTP long-poll with server-assigned message ordering, channel occupancy via Here Now, and message history through Message Persistence.",
   "scripts": {

src/core/components/configuration.ts

@@ -245,7 +245,7 @@ export const makeConfiguration = (
       return base.PubNubFile;
     },
     get version(): string {
-      return '13.1.0';
+      return '13.1.1';
     },
     getVersion(): string {
       return this.version;

src/core/endpoints/subscriptionUtils/handshake.ts

@@ -32,14 +32,15 @@ export class HandshakeSubscribeRequest extends BaseSubscribeRequest {
   }
 
   protected get queryParameters(): Query {
-    const { channelGroups, filterExpression, state, onDemand } = this
+    const { channelGroups, heartbeat, filterExpression, state, onDemand } = this
       .parameters as unknown as Subscription.CancelableSubscribeParameters;
     const query: Query = { ee: '' };
 
     if (onDemand) query['on-demand'] = 1;
     if (channelGroups && channelGroups.length > 0) query['channel-group'] = channelGroups.sort().join(',');
     if (filterExpression && filterExpression.length > 0) query['filter-expr'] = filterExpression;
     if (state && Object.keys(state).length > 0) query['state'] = JSON.stringify(state);
+    if (heartbeat) query.heartbeat = heartbeat;
 
     return query;
   }

src/core/endpoints/subscriptionUtils/receiveMessages.ts

@@ -38,7 +38,7 @@ export class ReceiveMessagesSubscribeRequest extends BaseSubscribeRequest {
   }
 
   protected get queryParameters(): Query {
-    const { channelGroups, filterExpression, timetoken, region, onDemand } = this
+    const { channelGroups, filterExpression, timetoken, region, heartbeat, onDemand } = this
       .parameters as unknown as Subscription.CancelableSubscribeParameters;
     const query: Query = { ee: '' };
 
@@ -49,6 +49,7 @@ export class ReceiveMessagesSubscribeRequest extends BaseSubscribeRequest {
       if (timetoken && timetoken !== '0' && timetoken.length > 0) query['tt'] = timetoken;
     } else if (timetoken && timetoken > 0) query['tt'] = timetoken;
     if (region) query['tr'] = region;
+    if (heartbeat) query.heartbeat = heartbeat;
 
     return query;
   }

src/core/pubnub-common.ts

@@ -1947,6 +1947,7 @@ export class PubNubCore<
     if (process.env.SUBSCRIBE_EVENT_ENGINE_MODULE !== 'disabled') {
       // `on-demand` query parameter not required for non-SharedWorker environment.
       if (!this._configuration.isSharedWorkerEnabled()) parameters.onDemand = false;
+      if (!parameters.heartbeat) parameters.heartbeat = this._configuration.getPresenceTimeout();
 
       const request = new HandshakeSubscribeRequest({
         ...parameters,
@@ -1984,6 +1985,7 @@ export class PubNubCore<
     if (process.env.SUBSCRIBE_EVENT_ENGINE_MODULE !== 'disabled') {
       // `on-demand` query parameter not required for non-SharedWorker environment.
       if (!this._configuration.isSharedWorkerEnabled()) parameters.onDemand = false;
+      if (!parameters.heartbeat) parameters.heartbeat = this._configuration.getPresenceTimeout();
 
       const request = new ReceiveMessagesSubscribeRequest({
         ...parameters,

test/integration/endpoints/subscribe.test.ts

@@ -65,6 +65,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
       })
       .reply(
         200,
@@ -79,6 +80,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
         tt: cursorTimetoken,
         tr: 1,
       })
@@ -116,7 +118,7 @@ describe('subscribe endpoints', () => {
   });
 
   it('supports addition of multiple channels / channel groups', (done) => {
-    // Event Engine: handshake uses `ee` (no `heartbeat` on subscribe); `m` on handshake is ignored.
+    // Event Engine: handshake uses `ee` and `heartbeat` (presence timeout); `m` on handshake is ignored.
     // Long-poll receive must be mocked after handshake.
     const cursorTimetoken = '14607577960932487';
 
@@ -128,6 +130,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
       })
       .reply(
         200,
@@ -143,6 +146,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
         tt: cursorTimetoken,
         tr: 1,
       })
@@ -193,6 +197,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
       })
       .reply(
         200,
@@ -208,6 +213,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
         tt: cursorTimetoken,
         tr: 1,
       })
@@ -255,6 +261,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
       })
       .reply(
         200,
@@ -270,6 +277,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
         tt: cursorTimetoken,
         tr: 1,
       })
@@ -442,6 +450,7 @@ describe('subscribe endpoints', () => {
         pnsdk: `PubNub-JS-Nodejs/${pubnub.getVersion()}`,
         uuid: 'myUUID',
         ee: '',
+        heartbeat: '300',
       })
       .reply(
         200,
@@ -457,6 +466,7 @@ describe('subscribe endpoints', () => {
         tt: cursorHandshake,
         tr: 1,
         ee: '',
+        heartbeat: '300',
       })
       .reply(
         200,
@@ -472,6 +482,7 @@ describe('subscribe endpoints', () => {
         tt: cursorAfterInterval,
         tr: 1,
         ee: '',
+        heartbeat: '300',
       })
       .reply(200, `{"t":{"t":"${cursorAfterInterval}","r":1},"m":[]}`, { 'content-type': 'text/javascript' })
       .persist();