diff options
author | eug-vs <eug-vs@keemail.me> | 2020-08-17 23:40:16 +0300 |
---|---|---|
committer | eug-vs <eug-vs@keemail.me> | 2020-08-17 23:40:39 +0300 |
commit | 1cddff7de99c6b209d35137ceb7cde3045573dc0 (patch) | |
tree | dde301d6529fc1140e413c9cd3db8c4033cff552 /hooks | |
parent | c43e6d185b7606ff8c0d038746b9e376e04143b5 (diff) | |
download | which-api-1cddff7de99c6b209d35137ceb7cde3045573dc0.tar.gz |
feat: cleanup after poll deletion
Diffstat (limited to 'hooks')
-rw-r--r-- | hooks/deleteImages.ts | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/hooks/deleteImages.ts b/hooks/deleteImages.ts new file mode 100644 index 0000000..8bfa47c --- /dev/null +++ b/hooks/deleteImages.ts @@ -0,0 +1,32 @@ +import { HookContext } from '@feathersjs/feathers'; +import Bluebird from 'bluebird'; +import _ from 'lodash'; +import Debug from 'debug'; + +const debug = Debug('s3-reuploads'); + +export default (paths: string[]) => async (context: HookContext): Promise<HookContext> => { + const { + service, + app, + id + } = context; + + const fileService = app.service('files'); + const model = service.Model; + const instance = await model.findOne({ _id: id }); + + Bluebird.map(paths, async (path: string) => { + const url = _.get(instance, path); + + // If image is not from our s3, fetch it! + if (fileService.isS3url(url)) { + debug('Found s3 url! Deleting...'); + const s3Path = fileService.getS3PathFromUrl(url); + await fileService.deleteFile(s3Path); + debug(`Deleted: ${s3Path}`); + } + }); + return context; +}; + |