diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-08 22:52:10 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-08 22:52:10 +0200 |
| commit | 177a29e44788040d654c4b12845d52202348853a (patch) | |
| tree | 05e57d2f4a261a50b03fb68d76958042687d7c81 /worker.js | |
| parent | 60da1e98c13664170ddd32449bc005a55f4f39ef (diff) | |
| download | shrinker-177a29e44788040d654c4b12845d52202348853a.tar.gz shrinker-177a29e44788040d654c4b12845d52202348853a.zip | |
push skill tier to player
Diffstat (limited to 'worker.js')
| -rw-r--r-- | worker.js | 14 |
1 files changed, 10 insertions, 4 deletions
@@ -272,21 +272,27 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI, }) ]); - // update last_match_created_date for players + // update last_match_created_date and skill tier for players await Promise.all(player_records.map(async (player) => { // set last_match_created_date console.log("updating player", player.name); let record = await model.Participant.findOne({ transaction: transaction, where: { player_api_id: player.api_id }, - attributes: [ [seq.col("created_at"), "last_match_created_date"] ], + attributes: [ + [seq.col("created_at"), "last_match_created_date"], + "skill_tier" + ], order: [ [seq.col("created_at"), "DESC"] ] }); if (record != null) { await model.Player.update( - { last_match_created_date: record.get("last_match_created_date") }, { + { + last_match_created_date: record.get("last_match_created_date"), + skill_tier: record.get("skill_tier") + }, { where: { api_id: player.api_id }, - fields: [ "last_match_created_date" ], + fields: [ "last_match_created_date", "skill_tier" ], transaction: transaction } ); |
