oscar-surf/misskey
oscar-surf/misskey
0
0
Fork 0
Code Issues Activity

fix(queue): I love NestJS ❤️

Browse source
This commit is contained in:
무라쿠모 2024-09-06 17:33:33 +09:00
parent 9a37ae7254
commit f01e03eedb
No known key found for this signature in database
GPG key ID: 139D6573F92DA9F7
3 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
packages/backend/src/queue/QueueProcessorModule.ts
View file

@ -19,6 +19,7 @@ import { CleanRemoteFilesProcessorService } from './processors/CleanRemoteFilesP
import { DeleteAccountProcessorService } from './processors/DeleteAccountProcessorService.js'; import { DeleteAccountProcessorService } from './processors/DeleteAccountProcessorService.js';
import { DeleteDriveFilesProcessorService } from './processors/DeleteDriveFilesProcessorService.js'; import { DeleteDriveFilesProcessorService } from './processors/DeleteDriveFilesProcessorService.js';
import { DeleteFileProcessorService } from './processors/DeleteFileProcessorService.js'; import { DeleteFileProcessorService } from './processors/DeleteFileProcessorService.js';
import { ReindexNotesProcessorService } from './processors/ReindexNotesProcessorService.js';
import { ExportBlockingProcessorService } from './processors/ExportBlockingProcessorService.js'; import { ExportBlockingProcessorService } from './processors/ExportBlockingProcessorService.js';
import { ExportCustomEmojisProcessorService } from './processors/ExportCustomEmojisProcessorService.js'; import { ExportCustomEmojisProcessorService } from './processors/ExportCustomEmojisProcessorService.js';
import { ExportFollowingProcessorService } from './processors/ExportFollowingProcessorService.js'; import { ExportFollowingProcessorService } from './processors/ExportFollowingProcessorService.js';
@ -53,6 +54,7 @@ import { RelationshipProcessorService } from './processors/RelationshipProcessor
CheckExpiredMutingsProcessorService, CheckExpiredMutingsProcessorService,
CleanProcessorService, CleanProcessorService,
DeleteDriveFilesProcessorService, DeleteDriveFilesProcessorService,
ReindexNotesProcessorService,
ExportCustomEmojisProcessorService, ExportCustomEmojisProcessorService,
ExportNotesProcessorService, ExportNotesProcessorService,
ExportClipsProcessorService, ExportClipsProcessorService,

2
packages/backend/src/queue/QueueProcessorService.ts
View file

@ -9,7 +9,7 @@ import type { Config } from '@/config.js';
import { DI } from '@/di-symbols.js'; import { DI } from '@/di-symbols.js';
import type Logger from '@/logger.js'; import type Logger from '@/logger.js';
import { bindThis } from '@/decorators.js'; import { bindThis } from '@/decorators.js';
import { ReindexNotesProcessorService } from "@/queue/processors/ReindexNotesProcessorService.js"; import { ReindexNotesProcessorService } from './processors/ReindexNotesProcessorService.js';
import { WebhookDeliverProcessorService } from './processors/WebhookDeliverProcessorService.js'; import { WebhookDeliverProcessorService } from './processors/WebhookDeliverProcessorService.js';
import { EndedPollNotificationProcessorService } from './processors/EndedPollNotificationProcessorService.js'; import { EndedPollNotificationProcessorService } from './processors/EndedPollNotificationProcessorService.js';
import { DeliverProcessorService } from './processors/DeliverProcessorService.js'; import { DeliverProcessorService } from './processors/DeliverProcessorService.js';

4
packages/backend/src/queue/processors/ReindexNotesProcessorService.ts
View file

@ -24,7 +24,7 @@ export class ReindexNotesProcessorService {
private searchService: SearchService, private searchService: SearchService,
private queueLoggerService: QueueLoggerService, private queueLoggerService: QueueLoggerService,
) { ) {
this.logger = this.queueLoggerService.logger.createSubLogger('clean-remote-files'); this.logger = this.queueLoggerService.logger.createSubLogger('reindex-notes');
} }
@bindThis @bindThis
@ -69,7 +69,7 @@ export class ReindexNotesProcessorService {
id: LessThanOrEqual(lastNote.id), id: LessThanOrEqual(lastNote.id),
}); });
job.updateProgress(100 / total * indexedCount); await job.updateProgress(100 / total * indexedCount);
} }
this.logger.succ('Successfully re-indexed all notes to search engine.'); this.logger.succ('Successfully re-indexed all notes to search engine.');