Added default workers for loading deletion events (#13)

Author: radovan-jorgic

README.md

@@ -2,6 +2,10 @@
 
 ## Release Notes
 
+#### v1.1.1
+
+- Added default workers for loading deletion events.
+
 #### v1.1.0
 
 - Support for sync from DevRev to external system. Known limitations: no support for loading attachments.

package.json

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

src/workers/default-workers/loader-state-deletion.ts

@@ -0,0 +1,14 @@
+import { processTask, LoaderEventType } from '../../index';
+
+processTask({
+  task: async ({ adapter }) => {
+    await adapter.emit(LoaderEventType.LoaderStateDeletionDone);
+  },
+  onTimeout: async ({ adapter }) => {
+    await adapter.emit(LoaderEventType.LoaderStateDeletionError, {
+      error: {
+        message: 'Failed to delete data. Lambda timeout.',
+      },
+    });
+  },
+});

src/workers/spawn.ts

@@ -58,6 +58,9 @@ function getWorkerPath({
     case EventType.ContinueLoadingData:
       path = __dirname + '/default-workers/data-loading';
       break;
+    case EventType.StartDeletingLoaderState:
+      path = __dirname + '/default-workers/loader-state-deletion';
+      break;
 
     default:
       emit({