diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2019-02-21 01:30:21 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2019-02-21 01:30:21 +0900 |
| commit | 3409a51cca11e611cc9629c0b0587d0c0ff78be2 (patch) | |
| tree | 473f2d284366d5cf6ac18075985af9e928b13006 /src/queue/index.ts | |
| parent | :art: (diff) | |
| download | misskey-3409a51cca11e611cc9629c0b0587d0c0ff78be2.tar.gz misskey-3409a51cca11e611cc9629c0b0587d0c0ff78be2.tar.bz2 misskey-3409a51cca11e611cc9629c0b0587d0c0ff78be2.zip | |
Resolve #2017
Diffstat (limited to 'src/queue/index.ts')
| -rw-r--r-- | src/queue/index.ts | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts index 7dc2319f50..9f874fea04 100644 --- a/src/queue/index.ts +++ b/src/queue/index.ts @@ -70,6 +70,32 @@ export function processInbox(activity: any, signature: httpSignature.IParsedSign } } +export function createDeleteNotesJob(user: ILocalUser) { + const data = { + type: 'deleteNotes', + user: user + }; + + if (queueAvailable && enableQueueProcessing) { + return queue.createJob(data).save(); + } else { + return handler({ data }, () => {}); + } +} + +export function createDeleteDriveFilesJob(user: ILocalUser) { + const data = { + type: 'deleteDriveFiles', + user: user + }; + + if (queueAvailable && enableQueueProcessing) { + return queue.createJob(data).save(); + } else { + return handler({ data }, () => {}); + } +} + export function createExportNotesJob(user: ILocalUser) { const data = { type: 'exportNotes', |