fix: internal server error when connecting to publication with backwa…

…rd compatibility flag
RocketChat · Mar 27, 2024 · 0bdd5ed · 0bdd5ed
1 parent 5b7623d
commit 0bdd5ed
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/.changeset/great-yaks-dream.md b/.changeset/great-yaks-dream.md
@@ -0,0 +1,5 @@
+---
+'@rocket.chat/ddp-streamer': patch
+---
+
+Fixed an internal server error when using the backwards compatibility flag to connect to the real time API for listening to all server message notifications.
diff --git a/ee/apps/ddp-streamer/src/Publication.ts b/ee/apps/ddp-streamer/src/Publication.ts
@@ -19,7 +19,7 @@ export class Publication extends EventEmitter implements IPublication {
 		this.once('stop', () => client.subscriptions.delete(packet.id));
 
 		this._session = {
-			sendAdded: this.added,
+			sendAdded: this.added.bind(this),
 			socket: client,
 			userId: client.userId,
 		};