diff options
| author | Hazelnoot <acomputerdog@gmail.com> | 2024-11-14 15:03:58 -0500 |
|---|---|---|
| committer | Hazelnoot <acomputerdog@gmail.com> | 2025-02-16 19:25:04 -0500 |
| commit | 561f46b8d4a159fe6f2317a112ca7f0464ef74cc (patch) | |
| tree | 1250880d0c689ba3a7ed20217ea695f911ec055f /packages/backend/src | |
| parent | add inbound activity logger for debugging (diff) | |
| download | sharkey-561f46b8d4a159fe6f2317a112ca7f0464ef74cc.tar.gz sharkey-561f46b8d4a159fe6f2317a112ca7f0464ef74cc.tar.bz2 sharkey-561f46b8d4a159fe6f2317a112ca7f0464ef74cc.zip | |
add logging for ActivityLogCleanupService
Diffstat (limited to 'packages/backend/src')
| -rw-r--r-- | packages/backend/src/daemons/ActivityLogCleanupService.ts | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/packages/backend/src/daemons/ActivityLogCleanupService.ts b/packages/backend/src/daemons/ActivityLogCleanupService.ts index e2ffef3c5f..bf5ddec05d 100644 --- a/packages/backend/src/daemons/ActivityLogCleanupService.ts +++ b/packages/backend/src/daemons/ActivityLogCleanupService.ts @@ -9,12 +9,15 @@ import { DI } from '@/di-symbols.js'; import type { Config } from '@/config.js'; import { bindThis } from '@/decorators.js'; import type { ActivityLogsRepository } from '@/models/_.js'; +import { LoggerService } from '@/core/LoggerService.js'; +import Logger from '@/logger.js'; // 10 minutes export const scanInterval = 1000 * 60 * 10; @Injectable() export class ActivityLogCleanupService implements OnApplicationShutdown { + private readonly logger: Logger; private scanTimer: NodeJS.Timeout | null = null; constructor( @@ -23,7 +26,11 @@ export class ActivityLogCleanupService implements OnApplicationShutdown { @Inject(DI.activityLogsRepository) private readonly activityLogsRepository: ActivityLogsRepository, - ) {} + + loggerService: LoggerService, + ) { + this.logger = loggerService.getLogger('activity-log-cleanup'); + } @bindThis public async start(): Promise<void> { @@ -44,9 +51,11 @@ export class ActivityLogCleanupService implements OnApplicationShutdown { const oldestAllowed = new Date(Date.now() - this.config.activityLogging.maxAge); // Delete all logs older than the threshold. - await this.activityLogsRepository.delete({ + const { affected } = await this.activityLogsRepository.delete({ at: LessThan(oldestAllowed), }); + + this.logger.info(`Activity Log cleanup complete; removed ${affected ?? 0} expired logs.`); } @bindThis |