From 4709e198d6d3af33b65867cc1196971fa3f83d78 Mon Sep 17 00:00:00 2001 From: schneefux Date: Fri, 31 Mar 2017 21:08:23 +0200 Subject: fix shard_id workaround --- worker.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'worker.js') diff --git a/worker.js b/worker.js index 1ea66bd..0dde0d1 100644 --- a/worker.js +++ b/worker.js @@ -75,12 +75,12 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", let matches = msgs.filter((m) => m.properties.type == "match").map((m) => JSON.parse(m.content)), players = msgs.filter((m) => m.properties.type == "player").map((m) => { let pl = JSON.parse(m.content); - pl.shard_id = m.properties.headers.shard; // TODO workaround for empty API field + pl.attributes.shard_id = m.properties.headers.shard; // TODO workaround for empty API field return pl; }), teams = msgs.filter((m) => m.properties.type == "team").map((m) => { let t = JSON.parse(m.content); - t.shard_id = m.properties.headers.shard; + t.attributes.shard_id = m.properties.headers.shard; return t; }); -- cgit v1.3.1