Komodo / komodo-gw-komodo

Download as
Browse Code ยป

Commit eb64ddc3993606f52635d8a338c303df64425689

Authored by Adhidarma Hadiwinoto
1 parent 3a7cccfa6f
Exists in master

res.end on reverseReportHandler

Showing 1 changed file with 2 additions and 0 deletions Inline Diff

1 "use strict"; 1 "use strict";
2 2
3 const HTTP = require('http'); 3 const HTTP = require('http');
4 const URL = require('url'); 4 const URL = require('url');
5 const request = require('request'); 5 const request = require('request');
6 const uuidv4 = require('uuid/v4'); 6 const uuidv4 = require('uuid/v4');
7 7
8 const config = require('komodo-sdk/config'); 8 const config = require('komodo-sdk/config');
9 const logger = require('komodo-sdk/logger'); 9 const logger = require('komodo-sdk/logger');
10 const matrix = require('komodo-sdk/matrix'); 10 const matrix = require('komodo-sdk/matrix');
11 const pull = require('komodo-sdk/gateway/pull'); 11 const pull = require('komodo-sdk/gateway/pull');
12 12
13 const komodoClient = require('./komodo-client'); 13 const komodoClient = require('./komodo-client');
14 const partnerRc = require('./komodo-rc'); 14 const partnerRc = require('./komodo-rc');
15 15
16 if (!matrix.pending_tasks) { 16 if (!matrix.pending_tasks) {
17 matrix.pending_tasks = {}; 17 matrix.pending_tasks = {};
18 } 18 }
19 19
20 function deleteFromPendingTasks(trx_id) { 20 function deleteFromPendingTasks(trx_id) {
21 if (matrix.pending_tasks && matrix.pending_tasks[trx_id]) { 21 if (matrix.pending_tasks && matrix.pending_tasks[trx_id]) {
22 delete matrix.pending_tasks[trx_id]; 22 delete matrix.pending_tasks[trx_id];
23 } 23 }
24 } 24 }
25 25
26 function report(data) { 26 function report(data) {
27 pull.report(data); 27 pull.report(data);
28 28
29 if (data.rc !== '68' && data.rc !== '96') { 29 if (data.rc !== '68' && data.rc !== '96') {
30 deleteFromPendingTasks(data.trx_id); 30 deleteFromPendingTasks(data.trx_id);
31 } 31 }
32 } 32 }
33 33
34 function _hit(task, is_advice) { 34 function _hit(task, is_advice) {
35 35
36 if (matrix.pending_tasks && !matrix.pending_tasks[task.trx_id]) { 36 if (matrix.pending_tasks && !matrix.pending_tasks[task.trx_id]) {
37 matrix.pending_tasks[task.trx_id] = task; 37 matrix.pending_tasks[task.trx_id] = task;
38 } 38 }
39 39
40 const request_options = { 40 const request_options = {
41 url: config.partner.url, 41 url: config.partner.url,
42 qs: { 42 qs: {
43 request_id: task.trx_id, 43 request_id: task.trx_id,
44 terminal_name: config.partner.terminal_name || config.partner.username, 44 terminal_name: config.partner.terminal_name || config.partner.username,
45 password: config.partner.password, 45 password: config.partner.password,
46 reverse_url: config.reverse_report_url, 46 reverse_url: config.reverse_report_url,
47 product_name: task.remote_product, 47 product_name: task.remote_product,
48 destination: task.destination 48 destination: task.destination
49 } 49 }
50 } 50 }
51 51
52 if (!request_options.qs.request_id || !request_options.qs.terminal_name || !request_options.qs.password || !request_options.qs.reverse_url || !request_options.qs.product_name || !request_options.qs.destination) { 52 if (!request_options.qs.request_id || !request_options.qs.terminal_name || !request_options.qs.password || !request_options.qs.reverse_url || !request_options.qs.product_name || !request_options.qs.destination) {
53 logger.verbose('Missing parameter on request', request_options.qs); 53 logger.verbose('Missing parameter on request', request_options.qs);
54 return; 54 return;
55 } 55 }
56 56
57 logger.info('Requesting to partner', {is_advice: is_advice, trx_id: task.trx_id, destination: task.destination, product: task.product, remote_product: task.remote_product}); 57 logger.info('Requesting to partner', {is_advice: is_advice, trx_id: task.trx_id, destination: task.destination, product: task.product, remote_product: task.remote_product});
58 request(request_options, function(err, res, body) { 58 request(request_options, function(err, res, body) {
59 if (err) { 59 if (err) {
60 logger.warn('Error requesting to partner', {err: err, trx_id: task.trx_id, destination: task.destination, is_advice: is_advice}); 60 logger.warn('Error requesting to partner', {err: err, trx_id: task.trx_id, destination: task.destination, is_advice: is_advice});
61 report({ 61 report({
62 trx_id: task.trx_id, 62 trx_id: task.trx_id,
63 rc: (!is_advice && (err.syscall === 'connect')) ? '91' : '68', 63 rc: (!is_advice && (err.syscall === 'connect')) ? '91' : '68',
64 message: 'INTERNAL: REQUEST ERROR: ' + err.toString(), 64 message: 'INTERNAL: REQUEST ERROR: ' + err.toString(),
65 misc: { 65 misc: {
66 task: task 66 task: task
67 } 67 }
68 }); 68 });
69 return; 69 return;
70 } 70 }
71 71
72 if (res.statusCode != 200) { 72 if (res.statusCode != 200) {
73 logger.warn('Partner returning non 200 HTTP status code', {trx_id: task.trx_id, destination: task.destination, is_advice: is_advice, http_status_code: res.statusCode, response_body: body}); 73 logger.warn('Partner returning non 200 HTTP status code', {trx_id: task.trx_id, destination: task.destination, is_advice: is_advice, http_status_code: res.statusCode, response_body: body});
74 report({ 74 report({
75 trx_id: task.trx_id, 75 trx_id: task.trx_id,
76 rc: '68', 76 rc: '68',
77 message: ('INTERNAL: Got non 200 HTTP status code: ' + res.statusCode + '\n\n' + body).trim(), 77 message: ('INTERNAL: Got non 200 HTTP status code: ' + res.statusCode + '\n\n' + body).trim(),
78 raw: body, 78 raw: body,
79 misc: { 79 misc: {
80 task: task 80 task: task
81 } 81 }
82 }); 82 });
83 return; 83 return;
84 } 84 }
85 85
86 logger.verbose('Got response from partner', {trx_id: task.trx_id, destination: task.destination, is_advice: is_advice, response_body: body}); 86 logger.verbose('Got response from partner', {trx_id: task.trx_id, destination: task.destination, is_advice: is_advice, response_body: body});
87 87
88 const result = komodoClient.parseResponse(body); 88 const result = komodoClient.parseResponse(body);
89 if (!result) { 89 if (!result) {
90 logger.warn('Partner returning invalid JSON', {trx_id: task.trx_id, destination: task.destination, is_advice: is_advice, response_body: body}); 90 logger.warn('Partner returning invalid JSON', {trx_id: task.trx_id, destination: task.destination, is_advice: is_advice, response_body: body});
91 report({ 91 report({
92 trx_id: task.trx_id, 92 trx_id: task.trx_id,
93 rc: is_advice ? '68' : '90', 93 rc: is_advice ? '68' : '90',
94 message: 'INTERNAL: Partner return invalid JSON:\n' + body, 94 message: 'INTERNAL: Partner return invalid JSON:\n' + body,
95 raw: body, 95 raw: body,
96 misc: { 96 misc: {
97 task: task 97 task: task
98 } 98 }
99 }); 99 });
100 return; 100 return;
101 } 101 }
102 102
103 report({ 103 report({
104 trx_id: task.trx_id, 104 trx_id: task.trx_id,
105 rc: partnerRc[result.rc] || '40', 105 rc: partnerRc[result.rc] || '40',
106 message: result.message, 106 message: result.message,
107 sn: result.sn, 107 sn: result.sn,
108 amount: Number(result.amount) || null, 108 amount: Number(result.amount) || null,
109 raw: body, 109 raw: body,
110 misc: { 110 misc: {
111 task: task 111 task: task
112 } 112 }
113 }); 113 });
114 }) 114 })
115 } 115 }
116 116
117 function buy(task) { 117 function buy(task) {
118 _hit(task, false); 118 _hit(task, false);
119 } 119 }
120 120
121 function advice(task) { 121 function advice(task) {
122 _hit(task, true); 122 _hit(task, true);
123 } 123 }
124 124
125 function reverseReportHandler(req, res) { 125 function reverseReportHandler(req, res) {
126 const report_id = uuidv4(); 126 const report_id = uuidv4();
127 127
128 logger.verbose('Incoming reverse report', {report_id: report_id, url: req.url}); 128 logger.verbose('Incoming reverse report', {report_id: report_id, url: req.url});
129 res.end('OK');
130
129 const qs = URL.parse(req.url, true).query; 131 const qs = URL.parse(req.url, true).query;
130 132
131 if (!qs.request_id || !qs.rc) { 133 if (!qs.request_id || !qs.rc) {
132 logger.verbose('No request_id and rc on reverse report message', {report_id: report_id, url: req.url, qs: qs}); 134 logger.verbose('No request_id and rc on reverse report message', {report_id: report_id, url: req.url, qs: qs});
133 return; 135 return;
134 } 136 }
135 137
136 const task = { 138 const task = {
137 trx_id: qs.request_id, 139 trx_id: qs.request_id,
138 destination: qs.destination, 140 destination: qs.destination,
139 remote_product: qs.product_name 141 remote_product: qs.product_name
140 } 142 }
141 143
142 report({ 144 report({
143 trx_id: qs.request_id, 145 trx_id: qs.request_id,
144 rc: partnerRc[qs.rc] || '40', 146 rc: partnerRc[qs.rc] || '40',
145 message: qs.message, 147 message: qs.message,
146 sn: qs.sn, 148 sn: qs.sn,
147 amount: qs.amount || null, 149 amount: qs.amount || null,
148 raw: req.url, 150 raw: req.url,
149 misc: { 151 misc: {
150 task: task 152 task: task
151 } 153 }
152 }); 154 });
153 } 155 }
154 156
155 function createReverseReportHttpServer() { 157 function createReverseReportHttpServer() {
156 const http_server = HTTP.createServer(reverseReportHandler); 158 const http_server = HTTP.createServer(reverseReportHandler);
157 http_server.listen(config.reverse_report_port, function(err) { 159 http_server.listen(config.reverse_report_port, function(err) {
158 if (err) { 160 if (err) {
159 logger.warn('Error creating reverse report HTTP server: ' + err.toString()); 161 logger.warn('Error creating reverse report HTTP server: ' + err.toString());
160 process.exit(1); 162 process.exit(1);
161 return; 163 return;
162 } 164 }
163 165
164 logger.info('Reverse report HTTP server listening on port ' + config.reverse_report_port); 166 logger.info('Reverse report HTTP server listening on port ' + config.reverse_report_port);
165 }) 167 })
166 } 168 }
167 169
168 createReverseReportHttpServer(); 170 createReverseReportHttpServer();
169 171
170 exports.buy = buy; 172 exports.buy = buy;
171 exports.advice = advice; 173 exports.advice = advice;
172 174