diff --git a/partner-trugee.js b/partner-trugee.js index 886d215..c8a4336 100644 --- a/partner-trugee.js +++ b/partner-trugee.js @@ -40,13 +40,12 @@ function createPayload(task) { ] }; - console.log(payload); + //console.log(payload); return "<?xml version=\"1.0\" ?>\n" + xml(payload); } function topupRequest(task, retry) { - console.log('Requesting to partner:'); var payload_xml = createPayload(task); var partner = url.parse(config.h2h_out.partner); @@ -62,9 +61,12 @@ function topupRequest(task, retry) { }; var buffer = ""; + + logger.info('Requesting to partner', {request_options: request_options}); + var req = http.request(request_options, function( res ) { - console.log('Status code: ' + res.statusCode ); + logger.info('Status code: ' + res.statusCode ); var buffer = ""; res.on( "data", function( data ) { buffer = buffer + data; } ); res.on( "end", function( data ) { @@ -74,23 +76,25 @@ function topupRequest(task, retry) { }); req.on('error', function(e) { - console.log('problem with request: ' + e.message); + logger.warn('problem with request: ' + e.message); callbackReport(task['requestId'], '40', e.message); }); + logger.verbose('Sending payload to partner', {payload: payload_xml}); req.write( payload_xml ); req.end(); } function directResponseHandler(body, request_id) { - console.log('Direct Response:'); + logger.info('Got direct response'); xml2js(body, function (err, result) { if (err) { - console.log(body); + logger.warn('Error parsing xml', {body: body}); callbackReport(request_id, '40', buffer); return; } - console.log(result); + + logger.info('Direct response parsed', {result: result}); var response_code = '68'; @@ -132,9 +136,8 @@ function createServer() { res.end('OK'); - console.log('Reverse Report:'); var qs = url.parse(req.url, true).query; - console.log(qs); + logger.info('Reverse Report', {qs: qs}); var response_code = '68'; var request_id = qs.pid; @@ -162,7 +165,7 @@ function createServer() { }); httpServer.listen(config.h2h_out.listen_port, function() { - console.log('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); + logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); }); }