diff --git a/partner-komodo.js b/partner-komodo.js index 24d56e8..6af577e 100644 --- a/partner-komodo.js +++ b/partner-komodo.js @@ -59,6 +59,7 @@ function start(options) { function callbackReport(requestId, rc, message, options) { aaa.callbackReportWithPushToMongoDb(requestId, rc, message); + /* if (!options.task) { return; } @@ -68,6 +69,7 @@ function callbackReport(requestId, rc, message, options) { } else { resendDelay.cancel(options.task) } + */ } @@ -94,14 +96,14 @@ function topupRequest(task, pendingOnConnectError) { if (err.syscall == 'connect' && !pendingOnConnectError) { rc = '91'; } - callbackReport(task.requestId, rc, 'Error requesting to partner: ' + err); + callbackReport(task.requestId, rc, 'Error requesting to partner: ' + err, {task: task}); return; } if (response.statusCode != 200) { let rc = '68'; - callbackReport(task.requestId, rc, 'Partner returning HTTP status code ' + response.statusCode + ', not 200'); + callbackReport(task.requestId, rc, 'Partner returning HTTP status code ' + response.statusCode + ', not 200', {task: task}); return; } @@ -119,7 +121,7 @@ function processPartnerResponse(resObj, task) { if (!resObj) { if (task.requestId) { - callbackReport(task.requestId, '40', 'Error parsing response from partner. Partner response: ' + body); + callbackReport(task.requestId, '40', 'Error parsing response from partner. Partner response: ' + body, {task: task}); } else { logger.warn('UNDEFINED REQUEST ID'); @@ -139,7 +141,7 @@ function processPartnerResponse(resObj, task) { st24Message = 'SN=' + resObj.sn + '; ' + st24Message; } - callbackReport(resObj.request_id, st24Rc, st24Message); + callbackReport(resObj.request_id, st24Rc, st24Message, {task: task}); } function parsePartnerMessage(partner_message) {