diff --git a/partner-cjk.js b/partner-cjk.js index 60d5a91..0e8dab3 100644 --- a/partner-cjk.js +++ b/partner-cjk.js @@ -117,16 +117,9 @@ function pushResponseToMongoDb(task, response) { if (!isMongoReady()) { return; } try { - var lastResponse = {}; - - if (response.parsed && response.parsed.ciwaru) { - lastResponse = response.parsed.ciwaru; - } - mongodb.collection(config.mongodb.collection).updateOne( {requestId: task.requestId}, { - lastResponse: lastResponse, $push: {responses: response} }, function(err, result) { @@ -136,6 +129,22 @@ function pushResponseToMongoDb(task, response) { } } ); + + if (response.parsed && response.parsed.ciwaru) { + mongodb.collection(config.mongodb.collection).updateOne( + {requestId: task.requestId}, + { + lastResponse: response.parsed.ciwaru + }, + function(err, result) { + if (err) { + logger.warn('Error when updating last response to mongodb', {err: err, task: task, response: response}); + return; + } + } + ); + } + } catch(err) { logger.warn('Exception when pushing response to mongodb', {err: err, task: task, response: response});