summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-10-08 13:13:55 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-10-08 13:13:55 +0200
commit6a75460785e25b79b3a46d7025fdd93971b2a0db (patch)
tree09ed5a0e34501ae644ba45534273cc2ee6b83807
parent885a10aaf42f0e16c87c7c41ec8a0cd5e3ac8e8c (diff)
downloadprocessor-6a75460785e25b79b3a46d7025fdd93971b2a0db.tar.gz
processor-6a75460785e25b79b3a46d7025fdd93971b2a0db.zip
properly set last_update for searched playersrelease/2.18.0
-rw-r--r--worker.js4
1 files changed, 1 insertions, 3 deletions
diff --git a/worker.js b/worker.js
index e83d27c..f83ffb1 100644
--- a/worker.js
+++ b/worker.js
@@ -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 });