Merge pull request #7184 from Countly/SER-2789-updates-on-a-cohort-message-is-not-reflected-to-cache

cihadtekin · web-flow · commit 188fdfa3bf3e · 2026-01-21T16:19:55.000+03:00
[push] Reflecting changes on a message to cache
diff --git a/plugins/push/api/api-message.js b/plugins/push/api/api-message.js
@@ -350,7 +350,7 @@ module.exports.update = async params => {
         }
         else {
             await msg.save();
-            if (!params.qstring.demo && msg.triggerPlain() && (msg.is(State.Paused) || msg.is(State.Streaming) || msg.is(State.Streamable))) {
+            if (!params.qstring.demo && (msg.is(State.Paused) || msg.is(State.Streaming) || msg.is(State.Streamable))) {
                 await msg.schedule(log, params);
             }
             common.plugins.dispatch('/systemlogs', {params: params, action: 'push_message_updated', data: msg.json});

Original file line number	Diff line number	Diff line change
`@@ -350,7 +350,7 @@ module.exports.update = async params => {`
`350`	`350`	`}`
`351`	`351`	`else {`
`352`	`352`	`await msg.save();`
`353`		`- if (!params.qstring.demo && msg.triggerPlain() && (msg.is(State.Paused) \|\| msg.is(State.Streaming) \|\| msg.is(State.Streamable))) {`
	`353`	`+ if (!params.qstring.demo && (msg.is(State.Paused) \|\| msg.is(State.Streaming) \|\| msg.is(State.Streamable))) {`
`354`	`354`	`await msg.schedule(log, params);`
`355`	`355`	`}`
`356`	`356`	`common.plugins.dispatch('/systemlogs', {params: params, action: 'push_message_updated', data: msg.json});`