Commit 439dd26b4179cdc61f70a0144415b3aaad744177
1 parent
f83de7efb4
Exists in
master
resendDelay embeded to callbackReport
Showing 1 changed file with 14 additions and 4 deletions Inline Diff
partner-fm.js
1 | var xml2js = require('xml2js'); | 1 | var xml2js = require('xml2js'); |
2 | var request = require('request'); | 2 | var request = require('request'); |
3 | var http = require('http'); | 3 | var http = require('http'); |
4 | var redis = require('redis'); | 4 | var redis = require('redis'); |
5 | var resendDelay = require('sate24/resend-delay.js'); | 5 | var resendDelay = require('sate24/resend-delay.js'); |
6 | var LRU = require('lru-cache'); | 6 | var LRU = require('lru-cache'); |
7 | 7 | ||
8 | var aaa; | 8 | var aaa; |
9 | var _callbackReport; | 9 | var _callbackReport; |
10 | var config; | 10 | var config; |
11 | var logger; | 11 | var logger; |
12 | var redisClient; | 12 | var redisClient; |
13 | 13 | ||
14 | var xmlBuilder = new xml2js.Builder(); | 14 | var xmlBuilder = new xml2js.Builder(); |
15 | var taskHistory = LRU({max: 500, maxAge: 1000 * 3600 * 2}); | 15 | var taskHistory = LRU({max: 500, maxAge: 1000 * 3600 * 2}); |
16 | 16 | ||
17 | function start(options) { | 17 | function start(options) { |
18 | if (!options) { | 18 | if (!options) { |
19 | console.log('Undefined options, terminating....'); | 19 | console.log('Undefined options, terminating....'); |
20 | process.exit(1); | 20 | process.exit(1); |
21 | } | 21 | } |
22 | 22 | ||
23 | if (options.config) { | 23 | if (options.config) { |
24 | config = options.config; | 24 | config = options.config; |
25 | } else { | 25 | } else { |
26 | console.log('Undefined options.config, terminating....') | 26 | console.log('Undefined options.config, terminating....') |
27 | process.exit(1); | 27 | process.exit(1); |
28 | } | 28 | } |
29 | 29 | ||
30 | if (options.aaa) { | 30 | if (options.aaa) { |
31 | aaa = options.aaa; | 31 | aaa = options.aaa; |
32 | _callbackReport = options.aaa.callbackReportWithPushToMongoDb; | 32 | _callbackReport = options.aaa.callbackReportWithPushToMongoDb; |
33 | } else { | 33 | } else { |
34 | console.log('Undefined options.aaa, terminating....') | 34 | console.log('Undefined options.aaa, terminating....') |
35 | process.exit(1); | 35 | process.exit(1); |
36 | } | 36 | } |
37 | 37 | ||
38 | if (options && options.logger) { | 38 | if (options && options.logger) { |
39 | logger = options.logger; | 39 | logger = options.logger; |
40 | } else { | 40 | } else { |
41 | console.log('Undefined options.logger, terminating....') | 41 | console.log('Undefined options.logger, terminating....') |
42 | process.exit(1); | 42 | process.exit(1); |
43 | } | 43 | } |
44 | 44 | ||
45 | createRedisClient(config.globals.redis_host, config.globals.redis_port); | 45 | createRedisClient(config.globals.redis_host, config.globals.redis_port); |
46 | createServer(); | 46 | createServer(); |
47 | 47 | ||
48 | resendDelay.init({ | 48 | resendDelay.init({ |
49 | config: config, | 49 | config: config, |
50 | topupRequest: topupStatus, | 50 | topupRequest: topupStatus, |
51 | logger: logger | 51 | logger: logger |
52 | }); | 52 | }); |
53 | } | 53 | } |
54 | 54 | ||
55 | function topupRequest(task) { | 55 | function topupRequest(task) { |
56 | aaa.insertTaskToMongoDb(task); | 56 | aaa.insertTaskToMongoDb(task); |
57 | 57 | ||
58 | getTaskFromHistory(task, function(err, archivedTask) { | 58 | getTaskFromHistory(task, function(err, archivedTask) { |
59 | putTaskToHistory(task); | 59 | putTaskToHistory(task); |
60 | 60 | ||
61 | if (archivedTask) { | 61 | if (archivedTask) { |
62 | logger.info('Task has been executed before, going to checkStatus', {task: task, archivedTask: archivedTask}); | 62 | logger.info('Task has been executed before, going to checkStatus', {task: task, archivedTask: archivedTask}); |
63 | topupStatus(task); | 63 | topupStatus(task); |
64 | } else { | 64 | } else { |
65 | _topupRequest(task); | 65 | _topupRequest(task); |
66 | } | 66 | } |
67 | }); | 67 | }); |
68 | } | 68 | } |
69 | 69 | ||
70 | function _topupRequest(task) { | 70 | function _topupRequest(task) { |
71 | 71 | ||
72 | var payload = composeTopupMessage( | 72 | var payload = composeTopupMessage( |
73 | config.h2h_out.pin, | 73 | config.h2h_out.pin, |
74 | task.remoteProduct, | 74 | task.remoteProduct, |
75 | task.destination, | 75 | task.destination, |
76 | task.requestId | 76 | task.requestId |
77 | ); | 77 | ); |
78 | 78 | ||
79 | var reqOpts = { | 79 | var reqOpts = { |
80 | url: config.h2h_out.partner, | 80 | url: config.h2h_out.partner, |
81 | method: "POST", | 81 | method: "POST", |
82 | body: payload, | 82 | body: payload, |
83 | headers: { | 83 | headers: { |
84 | 'Content-Type': 'text/xml', | 84 | 'Content-Type': 'text/xml', |
85 | } | 85 | } |
86 | }; | 86 | }; |
87 | 87 | ||
88 | logger.verbose('Requesting TOPUP to partner', {reqOpts: reqOpts, payload: payload}); | 88 | logger.verbose('Requesting TOPUP to partner', {reqOpts: reqOpts, payload: payload}); |
89 | request(reqOpts, function (err, response, body) { | 89 | request(reqOpts, function (err, response, body) { |
90 | if (err) { | 90 | if (err) { |
91 | var msg = 'Error requesting TOPUP to partner: ' + err; | 91 | var msg = 'Error requesting TOPUP to partner: ' + err; |
92 | logger.warn(msg, {task: task, err: err}); | 92 | logger.warn(msg, {task: task, err: err}); |
93 | callbackReport(task.requestId, '68', msg); | 93 | callbackReport(task.requestId, '68', msg); |
94 | return; | 94 | return; |
95 | } | 95 | } |
96 | 96 | ||
97 | logger.verbose('Got a direct response from TOPUP', {response: body, task: task}); | 97 | logger.verbose('Got a direct response from TOPUP', {response: body, task: task}); |
98 | topupResponseHandler(body, task.requestId, callbackReport); | 98 | topupResponseHandler(body, task.requestId, callbackReport); |
99 | }); | 99 | }); |
100 | } | 100 | } |
101 | 101 | ||
102 | function topupStatus(task) { | 102 | function topupStatus(task) { |
103 | var payload = composeTopupStatusMessage( | 103 | var payload = composeTopupStatusMessage( |
104 | config.h2h_out.pin, | 104 | config.h2h_out.pin, |
105 | task.requestId | 105 | task.requestId |
106 | ); | 106 | ); |
107 | 107 | ||
108 | var reqOpts = { | 108 | var reqOpts = { |
109 | url: config.h2h_out.partner, | 109 | url: config.h2h_out.partner, |
110 | method: "POST", | 110 | method: "POST", |
111 | body: payload, | 111 | body: payload, |
112 | headers: { | 112 | headers: { |
113 | 'Content-Type': 'text/xml', | 113 | 'Content-Type': 'text/xml', |
114 | } | 114 | } |
115 | }; | 115 | }; |
116 | 116 | ||
117 | logger.verbose('Requesting TOPUPSTATUS to partner', {reqOpts: reqOpts, payload: payload}); | 117 | logger.verbose('Requesting TOPUPSTATUS to partner', {reqOpts: reqOpts, payload: payload}); |
118 | request(reqOpts, function (err, response, body) { | 118 | request(reqOpts, function (err, response, body) { |
119 | if (err) { | 119 | if (err) { |
120 | var msg = 'Error requesting TOPUPSTATUS to partner: ' + err; | 120 | var msg = 'Error requesting TOPUPSTATUS to partner: ' + err; |
121 | logger.warn(msg, {task: task, err: err}); | 121 | logger.warn(msg, {task: task, err: err}); |
122 | callbackReport(task.requestId, '68', msg); | 122 | callbackReport(task.requestId, '68', msg); |
123 | return; | 123 | return; |
124 | } | 124 | } |
125 | 125 | ||
126 | logger.verbose('Got a direct response from TOPUPSTATUS', {response: body, task: task}); | 126 | logger.verbose('Got a direct response from TOPUPSTATUS', {response: body, task: task}); |
127 | topupResponseHandler(body, task.requestId, callbackReport); | 127 | topupResponseHandler(body, task.requestId, callbackReport); |
128 | }); | 128 | }); |
129 | } | 129 | } |
130 | 130 | ||
131 | function topupResponseHandler(xmlResponse, _requestId, cb) { | 131 | function topupResponseHandler(xmlResponse, _requestId, cb) { |
132 | var xmlParser = xml2js.parseString; | 132 | var xmlParser = xml2js.parseString; |
133 | xmlParser(xmlResponse, function(err, data) { | 133 | xmlParser(xmlResponse, function(err, data) { |
134 | var msg; | 134 | var msg; |
135 | var requestId; | 135 | var requestId; |
136 | var rc = '68'; | 136 | var rc = '68'; |
137 | 137 | ||
138 | if (_requestId) { | 138 | if (_requestId) { |
139 | requestId = _requestId; | 139 | requestId = _requestId; |
140 | } | 140 | } |
141 | 141 | ||
142 | if (err) { | 142 | if (err) { |
143 | msg = 'Error parsing xml response: ' + err; | 143 | msg = 'Error parsing xml response: ' + err; |
144 | 144 | ||
145 | if (logger) { | 145 | if (logger) { |
146 | logger.warn(msg, {err: err, response: xmlResponse, task: task}); | 146 | logger.warn(msg, {err: err, response: xmlResponse, task: task}); |
147 | } else { | 147 | } else { |
148 | console.log(msg); | 148 | console.log(msg); |
149 | } | 149 | } |
150 | } else { | 150 | } else { |
151 | 151 | ||
152 | try { | 152 | try { |
153 | msg = data.fm.message | 153 | msg = data.fm.message |
154 | } | 154 | } |
155 | catch(e) { | 155 | catch(e) { |
156 | msg = 'Unknown message' | 156 | msg = 'Unknown message' |
157 | } | 157 | } |
158 | 158 | ||
159 | if (data.fm.status == '0') { | 159 | if (data.fm.status == '0') { |
160 | 160 | ||
161 | rc = '00'; | 161 | rc = '00'; |
162 | msg = modifyMessageWithSn(msg); | 162 | msg = modifyMessageWithSn(msg); |
163 | 163 | ||
164 | } else if (data.fm.status == '1') { | 164 | } else if (data.fm.status == '1') { |
165 | rc = '68'; | 165 | rc = '68'; |
166 | } else if (data.fm.status == '2') { | 166 | } else if (data.fm.status == '2') { |
167 | rc = '40'; | 167 | rc = '40'; |
168 | } else if (data.fm.status == '3') { | 168 | } else if (data.fm.status == '3') { |
169 | rc = '40'; | 169 | rc = '40'; |
170 | } else { | 170 | } else { |
171 | rc = '68'; | 171 | rc = '68'; |
172 | } | 172 | } |
173 | 173 | ||
174 | if (data.fm.refTrxid) { | 174 | if (data.fm.refTrxid) { |
175 | requestId = data.fm.refTrxid; | 175 | requestId = data.fm.refTrxid; |
176 | } | 176 | } |
177 | 177 | ||
178 | } | 178 | } |
179 | 179 | ||
180 | cb(requestId, rc, msg, xmlResponse) | 180 | cb(requestId, rc, msg, xmlResponse) |
181 | }); | 181 | }); |
182 | } | 182 | } |
183 | 183 | ||
184 | function callbackReport(requestId, responseCode, msg, rawResponse) { | 184 | function callbackReport(requestId, responseCode, msg, rawResponse, dontResendDelay) { |
185 | if (requestId) { | 185 | if (!requestId) { |
186 | _callbackReport(requestId, responseCode, msg, null, rawResponse); | ||
187 | } else { | ||
188 | logger.warn('Undefined requestId, not sending callbackReport', {rc: responseCode, msg: msg, rawResponse: rawResponse}); | 186 | logger.warn('Undefined requestId, not sending callbackReport', {rc: responseCode, msg: msg, rawResponse: rawResponse}); |
187 | return; | ||
189 | } | 188 | } |
190 | 189 | ||
190 | if (responseCode != '68' || dontResendDelay) { | ||
191 | resendDelay.cancel(requestId); | ||
192 | } else { | ||
193 | getTaskFromHistory(requestId, function(err, archivedTask) { | ||
194 | if (archivedTask) { | ||
195 | resendDelay.register(archivedTask); | ||
196 | } | ||
197 | }); | ||
198 | } | ||
199 | |||
200 | _callbackReport(requestId, responseCode, msg, null, rawResponse); | ||
191 | } | 201 | } |
192 | 202 | ||
193 | function getSnFromMessage(msg) { | 203 | function getSnFromMessage(msg) { |
194 | try { | 204 | try { |
195 | var matches = msg.match(/SN:(\w+)/); | 205 | var matches = msg.match(/SN:(\w+)/); |
196 | return matches[1]; | 206 | return matches[1]; |
197 | } | 207 | } |
198 | catch(e) { | 208 | catch(e) { |
199 | return; | 209 | return; |
200 | } | 210 | } |
201 | } | 211 | } |
202 | 212 | ||
203 | function modifyMessageWithSn(msg) { | 213 | function modifyMessageWithSn(msg) { |
204 | var sn = getSnFromMessage(msg); | 214 | var sn = getSnFromMessage(msg); |
205 | if (sn) { | 215 | if (sn) { |
206 | msg = 'SN=' + sn + '; ' + msg; | 216 | msg = 'SN=' + sn + '; ' + msg; |
207 | } | 217 | } |
208 | return msg; | 218 | return msg; |
209 | } | 219 | } |
210 | 220 | ||
211 | function composeTopupMessage(pin, product, destination, requestId) { | 221 | function composeTopupMessage(pin, product, destination, requestId) { |
212 | var data = {fm: { | 222 | var data = {fm: { |
213 | command: 'TOPUP', | 223 | command: 'TOPUP', |
214 | pin: pin, | 224 | pin: pin, |
215 | product: product, | 225 | product: product, |
216 | msisdn: destination, | 226 | msisdn: destination, |
217 | refTrxid: requestId | 227 | refTrxid: requestId |
218 | }}; | 228 | }}; |
219 | 229 | ||
220 | return xmlBuilder.buildObject(data); | 230 | return xmlBuilder.buildObject(data); |
221 | } | 231 | } |
222 | 232 | ||
223 | function composeTopupStatusMessage(pin, requestId) { | 233 | function composeTopupStatusMessage(pin, requestId) { |
224 | var data = {fm: { | 234 | var data = {fm: { |
225 | command: 'TOPUPSTATUS', | 235 | command: 'TOPUPSTATUS', |
226 | pin: pin, | 236 | pin: pin, |
227 | refTrxid: requestId | 237 | refTrxid: requestId |
228 | }} | 238 | }} |
229 | 239 | ||
230 | return xmlBuilder.buildObject(data); | 240 | return xmlBuilder.buildObject(data); |
231 | } | 241 | } |
232 | 242 | ||
233 | function createServer() { | 243 | function createServer() { |
234 | var httpServer = http.createServer(function(request, response) { | 244 | var httpServer = http.createServer(function(request, response) { |
235 | 245 | ||
236 | logger.info('Got request from partner'); | 246 | logger.info('Got request from partner'); |
237 | 247 | ||
238 | var body = ""; | 248 | var body = ""; |
239 | req.on('data', function (chunk) { | 249 | req.on('data', function (chunk) { |
240 | body += chunk; | 250 | body += chunk; |
241 | }); | 251 | }); |
242 | 252 | ||
243 | req.on('end', function () { | 253 | req.on('end', function () { |
244 | res.writeHead(200); | 254 | res.writeHead(200); |
245 | res.end('OK'); | 255 | res.end('OK'); |
246 | 256 | ||
247 | topupResponseHandler(body, null, callbackReport); | 257 | topupResponseHandler(body, null, callbackReport); |
248 | 258 | ||
249 | }); | 259 | }); |
250 | 260 | ||
251 | }); | 261 | }); |
252 | 262 | ||
253 | httpServer.listen(config.h2h_out.listen_port, function() { | 263 | httpServer.listen(config.h2h_out.listen_port, function() { |
254 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); | 264 | logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); |
255 | }); | 265 | }); |
256 | } | 266 | } |
257 | 267 | ||
258 | function createRedisClient(host, port) { | 268 | function createRedisClient(host, port) { |
259 | if (!host && !port) { | 269 | if (!host && !port) { |
260 | logger.info('Not creating redis client because unspecified host or port'); | 270 | logger.info('Not creating redis client because unspecified host or port'); |
261 | return; | 271 | return; |
262 | } | 272 | } |
263 | 273 | ||
264 | try { | 274 | try { |
265 | redisClient = redis.createClient(port, host); | 275 | redisClient = redis.createClient(port, host); |
266 | } catch(err) { | 276 | } catch(err) { |
267 | logger.warn("Error creating redis client to " + host + ':' + port); | 277 | logger.warn("Error creating redis client to " + host + ':' + port); |
268 | } | 278 | } |
269 | } | 279 | } |
270 | 280 | ||
271 | function getTaskKey(task, chipInfo) { | 281 | function getTaskKey(task, chipInfo) { |
272 | var requestId; | 282 | var requestId; |
273 | 283 | ||
274 | if (typeof task === 'string') { | 284 | if (typeof task === 'string') { |
275 | requestId = task; | 285 | requestId = task; |
276 | } else { | 286 | } else { |
277 | try { | 287 | try { |
278 | requestId = task.requestId; | 288 | requestId = task.requestId; |
279 | } | 289 | } |
280 | catch(e) { | 290 | catch(e) { |
281 | logger.warn('Something wrong', {task: task}); | 291 | logger.warn('Something wrong', {task: task}); |
282 | console.trace('Cekidot'); | 292 | console.trace('Cekidot'); |
283 | process.exit(1); | 293 | process.exit(1); |
284 | } | 294 | } |
285 | 295 | ||
286 | } | 296 | } |
287 | 297 | ||
288 | if (!chipInfo && config && config.globals && config.globals.gateway_name) { | 298 | if (!chipInfo && config && config.globals && config.globals.gateway_name) { |
289 | chipInfo = config.globals.gateway_name; | 299 | chipInfo = config.globals.gateway_name; |
290 | } | 300 | } |
291 | 301 | ||
292 | return chipInfo + '.hitachi.rid:' + requestId; | 302 | return chipInfo + '.hitachi.rid:' + requestId; |
293 | } | 303 | } |
294 | 304 | ||
295 | 305 | ||
296 | function putTaskToHistory(task, cb) { | 306 | function putTaskToHistory(task, cb) { |
297 | if (Number(config.globals.no_dupe_check)) { | 307 | if (Number(config.globals.no_dupe_check)) { |
298 | if (cb) { cb(); } | 308 | if (cb) { cb(); } |
299 | return; | 309 | return; |
300 | } | 310 | } |
301 | var key = getTaskKey(task, config.globals.gateway_name); | 311 | var key = getTaskKey(task, config.globals.gateway_name); |
302 | logger.verbose('Saving task to history LRU', {key: key, task: task}); | 312 | logger.verbose('Saving task to history LRU', {key: key, task: task}); |
303 | 313 | ||
304 | try { | 314 | try { |
305 | taskHistory.set(key, JSON.parse(JSON.stringify(task))); | 315 | taskHistory.set(key, JSON.parse(JSON.stringify(task))); |
306 | } catch (e) { } | 316 | } catch (e) { } |
307 | 317 | ||
308 | putTaskToRedis(task, cb); | 318 | putTaskToRedis(task, cb); |
309 | } | 319 | } |
310 | 320 | ||
311 | function putTaskToRedis(task, cb) { | 321 | function putTaskToRedis(task, cb) { |
312 | if (!redisClient) { | 322 | if (!redisClient) { |
313 | logger.verbose('Not saving to redis because of undefined redisClient') | 323 | logger.verbose('Not saving to redis because of undefined redisClient') |
314 | if (cb) { cb(); } | 324 | if (cb) { cb(); } |
315 | return; | 325 | return; |
316 | } | 326 | } |
317 | 327 | ||
318 | var key = getTaskKey(task, config.globals.gateway_name); | 328 | var key = getTaskKey(task, config.globals.gateway_name); |
319 | logger.verbose('Saving task to redis', {key: key, task: task}); | 329 | logger.verbose('Saving task to redis', {key: key, task: task}); |
320 | 330 | ||
321 | redisClient.set(key, JSON.stringify(task), function() { | 331 | redisClient.set(key, JSON.stringify(task), function() { |
322 | redisClient.expire(key, 3600*24*30); | 332 | redisClient.expire(key, 3600*24*30); |
323 | if (cb) { | 333 | if (cb) { |
324 | cb(); | 334 | cb(); |
325 | } | 335 | } |
326 | }); | 336 | }); |
327 | } | 337 | } |
328 | 338 | ||
329 | function getTaskFromHistory(task, cb) { | 339 | function getTaskFromHistory(task, cb) { |
330 | logger.verbose('Getting task from history', {task: task}); | 340 | logger.verbose('Getting task from history', {task: task}); |
331 | var key = getTaskKey(task, config.globals.gateway_name); | 341 | var key = getTaskKey(task, config.globals.gateway_name); |
332 | var archive = taskHistory.get(key); | 342 | var archive = taskHistory.get(key); |
333 | 343 | ||
334 | if (archive) { | 344 | if (archive) { |
335 | if (cb) { cb(null, archive); } | 345 | if (cb) { cb(null, archive); } |
336 | } | 346 | } |
337 | else { | 347 | else { |
338 | getTaskFromRedis(task, cb); | 348 | getTaskFromRedis(task, cb); |
339 | } | 349 | } |
340 | } | 350 | } |
341 | 351 | ||
342 | function getTaskFromRedis(task, cb) { | 352 | function getTaskFromRedis(task, cb) { |
343 | if (!redisClient) { | 353 | if (!redisClient) { |
344 | if (cb) { cb(null, null); } | 354 | if (cb) { cb(null, null); } |
345 | return; | 355 | return; |
346 | } | 356 | } |
347 | 357 | ||
348 | var key = getTaskKey(task, config.globals.gateway_name); | 358 | var key = getTaskKey(task, config.globals.gateway_name); |
349 | redisClient.get(key, function(err, result) { | 359 | redisClient.get(key, function(err, result) { |
350 | if (err) { | 360 | if (err) { |
351 | logger.warn('Error retrieving task from redis', {err: err}); | 361 | logger.warn('Error retrieving task from redis', {err: err}); |
352 | cb(err, null); | 362 | cb(err, null); |
353 | return; | 363 | return; |
354 | } | 364 | } |
355 | 365 | ||
356 | var task; | 366 | var task; |
357 | try { | 367 | try { |
358 | task = JSON.parse(result); | 368 | task = JSON.parse(result); |
359 | } | 369 | } |
360 | catch(e) { | 370 | catch(e) { |
361 | logger.warn('Exception on parsing redis result as a json', {err: e}); | 371 | logger.warn('Exception on parsing redis result as a json', {err: e}); |
362 | } | 372 | } |
363 | 373 | ||
364 | cb(null, task); | 374 | cb(null, task); |
365 | }) | 375 | }) |
366 | } | 376 | } |
367 | 377 | ||
368 | 378 | ||
369 | exports.start = start; | 379 | exports.start = start; |
370 | exports.topupRequest = topupRequest; | 380 | exports.topupRequest = topupRequest; |
371 | exports.composeTopupMessage = composeTopupMessage; | 381 | exports.composeTopupMessage = composeTopupMessage; |
372 | exports.getSnFromMessage = getSnFromMessage; | 382 | exports.getSnFromMessage = getSnFromMessage; |