diff --git a/partner-fm.js b/partner-fm.js index e697b2d..6397689 100644 --- a/partner-fm.js +++ b/partner-fm.js @@ -1,4 +1,6 @@ var xml2js = require('xml2js'); +var request = require('request'); +var http = require('http'); var aaa; var _callbackReport; @@ -63,7 +65,7 @@ function topupRequest(task) { 'Content-Type': 'text/xml', 'Content-Length': Buffer.byteLength(payload) } - } + }; logger.verbose('Requesting to partner', {reqOpts: reqOpts, payload: payload}); var buffer = ""; @@ -166,11 +168,36 @@ function composeTopupStatusMessage(pin, product, destination, requestId) { product: product, msisdn: destination, refTrxid: requestId - }} + }}; return xmlBuilder.buildObject(data); } +function createServer() { + var httpServer = http.createServer(function(request, response) { + + logger.info('Got request from partner'); + + var body = ""; + req.on('data', function (chunk) { + body += chunk; + }); + + req.on('end', function () { + res.writeHead(200); + res.end('OK'); + + topupResponseHandler(body, null, callbackReport); + + }); + + }); + + httpServer.listen(config.h2h_out.listen_port, function() { + logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); + }); +} + exports.start = start; exports.topupRequest = topupRequest; exports.composeTopupStatusMessage = composeTopupStatusMessage;