diff options
| author | Hazelnoot <acomputerdog@gmail.com> | 2025-02-16 14:23:55 -0500 |
|---|---|---|
| committer | Hazelnoot <acomputerdog@gmail.com> | 2025-03-21 12:37:06 -0400 |
| commit | f2bb01f7da62159d1e9be828d9b5840c1677fce9 (patch) | |
| tree | c72fc70e48b037a563667d8e94e9a731d655844a /packages/backend/src/queue | |
| parent | allow overriding AP resolver recursion limit (diff) | |
| download | sharkey-f2bb01f7da62159d1e9be828d9b5840c1677fce9.tar.gz sharkey-f2bb01f7da62159d1e9be828d9b5840c1677fce9.tar.bz2 sharkey-f2bb01f7da62159d1e9be828d9b5840c1677fce9.zip | |
support Announce(Activity) activities
Diffstat (limited to 'packages/backend/src/queue')
| -rw-r--r-- | packages/backend/src/queue/processors/InboxProcessorService.ts | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts index e128108779..839c8c183a 100644 --- a/packages/backend/src/queue/processors/InboxProcessorService.ts +++ b/packages/backend/src/queue/processors/InboxProcessorService.ts @@ -4,7 +4,7 @@ */ import { URL } from 'node:url'; -import { Inject, Injectable, OnApplicationShutdown } from '@nestjs/common'; +import { forwardRef, Inject, Injectable, OnApplicationShutdown } from '@nestjs/common'; import httpSignature from '@peertube/http-signature'; import * as Bull from 'bullmq'; import type Logger from '@/logger.js'; @@ -43,7 +43,7 @@ type UpdateInstanceJob = { @Injectable() export class InboxProcessorService implements OnApplicationShutdown { private logger: Logger; - private updateInstanceQueue: CollapsedQueue<MiNote['id'], UpdateInstanceJob>; + public readonly updateInstanceQueue: CollapsedQueue<MiNote['id'], UpdateInstanceJob>; constructor( @Inject(DI.meta) @@ -53,6 +53,8 @@ export class InboxProcessorService implements OnApplicationShutdown { private config: Config, private utilityService: UtilityService, + + @Inject(forwardRef(() => ApInboxService)) private apInboxService: ApInboxService, private federatedInstanceService: FederatedInstanceService, private fetchInstanceMetadataService: FetchInstanceMetadataService, |