PubNub SDK v8.7.1 release.

.pubnub.yml

@@ -1,5 +1,10 @@
 ---
 changelog:
+  - date: 2025-01-31
+    version: v8.7.1
+    changes:
+      - type: bug
+        text: "Fix long-poll request cancellation caused by APM packages monkey patching 'fetch' and try to use 'native' implementation instead of patched."
   - date: 2025-01-30
     version: v8.7.0
     changes:
@@ -1118,7 +1123,7 @@ supported-platforms:
       - 'Ubuntu 14.04 and up'
       - 'Windows 7 and up'
     version: 'Pubnub Javascript for Node'
-version: '8.7.0'
+version: '8.7.1'
 sdks:
   - full-name: PubNub Javascript SDK
     short-name: Javascript
@@ -1134,7 +1139,7 @@ sdks:
           - distribution-type: source
             distribution-repository: GitHub release
             package-name: pubnub.js
-            location: https://github.com/pubnub/javascript/archive/refs/tags/v8.7.0.zip
+            location: https://github.com/pubnub/javascript/archive/refs/tags/v8.7.1.zip
             requires:
               - name: 'agentkeepalive'
                 min-version: '3.5.2'
@@ -1805,7 +1810,7 @@ sdks:
           - distribution-type: library
             distribution-repository: GitHub release
             package-name: pubnub.js
-            location: https://github.com/pubnub/javascript/releases/download/v8.7.0/pubnub.8.7.0.js
+            location: https://github.com/pubnub/javascript/releases/download/v8.7.1/pubnub.8.7.1.js
             requires:
               - name: 'agentkeepalive'
                 min-version: '3.5.2'

CHANGELOG.md

@@ -1,3 +1,9 @@
+## v8.7.1
+January 31 2025
+
+#### Fixed
+- Fix long-poll request cancellation caused by APM packages monkey patching 'fetch' and try to use 'native' implementation instead of patched.
+
 ## v8.7.0
 January 30 2025
 

README.md

@@ -28,8 +28,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.8.7.0.js
-     * https://cdn.pubnub.com/sdk/javascript/pubnub.8.7.0.min.js
+     * https://cdn.pubnub.com/sdk/javascript/pubnub.8.7.1.js
+     * https://cdn.pubnub.com/sdk/javascript/pubnub.8.7.1.min.js
 
 2. Configure your keys:
 

dist/web/pubnub.js

@@ -4000,7 +4000,7 @@
 	            return base.PubNubFile;
 	        },
 	        get version() {
-	            return '8.7.0';
+	            return '8.7.1';
 	        },
 	        getVersion() {
 	            return this.version;

lib/core/components/configuration.js

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

lib/react_native/index.js

@@ -62,7 +62,7 @@ class PubNub extends pubnub_common_1.PubNubCore {
         const transportMiddleware = new middleware_1.PubNubMiddleware({
             clientConfiguration,
             tokenManager,
-            transport: new web_react_native_transport_1.WebReactNativeTransport(clientConfiguration.keepAlive, clientConfiguration.logVerbosity),
+            transport: new web_react_native_transport_1.WebReactNativeTransport(fetch, clientConfiguration.keepAlive, clientConfiguration.logVerbosity),
         });
         super({
             configuration: clientConfiguration,

lib/transport/web-react-native-transport.js

@@ -26,14 +26,24 @@ class WebReactNativeTransport {
     /**
      * Create and configure transport provider for Web and Rect environments.
      *
+     * @param originalFetch - Pointer to the original (not monkey patched) `fetch` implementation.
      * @param [keepAlive] - Whether client should try to keep connections open for reuse or not.
      * @param logVerbosity - Whether verbose logs should be printed or not.
      *
      * @internal
      */
-    constructor(keepAlive = false, logVerbosity) {
+    constructor(originalFetch, keepAlive = false, logVerbosity = false) {
         this.keepAlive = keepAlive;
         this.logVerbosity = logVerbosity;
+        WebReactNativeTransport.originalFetch = originalFetch;
+        // Check whether `fetch` has been monkey patched or not.
+        if (logVerbosity && this.isFetchMonkeyPatched()) {
+            console.warn("[PubNub] Native Web Fetch API 'fetch' function monkey patched.");
+            if (!this.isFetchMonkeyPatched(WebReactNativeTransport.originalFetch))
+                console.info("[PubNub] Use native Web Fetch API 'fetch' implementation from iframe as APM workaround.");
+            else
+                console.warn('[PubNub] Unable receive native Web Fetch API. There can be issues with subscribe long-poll cancellation');
+        }
     }
     makeSendable(req) {
         let controller;
@@ -63,7 +73,11 @@ class WebReactNativeTransport {
                     }, req.timeout * 1000);
                 });
                 return Promise.race([
-                    fetch(request, { signal: abortController === null || abortController === void 0 ? void 0 : abortController.signal, credentials: 'omit', cache: 'no-cache' }),
+                    WebReactNativeTransport.originalFetch(request, {
+                        signal: abortController === null || abortController === void 0 ? void 0 : abortController.signal,
+                        credentials: 'omit',
+                        cache: 'no-cache',
+                    }),
                     requestTimeout,
                 ])
                     .then((response) => response.arrayBuffer().then((arrayBuffer) => [response, arrayBuffer]))
@@ -178,6 +192,17 @@ class WebReactNativeTransport {
             console.log('-----');
         }
     }
+    /**
+     * Check whether original `fetch` has been monkey patched or not.
+     *
+     * @returns `true` if original `fetch` has been patched.
+     *
+     * @internal
+     */
+    isFetchMonkeyPatched(oFetch) {
+        const fetchString = (oFetch !== null && oFetch !== void 0 ? oFetch : fetch).toString();
+        return !fetchString.includes('[native code]') && fetch.name !== 'fetch';
+    }
 }
 exports.WebReactNativeTransport = WebReactNativeTransport;
 /**

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pubnub",
-  "version": "8.7.0",
+  "version": "8.7.1",
   "author": "PubNub <[email protected]>",
   "description": "Publish & Subscribe Real-time Messaging with PubNub",
   "scripts": {

src/core/components/configuration.ts

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