summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/QueueService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-01-01 16:53:10 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-01-01 16:53:10 +0900
commite414737179bff4b744f49e431d7f3620be999e46 (patch)
tree44c0a28d523fd7841fd5fa7ba9298edaf27163a8 /packages/backend/src/core/QueueService.ts
parent:art: (diff)
downloadsharkey-e414737179bff4b744f49e431d7f3620be999e46.tar.gz
sharkey-e414737179bff4b744f49e431d7f3620be999e46.tar.bz2
sharkey-e414737179bff4b744f49e431d7f3620be999e46.zip
feat: make possible to export favorited notes
#9331
Diffstat (limited to 'packages/backend/src/core/QueueService.ts')
-rw-r--r--packages/backend/src/core/QueueService.ts12
1 files changed, 11 insertions, 1 deletions
diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts
index 7956a3a8f9..4bf41e0ac1 100644
--- a/packages/backend/src/core/QueueService.ts
+++ b/packages/backend/src/core/QueueService.ts
@@ -5,10 +5,10 @@ import type { DriveFile } from '@/models/entities/DriveFile.js';
import type { Webhook, webhookEventTypes } from '@/models/entities/Webhook.js';
import type { Config } from '@/config.js';
import { DI } from '@/di-symbols.js';
+import { bindThis } from '@/decorators.js';
import type { DbQueue, DeliverQueue, EndedPollNotificationQueue, InboxQueue, ObjectStorageQueue, SystemQueue, WebhookDeliverQueue } from './QueueModule.js';
import type { ThinUser } from '../queue/types.js';
import type httpSignature from '@peertube/http-signature';
-import { bindThis } from '@/decorators.js';
@Injectable()
export class QueueService {
@@ -98,6 +98,16 @@ export class QueueService {
}
@bindThis
+ public createExportFavoritesJob(user: ThinUser) {
+ return this.dbQueue.add('exportFavorites', {
+ user: user,
+ }, {
+ removeOnComplete: true,
+ removeOnFail: true,
+ });
+ }
+
+ @bindThis
public createExportFollowingJob(user: ThinUser, excludeMuting = false, excludeInactive = false) {
return this.dbQueue.add('exportFollowing', {
user: user,