Sleep if timeout is hit during default attachments processing

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@devrev/ts-adaas",
-  "version": "1.5.0",
+  "version": "1.5.1",
   "description": "Typescript library containing the ADaaS(AirDrop as a Service) control protocol.",
   "type": "commonjs",
   "main": "./dist/index.js",

src/common/constants.ts

@@ -43,3 +43,5 @@ export const AIRDROP_DEFAULT_ITEM_TYPES = {
 };
 
 export const LIBRARY_VERSION = getLibraryVersion();
+
+export const DEFAULT_SLEEP_DELAY_MS = 180000; // 3 minutes

src/common/helpers.ts

@@ -194,3 +194,8 @@ export function getLibraryVersion() {
     return '';
   }
 }
+
+export function sleep(ms: number) {
+  console.log(`Sleeping for ${ms}ms.`);
+  return new Promise((resolve) => setTimeout(resolve, ms));
+}

src/workers/worker-adapter.ts

@@ -25,6 +25,7 @@ import {
   AIRDROP_DEFAULT_ITEM_TYPES,
   ALLOWED_EXTRACTION_EVENT_TYPES,
   STATELESS_EVENT_TYPES,
+  DEFAULT_SLEEP_DELAY_MS,
 } from '../common/constants';
 import { State } from '../state/state';
 import { WorkerAdapterInterface, WorkerAdapterOptions } from '../types/workers';
@@ -46,6 +47,7 @@ import { Mappers } from '../mappers/mappers';
 import { Uploader } from '../uploader/uploader';
 import { serializeAxiosError } from '../logger/logger';
 import { SyncMapperRecordStatus } from '../mappers/mappers.interface';
+import { sleep } from '../common/helpers';
 
 export function createWorkerAdapter<ConnectorState>({
   event,
@@ -877,6 +879,12 @@ export class WorkerAdapter<ConnectorState> {
 
     // Loop through the batches of attachments
     for (let i = lastProcessedBatchIndex; i < reducedAttachments.length; i++) {
+
+      // Check if we hit timeout 
+      if (adapter.isTimeout) {
+        await sleep(DEFAULT_SLEEP_DELAY_MS);
+      }
+
       const attachmentsBatch = reducedAttachments[i];
 
       // Create a list of promises for parallel processing