From 9a3929c7f0f8aa3090ecfcd1cc017af7d7f4d078 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Thu, 1 Jun 2017 20:56:03 +0200
Subject: fix analyze match order

---
 server.js | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'server.js')

diff --git a/server.js b/server.js
index fa26c89..f43e418 100644
--- a/server.js
+++ b/server.js
@@ -377,7 +377,7 @@ async function analyzePlayer(api_id) {
     });
     logger.info("sending matches to analyzer",
         { length: participations.length });
-    await Promise.map(participations, async (p) =>
+    await Promise.each(participations, async (p) =>
         await ch.sendToQueue(ANALYZE_QUEUE, new Buffer(p.match_api_id),
             { persistent: true }));
 }
@@ -446,7 +446,7 @@ async function analyzeGlobal() {
             offset: offset,
             order: [ ["created_at", "ASC"] ]
         });
-        await Promise.map(matches, async (m) =>
+        await Promise.each(matches, async (m) =>
             await ch.sendToQueue(ANALYZE_QUEUE, new Buffer(m.api_id),
                 { persistent: true }));
         offset += SHOVEL_SIZE;
-- 
cgit v1.3.1