From 3b1cfd42539b2a72964b38c94bb6d782e71b9a51 Mon Sep 17 00:00:00 2001 From: Rob Colbert Date: Wed, 28 Aug 2019 03:00:57 -0400 Subject: [PATCH] send statuscard update on user-specific channel --- streaming/index.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streaming/index.js b/streaming/index.js index 7f212850..551df417 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -535,7 +535,7 @@ const startWorker = (workerId) => { app.use(errorMiddleware); app.get('/api/v1/streaming/statuscard', (req, res) => { - const channel = `statuscard`; + const channel = `statuscard:${req.accountId}`; streamFrom(channel, req, streamToHttp(req, res), streamHttpEnd(req, subscriptionHeartbeat(channel))); }); @@ -614,7 +614,7 @@ const startWorker = (workerId) => { switch(location.query.stream) { case 'statuscard': - channel = `statuscard`; + channel = `statuscard:${req.accountId}`; streamFrom(channel, req, streamToWs(req, ws), streamWsEnd(req, ws, subscriptionHeartbeat(channel))); break; case 'user':