Adhidarma Hadiwinoto · Adhidarma Hadiwinoto
Showing 2 changed files Side-by-side Diff
gateway/pull.js
package.json
@@ -70,20 +70,20 @@ function forwardCoreTaskToPartner(coreMessage) {
     partner.buy(task);
 }
  
-function report(trx_id, rc, message, sn) {
+//function report(trx_id, rc, message, sn) {
+function report(data) {
     let options = {
         url: config.pull_url.report.replace('<CORE_APIKEY>', config.core_apikey),
         qs: {
-            trx_id: trx_id,
-            rc: rc,
-            message: message,
-            handler: config.handler_name
+            trx_id: data.trx_id,
+            rc: data.rc,
+            message: data.message,
+            handler: config.handler_name,
+            sn: data.sn,
+            supplier_price: data.supplier_price
         }
     }
  
-    if (sn) {
-        options.qs.sn = sn;
-    }
  
     request(options, function(error, response, body) {
         if (error) {
@@ -98,13 +98,13 @@ function report(trx_id, rc, message, sn) {
     });
 }
  
-function resendReport(trx_id, rc, message, sn) {
+function resendReport(data) {
     let sleepBeforeResend = 1000;
     logger.verbose('Resend report to CORE in ' + sleepBeforeResend + 'ms')
  
     setTimeout(
         function() {
-            report(trx_id, rc, message, sn);
+            report(data);
         },
         sleepBeforeResend
     )
 {
   "name": "komodo-sdk",
-  "version": "1.6.0",
+  "version": "1.6.1",
   "description": "SDK for Komodo",
   "main": "index.js",
   "scripts": {
...	...	@@ -70,20 +70,20 @@ function forwardCoreTaskToPartner(coreMessage) {
70	70	partner.buy(task);
71	71	}
72	72
73		-function report(trx_id, rc, message, sn) {
	73	+//function report(trx_id, rc, message, sn) {
	74	+function report(data) {
74	75	let options = {
75	76	url: config.pull_url.report.replace('<CORE_APIKEY>', config.core_apikey),
76	77	qs: {
77		- trx_id: trx_id,
78		- rc: rc,
79		- message: message,
80		- handler: config.handler_name
	78	+ trx_id: data.trx_id,
	79	+ rc: data.rc,
	80	+ message: data.message,
	81	+ handler: config.handler_name,
	82	+ sn: data.sn,
	83	+ supplier_price: data.supplier_price
81	84	}
82	85	}
83	86
84		- if (sn) {
85		- options.qs.sn = sn;
86		- }
87	87
88	88	request(options, function(error, response, body) {
89	89	if (error) {
...	...	@@ -98,13 +98,13 @@ function report(trx_id, rc, message, sn) {
98	98	});
99	99	}
100	100
101		-function resendReport(trx_id, rc, message, sn) {
	101	+function resendReport(data) {
102	102	let sleepBeforeResend = 1000;
103	103	logger.verbose('Resend report to CORE in ' + sleepBeforeResend + 'ms')
104	104
105	105	setTimeout(
106	106	function() {
107		- report(trx_id, rc, message, sn);
	107	+ report(data);
108	108	},
109	109	sleepBeforeResend
110	110	)