fix: Canned responses stream not working (#30959)

RocketChat · Nov 14, 2023 · aaf11e9 · aaf11e9
1 parent 8d2d396
commit aaf11e9
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 15 deletions.
diff --git a/.changeset/selfish-panthers-stare.md b/.changeset/selfish-panthers-stare.md
@@ -0,0 +1,5 @@
+---
+"@rocket.chat/meteor": patch
+---
+
+Fixed Canned responses stream not working, causing users to refresh to see newly created responses.
diff --git a/apps/meteor/ee/app/canned-responses/client/startup/responses.js b/apps/meteor/ee/app/canned-responses/client/startup/responses.js
@@ -24,20 +24,23 @@ Meteor.startup(() => {
 		if (!hasPermission('view-canned-responses')) {
 			return;
 		}
-		try {
-			// TODO: check options
-			sdk.stream('canned-responses', 'canned-responses', (response, options) => {
-				const { agentsId } = options || {};
-				if (Array.isArray(agentsId) && !agentsId.includes(Meteor.userId())) {
-					return;
-				}
-				events[response.type](response);
-			});
-			const { responses } = await sdk.rest.get('/v1/canned-responses.get');
-			responses.forEach((response) => CannedResponse.insert(response));
-			c.stop();
-		} catch (error) {
-			console.log(error);
-		}
+		Tracker.afterFlush(() => {
+			try {
+				// TODO: check options
+				sdk.stream('canned-responses', ['canned-responses'], (response, options) => {
+					const { agentsId } = options || {};
+					if (Array.isArray(agentsId) && !agentsId.includes(Meteor.userId())) {
+						return;
+					}
+					events[response.type](response);
+				});
+			} catch (error) {
+				console.log(error);
+			}
+		});
+
+		const { responses } = await sdk.rest.get('/v1/canned-responses.get');
+		responses.forEach((response) => CannedResponse.insert(response));
+		c.stop();
 	});
 });