submit one phase_update per message; send to dest according to notif header

1 files changed, 4 insertions, 7 deletions

diff --git a/worker.js b/worker.js
index 971e24b..12b00b6 100644
--- a/worker.js
+++ b/worker.js
@@ -803,13 +803,10 @@ function flatten(obj) {
             if (m.properties.type == "player") notif = "stats_update";
             // new phases
             if (m.properties.type == "telemetry") {
-                notif = "phases_update";
-                // notify player.name.api_id about phase_update
-                await Promise.map(telemetry_objects, async (t) =>
-                    await ch.publish("amq.topic",
-                        m.properties.headers.notify + "." + t.match_api_id,
-                        new Buffer("phase_update"))
-                );
+                // notify match.api_id about phase_update
+                await ch.publish("amq.topic",
+                    m.properties.headers.notify,
+                    new Buffer("phase_update"))
             }
 
             if (m.properties.headers.donotify == true)  // TODO remove later