From 91babc4b5b127a95139adcf5441878d4eea944ba Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Thu, 13 Apr 2017 12:55:25 +0200
Subject: send only one notification per player

---
 worker.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index 2e76409..eef402b 100644
--- a/worker.js
+++ b/worker.js
@@ -181,7 +181,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI,
             await Promise.all(msgs.map((m) => ch.nack(m, true)) );  // requeue
         }
 
-        await Promise.all(player_records.map(async (p) =>
+        await Promise.all(players_done.map(async (p) =>
             await ch.publish("amq.topic", "player." + p.name, new Buffer("points_update")) ));
         if (global_records.length > 0)
             await ch.publish("amq.topic", "global", new Buffer("points_update"));
-- 
cgit v1.3.1