Compare View
Commits (2)
Changes
Showing 2 changed files Side-by-side Diff
gateway/pull.js
... | ... | @@ -70,8 +70,37 @@ function forwardCoreTaskToPartner(coreMessage) { |
70 | 70 | partner.buy(task); |
71 | 71 | } |
72 | 72 | |
73 | -//function report(trx_id, rc, message, sn) { | |
74 | 73 | function report(data) { |
74 | + reportUsingHttpPost(data); | |
75 | +} | |
76 | + | |
77 | +function reportUsingHttpPost(data) { | |
78 | + let options = { | |
79 | + url: config.pull_url.report.replace('<CORE_APIKEY>', config.core_apikey), | |
80 | + form: { | |
81 | + trx_id: data.trx_id, | |
82 | + rc: data.rc, | |
83 | + message: data.message, | |
84 | + handler: config.handler_name, | |
85 | + sn: data.sn, | |
86 | + amount: data.amount | |
87 | + } | |
88 | + } | |
89 | + | |
90 | + request.post(options, function(error, response, body) { | |
91 | + if (error) { | |
92 | + logger.warn('Error reporting to CORE', {error: error}); | |
93 | + } | |
94 | + else if (response.statusCode != 200) { | |
95 | + logger.warn('CORE http response status is not 200', {requestOptions: options, http_response_status: response.statusCode}); | |
96 | + } | |
97 | + else { | |
98 | + logger.verbose('Report has been sent to CORE', {requestOptions: options}); | |
99 | + } | |
100 | + }); | |
101 | +} | |
102 | + | |
103 | +function reportUsingHttpGet(data) { | |
75 | 104 | let options = { |
76 | 105 | url: config.pull_url.report.replace('<CORE_APIKEY>', config.core_apikey), |
77 | 106 | qs: { |