summaryrefslogtreecommitdiff
path: root/src/queue/processors/object-storage/delete-file.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/processors/object-storage/delete-file.ts')
-rw-r--r--src/queue/processors/object-storage/delete-file.ts16
1 files changed, 2 insertions, 14 deletions
diff --git a/src/queue/processors/object-storage/delete-file.ts b/src/queue/processors/object-storage/delete-file.ts
index 8e6b5f959e..f899df7d2e 100644
--- a/src/queue/processors/object-storage/delete-file.ts
+++ b/src/queue/processors/object-storage/delete-file.ts
@@ -1,22 +1,10 @@
import * as Bull from 'bull';
-import * as Minio from 'minio';
-import { fetchMeta } from '../../../misc/fetch-meta';
+import { deleteObjectStorageFile } from '../../../services/drive/delete-file';
export default async (job: Bull.Job) => {
- const meta = await fetchMeta();
-
- const minio = new Minio.Client({
- endPoint: meta.objectStorageEndpoint!,
- region: meta.objectStorageRegion ? meta.objectStorageRegion : undefined,
- port: meta.objectStoragePort ? meta.objectStoragePort : undefined,
- useSSL: meta.objectStorageUseSSL,
- accessKey: meta.objectStorageAccessKey!,
- secretKey: meta.objectStorageSecretKey!,
- });
-
const key: string = job.data.key;
- await minio.removeObject(meta.objectStorageBucket!, key);
+ await deleteObjectStorageFile(key);
return 'Success';
};