From 34e3a8871cdfaa4675bfd8e96c38dfe9426ab2ec Mon Sep 17 00:00:00 2001 From: schneefux Date: Thu, 11 May 2017 17:43:12 +0200 Subject: prevent fame calculation being mixed during two concurrent team updates --- worker.js | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) (limited to 'worker.js') diff --git a/worker.js b/worker.js index d7b7ffe..cece1a7 100644 --- a/worker.js +++ b/worker.js @@ -118,11 +118,14 @@ if (LOGGLY_TOKEN) replacements: { participant_api_ids: api_ids_global }, type: seq.QueryTypes.UPSERT }); - if (team_ids.length > 0) - await seq.query(team_script, { - replacements: { team_ids: team_ids }, - type: seq.QueryTypes.UPDATE - }); + if (team_ids.length > 0) { + await Promise.each(team_ids, async (tid) => + await seq.query(team_script, { + replacements: { team_id: tid }, + type: seq.QueryTypes.UPDATE + }) + ); + } if (api_ids_player.length > 0) await seq.query(player_script, { replacements: { participant_api_ids: api_ids_player }, -- cgit v1.3.1