summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-08 22:52:10 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-08 22:52:10 +0200
commit177a29e44788040d654c4b12845d52202348853a (patch)
tree05e57d2f4a261a50b03fb68d76958042687d7c81
parent60da1e98c13664170ddd32449bc005a55f4f39ef (diff)
downloadprocessor-177a29e44788040d654c4b12845d52202348853a.tar.gz
processor-177a29e44788040d654c4b12845d52202348853a.zip
push skill tier to player
-rw-r--r--worker.js14
1 files changed, 10 insertions, 4 deletions
diff --git a/worker.js b/worker.js
index dff74ef..8dcbf26 100644
--- a/worker.js
+++ b/worker.js
@@ -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
}
);