@@ -25,7 +25,16 @@ import { getNoteSummary } from '@/misc/get-note-summary.js';
2525import { DI } from '@/di-symbols.js' ;
2626import * as Acct from '@/misc/acct.js' ;
2727import { MetaService } from '@/core/MetaService.js' ;
28- import type { DbQueue , DeliverQueue , EndedPollNotificationQueue , InboxQueue , ObjectStorageQueue , SystemQueue , WebhookDeliverQueue } from '@/core/QueueModule.js' ;
28+ import type {
29+ DbQueue ,
30+ DeliverQueue ,
31+ EndedPollNotificationQueue ,
32+ InboxQueue ,
33+ ObjectStorageQueue ,
34+ RelationshipQueue ,
35+ SystemQueue ,
36+ WebhookDeliverQueue ,
37+ } from '@/core/QueueModule.js' ;
2938import { UserEntityService } from '@/core/entities/UserEntityService.js' ;
3039import { NoteEntityService } from '@/core/entities/NoteEntityService.js' ;
3140import { PageEntityService } from '@/core/entities/PageEntityService.js' ;
@@ -110,6 +119,7 @@ export class ClientServerService {
110119 @Inject ( 'queue:deliver' ) public deliverQueue : DeliverQueue ,
111120 @Inject ( 'queue:inbox' ) public inboxQueue : InboxQueue ,
112121 @Inject ( 'queue:db' ) public dbQueue : DbQueue ,
122+ @Inject ( 'queue:relationship' ) public relationshipQueue : RelationshipQueue ,
113123 @Inject ( 'queue:objectStorage' ) public objectStorageQueue : ObjectStorageQueue ,
114124 @Inject ( 'queue:webhookDeliver' ) public webhookDeliverQueue : WebhookDeliverQueue ,
115125 ) {
@@ -237,6 +247,7 @@ export class ClientServerService {
237247 this . endedPollNotificationQueue ,
238248 this . inboxQueue ,
239249 this . dbQueue ,
250+ this . relationshipQueue ,
240251 this . objectStorageQueue ,
241252 this . webhookDeliverQueue ,
242253 ] . map ( q => new BullMQAdapter ( q ) )
0 commit comments