Commit 5c8ba4b52da7af1f22aabc1decec3cb404ecfc03

Authored by Adhidarma Hadiwinoto
1 parent 39af55cbf7
Exists in master

strip duplikat sn pada message

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

1 var http = require('http'); 1 var http = require('http');
2 var xmlrpc = require('xmlrpc'); 2 var xmlrpc = require('xmlrpc');
3 var url = require('url'); 3 var url = require('url');
4 var math = require('mathjs'); 4 var math = require('mathjs');
5 var winston = require('winston'); 5 var winston = require('winston');
6 var redis = require('redis'); 6 var redis = require('redis');
7 var resendDelay = require('sate24/resend-delay.js'); 7 var resendDelay = require('sate24/resend-delay.js');
8 var LRU = require('lru-cache'); 8 var LRU = require('lru-cache');
9 9
10 var aaa; 10 var aaa;
11 var logger; 11 var logger;
12 var config; 12 var config;
13 var _callbackReport; 13 var _callbackReport;
14 var redisClient; 14 var redisClient;
15 15
16 var taskHistory = LRU({max: 500, maxAge: 1000 * 3600 * 2}); 16 var taskHistory = LRU({max: 500, maxAge: 1000 * 3600 * 2});
17 17
18 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; 18 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
19 http.globalAgent.maxSockets = Infinity; 19 http.globalAgent.maxSockets = Infinity;
20 20
21 var irsRc = { 21 var irsRc = {
22 '0': '00', 22 '0': '00',
23 '00': '00', 23 '00': '00',
24 '1': '00', 24 '1': '00',
25 '2': '14', 25 '2': '14',
26 '17': '40', 26 '17': '40',
27 '63': '40', 27 '63': '40',
28 '89': '40', 28 '89': '40',
29 '68': '68', 29 '68': '68',
30 '94': '68', 30 '94': '68',
31 '05': '40', 31 '05': '40',
32 '30': '40', 32 '30': '40',
33 '51': '40', 33 '51': '40',
34 '13': '40', 34 '13': '40',
35 '14': '14', 35 '14': '14',
36 '91': '40', 36 '91': '40',
37 '40': '40', 37 '40': '40',
38 '49': '40', 38 '49': '40',
39 '53': '40', 39 '53': '40',
40 '54': '40', 40 '54': '40',
41 '914': '55', 41 '914': '55',
42 '55': '55', 42 '55': '55',
43 '06': '40', 43 '06': '40',
44 '92': '40' 44 '92': '40'
45 } 45 }
46 46
47 function callbackReport(requestId, responseCode, message, dontResendDelay, raw) { 47 function callbackReport(requestId, responseCode, message, dontResendDelay, raw) {
48 var responseToSave = { 48 var responseToSave = {
49 parsed: { 49 parsed: {
50 MESSAGE: message, 50 MESSAGE: message,
51 } 51 }
52 }; 52 };
53 53
54 if (raw) { 54 if (raw) {
55 responseToSave.raw = raw; 55 responseToSave.raw = raw;
56 } else { 56 } else {
57 responseToSave.raw = message; 57 responseToSave.raw = message;
58 } 58 }
59 59
60 if (responseCode != '68' || dontResendDelay) { 60 if (responseCode != '68' || dontResendDelay) {
61 resendDelay.cancel(requestId); 61 resendDelay.cancel(requestId);
62 } else { 62 } else {
63 getTaskFromHistory(requestId, function(err, archivedTask) { 63 getTaskFromHistory(requestId, function(err, archivedTask) {
64 if (archivedTask) { 64 if (archivedTask) {
65 logger.verbose('DEBUG', {archivedTask: archivedTask}); 65 logger.verbose('DEBUG', {archivedTask: archivedTask});
66 resendDelay.register(archivedTask); 66 resendDelay.register(archivedTask);
67 } 67 }
68 }); 68 });
69 } 69 }
70 70
71 _callbackReport(requestId, responseCode, message, null, responseToSave); 71 _callbackReport(requestId, responseCode, message, null, responseToSave);
72 } 72 }
73 73
74 function createRedisClient(host, port) { 74 function createRedisClient(host, port) {
75 if (!host && !port) { 75 if (!host && !port) {
76 logger.info('Not creating redis client because unspecified host or port'); 76 logger.info('Not creating redis client because unspecified host or port');
77 return; 77 return;
78 } 78 }
79 79
80 try { 80 try {
81 redisClient = redis.createClient(port, host); 81 redisClient = redis.createClient(port, host);
82 } catch(err) { 82 } catch(err) {
83 logger.warn("Error creating redis client to " + host + ':' + port); 83 logger.warn("Error creating redis client to " + host + ':' + port);
84 } 84 }
85 } 85 }
86 86
87 function topupRequest(task) { 87 function topupRequest(task) {
88 aaa.insertTaskToMongoDb(task); 88 aaa.insertTaskToMongoDb(task);
89 89
90 getTaskFromHistory(task, function(err, archivedTask) { 90 getTaskFromHistory(task, function(err, archivedTask) {
91 putTaskToHistory(task); 91 putTaskToHistory(task);
92 92
93 if (archivedTask) { 93 if (archivedTask) {
94 logger.info('Task has been executed before, going to checkStatus', {task: task, archivedTask: archivedTask}); 94 logger.info('Task has been executed before, going to checkStatus', {task: task, archivedTask: archivedTask});
95 checkStatus(task); 95 checkStatus(task);
96 } else { 96 } else {
97 _topupRequest(task); 97 _topupRequest(task);
98 } 98 }
99 }); 99 });
100 } 100 }
101 101
102 function _topupRequest(task, pendingOnConnectError) { 102 function _topupRequest(task, pendingOnConnectError) {
103 103
104 if (!aaa.isTodayTrx(task)) { 104 if (!aaa.isTodayTrx(task)) {
105 callbackReport(task.requestId, '68', 'Terdeteksi transaksi beda hari, batal kirim ke supplier. Silahkan cek webreport', true); 105 callbackReport(task.requestId, '68', 'Terdeteksi transaksi beda hari, batal kirim ke supplier. Silahkan cek webreport', true);
106 return; 106 return;
107 } 107 }
108 108
109 var partnerUrl = url.parse(config.h2h_out.partner); 109 var partnerUrl = url.parse(config.h2h_out.partner);
110 var clientOptions = { 110 var clientOptions = {
111 host: partnerUrl.hostname, 111 host: partnerUrl.hostname,
112 port: partnerUrl.port, 112 port: partnerUrl.port,
113 path: partnerUrl.pathname 113 path: partnerUrl.pathname
114 }; 114 };
115 115
116 var client; 116 var client;
117 if (partnerUrl.protocol == 'https:') { 117 if (partnerUrl.protocol == 'https:') {
118 client = xmlrpc.createSecureClient(clientOptions); 118 client = xmlrpc.createSecureClient(clientOptions);
119 } else { 119 } else {
120 client = xmlrpc.createClient(clientOptions); 120 client = xmlrpc.createClient(clientOptions);
121 } 121 }
122 122
123 var params = { 123 var params = {
124 MSISDN: config.h2h_out.userid, 124 MSISDN: config.h2h_out.userid,
125 REQUESTID: task['requestId'], 125 REQUESTID: task['requestId'],
126 PIN: config.h2h_out.password, 126 PIN: config.h2h_out.password,
127 NOHP: task['destination'], 127 NOHP: task['destination'],
128 NOM: task['remoteProduct'] 128 NOM: task['remoteProduct']
129 }; 129 };
130 130
131 var methodName = 'topUpRequest'; 131 var methodName = 'topUpRequest';
132 logger.info('Preparing XMLRPC request', {methodname: methodName, params: params, partnerUrl: partnerUrl.href}); 132 logger.info('Preparing XMLRPC request', {methodname: methodName, params: params, partnerUrl: partnerUrl.href});
133 133
134 client.methodCall(methodName, [ params ], function (error, value) { 134 client.methodCall(methodName, [ params ], function (error, value) {
135 135
136 // Results of the method response 136 // Results of the method response
137 137
138 if (error) { 138 if (error) {
139 var rc = '68'; 139 var rc = '68';
140 var msg = 'XMLRPC Client Error: ' + error; 140 var msg = 'XMLRPC Client Error: ' + error;
141 141
142 if (!pendingOnConnectError && (error.code == 'ECONNREFUSED' || error.code == 'EHOSTUNREACH')) { 142 if (!pendingOnConnectError && (error.code == 'ECONNREFUSED' || error.code == 'EHOSTUNREACH')) {
143 rc = '91'; 143 rc = '91';
144 msg = 'XMLRPC Client Error on connecting'; 144 msg = 'XMLRPC Client Error on connecting';
145 } else if (!pendingOnConnectError && error.code == 'ETIMEDOUT' && error.syscall == "connect") { 145 } else if (!pendingOnConnectError && error.code == 'ETIMEDOUT' && error.syscall == "connect") {
146 rc = '91'; 146 rc = '91';
147 msg = 'XMLRPC Client Error on connecting'; 147 msg = 'XMLRPC Client Error on connecting';
148 } 148 }
149 149
150 logger.warn('XMLRPC Client Error', {methodName: methodName, task: task, err:error}); 150 logger.warn('XMLRPC Client Error', {methodName: methodName, task: task, err:error});
151 151
152 callbackReport(task['requestId'], rc, msg, null, JSON.stringify({methodName: methodName, error: error.toString(), body: error.body})); 152 callbackReport(task['requestId'], rc, msg, null, JSON.stringify({methodName: methodName, error: error.toString(), body: error.body}));
153 return; 153 return;
154 } 154 }
155 155
156 logger.info('Got XMLRPC response from partner for', {methodName: methodName, response_message: value}); 156 logger.info('Got XMLRPC response from partner for', {methodName: methodName, response_message: value});
157 157
158 if (value['RESPONSECODE'] == '94') { 158 if (value['RESPONSECODE'] == '94') {
159 logger.info('Change RC 94 to 68'); 159 logger.info('Change RC 94 to 68');
160 value['RESPONSECODE'] = '68'; 160 value['RESPONSECODE'] = '68';
161 } 161 }
162 162
163 var msg = prefixMessageWithSN(value); 163 var msg = prefixMessageWithSN(value);
164 164
165 callbackReport( 165 callbackReport(
166 task.requestId, value['RESPONSECODE'], msg, null, JSON.stringify({methodName: methodName, response: value}) 166 task.requestId, value['RESPONSECODE'], msg, null, JSON.stringify({methodName: methodName, response: value})
167 ); 167 );
168 }); 168 });
169 } 169 }
170 170
171 function prefixMessageWithSN(data) { 171 function prefixMessageWithSN(data) {
172 172
173 if (data['RESPONSECODE'] != '00') { 173 if (data['RESPONSECODE'] != '00') {
174 return data['MESSAGE']; 174 return data['MESSAGE'];
175 } 175 }
176 176
177 sn = ''; 177 sn = '';
178 178
179 if (data.SN && data.SN.trim()) { 179 if (data.SN && data.SN.trim()) {
180 sn = data['SN'].trim(); 180 sn = data['SN'].trim();
181 } 181 }
182 else if (data['MESSAGE'].search(/^SN=.+;/) == -1) { 182 else if (data['MESSAGE'].search(/^SN=.+;/) == -1) {
183 if (data['SN'] && data['SN'].trim()) { 183 if (data['SN'] && data['SN'].trim()) {
184 sn = data['SN'].trim(); 184 sn = data['SN'].trim();
185 } 185 }
186 else if (config.h2h_out.parse_sn == 'YES') { 186 else if (config.h2h_out.parse_sn == 'YES') {
187 sn = parseSN(data['MESSAGE']); 187 sn = parseSN(data['MESSAGE']);
188 } 188 }
189 } 189 }
190 190
191 if (sn) { 191 if (sn) {
192 sn = sn.replace(/ /g, '-'); 192 sn = sn.replace(/ /g, '-');
193 sn = sn.replace(/[\()]/g, '-'); 193 sn = sn.replace(/[\()]/g, '-');
194 sn = sn.replace(/-+/g, '-') 194 sn = sn.replace(/-+/g, '-')
195 sn = sn.replace(/^-+/, ''); 195 sn = sn.replace(/^-+/, '');
196 sn = sn.replace(/-+$/, ''); 196 sn = sn.replace(/-+$/, '');
197 sn = sn.replace(/;\s*SN=.+?;/, '; ');
197 sn = sn.trim(); 198 sn = sn.trim();
198 return 'SN=' + sn + '; ' + data['MESSAGE']; 199 return 'SN=' + sn + '; ' + data['MESSAGE'];
199 } 200 }
200 201
201 return data['MESSAGE']; 202 return data['MESSAGE'];
202 } 203 }
203 204
204 function createServer() { 205 function createServer() {
205 206
206 logger.info('Creating XML-RPC server on port ' + config.h2h_out.listen_port); 207 logger.info('Creating XML-RPC server on port ' + config.h2h_out.listen_port);
207 var serverOptions = { 208 var serverOptions = {
208 port: config.h2h_out.listen_port 209 port: config.h2h_out.listen_port
209 }; 210 };
210 211
211 var server = xmlrpc.createServer(serverOptions); 212 var server = xmlrpc.createServer(serverOptions);
212 213
213 server.on('NotFound', function (method, params) { 214 server.on('NotFound', function (method, params) {
214 logger.warn('Unknown method recevied on XMLRPC server', {xmlrpc_method: method, xmlrpc_params: params}); 215 logger.warn('Unknown method recevied on XMLRPC server', {xmlrpc_method: method, xmlrpc_params: params});
215 }); 216 });
216 217
217 server.on('topUpReport', function (err, params, callback) { 218 server.on('topUpReport', function (err, params, callback) {
218 219
219 logger.info('Got XMLRPC topUpReport request from partner', {xmlrpc_method: 'topUpReport', xmlrpc_params: params}); 220 logger.info('Got XMLRPC topUpReport request from partner', {xmlrpc_method: 'topUpReport', xmlrpc_params: params});
220 221
221 var paramscount = params.length; 222 var paramscount = params.length;
222 for (var i = 0; i < paramscount; i++) { 223 for (var i = 0; i < paramscount; i++) {
223 var value = params[i]; 224 var value = params[i];
224 225
225 if (value['RESPONSECODE'] == '94') { 226 if (value['RESPONSECODE'] == '94') {
226 logger.info('Change RC 94 to 68'); 227 logger.info('Change RC 94 to 68');
227 value['RESPONSECODE'] = '68'; 228 value['RESPONSECODE'] = '68';
228 } 229 }
229 230
230 var msg = prefixMessageWithSN(value); 231 var msg = prefixMessageWithSN(value);
231 232
232 callbackReport( 233 callbackReport(
233 value['REQUESTID'], value['RESPONSECODE'], msg, null, JSON.stringify({methodName: 'topUpReport', msg: value}) 234 value['REQUESTID'], value['RESPONSECODE'], msg, null, JSON.stringify({methodName: 'topUpReport', msg: value})
234 ); 235 );
235 } 236 }
236 237
237 callback(null, 'ACK REPORT OK'); 238 callback(null, 'ACK REPORT OK');
238 }) 239 })
239 240
240 } 241 }
241 242
242 function createPlainHttpServer() { 243 function createPlainHttpServer() {
243 logger.info('Creating IRS HTTP server on port ' + config.h2h_out.listen_port); 244 logger.info('Creating IRS HTTP server on port ' + config.h2h_out.listen_port);
244 245
245 var httpServer = http.createServer(function(request, response) { 246 var httpServer = http.createServer(function(request, response) {
246 247
247 var qs = url.parse(request.url, true).query; 248 var qs = url.parse(request.url, true).query;
248 logger.info('Got reverse report from gateway', {qs: qs}); 249 logger.info('Got reverse report from gateway', {qs: qs});
249 250
250 var request_id = qs.clientid; 251 var request_id = qs.clientid;
251 252
252 var rc = irsRc[qs.statuscode] || '68'; 253 var rc = irsRc[qs.statuscode] || '68';
253 254
254 var msg = qs.msg + '. STATUSCODE:' + qs.statuscode; 255 var msg = qs.msg + '. STATUSCODE:' + qs.statuscode;
255 256
256 if (rc == '00' && qs.sn) { 257 if (rc == '00' && qs.sn) {
257 msg = 'SN=' + qs.sn.replace(/ /g, '-').trim() + '; ' + msg; 258 msg = 'SN=' + qs.sn.replace(/ /g, '-').trim() + '; ' + msg;
258 } 259 }
259 260
260 response.end('OK'); 261 response.end('OK');
261 262
262 callbackReport(request_id, rc, msg); 263 callbackReport(request_id, rc, msg);
263 264
264 }); 265 });
265 266
266 httpServer.listen(config.h2h_out.listen_port, function() { 267 httpServer.listen(config.h2h_out.listen_port, function() {
267 logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port); 268 logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
268 }); 269 });
269 } 270 }
270 271
271 function getBalanceFromMessage(message, balance_regex) { 272 function getBalanceFromMessage(message, balance_regex) {
272 if (!balance_regex) { 273 if (!balance_regex) {
273 if (config && config.globals && config.globals.balance_regex) { 274 if (config && config.globals && config.globals.balance_regex) {
274 balance_regex = config.globals.balance_regex; 275 balance_regex = config.globals.balance_regex;
275 } 276 }
276 } 277 }
277 278
278 if (!balance_regex) { 279 if (!balance_regex) {
279 return; 280 return;
280 } 281 }
281 282
282 try { 283 try {
283 var re = new RegExp(balance_regex); 284 var re = new RegExp(balance_regex);
284 var matches = message.match(re); 285 var matches = message.match(re);
285 286
286 var result = matches[1]; 287 var result = matches[1];
287 result = result.replace(/\./g, ''); 288 result = result.replace(/\./g, '');
288 result = result.replace(/,/g, ''); 289 result = result.replace(/,/g, '');
289 290
290 291
291 return Number(result); 292 return Number(result);
292 } 293 }
293 catch(err) { 294 catch(err) {
294 return; 295 return;
295 } 296 }
296 } 297 }
297 298
298 function updateBalance(message) { 299 function updateBalance(message) {
299 var balance = getBalanceFromMessage(message); 300 var balance = getBalanceFromMessage(message);
300 if (balance) { 301 if (balance) {
301 logger.info('Balance: ' + balance); 302 logger.info('Balance: ' + balance);
302 aaa.updateBalance(balance); 303 aaa.updateBalance(balance);
303 } 304 }
304 } 305 }
305 306
306 function checkStatus(task) { 307 function checkStatus(task) {
307 308
308 if (Number(config.globals.topup_request_on_check_status)) { 309 if (Number(config.globals.topup_request_on_check_status)) {
309 _topupRequest(task, true); 310 _topupRequest(task, true);
310 return; 311 return;
311 } 312 }
312 313
313 var partnerUrl = url.parse(config.h2h_out.partner); 314 var partnerUrl = url.parse(config.h2h_out.partner);
314 var clientOptions = { 315 var clientOptions = {
315 host: partnerUrl.hostname 316 host: partnerUrl.hostname
316 , port: partnerUrl.port 317 , port: partnerUrl.port
317 , path: partnerUrl.pathname 318 , path: partnerUrl.pathname
318 }; 319 };
319 logger.info('XMLRPC client options:'); 320 logger.info('XMLRPC client options:');
320 logger.info(clientOptions); 321 logger.info(clientOptions);
321 322
322 var client; 323 var client;
323 if (partnerUrl.protocol == 'https:') { 324 if (partnerUrl.protocol == 'https:') {
324 client = xmlrpc.createSecureClient(clientOptions); 325 client = xmlrpc.createSecureClient(clientOptions);
325 } else { 326 } else {
326 client = xmlrpc.createClient(clientOptions); 327 client = xmlrpc.createClient(clientOptions);
327 } 328 }
328 329
329 var methodName = 'topUpInquiry'; 330 var methodName = 'topUpInquiry';
330 331
331 var params = { 332 var params = {
332 REQUESTID: task['requestId'], 333 REQUESTID: task['requestId'],
333 MSISDN: config.h2h_out.userid, 334 MSISDN: config.h2h_out.userid,
334 PIN: config.h2h_out.password, 335 PIN: config.h2h_out.password,
335 NOHP: task['destination'] 336 NOHP: task['destination']
336 }; 337 };
337 338
338 logger.info('Requesting topUpInquiry', {params: params}); 339 logger.info('Requesting topUpInquiry', {params: params});
339 340
340 client.methodCall(methodName, [ params ], function (error, value) { 341 client.methodCall(methodName, [ params ], function (error, value) {
341 // Results of the method response 342 // Results of the method response
342 if (error) { 343 if (error) {
343 logger.warn('Error requesting topUpInquiry: ', {err: error, params: params}); 344 logger.warn('Error requesting topUpInquiry: ', {err: error, params: params});
344 callbackReport( 345 callbackReport(
345 task.requestId, '68', 'Error requesting topUpInquiry: ' + error, null, JSON.stringify({methodName: methodName, error: error}) 346 task.requestId, '68', 'Error requesting topUpInquiry: ' + error, null, JSON.stringify({methodName: methodName, error: error})
346 ); 347 );
347 return; 348 return;
348 } 349 }
349 logger.info('Method response for \'' + methodName, {response: value}); 350 logger.info('Method response for \'' + methodName, {response: value});
350 351
351 callbackReport(task.requestId, value['RESPONSECODE'], value['MESSAGE'], null, JSON.stringify({methodName: methodName, response: value})); 352 callbackReport(task.requestId, value['RESPONSECODE'], value['MESSAGE'], null, JSON.stringify({methodName: methodName, response: value}));
352 }); 353 });
353 } 354 }
354 355
355 function start(options) { 356 function start(options) {
356 if (!options) { 357 if (!options) {
357 console.log('Undefined options, terminating....'); 358 console.log('Undefined options, terminating....');
358 process.exit(1); 359 process.exit(1);
359 } 360 }
360 361
361 if (options.config) { 362 if (options.config) {
362 config = options.config; 363 config = options.config;
363 } else { 364 } else {
364 console.log('Undefined options.config, terminating....') 365 console.log('Undefined options.config, terminating....')
365 process.exit(1); 366 process.exit(1);
366 } 367 }
367 368
368 if (options.aaa) { 369 if (options.aaa) {
369 aaa = options.aaa; 370 aaa = options.aaa;
370 _callbackReport = options.aaa.callbackReportWithPushToMongoDb; 371 _callbackReport = options.aaa.callbackReportWithPushToMongoDb;
371 } else { 372 } else {
372 console.log('Undefined options.aaa, terminating....') 373 console.log('Undefined options.aaa, terminating....')
373 process.exit(1); 374 process.exit(1);
374 } 375 }
375 376
376 if (options && options.logger) { 377 if (options && options.logger) {
377 logger = options.logger; 378 logger = options.logger;
378 } else { 379 } else {
379 logger = new winston.Logger({ 380 logger = new winston.Logger({
380 transports: [ 381 transports: [
381 new (winston.transports.Console)() 382 new (winston.transports.Console)()
382 ] 383 ]
383 }); 384 });
384 } 385 }
385 386
386 createRedisClient(config.globals.redis_host, config.globals.redis_port); 387 createRedisClient(config.globals.redis_host, config.globals.redis_port);
387 388
388 if (!Number(config.h2h_out.irs_mode)) { 389 if (!Number(config.h2h_out.irs_mode)) {
389 createServer(); 390 createServer();
390 } 391 }
391 else { 392 else {
392 createPlainHttpServer(); 393 createPlainHttpServer();
393 } 394 }
394 395
395 396
396 var resendDelayOptions = { 397 var resendDelayOptions = {
397 config: config, 398 config: config,
398 topupRequest: checkStatus, 399 topupRequest: checkStatus,
399 logger: logger 400 logger: logger
400 }; 401 };
401 402
402 if (Number(config.globals.topup_request_on_resend_delay)) { 403 if (Number(config.globals.topup_request_on_resend_delay)) {
403 resendDelayOptions.topupRequest = topupRequest; 404 resendDelayOptions.topupRequest = topupRequest;
404 } 405 }
405 406
406 resendDelay.init(resendDelayOptions); 407 resendDelay.init(resendDelayOptions);
407 } 408 }
408 409
409 function parseSN(message, _config) { 410 function parseSN(message, _config) {
410 411
411 if (!_config) { 412 if (!_config) {
412 _config = config; 413 _config = config;
413 } 414 }
414 415
415 var sn_regex = new RegExp(_config.h2h_out.sn_pattern); 416 var sn_regex = new RegExp(_config.h2h_out.sn_pattern);
416 var sn_match = message.match(sn_regex); 417 var sn_match = message.match(sn_regex);
417 418
418 if (sn_match <= 0) { 419 if (sn_match <= 0) {
419 logger.info('SN Not found: ' + message); 420 logger.info('SN Not found: ' + message);
420 return ''; 421 return '';
421 } 422 }
422 423
423 var match_index = 0; 424 var match_index = 0;
424 if (_config.h2h_out.sn_match_index) { 425 if (_config.h2h_out.sn_match_index) {
425 match_index = Number(_config.h2h_out.sn_match_index); 426 match_index = Number(_config.h2h_out.sn_match_index);
426 } 427 }
427 428
428 var sn = sn_match[match_index]; 429 var sn = sn_match[match_index];
429 430
430 if (_config.h2h_out.sn_remove_whitespace) { 431 if (_config.h2h_out.sn_remove_whitespace) {
431 sn = sn.replace(/\s/g, ''); 432 sn = sn.replace(/\s/g, '');
432 } 433 }
433 434
434 var sn_remove_patterns = []; 435 var sn_remove_patterns = [];
435 if (_config.h2h_out.sn_remove_patterns && _config.h2h_out.sn_remove_patterns_separator) { 436 if (_config.h2h_out.sn_remove_patterns && _config.h2h_out.sn_remove_patterns_separator) {
436 sn_remove_patterns = _config.h2h_out.sn_remove_patterns.split(_config.h2h_out.sn_remove_patterns_separator); 437 sn_remove_patterns = _config.h2h_out.sn_remove_patterns.split(_config.h2h_out.sn_remove_patterns_separator);
437 } 438 }
438 var count = sn_remove_patterns.length; 439 var count = sn_remove_patterns.length;
439 440
440 for(var i = 0; i < count; i++) { 441 for(var i = 0; i < count; i++) {
441 442
442 //sn = sn.replace(sn_remove_patterns[i], ''); 443 //sn = sn.replace(sn_remove_patterns[i], '');
443 444
444 var re = new RegExp(sn_remove_patterns[i], 'g'); 445 var re = new RegExp(sn_remove_patterns[i], 'g');
445 sn = sn.replace(re, ''); 446 sn = sn.replace(re, '');
446 } 447 }
447 448
448 //sn = paddingSN(sn, _config); 449 //sn = paddingSN(sn, _config);
449 450
450 return sn.trim(); 451 return sn.trim();
451 } 452 }
452 453
453 function getTaskKey(task, chipInfo) { 454 function getTaskKey(task, chipInfo) {
454 var requestId; 455 var requestId;
455 456
456 if (typeof task === 'string') { 457 if (typeof task === 'string') {
457 requestId = task; 458 requestId = task;
458 } else { 459 } else {
459 try { 460 try {
460 requestId = task.requestId; 461 requestId = task.requestId;
461 } 462 }
462 catch(e) { 463 catch(e) {
463 logger.warn('Something wrong', {task: task}); 464 logger.warn('Something wrong', {task: task});
464 console.trace('Cekidot'); 465 console.trace('Cekidot');
465 process.exit(1); 466 process.exit(1);
466 } 467 }
467 468
468 } 469 }
469 470
470 if (!chipInfo && config && config.globals && config.globals.gateway_name) { 471 if (!chipInfo && config && config.globals && config.globals.gateway_name) {
471 chipInfo = config.globals.gateway_name; 472 chipInfo = config.globals.gateway_name;
472 } 473 }
473 474
474 return chipInfo + '.hitachi.rid:' + requestId; 475 return chipInfo + '.hitachi.rid:' + requestId;
475 } 476 }
476 477
477 478
478 function putTaskToHistory(task, cb) { 479 function putTaskToHistory(task, cb) {
479 if (Number(config.globals.no_dupe_check)) { 480 if (Number(config.globals.no_dupe_check)) {
480 if (cb) { cb(); } 481 if (cb) { cb(); }
481 return; 482 return;
482 } 483 }
483 var key = getTaskKey(task, config.globals.gateway_name); 484 var key = getTaskKey(task, config.globals.gateway_name);
484 logger.verbose('Saving task to history LRU', {key: key, task: task}); 485 logger.verbose('Saving task to history LRU', {key: key, task: task});
485 486
486 try { 487 try {
487 taskHistory.set(key, JSON.parse(JSON.stringify(task))); 488 taskHistory.set(key, JSON.parse(JSON.stringify(task)));
488 } catch (e) { } 489 } catch (e) { }
489 490
490 putTaskToRedis(task, cb); 491 putTaskToRedis(task, cb);
491 } 492 }
492 493
493 function putTaskToRedis(task, cb) { 494 function putTaskToRedis(task, cb) {
494 if (!redisClient) { 495 if (!redisClient) {
495 logger.verbose('Not saving to redis because of undefined redisClient') 496 logger.verbose('Not saving to redis because of undefined redisClient')
496 if (cb) { cb(); } 497 if (cb) { cb(); }
497 return; 498 return;
498 } 499 }
499 500
500 var key = getTaskKey(task, config.globals.gateway_name); 501 var key = getTaskKey(task, config.globals.gateway_name);
501 logger.verbose('Saving task to redis', {key: key, task: task}); 502 logger.verbose('Saving task to redis', {key: key, task: task});
502 503
503 redisClient.set(key, JSON.stringify(task), function() { 504 redisClient.set(key, JSON.stringify(task), function() {
504 redisClient.expire(key, 3600*24*30); 505 redisClient.expire(key, 3600*24*30);
505 if (cb) { 506 if (cb) {
506 cb(); 507 cb();
507 } 508 }
508 }); 509 });
509 } 510 }
510 511
511 function getTaskFromHistory(task, cb) { 512 function getTaskFromHistory(task, cb) {
512 logger.verbose('Getting task from history', {task: task}); 513 logger.verbose('Getting task from history', {task: task});
513 var key = getTaskKey(task, config.globals.gateway_name); 514 var key = getTaskKey(task, config.globals.gateway_name);
514 var archive = taskHistory.get(key); 515 var archive = taskHistory.get(key);
515 516
516 if (archive) { 517 if (archive) {
517 if (cb) { cb(null, archive); } 518 if (cb) { cb(null, archive); }
518 } 519 }
519 else { 520 else {
520 getTaskFromRedis(task, cb); 521 getTaskFromRedis(task, cb);
521 } 522 }
522 } 523 }
523 524
524 function getTaskFromRedis(task, cb) { 525 function getTaskFromRedis(task, cb) {
525 if (!redisClient) { 526 if (!redisClient) {
526 if (cb) { cb(null, null); } 527 if (cb) { cb(null, null); }
527 return; 528 return;
528 } 529 }
529 530
530 var key = getTaskKey(task, config.globals.gateway_name); 531 var key = getTaskKey(task, config.globals.gateway_name);
531 redisClient.get(key, function(err, result) { 532 redisClient.get(key, function(err, result) {
532 if (err) { 533 if (err) {
533 logger.warn('Error retrieving task from redis', {err: err}); 534 logger.warn('Error retrieving task from redis', {err: err});
534 cb(err, null); 535 cb(err, null);
535 return; 536 return;
536 } 537 }
537 538
538 var task; 539 var task;
539 try { 540 try {
540 task = JSON.parse(result); 541 task = JSON.parse(result);
541 } 542 }
542 catch(e) { 543 catch(e) {
543 logger.warn('Exception on parsing redis result as a json', {err: e}); 544 logger.warn('Exception on parsing redis result as a json', {err: e});
544 } 545 }
545 546
546 cb(null, task); 547 cb(null, task);
547 }) 548 })
548 } 549 }
549 550
550 exports.start = start; 551 exports.start = start;
551 exports.topupRequest = topupRequest; 552 exports.topupRequest = topupRequest;
552 exports.getBalanceFromMessage = getBalanceFromMessage; 553 exports.getBalanceFromMessage = getBalanceFromMessage;
553 exports.checkStatus = checkStatus; 554 exports.checkStatus = checkStatus;
554 555