diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-03 16:43:29 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-03 16:43:29 +0200 |
| commit | a41d397a57be9e7595baa9310f83d2d6a411175f (patch) | |
| tree | d343300a11fc9e78badc279a8254ec63872bfd22 | |
| parent | 3ab7ff81923d4472c6aa04e5a9a5f36e64d6fdd8 (diff) | |
| download | compiler-a41d397a57be9e7595baa9310f83d2d6a411175f.tar.gz compiler-a41d397a57be9e7595baa9310f83d2d6a411175f.zip | |
anticipate players with no match history
| -rw-r--r-- | worker.js | 18 |
1 files changed, 12 insertions, 6 deletions
@@ -63,7 +63,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", player_ext = {}; // set last_match_created_date - let lmcd = (await model.Participant.findOne({ + let record = await model.Participant.findOne({ where: { player_api_id: player_api_id }, @@ -79,9 +79,13 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", order: [ [seq.col("last_match_created_date"), "DESC"] ] - })).get("last_match_created_date"); - // do later in the transaction - player_updates.push([{ last_match_created_date: lmcd }, { where: { api_id: player_api_id } }]); + }); + if (record != null) + // do later in the transaction + player_updates.push([ + { last_match_created_date: record.get("last_match_created_date") }, + { where: { api_id: player_api_id } } + ]); // calculate "extended" player_ext fields like wins per patch player_ext.player_api_id = player_api_id; @@ -91,7 +95,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", // TODO maybe this can be done in fewer/combined/subqueries let count_matches_where = async (where) => { - return (await model.Participant.findOne({ + let record = await model.Participant.findOne({ where: where, attributes: [[seq.fn("COUNT", "$roster.match$"), "count"]], include: [ { @@ -102,7 +106,9 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", attributes: [] } ] } ] - })).get("count"); + }) + if (record == null) return 0; + return record.get("count"); }; // TODO run in parallel |