Commit ad94aae82d42619852830b594ea9cfb71da7ffb1
1 parent
78e1fc50b9
Exists in
master
createReverseHttpServer
Showing 1 changed file with 14 additions and 0 deletions Side-by-side Diff
partner-otomax.js
... | ... | @@ -2,6 +2,7 @@ |
2 | 2 | |
3 | 3 | var request = require('request'); |
4 | 4 | var crypto = require('crypto'); |
5 | +var url = require('url'); | |
5 | 6 | |
6 | 7 | var taskHistory = require('sate24/task-history'); |
7 | 8 | var antiSameDayDupe = require('sate24/anti-same-day-dupe'); |
... | ... | @@ -46,6 +47,8 @@ function start(options) { |
46 | 47 | |
47 | 48 | taskHistory.init(options); |
48 | 49 | antiSameDayDupe.init(options); |
50 | + | |
51 | + createReverseHttpServer(); | |
49 | 52 | } |
50 | 53 | |
51 | 54 | function callbackReport(requestId, rc, message) { |
... | ... | @@ -146,6 +149,17 @@ function onSameDayDupe(task) { |
146 | 149 | callbackReport(task.requestId, '55', 'Transaksi duplikat dalam satu hari yang sama'); |
147 | 150 | } |
148 | 151 | |
152 | +function createReverseHttpServer() { | |
153 | + var httpServer = http.createServer(function(request, response) { | |
154 | + let qs = url.parse(request.url, true).query; | |
155 | + logger.verbose('Hit on Reverse HTTP server', {url: request.url, qs: qs}); | |
156 | + }); | |
157 | + | |
158 | + httpServer.listen(config.h2h_out.listen_port, function() { | |
159 | + logger.info('Reverse Report HTTP Server listen on %d', config.h2h_out.listen_port); | |
160 | + }); | |
161 | +} | |
162 | + | |
149 | 163 | exports.start = start; |
150 | 164 | exports.topupRequest = topupRequest; |
151 | 165 | exports.generateSign = generateSign; |