fix player flattens

1 files changed, 4 insertions, 3 deletions

diff --git a/worker.js b/worker.js
index a943d8c..88edc7e 100644
--- a/worker.js
+++ b/worker.js
@@ -90,9 +90,10 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost",
         msgs.filter((m) => m.properties.type == "player").map((msg) => {
             let players = JSON.parse(msg.content);
             players.map(async (p) => {
-                player = flatten(p);
-                if (!is_in(player_records, p.player))
-                    player_records.push(p.player);
+                console.log(p);
+                let player = flatten(p);
+                if (!is_in(player_records, player))
+                    player_records.push(player);
             });
         });