diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2019-05-27 16:54:47 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2019-05-27 16:54:47 +0900 |
| commit | 72fb23f4d51db1b999a10b7d8bb50293a81af163 (patch) | |
| tree | 07a7fa62cb7a822ce3759db5b2035368cd4e8e29 /src/queue/processors/object-storage/index.ts | |
| parent | Improve post form (diff) | |
| download | misskey-72fb23f4d51db1b999a10b7d8bb50293a81af163.tar.gz misskey-72fb23f4d51db1b999a10b7d8bb50293a81af163.tar.bz2 misskey-72fb23f4d51db1b999a10b7d8bb50293a81af163.zip | |
Improve drive management
Diffstat (limited to 'src/queue/processors/object-storage/index.ts')
| -rw-r--r-- | src/queue/processors/object-storage/index.ts | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/src/queue/processors/object-storage/index.ts b/src/queue/processors/object-storage/index.ts new file mode 100644 index 0000000000..f2fc08f1ab --- /dev/null +++ b/src/queue/processors/object-storage/index.ts @@ -0,0 +1,12 @@ +import * as Bull from 'bull'; +import deleteFile from './delete-file'; + +const jobs = { + deleteFile, +} as any; + +export default function(q: Bull.Queue) { + for (const [k, v] of Object.entries(jobs)) { + q.process(k, v as any); + } +} |