diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-01 12:03:55 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-01 12:03:55 +0200 |
| commit | aababc344fe2fa741a35eaea6248df5e8d7be3fd (patch) | |
| tree | c09604e0ed65e2057c2e1d886f7fa7f85c1fa10d | |
| parent | c78435c7b68fbaa92a36d366f11fd5db9699ddf4 (diff) | |
| parent | c15e6575dc5e28d391766eef04ea84b86f7e7793 (diff) | |
| download | shrinker-aababc344fe2fa741a35eaea6248df5e8d7be3fd.tar.gz shrinker-aababc344fe2fa741a35eaea6248df5e8d7be3fd.zip | |
Merge branch 'release/2.0.0' of https://gitlab.com/vainglorygame/processor into release/2.0.0
| -rw-r--r-- | worker.js | 3 |
1 files changed, 3 insertions, 0 deletions
@@ -110,6 +110,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", await Promise.all(match.rosters.map(async (roster) => { roster.match_api_id = match.api_id; roster.shard_id = match.shard_id; + roster.created_at = match.created_at; await model.Roster.upsert(roster, { include: [ model.Participant/*, model.Team */], @@ -119,7 +120,9 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", await Promise.all(roster.participants.map(async (participant) => { participant.shard_id = roster.shard_id; participant.roster_api_id = roster.api_id; + participant.created_at = roster.created_at; participant.player_api_id = participant.player.api_id; + await model.Participant.upsert(participant, { include: [ model.Player ], transaction: transaction |