summaryrefslogtreecommitdiff
path: root/packages/backend/src/daemons
diff options
context:
space:
mode:
authorHazelnoot <acomputerdog@gmail.com>2024-11-14 15:03:58 -0500
committerHazelnoot <acomputerdog@gmail.com>2025-02-16 19:25:04 -0500
commit561f46b8d4a159fe6f2317a112ca7f0464ef74cc (patch)
tree1250880d0c689ba3a7ed20217ea695f911ec055f /packages/backend/src/daemons
parentadd inbound activity logger for debugging (diff)
downloadsharkey-561f46b8d4a159fe6f2317a112ca7f0464ef74cc.tar.gz
sharkey-561f46b8d4a159fe6f2317a112ca7f0464ef74cc.tar.bz2
sharkey-561f46b8d4a159fe6f2317a112ca7f0464ef74cc.zip
add logging for ActivityLogCleanupService
Diffstat (limited to 'packages/backend/src/daemons')
-rw-r--r--packages/backend/src/daemons/ActivityLogCleanupService.ts13
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