diff --git a/partner-kospinjasa.js b/partner-kospinjasa.js index bddd61b..de1b23d 100644 --- a/partner-kospinjasa.js +++ b/partner-kospinjasa.js @@ -55,31 +55,40 @@ function saldoCheck(callback, task) { params.signature = createSignatureForSaldoCheck(params, config.h2h_out.password); - logger.info('Requesting to service', {url: config.h2h_out.partner, params: params}); - soapClient.apih2h.apih2hPort.saldoCheck({ inputSaldo: params }, function(err, result) { - - logger.verbose( - 'Got saldoCheck response', - { - lastEndpoint: soapClient.lastEndpoint, - lastRequest: soapClient.lastRequest, - lastMessage: soapClient.lastMessage, - lastResponse: soapClient.lastResponse, - } - ); + soap.createClient(config.h2h_out.partner, function(err, soapClient) { if (err) { - logger.warn('Error requesting saldoCheck', {err: err}); + logger.warn('Error creating soap client for saldoCheck', {err: err}); + callbackReport(task.requestId, '40', 'Error creating soap client for saldoCheck: ' + err); + return; } - var balance; - logger.verbose('saldoCheck result', {result: result}); + logger.info('Requesting to service', {url: config.h2h_out.partner, params: params}); + soapClient.apih2h.apih2hPort.saldoCheck({ inputSaldo: params }, function(err, result) { + + logger.verbose( + 'Got saldoCheck response', + { + lastEndpoint: soapClient.lastEndpoint, + lastRequest: soapClient.lastRequest, + lastMessage: soapClient.lastMessage, + lastResponse: soapClient.lastResponse, + } + ); + + if (err) { + logger.warn('Error requesting saldoCheck', {err: err}); + } + var balance; + logger.verbose('saldoCheck result', {result: result}); - if (task) { - callback(task, balance); - } - }); + + if (task) { + callback(task, balance); + } + }); + } }