diff --git a/partner-cjk.js b/partner-cjk.js index 66223ac..b08a7fb 100644 --- a/partner-cjk.js +++ b/partner-cjk.js @@ -106,7 +106,7 @@ function insertTaskToMongoDb(task) { } } -function pushResponseToMongoDb(task, response) { +function pushResponseToMongoDb(task, response, rc) { if (!isMongoReady()) { return; } try { @@ -115,7 +115,8 @@ function pushResponseToMongoDb(task, response) { { $set: { lastResponse: response, - supplier: config.globals.gateway_name + supplier: config.globals.gateway_name, + rc: rc }, $push: { responses: response @@ -202,11 +203,10 @@ function topupResponseHandler(body, task) { logger.warn('Got invalid XML from partner', {err: err, body: body, task: task}); callbackReport(task.requestId, '68', body); - pushResponseToMongoDb(task, {ts: ts, supplier: config.globals.gateway_name, raw: body}); + pushResponseToMongoDb(task, {ts: ts, supplier: config.globals.gateway_name, raw: body}, '68'); return; } logger.info('XML message from partner', {result: result}); - pushResponseToMongoDb(task, {ts: ts, supplier: config.globals.gateway_name, raw: body, parsed: result}); var rc = '68'; var message = result.ciwaru.msg[0]; @@ -237,6 +237,8 @@ function topupResponseHandler(body, task) { } } + pushResponseToMongoDb(task, {ts: ts, supplier: config.globals.gateway_name, raw: body, parsed: result}, rc); + if ((task.retry == maxRetry) || (rc != '68')) { callbackReport(task.requestId, rc, message); } else {