refactor: introduce bindThis decorator to bind this automaticaly

1 files changed, 6 insertions, 1 deletions

diff --git a/packages/backend/src/server/api/stream/channels/antenna.ts b/packages/backend/src/server/api/stream/channels/antenna.ts
index 7c34aef495..44beef2da2 100644
--- a/packages/backend/src/server/api/stream/channels/antenna.ts
+++ b/packages/backend/src/server/api/stream/channels/antenna.ts
@@ -2,6 +2,7 @@ import { Inject, Injectable } from '@nestjs/common';
 import type { NotesRepository } from '@/models/index.js';
 import { isUserRelated } from '@/misc/is-user-related.js';
 import { NoteEntityService } from '@/core/entities/NoteEntityService.js';
+import { bindThis } from '@/decorators.js';
 import Channel from '../channel.js';
 import type { StreamMessages } from '../types.js';
 
@@ -18,9 +19,10 @@ class AntennaChannel extends Channel {
 		connection: Channel['connection'],
 	) {
 		super(id, connection);
-		this.onEvent = this.onEvent.bind(this);
+		//this.onEvent = this.onEvent.bind(this);
 	}
 
+	@bindThis
 	public async init(params: any) {
 		this.antennaId = params.antennaId as string;
 
@@ -28,6 +30,7 @@ class AntennaChannel extends Channel {
 		this.subscriber.on(`antennaStream:${this.antennaId}`, this.onEvent);
 	}
 
+	@bindThis
 	private async onEvent(data: StreamMessages['antenna']['payload']) {
 		if (data.type === 'note') {
 			const note = await this.noteEntityService.pack(data.body.id, this.user, { detail: true });
@@ -45,6 +48,7 @@ class AntennaChannel extends Channel {
 		}
 	}
 
+	@bindThis
 	public dispose() {
 		// Unsubscribe events
 		this.subscriber.off(`antennaStream:${this.antennaId}`, this.onEvent);
@@ -61,6 +65,7 @@ export class AntennaChannelService {
 	) {
 	}
 
+	@bindThis
 	public create(id: string, connection: Channel['connection']): AntennaChannel {
 		return new AntennaChannel(
 			this.noteEntityService,