From 73562169d4b5e49b5a159015b5f7ee3bb39ecb1b Mon Sep 17 00:00:00 2001 From: schneefux Date: Fri, 30 Jun 2017 18:08:02 +0200 Subject: submit one phase_update per message; send to dest according to notif header --- worker.js | 11 ++++------- 1 file 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 -- cgit v1.3.1