summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/QueueService.ts
diff options
context:
space:
mode:
authorMar0xy <marie@kaifa.ch>2023-11-22 16:00:46 +0100
committerMar0xy <marie@kaifa.ch>2023-11-22 16:00:46 +0100
commitd078a72f38d9722bcb6b6b9c657011c54d34b37b (patch)
tree6e41e11afc06304cec4e3c6489f0ed9275265dca /packages/backend/src/core/QueueService.ts
parentchore: remove unused type (diff)
downloadsharkey-d078a72f38d9722bcb6b6b9c657011c54d34b37b.tar.gz
sharkey-d078a72f38d9722bcb6b6b9c657011c54d34b37b.tar.bz2
sharkey-d078a72f38d9722bcb6b6b9c657011c54d34b37b.zip
upd: add `Facebook` to note importing
Diffstat (limited to 'packages/backend/src/core/QueueService.ts')
-rw-r--r--packages/backend/src/core/QueueService.ts8
1 files changed, 7 insertions, 1 deletions
diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts
index 7135f1b1b4..0230c9a7b8 100644
--- a/packages/backend/src/core/QueueService.ts
+++ b/packages/backend/src/core/QueueService.ts
@@ -302,6 +302,12 @@ export class QueueService {
}
@bindThis
+ public createImportFBToDbJob(user: ThinUser, targets: string[]) {
+ const jobs = targets.map(rel => this.generateToDbJobData('importFBToDb', { user, target: rel }));
+ return this.dbQueue.addBulk(jobs);
+ }
+
+ @bindThis
public createImportFollowingToDbJob(user: ThinUser, targets: string[], withReplies?: boolean) {
const jobs = targets.map(rel => this.generateToDbJobData('importFollowingToDb', { user, target: rel, withReplies }));
return this.dbQueue.addBulk(jobs);
@@ -336,7 +342,7 @@ export class QueueService {
}
@bindThis
- private generateToDbJobData<T extends 'importFollowingToDb' | 'importBlockingToDb' | 'importTweetsToDb' | 'importIGToDb' | 'importMastoToDb' | 'importPleroToDb' | 'importKeyNotesToDb', D extends DbJobData<T>>(name: T, data: D): {
+ private generateToDbJobData<T extends 'importFollowingToDb' | 'importBlockingToDb' | 'importTweetsToDb' | 'importIGToDb' | 'importFBToDb' | 'importMastoToDb' | 'importPleroToDb' | 'importKeyNotesToDb', D extends DbJobData<T>>(name: T, data: D): {
name: string,
data: D,
opts: Bull.JobsOptions,