summaryrefslogtreecommitdiff
path: root/src/queue/processors/object-storage/delete-file.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-07-01 21:12:14 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-07-01 21:12:14 +0900
commit03e999875a7678c0e5293b87397ab67040010eeb (patch)
tree6451269e48a08baf562e6e57909df33ae95b708a /src/queue/processors/object-storage/delete-file.ts
parentSet job concurrency to reduce performance issue (diff)
downloadsharkey-03e999875a7678c0e5293b87397ab67040010eeb.tar.gz
sharkey-03e999875a7678c0e5293b87397ab67040010eeb.tar.bz2
sharkey-03e999875a7678c0e5293b87397ab67040010eeb.zip
リモートファイルの削除が重い問題を修正
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';
};