summaryrefslogtreecommitdiff
path: root/src/queue/index.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-02-21 01:30:21 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-02-21 01:30:21 +0900
commit3409a51cca11e611cc9629c0b0587d0c0ff78be2 (patch)
tree473f2d284366d5cf6ac18075985af9e928b13006 /src/queue/index.ts
parent:art: (diff)
downloadmisskey-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.ts26
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',