PULL & ADVICE: config.sdk_trx_id_adder

Adhidarma Hadiwinoto
1 parent a15c1392c1
Showing 2 changed files with 8 additions and 1 deletions Side-by-side Diff
gateway/advice-push-server.js
gateway/pull.js
@@ -58,6 +58,10 @@ function adviceHandler(req, res, next) {
     logger.verbose('PUSH-ADVICE: Got advice push', {task: task});
  
     task.remote_product = pull.getRemoteProduct(task.product);
+    if (Number(config.sdk_trx_id_adder)) {
+        task.trx_id = Number(task.trx_id) + Number(config.sdk_trx_id_adder);
+    }
+
     partner.advice(task);
 }
  
@@ -245,6 +245,9 @@ function forwardCoreTaskToPartner(coreMessage, start_time) {
     incrementCounterTrx();
  
     task.remote_product = getRemoteProduct(task.product);
+    if (Number(config.sdk_trx_id_adder)) {
+        task.trx_id = Number(task.trx_id) + Number(config.sdk_trx_id_adder);
+    }
  
     putTaskToMatrix(task);
  
@@ -301,7 +304,7 @@ function report(data) {
     let options = {
         url: core_pull_report_url,
         form: {
-            trx_id: data.trx_id,
+            trx_id: Number(data.trx_id) - (Number(config.sdk_trx_id_adder) || 0),
             rc: replaceRc(data.rc),
             rc_from_handler: data.rc_from_handler,
             message: data.message,
...	...	@@ -58,6 +58,10 @@ function adviceHandler(req, res, next) {
58	58	logger.verbose('PUSH-ADVICE: Got advice push', {task: task});
59	59
60	60	task.remote_product = pull.getRemoteProduct(task.product);
	61	+ if (Number(config.sdk_trx_id_adder)) {
	62	+ task.trx_id = Number(task.trx_id) + Number(config.sdk_trx_id_adder);
	63	+ }
	64	+
61	65	partner.advice(task);
62	66	}
63	67
...	...	@@ -245,6 +245,9 @@ function forwardCoreTaskToPartner(coreMessage, start_time) {
245	245	incrementCounterTrx();
246	246
247	247	task.remote_product = getRemoteProduct(task.product);
	248	+ if (Number(config.sdk_trx_id_adder)) {
	249	+ task.trx_id = Number(task.trx_id) + Number(config.sdk_trx_id_adder);
	250	+ }
248	251
249	252	putTaskToMatrix(task);
250	253
...	...	@@ -301,7 +304,7 @@ function report(data) {
301	304	let options = {
302	305	url: core_pull_report_url,
303	306	form: {
304		- trx_id: data.trx_id,
	307	+ trx_id: Number(data.trx_id) - (Number(config.sdk_trx_id_adder) \|\| 0),
305	308	rc: replaceRc(data.rc),
306	309	rc_from_handler: data.rc_from_handler,
307	310	message: data.message,