set enableEventEngine to true, restore flag to true by default,

fix titanium test to equate expected operation type

Author: Mohit Tejani

src/core/interfaces/configuration.ts

@@ -23,7 +23,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
@@ -49,7 +49,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.
@@ -250,7 +250,7 @@ export type UserConfiguration = {
   /**
    * `true` to allow catch up on the front-end applications.
    *
-   * @default `false`
+   * @default `true`
    */
   restore?: boolean;
 
@@ -303,7 +303,7 @@ export type UserConfiguration = {
    * param description in this table.
    *
    *
-   * @default `false`
+   * @default `true`
    */
   enableEventEngine?: boolean;
 

src/event-engine/states/handshaking.ts

@@ -77,6 +77,7 @@ HandshakingState.on(handshakeSuccess.type, (context, { payload }) =>
         category: categoryConstants.PNConnectedCategory,
         affectedChannels: context.channels.slice(0),
         affectedChannelGroups: context.groups.slice(0),
+        operation: RequestOperation.PNSubscribeOperation,
         currentTimetoken: !!context.cursor?.timetoken ? context.cursor?.timetoken : payload.timetoken,
       }),
     ],

src/event-engine/states/receiving.ts

@@ -76,6 +76,7 @@ ReceivingState.on(subscriptionChange.type, (context, { payload }) => {
         category: !payload.isOffline
           ? categoryConstants.PNDisconnectedCategory
           : categoryConstants.PNDisconnectedUnexpectedlyCategory,
+        operation: RequestOperation.PNUnsubscribeOperation,
         ...(errorCategory ? { error: errorCategory } : {}),
       }),
     ]);
@@ -136,7 +137,10 @@ ReceivingState.on(receiveFailure.type, (context, { payload }) =>
 ReceivingState.on(disconnect.type, (context, event) => {
   if (!event.payload.isOffline) {
     return ReceiveStoppedState.with({ ...context }, [
-      emitStatus({ category: categoryConstants.PNDisconnectedCategory }),
+      emitStatus({
+        category: categoryConstants.PNDisconnectedCategory,
+        operation: RequestOperation.PNUnsubscribeOperation,
+      }),
     ]);
   } else {
     const errorReason = PubNubAPIError.create(new Error('Network connection error')).toPubNubError(
@@ -146,12 +150,18 @@ ReceivingState.on(disconnect.type, (context, event) => {
     return ReceiveFailedState.with({ ...context, reason: errorReason }, [
       emitStatus({
         category: categoryConstants.PNDisconnectedUnexpectedlyCategory,
+        operation: RequestOperation.PNUnsubscribeOperation,
         error: errorReason.status?.category,
       }),
     ]);
   }
 });
 
 ReceivingState.on(unsubscribeAll.type, (_) =>
-  UnsubscribedState.with(undefined, [emitStatus({ category: categoryConstants.PNDisconnectedCategory })]),
+  UnsubscribedState.with(undefined, [
+    emitStatus({
+      category: categoryConstants.PNDisconnectedCategory,
+      operation: RequestOperation.PNUnsubscribeOperation,
+    }),
+  ]),
 );

test/dist/web-titanium.test.js

@@ -150,9 +150,7 @@ describe('#distribution test (titanium)', function () {
   });
 
   it('should have to unsubscribe', function (done) {
-    pubnub.disconnect();
-    pubnub.removeListener(listener);
-    pubnub.reconnect();
+    pubnub.subscribe({ channels: [myChannel1] });
 
     var finished = false;
 
@@ -171,6 +169,6 @@ describe('#distribution test (titanium)', function () {
         }
       },
     });
-    pubnub.unsubscribe({ channels: [myChannel1] });
+    pubnub.unsubscribeAll();
   });
-});
+});