dummy server

Adhidarma Hadiwinoto
1 parent b7f5b23dc0
Showing 1 changed file with 35 additions and 1 deletions Side-by-side Diff
xmlout.js
@@ -198,6 +198,33 @@ function createServer() {
  
 }
  
+function createPlainHttpServer() {
+    logger.info('Creating dummy plain HTTP server on port ' + config.h2h_out.listen_port);
+
+    var httpServer = http.createServer(function(request, response) {
+
+        logger.info('Got request from partner');
+
+        var body = "";
+        request.on('data', function (chunk) {
+            body += chunk;
+        });
+
+        request.on('end', function () {
+            response.writeHead(200);
+            response.end('OK');
+
+            //reverseReportHandler(body);
+            logger.verbose('Got reverse report on dummy plain http server', {url: request.url, body: body});
+        });
+
+    });
+
+    httpServer.listen(config.h2h_out.listen_port, function() {
+        logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
+    });
+}
+
 function getBalanceFromMessage(message, balance_regex) {
     if (!balance_regex) {
         if (config && config.globals && config.globals.balance_regex) {
@@ -314,7 +341,14 @@ function start(options) {
     }
  
     createRedisClient(config.globals.redis_host, config.globals.redis_port);
-    createServer();
+
+    if (!config.globals.use_dummy_server) {
+        createServer();
+    }
+    else {
+        createPlainHttpServer();
+    }
+
  
     var resendDelayOptions = {
         config: config,
...	...	@@ -198,6 +198,33 @@ function createServer() {
198	198
199	199	}
200	200
	201	+function createPlainHttpServer() {
	202	+ logger.info('Creating dummy plain HTTP server on port ' + config.h2h_out.listen_port);
	203	+
	204	+ var httpServer = http.createServer(function(request, response) {
	205	+
	206	+ logger.info('Got request from partner');
	207	+
	208	+ var body = "";
	209	+ request.on('data', function (chunk) {
	210	+ body += chunk;
	211	+ });
	212	+
	213	+ request.on('end', function () {
	214	+ response.writeHead(200);
	215	+ response.end('OK');
	216	+
	217	+ //reverseReportHandler(body);
	218	+ logger.verbose('Got reverse report on dummy plain http server', {url: request.url, body: body});
	219	+ });
	220	+
	221	+ });
	222	+
	223	+ httpServer.listen(config.h2h_out.listen_port, function() {
	224	+ logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
	225	+ });
	226	+}
	227	+
201	228	function getBalanceFromMessage(message, balance_regex) {
202	229	if (!balance_regex) {
203	230	if (config && config.globals && config.globals.balance_regex) {
...	...	@@ -314,7 +341,14 @@ function start(options) {
314	341	}
315	342
316	343	createRedisClient(config.globals.redis_host, config.globals.redis_port);
317		- createServer();
	344	+
	345	+ if (!config.globals.use_dummy_server) {
	346	+ createServer();
	347	+ }
	348	+ else {
	349	+ createPlainHttpServer();
	350	+ }
	351	+
318	352
319	353	var resendDelayOptions = {
320	354	config: config,