From d077430dfbd32c4f90f13f67e0e8fc68dc9a9a94 Mon Sep 17 00:00:00 2001
From: Adhidarma Hadiwinoto <gua@adhisimon.org>
Date: Mon, 9 May 2016 13:56:31 +0700
Subject: [PATCH] perbaikan mongo
---
partner-cjk.js | 23 ++++++++++++++++-------
1 file changed, 16 insertions(+), 7 deletions(-)
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});
--
1.9.0