From a3c78c9512b96a211ac445b68d5af8922d3fc37a Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Wed, 23 Aug 2017 19:46:50 +0200
Subject: add crunch_update notification according to header

---
 worker.js | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index ba20ee9..bf6b499 100644
--- a/worker.js
+++ b/worker.js
@@ -193,11 +193,12 @@ ${columnName} = column_create(` +
 
         await Promise.map(msgs, async (m) => await ch.ack(m));
         // notify web
-        // TODO notify for player too
-        await Promise.map(api_ids, async (id) => {
-            await ch.publish("amq.topic",
-                "crunch." + id,
-                new Buffer("points_update"));
+        await Promise.map(msgs, async (m) => {
+            if (m.properties.headers.notify)
+                await ch.publish("amq.topic",
+                    m.properties.headers.notify,
+                    new Buffer("crunch_update")
+                );
         });
     }
 
-- 
cgit v1.3.1