refactor: introduce bindThis decorator to bind this automaticaly

1 files changed, 20 insertions, 0 deletions

diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts
index a27d68ee19..7956a3a8f9 100644
--- a/packages/backend/src/core/QueueService.ts
+++ b/packages/backend/src/core/QueueService.ts
@@ -8,6 +8,7 @@ import { DI } from '@/di-symbols.js';
 import type { DbQueue, DeliverQueue, EndedPollNotificationQueue, InboxQueue, ObjectStorageQueue, SystemQueue, WebhookDeliverQueue } from './QueueModule.js';
 import type { ThinUser } from '../queue/types.js';
 import type httpSignature from '@peertube/http-signature';
+import { bindThis } from '@/decorators.js';
 
 @Injectable()
 export class QueueService {
@@ -24,6 +25,7 @@ export class QueueService {
 		@Inject('queue:webhookDeliver') public webhookDeliverQueue: WebhookDeliverQueue,
 	) {}
 
+	@bindThis
 	public deliver(user: ThinUser, content: IActivity | null, to: string | null) {
 		if (content == null) return null;
 		if (to == null) return null;
@@ -47,6 +49,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public inbox(activity: IActivity, signature: httpSignature.IParsedSignature) {
 		const data = {
 			activity: activity,
@@ -64,6 +67,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createDeleteDriveFilesJob(user: ThinUser) {
 		return this.dbQueue.add('deleteDriveFiles', {
 			user: user,
@@ -73,6 +77,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createExportCustomEmojisJob(user: ThinUser) {
 		return this.dbQueue.add('exportCustomEmojis', {
 			user: user,
@@ -82,6 +87,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createExportNotesJob(user: ThinUser) {
 		return this.dbQueue.add('exportNotes', {
 			user: user,
@@ -91,6 +97,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createExportFollowingJob(user: ThinUser, excludeMuting = false, excludeInactive = false) {
 		return this.dbQueue.add('exportFollowing', {
 			user: user,
@@ -102,6 +109,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createExportMuteJob(user: ThinUser) {
 		return this.dbQueue.add('exportMuting', {
 			user: user,
@@ -111,6 +119,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createExportBlockingJob(user: ThinUser) {
 		return this.dbQueue.add('exportBlocking', {
 			user: user,
@@ -120,6 +129,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createExportUserListsJob(user: ThinUser) {
 		return this.dbQueue.add('exportUserLists', {
 			user: user,
@@ -129,6 +139,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createImportFollowingJob(user: ThinUser, fileId: DriveFile['id']) {
 		return this.dbQueue.add('importFollowing', {
 			user: user,
@@ -139,6 +150,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createImportMutingJob(user: ThinUser, fileId: DriveFile['id']) {
 		return this.dbQueue.add('importMuting', {
 			user: user,
@@ -149,6 +161,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createImportBlockingJob(user: ThinUser, fileId: DriveFile['id']) {
 		return this.dbQueue.add('importBlocking', {
 			user: user,
@@ -159,6 +172,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createImportUserListsJob(user: ThinUser, fileId: DriveFile['id']) {
 		return this.dbQueue.add('importUserLists', {
 			user: user,
@@ -169,6 +183,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createImportCustomEmojisJob(user: ThinUser, fileId: DriveFile['id']) {
 		return this.dbQueue.add('importCustomEmojis', {
 			user: user,
@@ -179,6 +194,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createDeleteAccountJob(user: ThinUser, opts: { soft?: boolean; } = {}) {
 		return this.dbQueue.add('deleteAccount', {
 			user: user,
@@ -189,6 +205,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createDeleteObjectStorageFileJob(key: string) {
 		return this.objectStorageQueue.add('deleteFile', {
 			key: key,
@@ -198,6 +215,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public createCleanRemoteFilesJob() {
 		return this.objectStorageQueue.add('cleanRemoteFiles', {}, {
 			removeOnComplete: true,
@@ -205,6 +223,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public webhookDeliver(webhook: Webhook, type: typeof webhookEventTypes[number], content: unknown) {
 		const data = {
 			type,
@@ -228,6 +247,7 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
 	public destroy() {
 		this.deliverQueue.once('cleaned', (jobs, status) => {
 			//deliverLogger.succ(`Cleaned ${jobs.length} ${status} jobs`);