diff --git a/partner-trugee.js b/partner-trugee.js index d335835..8b67348 100644 --- a/partner-trugee.js +++ b/partner-trugee.js @@ -103,7 +103,13 @@ function directResponseHandler(body, request_id) { return; } console.log(result); - //request_id = result.pulsamatic.trxid; + + var response_code = '68'; + + var request_id = result.pulsamatic.partner_trxid[0].trim(); + var message = result.pulsamatic.message[0].trim(); + + callbackReport(request_id, response_code, message); }); } @@ -218,34 +224,22 @@ function parseSN(message) { function createServer() { var httpServer = http.createServer(function(req, res) { - var parsed_url = url.parse(req.url, true, true); - - console.log('Got request from partner ("' + req.url + '")'); + //console.log('Got request from partner ("' + req.url + '")'); - var body = ""; - req.on('data', function (chunk) { - body += chunk; - }); + res.end('OK'); - req.on('end', function () { - res.writeHead(200); - res.end('OK'); - - //console.log(body); - - if (parsed_url.pathname == '/sn') { - console.log('Reverse report -- SN'); - topupResponseHandler(body); - - } else if (parsed_url.pathname = '/refund') { - console.log('Reverse report -- REFUND'); - callbackReport(parsed_url.query.ref_trxid, '40', parsed_url.query.message); - - } else { - console.log('Reverse report -- UNKNOWN'); - console.log('Ignore unknown request on reverse url'); - } - }); + var qs = url.parse(req.url, true).query; + console.log(qs); + + var response_code = '68'; + var request_id = qs.pid; + var message = qs.msg; + + if (message.indexOf('REFUND') >= 0) { + response_code = '40'; + } + + callbackReport(request_id, response_code, message); }); httpServer.listen(config.h2h_out.listen_port, function() {