summaryrefslogtreecommitdiff
path: root/src/queue/index.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2021-10-20 01:11:13 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2021-10-20 01:11:13 +0900
commitbc19cd77adfc1ba73df5358dac0a7b49166b02ac (patch)
treec142dd6ae9baf9c6e3a4d6bbf7f465bc2e1fb933 /src/queue/index.ts
parentrefactor: use insert (diff)
downloadsharkey-bc19cd77adfc1ba73df5358dac0a7b49166b02ac.tar.gz
sharkey-bc19cd77adfc1ba73df5358dac0a7b49166b02ac.tar.bz2
sharkey-bc19cd77adfc1ba73df5358dac0a7b49166b02ac.zip
feat: ミュートとブロックのインポート
Resolve #7885
Diffstat (limited to 'src/queue/index.ts')
-rw-r--r--src/queue/index.ts20
1 files changed, 20 insertions, 0 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts
index 1e1d5da5a2..43c062bae7 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -163,6 +163,26 @@ export function createImportFollowingJob(user: ThinUser, fileId: DriveFile['id']
});
}
+export function createImportMutingJob(user: ThinUser, fileId: DriveFile['id']) {
+ return dbQueue.add('importMuting', {
+ user: user,
+ fileId: fileId
+ }, {
+ removeOnComplete: true,
+ removeOnFail: true
+ });
+}
+
+export function createImportBlockingJob(user: ThinUser, fileId: DriveFile['id']) {
+ return dbQueue.add('importBlocking', {
+ user: user,
+ fileId: fileId
+ }, {
+ removeOnComplete: true,
+ removeOnFail: true
+ });
+}
+
export function createImportUserListsJob(user: ThinUser, fileId: DriveFile['id']) {
return dbQueue.add('importUserLists', {
user: user,