1 files changed, 50 insertions, 0 deletions
diff --git a/packages/backend/src/queue/processors/CheckExpiredMutingsProcessorService.ts b/packages/backend/src/queue/processors/CheckExpiredMutingsProcessorService.ts
new file mode 100644
index 0000000000..514dc1dcf3
--- /dev/null
+++ b/packages/backend/src/queue/processors/CheckExpiredMutingsProcessorService.ts
@@ -0,0 +1,50 @@
+import { Inject, Injectable } from '@nestjs/common';
+import { In, MoreThan } from 'typeorm';
+import { DI } from '@/di-symbols.js';
+import { MutingsRepository } from '@/models/index.js';
+import { Config } from '@/config.js';
+import type Logger from '@/logger.js';
+import { GlobalEventService } from '@/core/GlobalEventService.js';
+import { QueueLoggerService } from '../QueueLoggerService.js';
+import type Bull from 'bull';
+
+@Injectable()
+export class CheckExpiredMutingsProcessorService {
+	#logger: Logger;
+
+	constructor(
+		@Inject(DI.config)
+		private config: Config,
+
+		@Inject(DI.mutingsRepository)
+		private mutingsRepository: MutingsRepository,
+
+		private globalEventService: GlobalEventService,
+		private queueLoggerService: QueueLoggerService,
+	) {
+		this.#logger = this.queueLoggerService.logger.createSubLogger('check-expired-mutings');
+	}
+
+	public async process(job: Bull.Job<Record<string, unknown>>, done: () => void): Promise<void> {
+		this.#logger.info('Checking expired mutings...');
+
+		const expired = await this.mutingsRepository.createQueryBuilder('muting')
+			.where('muting.expiresAt IS NOT NULL')
+			.andWhere('muting.expiresAt < :now', { now: new Date() })
+			.innerJoinAndSelect('muting.mutee', 'mutee')
+			.getMany();
+
+		if (expired.length > 0) {
+			await this.mutingsRepository.delete({
+				id: In(expired.map(m => m.id)),
+			});
+
+			for (const m of expired) {
+				this.globalEventService.publishUserEvent(m.muterId, 'unmute', m.mutee!);
+			}
+		}
+
+		this.#logger.succ('All expired mutings checked.');
+		done();
+	}
+}