kaslo/pawkey-sk
1
0
Fork 0
Code Packages Activity

support Announce(Activity) activities

Browse Source
This commit is contained in:
Hazelnoot
2025-02-16 14:23:55 -05:00
parent 1eb9070e39
commit f2bb01f7da
2 changed files with 84 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/backend/src/queue/processors/InboxProcessorService.ts
+4 -2
View File
@@ -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,