From 107593094876a87adc95d9695701cb97faea1236 Mon Sep 17 00:00:00 2001 From: schneefux Date: Fri, 25 Aug 2017 23:07:07 +0200 Subject: clone msg objects to allow resending 1:1 into the failed queue --- worker.js | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/worker.js b/worker.js index ac5c69f..22b4542 100644 --- a/worker.js +++ b/worker.js @@ -333,7 +333,9 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { // populate `_records` // data from `/players` player_objects.forEach((msg) => { - let player = flatten(msg.content); + // flatten a deep clone, the original object is needed + // so it can be moved into the failed queue + 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; @@ -351,7 +353,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { // data from `/matches` match_objects.forEach((msg) => { - let match = msg.content; + let match = JSON.parse(JSON.stringify(msg.content)); // deep clone match.createdAt = new Date(Date.parse(match.createdAt)); // flatten jsonapi nested response into our db structure-like shape -- cgit v1.3.1