diff --git a/packages/backend/src/queue/processors/system/check-expired.ts b/packages/backend/src/queue/processors/system/check-expired.ts index 0666367f3..ba344b712 100644 --- a/packages/backend/src/queue/processors/system/check-expired.ts +++ b/packages/backend/src/queue/processors/system/check-expired.ts @@ -1,6 +1,6 @@ import Bull from 'bull'; import { In, LessThan } from 'typeorm'; -import { AttestationChallenges, AuthSessions, Mutings, PasswordResetRequests, Signins } from '@/models/index.js'; +import { AttestationChallenges, AuthSessions, Mutings, Notifications, PasswordResetRequests, Signins } from '@/models/index.js'; import { publishUserEvent } from '@/services/stream.js'; import { MINUTE, DAY, MONTH } from '@/const.js'; import { queueLogger } from '@/queue/logger.js'; @@ -47,6 +47,11 @@ export async function checkExpired(job: Bull.Job>, done: createdAt: OlderThan(15 * MINUTE), }); + await Notifications.delete({ + isRead: true, + createdAt: OlderThan(3 * MONTH), + }); + logger.succ('Deleted expired data.'); done();