Reload97 / sate24-to-sate24

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

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

16

var taskHistory = LRU({max: 500, maxAge: 1000 * 3600 * 2});

16

var taskHistory = LRU({max: 500, maxAge: 1000 * 3600 * 2});

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

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

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

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

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

71

_callbackReport(requestId, responseCode, message, null, responseToSave);

71

_callbackReport(requestId, responseCode, message, null, responseToSave);

72

}

72

}

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

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

87

function topupRequest(task) {

87

function topupRequest(task) {

88

aaa.insertTaskToMongoDb(task);

88

aaa.insertTaskToMongoDb(task);

89

90

getTaskFromHistory(task, function(err, archivedTask) {

90

getTaskFromHistory(task, function(err, archivedTask) {

91

putTaskToHistory(task);

91

putTaskToHistory(task);

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

102

function _topupRequest(task, pendingOnConnectError) {

102

function _topupRequest(task, pendingOnConnectError) {

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

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

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

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

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

134

client.methodCall(methodName, [ params ], function (error, value) {

134

client.methodCall(methodName, [ params ], function (error, value) {

135

136

// Results of the method response

136

// Results of the method response

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

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

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

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

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

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

163

var msg = prefixMessageWithSN(value);

163

var msg = prefixMessageWithSN(value);

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

171

function prefixMessageWithSN(data) {

171

function prefixMessageWithSN(data) {

172

173

if (data['RESPONSECODE'] != '00') {

173

if (data['RESPONSECODE'] != '00') {

174

return data['MESSAGE'];

174

return data['MESSAGE'];

175

}

175

}

176

177

sn = '';

177

sn = '';

178

179

if (data.SN && data.SN.trim()) {

179

if (data.SN && data.SN.trim()) {

180

sn = data['SN'].replace(/ /g, '-');

180

sn = data['SN'].trim();

181

sn = sn.replace(/[\()]/g, '-');

182

sn = sn.replace(/-/g, '-').trim();

183

return 'SN=' + sn + '; ' + data['MESSAGE'];

184

}

181

}

185

else if (data['MESSAGE'].search(/^SN=.+;/) == -1) {

182

else if (data['MESSAGE'].search(/^SN=.+;/) == -1) {

186

if (data['SN'] && data['SN'].trim()) {

183

if (data['SN'] && data['SN'].trim()) {

187

sn = data['SN'].trim();

184

sn = data['SN'].trim();

188

}

185

}

189

else if (config.h2h_out.parse_sn == 'YES') {

186

else if (config.h2h_out.parse_sn == 'YES') {

190

sn = parseSN(data['MESSAGE']);

187

sn = parseSN(data['MESSAGE']);

191

}

188

}

189

}

192

190

191

if (sn) {

193

sn = sn.replace(/ /g, '-');

192

sn = sn.replace(/ /g, '-');

194

193

sn = sn.replace(/[\()]/g, '-');

194

sn = sn.replace(/-+/g, '-')

195

sn = sn.replace(/^-+/, '');

196

sn = sn.replace(/-+$/, '');

197

sn = sn.trim();

195

return 'SN=' + sn + '; ' + data['MESSAGE'];

198

return 'SN=' + sn + '; ' + data['MESSAGE'];

196

}

199

}

197

200

198

return data['MESSAGE'];

201

return data['MESSAGE'];

199

}

202

}

200

203

201

function createServer() {

204

function createServer() {

202

205

203

logger.info('Creating XML-RPC server on port ' + config.h2h_out.listen_port);

206

logger.info('Creating XML-RPC server on port ' + config.h2h_out.listen_port);

204

var serverOptions = {

207

var serverOptions = {

205

port: config.h2h_out.listen_port

208

port: config.h2h_out.listen_port

206

};

209

};

207

210

208

var server = xmlrpc.createServer(serverOptions);

211

var server = xmlrpc.createServer(serverOptions);

209

212

210

server.on('NotFound', function (method, params) {

213

server.on('NotFound', function (method, params) {

211

logger.warn('Unknown method recevied on XMLRPC server', {xmlrpc_method: method, xmlrpc_params: params});

214

logger.warn('Unknown method recevied on XMLRPC server', {xmlrpc_method: method, xmlrpc_params: params});

212

});

215

});

213

216

214

server.on('topUpReport', function (err, params, callback) {

217

server.on('topUpReport', function (err, params, callback) {

215

218

216

logger.info('Got XMLRPC topUpReport request from partner', {xmlrpc_method: 'topUpReport', xmlrpc_params: params});

219

logger.info('Got XMLRPC topUpReport request from partner', {xmlrpc_method: 'topUpReport', xmlrpc_params: params});

217

220

218

var paramscount = params.length;

221

var paramscount = params.length;

219

for (var i = 0; i < paramscount; i++) {

222

for (var i = 0; i < paramscount; i++) {

220

var value = params[i];

223

var value = params[i];

221

224

222

if (value['RESPONSECODE'] == '94') {

225

if (value['RESPONSECODE'] == '94') {

223

logger.info('Change RC 94 to 68');

226

logger.info('Change RC 94 to 68');

224

value['RESPONSECODE'] = '68';

227

value['RESPONSECODE'] = '68';

225

}

228

}

226

229

227

var msg = prefixMessageWithSN(value);

230

var msg = prefixMessageWithSN(value);

228

231

229

callbackReport(

232

callbackReport(

230

value['REQUESTID'], value['RESPONSECODE'], msg, null, JSON.stringify({methodName: 'topUpReport', msg: value})

233

value['REQUESTID'], value['RESPONSECODE'], msg, null, JSON.stringify({methodName: 'topUpReport', msg: value})

231

);

234

);

232

}

235

}

233

236

234

callback(null, 'ACK REPORT OK');

237

callback(null, 'ACK REPORT OK');

235

})

238

})

236

239

237

}

240

}

238

241

239

function createPlainHttpServer() {

242

function createPlainHttpServer() {

240

logger.info('Creating IRS HTTP server on port ' + config.h2h_out.listen_port);

243

logger.info('Creating IRS HTTP server on port ' + config.h2h_out.listen_port);

241

244

242

var httpServer = http.createServer(function(request, response) {

245

var httpServer = http.createServer(function(request, response) {

243

246

244

var qs = url.parse(request.url, true).query;

247

var qs = url.parse(request.url, true).query;

245

logger.info('Got reverse report from gateway', {qs: qs});

248

logger.info('Got reverse report from gateway', {qs: qs});

246

249

247

var request_id = qs.clientid;

250

var request_id = qs.clientid;

248

251

249

var rc = irsRc[qs.statuscode] || '68';

252

var rc = irsRc[qs.statuscode] || '68';

250

253

251

var msg = qs.msg + '. STATUSCODE:' + qs.statuscode;

254

var msg = qs.msg + '. STATUSCODE:' + qs.statuscode;

252

255

253

if (rc == '00' && qs.sn) {

256

if (rc == '00' && qs.sn) {

254

msg = 'SN=' + qs.sn.replace(/ /g, '-').trim() + '; ' + msg;

257

msg = 'SN=' + qs.sn.replace(/ /g, '-').trim() + '; ' + msg;

255

}

258

}

256

259

257

response.end('OK');

260

response.end('OK');

258

261

259

callbackReport(request_id, rc, msg);

262

callbackReport(request_id, rc, msg);

260

263

261

});

264

});

262

265

263

httpServer.listen(config.h2h_out.listen_port, function() {

266

httpServer.listen(config.h2h_out.listen_port, function() {

264

logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);

267

logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);

265

});

268

});

266

}

269

}

267

270

268

function getBalanceFromMessage(message, balance_regex) {

271

function getBalanceFromMessage(message, balance_regex) {

269

if (!balance_regex) {

272

if (!balance_regex) {

270

if (config && config.globals && config.globals.balance_regex) {

273

if (config && config.globals && config.globals.balance_regex) {

271

balance_regex = config.globals.balance_regex;

274

balance_regex = config.globals.balance_regex;

272

}

275

}

273

}

276

}

274

277

275

if (!balance_regex) {

278

if (!balance_regex) {

276

return;

279

return;

277

}

280

}

278

281

279

try {

282

try {

280

var re = new RegExp(balance_regex);

283

var re = new RegExp(balance_regex);

281

var matches = message.match(re);

284

var matches = message.match(re);

282

285

283

var result = matches[1];

286

var result = matches[1];

284

result = result.replace(/\./g, '');

287

result = result.replace(/\./g, '');

285

result = result.replace(/,/g, '');

288

result = result.replace(/,/g, '');

286

289

287

290

288

return Number(result);

291

return Number(result);

289

}

292

}

290

catch(err) {

293

catch(err) {

291

return;

294

return;

292

}

295

}

293

}

296

}

294

297

295

function updateBalance(message) {

298

function updateBalance(message) {

296

var balance = getBalanceFromMessage(message);

299

var balance = getBalanceFromMessage(message);

297

if (balance) {

300

if (balance) {

298

logger.info('Balance: ' + balance);

301

logger.info('Balance: ' + balance);

299

aaa.updateBalance(balance);

302

aaa.updateBalance(balance);

300

}

303

}

301

}

304

}

302

305

303

function checkStatus(task) {

306

function checkStatus(task) {

304

307

305

if (Number(config.globals.topup_request_on_check_status)) {

308

if (Number(config.globals.topup_request_on_check_status)) {

306

_topupRequest(task, true);

309

_topupRequest(task, true);

307

return;

310

return;

308

}

311

}

309

312

310

var partnerUrl = url.parse(config.h2h_out.partner);

313

var partnerUrl = url.parse(config.h2h_out.partner);

311

var clientOptions = {

314

var clientOptions = {

312

host: partnerUrl.hostname

315

host: partnerUrl.hostname

313

, port: partnerUrl.port

316

, port: partnerUrl.port

314

, path: partnerUrl.pathname

317

, path: partnerUrl.pathname

315

};

318

};

316

logger.info('XMLRPC client options:');

319

logger.info('XMLRPC client options:');

317

logger.info(clientOptions);

320

logger.info(clientOptions);

318

321

319

var client;

322

var client;

320

if (partnerUrl.protocol == 'https:') {

323

if (partnerUrl.protocol == 'https:') {

321

client = xmlrpc.createSecureClient(clientOptions);

324

client = xmlrpc.createSecureClient(clientOptions);

322

} else {

325

} else {

323

client = xmlrpc.createClient(clientOptions);

326

client = xmlrpc.createClient(clientOptions);

324

}

327

}

325

328

326

var methodName = 'topUpInquiry';

329

var methodName = 'topUpInquiry';

327

330

328

var params = {

331

var params = {

329

REQUESTID: task['requestId'],

332

REQUESTID: task['requestId'],

330

MSISDN: config.h2h_out.userid,

333

MSISDN: config.h2h_out.userid,

331

PIN: config.h2h_out.password,

334

PIN: config.h2h_out.password,

332

NOHP: task['destination']

335

NOHP: task['destination']

333

};

336

};

334

337

335

logger.info('Requesting topUpInquiry', {params: params});

338

logger.info('Requesting topUpInquiry', {params: params});

336

339

337

client.methodCall(methodName, [ params ], function (error, value) {

340

client.methodCall(methodName, [ params ], function (error, value) {

338

// Results of the method response

341

// Results of the method response

339

if (error) {

342

if (error) {

340

logger.warn('Error requesting topUpInquiry: ', {err: error, params: params});

343

logger.warn('Error requesting topUpInquiry: ', {err: error, params: params});

341

callbackReport(

344

callbackReport(

342

task.requestId, '68', 'Error requesting topUpInquiry: ' + error, null, JSON.stringify({methodName: methodName, error: error})

345

task.requestId, '68', 'Error requesting topUpInquiry: ' + error, null, JSON.stringify({methodName: methodName, error: error})

343

);

346

);

344

return;

347

return;

345

}

348

}

346

logger.info('Method response for \'' + methodName, {response: value});

349

logger.info('Method response for \'' + methodName, {response: value});

347

350

348

callbackReport(task.requestId, value['RESPONSECODE'], value['MESSAGE'], null, JSON.stringify({methodName: methodName, response: value}));

351

callbackReport(task.requestId, value['RESPONSECODE'], value['MESSAGE'], null, JSON.stringify({methodName: methodName, response: value}));

349

});

352

});

350

}

353

}

351

354

352

function start(options) {

355

function start(options) {

353

if (!options) {

356

if (!options) {

354

console.log('Undefined options, terminating....');

357

console.log('Undefined options, terminating....');

355

process.exit(1);

358

process.exit(1);

356

}

359

}

357

360

358

if (options.config) {

361

if (options.config) {

359

config = options.config;

362

config = options.config;

360

} else {

363

} else {

361

console.log('Undefined options.config, terminating....')

364

console.log('Undefined options.config, terminating....')

362

process.exit(1);

365

process.exit(1);

363

}

366

}

364

367

365

if (options.aaa) {

368

if (options.aaa) {

366

aaa = options.aaa;

369

aaa = options.aaa;

367

_callbackReport = options.aaa.callbackReportWithPushToMongoDb;

370

_callbackReport = options.aaa.callbackReportWithPushToMongoDb;

368

} else {

371

} else {

369

console.log('Undefined options.aaa, terminating....')

372

console.log('Undefined options.aaa, terminating....')

370

process.exit(1);

373

process.exit(1);

371

}

374

}

372

375

373

if (options && options.logger) {

376

if (options && options.logger) {

374

logger = options.logger;

377

logger = options.logger;

375

} else {

378

} else {

376

logger = new winston.Logger({

379

logger = new winston.Logger({

377

transports: [

380

transports: [

378

new (winston.transports.Console)()

381

new (winston.transports.Console)()

379

]

382

]

380

});

383

});

381

}

384

}

382

385

383

createRedisClient(config.globals.redis_host, config.globals.redis_port);

386

createRedisClient(config.globals.redis_host, config.globals.redis_port);

384

387

385

if (!Number(config.h2h_out.irs_mode)) {

388

if (!Number(config.h2h_out.irs_mode)) {

386

createServer();

389

createServer();

387

}

390

}

388

else {

391

else {

389

createPlainHttpServer();

392

createPlainHttpServer();

390

}

393

}

391

394

392

395

393

var resendDelayOptions = {

396

var resendDelayOptions = {

394

config: config,

397

config: config,

395

topupRequest: checkStatus,

398

topupRequest: checkStatus,

396

logger: logger

399

logger: logger

397

};

400

};

398

401

399

if (Number(config.globals.topup_request_on_resend_delay)) {

402

if (Number(config.globals.topup_request_on_resend_delay)) {

400

resendDelayOptions.topupRequest = topupRequest;

403

resendDelayOptions.topupRequest = topupRequest;

401

}

404

}

402

405

403

resendDelay.init(resendDelayOptions);

406

resendDelay.init(resendDelayOptions);

404

}

407

}

405

408

406

function parseSN(message, _config) {

409

function parseSN(message, _config) {

407

410

408

if (!_config) {

411

if (!_config) {

409

_config = config;

412

_config = config;

410

}

413

}

411

414

412

var sn_regex = new RegExp(_config.h2h_out.sn_pattern);

415

var sn_regex = new RegExp(_config.h2h_out.sn_pattern);

413

var sn_match = message.match(sn_regex);

416

var sn_match = message.match(sn_regex);

414

417

415

if (sn_match <= 0) {

418

if (sn_match <= 0) {

416

logger.info('SN Not found: ' + message);

419

logger.info('SN Not found: ' + message);

417

return '';

420

return '';

418

}

421

}

419

422

420

var match_index = 0;

423

var match_index = 0;

421

if (_config.h2h_out.sn_match_index) {

424

if (_config.h2h_out.sn_match_index) {

422

match_index = Number(_config.h2h_out.sn_match_index);

425

match_index = Number(_config.h2h_out.sn_match_index);

423

}

426

}

424

427

425

var sn = sn_match[match_index];

428

var sn = sn_match[match_index];

426

429

427

if (_config.h2h_out.sn_remove_whitespace) {

430

if (_config.h2h_out.sn_remove_whitespace) {

428

sn = sn.replace(/\s/g, '');

431

sn = sn.replace(/\s/g, '');

429

}

432

}

430

433

431

var sn_remove_patterns = [];

434

var sn_remove_patterns = [];

432

if (_config.h2h_out.sn_remove_patterns && _config.h2h_out.sn_remove_patterns_separator) {

435

if (_config.h2h_out.sn_remove_patterns && _config.h2h_out.sn_remove_patterns_separator) {

433

sn_remove_patterns = _config.h2h_out.sn_remove_patterns.split(_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);

434

}

437

}

435

var count = sn_remove_patterns.length;

438

var count = sn_remove_patterns.length;

436

439

437

for(var i = 0; i < count; i++) {

440

for(var i = 0; i < count; i++) {

438

441

439

//sn = sn.replace(sn_remove_patterns[i], '');

442

//sn = sn.replace(sn_remove_patterns[i], '');

440

443

441

var re = new RegExp(sn_remove_patterns[i], 'g');

444

var re = new RegExp(sn_remove_patterns[i], 'g');

442

sn = sn.replace(re, '');

445

sn = sn.replace(re, '');

443

}

446

}

444

447

445

//sn = paddingSN(sn, _config);

448

//sn = paddingSN(sn, _config);

446

449

447

return sn.trim();

450

return sn.trim();

448

}

451

}

449

452

450

function getTaskKey(task, chipInfo) {

453

function getTaskKey(task, chipInfo) {

451

var requestId;

454

var requestId;

452

455

453

if (typeof task === 'string') {

456

if (typeof task === 'string') {

454

requestId = task;

457

requestId = task;

455

} else {

458

} else {

456

try {

459

try {

457

requestId = task.requestId;

460

requestId = task.requestId;

458

}

461

}

459

catch(e) {

462

catch(e) {

460

logger.warn('Something wrong', {task: task});

463

logger.warn('Something wrong', {task: task});

461

console.trace('Cekidot');

464

console.trace('Cekidot');

462

process.exit(1);

465

process.exit(1);

463

}

466

}

464

467

465

}

468

}

466

469

467

if (!chipInfo && config && config.globals && config.globals.gateway_name) {

470

if (!chipInfo && config && config.globals && config.globals.gateway_name) {

468

chipInfo = config.globals.gateway_name;

471

chipInfo = config.globals.gateway_name;

469

}

472

}

470

473

471

return chipInfo + '.hitachi.rid:' + requestId;

474

return chipInfo + '.hitachi.rid:' + requestId;

472

}

475

}

473

476

474

477

475

function putTaskToHistory(task, cb) {

478

function putTaskToHistory(task, cb) {

476

if (Number(config.globals.no_dupe_check)) {

479

if (Number(config.globals.no_dupe_check)) {

477

if (cb) { cb(); }

480

if (cb) { cb(); }

478

return;

481

return;

479

}

482

}

480

var key = getTaskKey(task, config.globals.gateway_name);

483

var key = getTaskKey(task, config.globals.gateway_name);

481

logger.verbose('Saving task to history LRU', {key: key, task: task});

484

logger.verbose('Saving task to history LRU', {key: key, task: task});

482

485

483

try {

486

try {

484

taskHistory.set(key, JSON.parse(JSON.stringify(task)));

487

taskHistory.set(key, JSON.parse(JSON.stringify(task)));

485

} catch (e) { }

488

} catch (e) { }

486

489

487

putTaskToRedis(task, cb);

490

putTaskToRedis(task, cb);

488

}

491

}

489

492

490

function putTaskToRedis(task, cb) {

493

function putTaskToRedis(task, cb) {

491

if (!redisClient) {

494

if (!redisClient) {

492

logger.verbose('Not saving to redis because of undefined redisClient')

495

logger.verbose('Not saving to redis because of undefined redisClient')

493

if (cb) { cb(); }

496

if (cb) { cb(); }

494

return;

497

return;

495

}

498

}

496

499

497

var key = getTaskKey(task, config.globals.gateway_name);

500

var key = getTaskKey(task, config.globals.gateway_name);

498

logger.verbose('Saving task to redis', {key: key, task: task});

501

logger.verbose('Saving task to redis', {key: key, task: task});

499

502

500

redisClient.set(key, JSON.stringify(task), function() {

503

redisClient.set(key, JSON.stringify(task), function() {

501

redisClient.expire(key, 3600*24*30);

504

redisClient.expire(key, 3600*24*30);

502

if (cb) {

505

if (cb) {

503

cb();

506

cb();

504

}

507

}

505

});

508

});

506

}

509

}

507

510

508

function getTaskFromHistory(task, cb) {

511

function getTaskFromHistory(task, cb) {

509

logger.verbose('Getting task from history', {task: task});

512

logger.verbose('Getting task from history', {task: task});

510

var key = getTaskKey(task, config.globals.gateway_name);

513

var key = getTaskKey(task, config.globals.gateway_name);

511

var archive = taskHistory.get(key);

514

var archive = taskHistory.get(key);

512

515

513

if (archive) {

516

if (archive) {

514

if (cb) { cb(null, archive); }

517

if (cb) { cb(null, archive); }

515

}

518

}

516

else {

519

else {

517

getTaskFromRedis(task, cb);

520

getTaskFromRedis(task, cb);

518

}

521

}

519

}

522

}

520

523

521

function getTaskFromRedis(task, cb) {

524

function getTaskFromRedis(task, cb) {

522

if (!redisClient) {

525

if (!redisClient) {

523

if (cb) { cb(null, null); }

526

if (cb) { cb(null, null); }

524

return;

527

return;

525

}

528

}

526

529

527

var key = getTaskKey(task, config.globals.gateway_name);

530

var key = getTaskKey(task, config.globals.gateway_name);

528

redisClient.get(key, function(err, result) {

531

redisClient.get(key, function(err, result) {

529

if (err) {

532

if (err) {

530

logger.warn('Error retrieving task from redis', {err: err});

533

logger.warn('Error retrieving task from redis', {err: err});

531

cb(err, null);

534

cb(err, null);

532

return;

535

return;

533

}

536

}

534

537

535

var task;

538

var task;

536

try {

539

try {

537

task = JSON.parse(result);

540

task = JSON.parse(result);

538

}

541

}

539

catch(e) {

542

catch(e) {

540

logger.warn('Exception on parsing redis result as a json', {err: e});

543

logger.warn('Exception on parsing redis result as a json', {err: e});

541

}

544

}

542

545

543

cb(null, task);

546

cb(null, task);

544

})

547

})

545

}

548

}

546

549

547

exports.start = start;

550

exports.start = start;

548

exports.topupRequest = topupRequest;

551

exports.topupRequest = topupRequest;

GITLAB

Reload97 / sate24-to-sate24

update prefixMessageWithSN again