add crunch_update notification according to header

1 files changed, 6 insertions, 5 deletions

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")
+                );
         });
     }