From aa2fa227e9cdd5aa4f8facd93775f6180e44a17b Mon Sep 17 00:00:00 2001
From: Eugen Rochko <eugen@zeonfederated.com>
Date: Thu, 2 Feb 2017 16:35:06 +0100
Subject: Adding documentation for streaming API. Fixing filtering bug

---
 streaming/index.js | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'streaming')

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)
-- 
cgit