diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-10-08 13:13:55 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-10-08 13:13:55 +0200 |
| commit | 6a75460785e25b79b3a46d7025fdd93971b2a0db (patch) | |
| tree | 09ed5a0e34501ae644ba45534273cc2ee6b83807 | |
| parent | 885a10aaf42f0e16c87c7c41ec8a0cd5e3ac8e8c (diff) | |
| download | processor-release/2.18.0.tar.gz processor-release/2.18.0.zip | |
properly set last_update for searched playersrelease/2.18.0
| -rw-r--r-- | worker.js | 4 |
1 files changed, 1 insertions, 3 deletions
@@ -165,9 +165,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { // bridge sends a single object let player = JSON.parse(msg.content); msg.content = player; - // player objects that arrive here came from a search - // with search, bridge can't update last_update - player.last_update = seq.fn("NOW"); player_data.add(msg); break; case "match": @@ -338,6 +335,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { let player = flatten(JSON.parse(JSON.stringify(msg.content))); player.created_at = new Date(Date.parse(player.created_at)); player.last_match_created_date = player.created_at; + player.last_update = seq.fn("NOW"); // TODO set msg.timestamp in bridge and parse here logger.info("processing player", { name: player.name, region: player.shard_id }); |
