feat: enableEventEngine, restore set default

.coderabbit.yaml

@@ -0,0 +1,105 @@
+# yaml-language-server: $schema=https://coderabbit.ai/integrations/schema.v2.json
+
+language: en-US
+
+reviews:
+  # Enable high-level summary of changes
+  high_level_summary: false
+
+  # Add a poem... just kidding, disable it
+  poem: false
+
+  # Collapse walkthrough to keep PR comments clean
+  collapse_walkthrough: true
+
+  # Auto-review on every push
+  auto_review:
+    enabled: true
+    drafts: true
+
+  # Path-based review instructions
+  path_instructions:
+    - path: "src/core/**"
+      instructions: |
+        This is the core SDK module. Pay close attention to:
+        - Backward compatibility of public API changes
+        - Proper TypeScript typing (strict mode is enabled)
+        - No platform-specific code (Node.js, Web, React Native specifics belong in their respective platform directories)
+        - Thread safety considerations for shared state
+    - path: "src/core/endpoints/**"
+      instructions: |
+        These are REST API endpoint implementations. Review for:
+        - Correct request/response type definitions
+        - Proper error handling and status code mapping
+        - Consistent parameter validation
+        - Adherence to PubNub REST API contracts
+    - path: "src/core/types/**"
+      instructions: |
+        TypeScript type definitions. Ensure:
+        - Types are precise and not overly permissive (avoid `any`)
+        - Exported types maintain backward compatibility
+        - Proper use of generics and utility types
+    - path: "src/event-engine/**"
+      instructions: |
+        State-machine-based subscription management. Review for:
+        - Correct state transitions and edge cases
+        - No leaked subscriptions or event listeners
+        - Proper cleanup on state exit
+    - path: "src/entities/**"
+      instructions: |
+        High-level subscription API (Channel, ChannelGroup, etc.). Review for:
+        - Proper event handler lifecycle management
+        - Memory leak prevention (listener cleanup)
+    - path: "src/transport/**"
+      instructions: |
+        Platform-specific HTTP transport implementations. Review for:
+        - Proper timeout and cancellation handling
+        - Correct header management
+        - Error propagation consistency across platforms
+    - path: "src/node/**"
+      instructions: "Node.js platform implementation. Ensure no browser/DOM APIs are used."
+    - path: "src/web/**"
+      instructions: "Browser platform implementation. Ensure no Node.js-specific APIs (fs, crypto, etc.) are used."
+    - path: "src/react_native/**"
+      instructions: "React Native platform implementation. Verify compatibility with RN runtime."
+    - path: "test/**"
+      instructions: |
+        Test files. Review for:
+        - Adequate coverage of edge cases
+        - Proper use of mocks/stubs (Sinon + Nock)
+        - No flaky patterns (hardcoded timeouts, race conditions)
+        - Tests that actually assert meaningful behavior
+
+  # Tools configuration
+  tools:
+    # Enable GitHub checks integration
+    github-checks:
+      enabled: true
+      timeout_ms: 120000
+
+chat:
+  auto_reply: true
+
+knowledge_base:
+  mcp:
+    usage: enabled
+
+# Path filters - ignore generated/vendored/build output
+path_filters:
+  # Build outputs
+  - "!dist/**"
+  - "!lib/**"
+  - "!upload/**"
+
+  # Dependencies
+  - "!node_modules/**"
+
+  # Lock files - too noisy, low review value
+  - "!package-lock.json"
+
+  # Config/metadata that rarely needs review
+  - "!.pubnub.yml"
+  - "!.vscode/**"
+
+  # Generated type bundles
+  - "!lib/types/**"

.pubnub.yml

@@ -1,5 +1,12 @@
 ---
 changelog:
+  - date: 2026-04-20
+    version: v11.0.0
+    changes:
+      - type: feature
+        text: "BREAKING CHANGES: Subscription now uses the event engine workflow by default and automatically restores subscriptions after reconnect."
+      - type: improvement
+        text: "Drop `maximumRetry` validation caps for linear/exponential policies."
   - date: 2026-03-16
     version: v10.2.9
     changes:
@@ -1399,7 +1406,7 @@ supported-platforms:
       - 'Ubuntu 14.04 and up'
       - 'Windows 7 and up'
     version: 'Pubnub Javascript for Node'
-version: '10.2.9'
+version: '11.0.0'
 sdks:
   - full-name: PubNub Javascript SDK
     short-name: Javascript
@@ -1415,7 +1422,7 @@ sdks:
           - distribution-type: source
             distribution-repository: GitHub release
             package-name: pubnub.js
-            location: https://github.com/pubnub/javascript/archive/refs/tags/v10.2.9.zip
+            location: https://github.com/pubnub/javascript/archive/refs/tags/v11.0.0.zip
             requires:
               - name: 'agentkeepalive'
                 min-version: '3.5.2'
@@ -2086,7 +2093,7 @@ sdks:
           - distribution-type: library
             distribution-repository: GitHub release
             package-name: pubnub.js
-            location: https://github.com/pubnub/javascript/releases/download/v10.2.9/pubnub.10.2.9.js
+            location: https://github.com/pubnub/javascript/releases/download/v11.0.0/pubnub.11.0.0.js
             requires:
               - name: 'agentkeepalive'
                 min-version: '3.5.2'

CHANGELOG.md

@@ -1,3 +1,12 @@
+## v11.0.0
+April 20 2026
+
+#### Added
+- **BREAKING CHANGES**: Subscription now uses the event engine workflow by default and automatically restores subscriptions after reconnect.
+
+#### Modified
+- Drop `maximumRetry` validation caps for linear/exponential policies.
+
 ## v10.2.9
 March 16 2026
 

README.md

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

dist/web/pubnub.js

@@ -4068,7 +4068,7 @@
 	/**
 	 * Whether PubNub client should catch up subscription after network issues.
 	 */
-	const RESTORE = false;
+	const RESTORE = true;
 	/**
 	 * Whether network availability change should be announced with `PNNetworkDownCategory` and
 	 * `PNNetworkUpCategory` state or not.
@@ -4089,7 +4089,7 @@
 	/**
 	 * Whether subscription event engine should be used or not.
 	 */
-	const ENABLE_EVENT_ENGINE = false;
+	const ENABLE_EVENT_ENGINE = true;
 	/**
 	 * Whether configured user presence state should be maintained by the PubNub client or not.
 	 */
@@ -4991,8 +4991,6 @@
 	            validate() {
 	                if (this.delay < 2)
 	                    throw new Error('Delay can not be set less than 2 seconds for retry');
-	                if (this.maximumRetry > 10)
-	                    throw new Error('Maximum retry for linear retry policy can not be more than 10');
 	            },
 	        };
 	    }
@@ -5017,10 +5015,6 @@
 	            validate() {
 	                if (this.minimumDelay < 2)
 	                    throw new Error('Minimum delay can not be set less than 2 seconds for retry');
-	                else if (this.maximumDelay > 150)
-	                    throw new Error('Maximum delay can not be set more than 150 seconds for' + ' retry');
-	                else if (this.maximumRetry > 6)
-	                    throw new Error('Maximum retry for exponential retry policy can not be more than 6');
 	            },
 	        };
 	    }
@@ -5438,7 +5432,7 @@
 	            return base.PubNubFile;
 	        },
 	        get version() {
-	            return '10.2.9';
+	            return '11.0.0';
 	        },
 	        getVersion() {
 	            return this.version;
@@ -9307,6 +9301,7 @@
 	            category: StatusCategory$1.PNConnectedCategory,
 	            affectedChannels: context.channels.slice(0),
 	            affectedChannelGroups: context.groups.slice(0),
+	            operation: RequestOperation$1.PNSubscribeOperation,
 	            currentTimetoken: !!((_d = context.cursor) === null || _d === void 0 ? void 0 : _d.timetoken) ? (_e = context.cursor) === null || _e === void 0 ? void 0 : _e.timetoken : payload.timetoken,
 	        }),
 	    ]);
@@ -9464,7 +9459,7 @@
 	        return UnsubscribedState.with(undefined, [
 	            emitStatus(Object.assign({ category: !payload.isOffline
 	                    ? StatusCategory$1.PNDisconnectedCategory
-	                    : StatusCategory$1.PNDisconnectedUnexpectedlyCategory }, (errorCategory ? { error: errorCategory } : {}))),
+	                    : StatusCategory$1.PNDisconnectedUnexpectedlyCategory, operation: RequestOperation$1.PNUnsubscribeOperation }, (errorCategory ? { error: errorCategory } : {}))),
 	        ]);
 	    }
 	    return ReceivingState.with({
@@ -9510,20 +9505,29 @@
 	    var _a;
 	    if (!event.payload.isOffline) {
 	        return ReceiveStoppedState.with(Object.assign({}, context), [
-	            emitStatus({ category: StatusCategory$1.PNDisconnectedCategory }),
+	            emitStatus({
+	                category: StatusCategory$1.PNDisconnectedCategory,
+	                operation: RequestOperation$1.PNSubscribeOperation,
+	            }),
 	        ]);
 	    }
 	    else {
 	        const errorReason = PubNubAPIError.create(new Error('Network connection error')).toPubNubError(RequestOperation$1.PNSubscribeOperation);
 	        return ReceiveFailedState.with(Object.assign(Object.assign({}, context), { reason: errorReason }), [
 	            emitStatus({
 	                category: StatusCategory$1.PNDisconnectedUnexpectedlyCategory,
+	                operation: RequestOperation$1.PNSubscribeOperation,
 	                error: (_a = errorReason.status) === null || _a === void 0 ? void 0 : _a.category,
 	            }),
 	        ]);
 	    }
 	});
-	ReceivingState.on(unsubscribeAll.type, (_) => UnsubscribedState.with(undefined, [emitStatus({ category: StatusCategory$1.PNDisconnectedCategory })]));
+	ReceivingState.on(unsubscribeAll.type, (_) => UnsubscribedState.with(undefined, [
+	    emitStatus({
+	        category: StatusCategory$1.PNDisconnectedCategory,
+	        operation: RequestOperation$1.PNUnsubscribeOperation,
+	    }),
+	]));
 
 	/**
 	 * Subscribe Event Engine effects dispatcher.

lib/core/components/configuration.js

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

lib/core/components/retry-policy.js

@@ -153,8 +153,6 @@ class RetryPolicy {
             validate() {
                 if (this.delay < 2)
                     throw new Error('Delay can not be set less than 2 seconds for retry');
-                if (this.maximumRetry > 10)
-                    throw new Error('Maximum retry for linear retry policy can not be more than 10');
             },
         };
     }
@@ -179,10 +177,6 @@ class RetryPolicy {
             validate() {
                 if (this.minimumDelay < 2)
                     throw new Error('Minimum delay can not be set less than 2 seconds for retry');
-                else if (this.maximumDelay > 150)
-                    throw new Error('Maximum delay can not be set more than 150 seconds for' + ' retry');
-                else if (this.maximumRetry > 6)
-                    throw new Error('Maximum retry for exponential retry policy can not be more than 6');
             },
         };
     }

lib/core/interfaces/configuration.js

@@ -16,7 +16,7 @@ const USE_SSL = true;
 /**
  * Whether PubNub client should catch up subscription after network issues.
  */
-const RESTORE = false;
+const RESTORE = true;
 /**
  * Whether network availability change should be announced with `PNNetworkDownCategory` and
  * `PNNetworkUpCategory` state or not.
@@ -37,7 +37,7 @@ const FILE_PUBLISH_RETRY_LIMIT = 5;
 /**
  * Whether subscription event engine should be used or not.
  */
-const ENABLE_EVENT_ENGINE = false;
+const ENABLE_EVENT_ENGINE = true;
 /**
  * Whether configured user presence state should be maintained by the PubNub client or not.
  */

lib/event-engine/states/handshaking.js

@@ -56,6 +56,7 @@ exports.HandshakingState.on(events_1.handshakeSuccess.type, (context, { payload
             category: categories_1.default.PNConnectedCategory,
             affectedChannels: context.channels.slice(0),
             affectedChannelGroups: context.groups.slice(0),
+            operation: operations_1.default.PNSubscribeOperation,
             currentTimetoken: !!((_d = context.cursor) === null || _d === void 0 ? void 0 : _d.timetoken) ? (_e = context.cursor) === null || _e === void 0 ? void 0 : _e.timetoken : payload.timetoken,
         }),
     ]);

lib/event-engine/states/receiving.js

@@ -44,7 +44,7 @@ exports.ReceivingState.on(events_1.subscriptionChange.type, (context, { payload
         return unsubscribed_1.UnsubscribedState.with(undefined, [
             (0, effects_1.emitStatus)(Object.assign({ category: !payload.isOffline
                     ? categories_1.default.PNDisconnectedCategory
-                    : categories_1.default.PNDisconnectedUnexpectedlyCategory }, (errorCategory ? { error: errorCategory } : {}))),
+                    : categories_1.default.PNDisconnectedUnexpectedlyCategory, operation: operations_1.default.PNUnsubscribeOperation }, (errorCategory ? { error: errorCategory } : {}))),
         ]);
     }
     return exports.ReceivingState.with({
@@ -90,17 +90,26 @@ exports.ReceivingState.on(events_1.disconnect.type, (context, event) => {
     var _a;
     if (!event.payload.isOffline) {
         return receive_stopped_1.ReceiveStoppedState.with(Object.assign({}, context), [
-            (0, effects_1.emitStatus)({ category: categories_1.default.PNDisconnectedCategory }),
+            (0, effects_1.emitStatus)({
+                category: categories_1.default.PNDisconnectedCategory,
+                operation: operations_1.default.PNSubscribeOperation,
+            }),
         ]);
     }
     else {
         const errorReason = pubnub_api_error_1.PubNubAPIError.create(new Error('Network connection error')).toPubNubError(operations_1.default.PNSubscribeOperation);
         return receive_failed_1.ReceiveFailedState.with(Object.assign(Object.assign({}, context), { reason: errorReason }), [
             (0, effects_1.emitStatus)({
                 category: categories_1.default.PNDisconnectedUnexpectedlyCategory,
+                operation: operations_1.default.PNSubscribeOperation,
                 error: (_a = errorReason.status) === null || _a === void 0 ? void 0 : _a.category,
             }),
         ]);
     }
 });
-exports.ReceivingState.on(events_1.unsubscribeAll.type, (_) => unsubscribed_1.UnsubscribedState.with(undefined, [(0, effects_1.emitStatus)({ category: categories_1.default.PNDisconnectedCategory })]));
+exports.ReceivingState.on(events_1.unsubscribeAll.type, (_) => unsubscribed_1.UnsubscribedState.with(undefined, [
+    (0, effects_1.emitStatus)({
+        category: categories_1.default.PNDisconnectedCategory,
+        operation: operations_1.default.PNUnsubscribeOperation,
+    }),
+]));

lib/types/index.d.ts

@@ -2638,7 +2638,7 @@ declare namespace PubNub {
     /**
      * `true` to allow catch up on the front-end applications.
      *
-     * @default `false`
+     * @default `true`
      */
     restore?: boolean;
     /**
@@ -2685,7 +2685,7 @@ declare namespace PubNub {
      * param description in this table.
      *
      *
-     * @default `false`
+     * @default `true`
      */
     enableEventEngine?: boolean;
     /**

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pubnub",
-  "version": "10.2.9",
+  "version": "11.0.0",
   "author": "PubNub <support@pubnub.com>",
   "description": "Publish & Subscribe Real-time Messaging with PubNub",
   "scripts": {