Merge branch 'develop'

1 files changed, 33 insertions, 0 deletions

diff --git a/packages/backend/src/queue/processors/DeleteFileProcessorService.ts b/packages/backend/src/queue/processors/DeleteFileProcessorService.ts
new file mode 100644
index 0000000000..2fb2f56f8d
--- /dev/null
+++ b/packages/backend/src/queue/processors/DeleteFileProcessorService.ts
@@ -0,0 +1,33 @@
+import { Inject, Injectable } from '@nestjs/common';
+import { DI } from '@/di-symbols.js';
+import type { Config } from '@/config.js';
+import type Logger from '@/logger.js';
+import { DriveService } from '@/core/DriveService.js';
+import { QueueLoggerService } from '../QueueLoggerService.js';
+import type Bull from 'bull';
+import type { ObjectStorageFileJobData } from '../types.js';
+import { bindThis } from '@/decorators.js';
+
+@Injectable()
+export class DeleteFileProcessorService {
+	private logger: Logger;
+
+	constructor(
+		@Inject(DI.config)
+		private config: Config,
+
+		private driveService: DriveService,
+		private queueLoggerService: QueueLoggerService,
+	) {
+		this.logger = this.queueLoggerService.logger.createSubLogger('delete-file');
+	}
+
+	@bindThis
+	public async process(job: Bull.Job<ObjectStorageFileJobData>): Promise<string> {
+		const key: string = job.data.key;
+
+		await this.driveService.deleteObjectStorageFile(key);
+
+		return 'Success';
+	}
+}