diff --git a/README.md b/README.md index 186ad02..67de3fd 100644 --- a/README.md +++ b/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. diff --git a/package.json b/package.json index 0a80187..804eeda 100644 --- a/package.json +++ b/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", diff --git a/src/workers/default-workers/loader-state-deletion.ts b/src/workers/default-workers/loader-state-deletion.ts new file mode 100644 index 0000000..1858dd6 --- /dev/null +++ b/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.', + }, + }); + }, +}); diff --git a/src/workers/spawn.ts b/src/workers/spawn.ts index 3eda5cb..3994ab8 100644 --- a/src/workers/spawn.ts +++ b/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({