Create includeDeleteEvents to subcribe options (default: true) in ord…

…er to make it optional

README.md

@@ -86,6 +86,7 @@ const customSubscription = client.subscribe(
   },
   {
     includeCreateEvents: true,
+    includeDeleteEvents: true,
     subscribeAction: 'subscribe_all',
     unsubscribeAction: 'unsubscribe_all',
   },

src/index.ts

@@ -306,6 +306,7 @@ export class DCRFClient implements IStreamingAPI {
 
     options = options ?? {};
     options.includeCreateEvents = options.includeCreateEvents ?? false;
+    options.includeDeleteEvents = options.includeDeleteEvents ?? true;
     options.requestId = options.requestId ?? UUID.generate();
     options.subscribeAction = options.subscribeAction ?? "subscribe_instance";
     options.unsubscribeAction =
@@ -322,10 +323,8 @@ export class DCRFClient implements IStreamingAPI {
 
     const requestId = options.requestId;
 
-    const createSelector = this.buildSubscribeCreateSelector(stream, requestId);
     const updateSelector = this.buildSubscribeUpdateSelector(stream, requestId);
-    const deleteSelector = this.buildSubscribeDeleteSelector(stream, requestId);
-
+
     const handler: (
       data: typeof updateSelector & { payload: { data: any; action: string } }
     ) => void = this.buildSubscribeListener(callback);
@@ -362,8 +361,14 @@ export class DCRFClient implements IStreamingAPI {
     };
 
     addListener(updateSelector);
-    addListener(deleteSelector);
+
+    if (options.includeDeleteEvents) {
+      const deleteSelector = this.buildSubscribeDeleteSelector(stream, requestId);
+      addListener(deleteSelector);
+    }
+
     if (options.includeCreateEvents) {
+      const createSelector = this.buildSubscribeCreateSelector(stream, requestId);
       addListener(createSelector);
     }
 

src/interface.ts

@@ -177,6 +177,7 @@ export type SubscribeOptions = {
   subscribeAction?: string,
   unsubscribeAction?: string,
   includeCreateEvents?: boolean,
+  includeDeleteEvents?: boolean,
 }
 
 export type SubscriptionAction = 'create' | 'update' | 'delete';