From a05e70477f930816aa9707b1c09428f8f1a6f2e4 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sun, 28 May 2017 10:15:52 +0200
Subject: send phases_update notification

---
 worker.js | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/worker.js b/worker.js
index 40e67b4..50c50d5 100644
--- a/worker.js
+++ b/worker.js
@@ -711,6 +711,10 @@ function flatten(obj) {
         // …global about new matches
         if (match_records.length > 0)
             await ch.publish("amq.topic", "global", new Buffer("matches_update"));
+        // …about new phases
+        await Promise.map(telemetry_objects, async (t) =>
+            await ch.publish("amq.topic", "match." + t.match_api_id,
+                new Buffer("phases_update")) );
     }
 
     // Split participant API data into participant and participant_stats
-- 
cgit v1.3.1