penanganan ref_id dan ts pada reverse report

Adhidarma Hadiwinoto
1 parent f4ad423194
Showing 1 changed file with 17 additions and 8 deletions Side-by-side Diff
gentong.js
@@ -241,15 +241,12 @@ function createServer() {
  
         response.end('OK');
  
-        var key = getRedisKey(qs.ts);
-        redisClient.get(key, function(err, request_id) {
-            if (err) {
-                logger.warn('Error when requesting request id for ts:' + qs.ts + ' (' + key + ')', {redis_error: err});
-                return;
-            }
+        if (qs.ref_id) {
+            callbackReport(qs.ref_id, response_code, message);
+        } else {
+            reverseHandlerByTs(qs.ts, response_code, message);
+        }
  
-            callbackReport(request_id, response_code, message);
-        });
     });
  
     httpServer.listen(config.h2h_out.listen_port, function() {
@@ -257,6 +254,18 @@ function createServer() {
     });
 }
  
+function reverseHandlerByTs(ts, responseCode, message) {
+    var key = getRedisKey(ts);
+    redisClient.get(key, function(err, request_id) {
+        if (err) {
+            logger.warn('Error when requesting request id for ts:' + ts + ' (' + key + ')', {redis_error: err});
+            return;
+        }
+
+        callbackReport(request_id, responseCode, message);
+    });
+}
+
 function splitSN(sn, _config) {
     var sn_pieces = sn.split(' ');
...	...	@@ -241,15 +241,12 @@ function createServer() {
241	241
242	242	response.end('OK');
243	243
244		- var key = getRedisKey(qs.ts);
245		- redisClient.get(key, function(err, request_id) {
246		- if (err) {
247		- logger.warn('Error when requesting request id for ts:' + qs.ts + ' (' + key + ')', {redis_error: err});
248		- return;
249		- }
	244	+ if (qs.ref_id) {
	245	+ callbackReport(qs.ref_id, response_code, message);
	246	+ } else {
	247	+ reverseHandlerByTs(qs.ts, response_code, message);
	248	+ }
250	249
251		- callbackReport(request_id, response_code, message);
252		- });
253	250	});
254	251
255	252	httpServer.listen(config.h2h_out.listen_port, function() {
...	...	@@ -257,6 +254,18 @@ function createServer() {
257	254	});
258	255	}
259	256
	257	+function reverseHandlerByTs(ts, responseCode, message) {
	258	+ var key = getRedisKey(ts);
	259	+ redisClient.get(key, function(err, request_id) {
	260	+ if (err) {
	261	+ logger.warn('Error when requesting request id for ts:' + ts + ' (' + key + ')', {redis_error: err});
	262	+ return;
	263	+ }
	264	+
	265	+ callbackReport(request_id, responseCode, message);
	266	+ });
	267	+}
	268	+
260	269	function splitSN(sn, _config) {
261	270	var sn_pieces = sn.split(' ');
262	271