diff options
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/index.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/streaming/index.js b/streaming/index.js index fd57c4e56..af1da8ae7 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -90,7 +90,9 @@ const streamFrom = (id, req, res, needsFiltering = false) => { redisClient.on('message', (channel, message) => { const { event, payload } = JSON.parse(message) - if (needsFiltering) { + // Only messages that may require filtering are statuses, since notifications + // are already personalized and deletes do not matter + if (needsFiltering && event === 'update') { pgPool.connect((err, client, done) => { if (err) { log.error(err) |