diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2019-07-01 21:12:14 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2019-07-01 21:12:14 +0900 |
| commit | 03e999875a7678c0e5293b87397ab67040010eeb (patch) | |
| tree | 6451269e48a08baf562e6e57909df33ae95b708a /src/queue/processors/object-storage/delete-file.ts | |
| parent | Set job concurrency to reduce performance issue (diff) | |
| download | sharkey-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.ts | 16 |
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'; }; |