diff options
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/index.js | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/streaming/index.js b/streaming/index.js index 304e7e046..64e71f353 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -376,6 +376,12 @@ const startWorker = (workerId) => { return; } + // Only send local-only statuses to logged-in users + if (event === 'update' && payload.local_only && !req.accountId) { + log.silly(req.requestId, `Message ${payload.id} filtered because it was local-only`); + return; + } + // Only messages that may require filtering are statuses, since notifications // are already personalized and deletes do not matter if (!needsFiltering || event !== 'update') { |