Reload97 / sate24-to-sc

1

var fs = require('fs');

1

var fs = require('fs');

2

var https = require('https');

2

var https = require('https');

3

var http = require('http');

3

var http = require('http');

4

var url = require('url');

4

var url = require('url');

5

var request = require('request');

5

var request = require('request');

6

var xml2js = require('xml2js').parseString;

6

var xml2js = require('xml2js').parseString;

7

var strftime = require('strftime');

7

var strftime = require('strftime');

8

var math = require('mathjs');

8

var math = require('mathjs');

9

var winston = require('winston');

9

var winston = require('winston');

10

var cekstatus = require('./cekstatus.js');

10

var cekstatus = require('./cekstatus.js');

11

var mongoClient = require('mongodb').MongoClient;

11

var mongoClient = require('mongodb').MongoClient;

12

var LRU = require('lru-cache');

12

var LRU = require('lru-cache');

13

14

var config;

14

var config;

15

var httpServer;

15

var httpServer;

16

var aaa;

16

var aaa;

17

var logger;

17

var logger;

18

var callbackReport;

18

var callbackReport;

19

var mongodb;

19

var mongodb;

20

21

var tasks = LRU(10000);

21

var tasks = LRU(10000);

22

23

process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';

23

process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';

24

25

var sleep_before_retry = 30000;

25

var sleep_before_retry = 30000;

26

var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];

26

var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];

27

28

var logTag = __filename.split('/').reverse()[0];

28

var logTag = __filename.split('/').reverse()[0];

29

30

function initMongoClient() {

30

function initMongoClient() {

31

if (!config.mongodbstruk || !config.mongodbstruk.url) {

31

if (!config.mongodbstruk || !config.mongodbstruk.url) {

32

return;

32

return;

33

}

33

}

34

35

try {

35

try {

36

var url = config.mongodbstruk.url;

36

var url = config.mongodbstruk.url;

37

38

mongoClient.connect(url, function(err, db) {

38

mongoClient.connect(url, function(err, db) {

39

if (err) {

39

if (err) {

40

logger.warn('Failed to connect to mongodb', {err: err});

40

logger.warn('Failed to connect to mongodb', {err: err});

41

return;

41

return;

42

}

42

}

43

mongodb = db;

43

mongodb = db;

44

logger.info('MongoDB connected');

44

logger.info('MongoDB connected');

45

});

45

});

46

}

46

}

47

catch(err) {

47

catch(err) {

48

logger.warn('Exception when connecting to mongodb', {err: err, url: url});

48

logger.warn('Exception when connecting to mongodb', {err: err, url: url});

49

}

49

}

50

51

}

51

}

52

53

function prepareResultData(result) {

53

function prepareResultData(result) {

54

var task;

54

var task;

55

56

var data = {};

56

var data = {};

57

data.gateway = config.globals.gateway_name;

57

data.gateway = config.globals.gateway_name;

58

59

try {

59

try {

60

data.requestId = result.reffid[0].trim();

60

data.requestId = result.reffid[0].trim();

61

62

var key = config.globals.gateway_name + '.rid:' + data.requestId;

62

var key = config.globals.gateway_name + '.rid:' + data.requestId;

63

task = tasks.get(key);

63

task = tasks.get(key);

64

}

64

}

65

catch(err) { data.requestId = null; }

65

catch(err) { data.requestId = null; }

66

67

try {

67

try {

68

data.status = result.ResultCode[0].trim();

68

data.status = result.ResultCode[0].trim();

69

}

69

}

70

catch(err) { data.status = '68' }

70

catch(err) { data.status = '68' }

71

72

try {

72

try {

73

data.rcmessage = result.ErrorMsg[0].trim();

73

data.rcmessage = result.ErrorMsg[0].trim();

74

}

74

}

75

catch(err) { data.rcmessage = ''; }

75

catch(err) { data.rcmessage = ''; }

76

77

try {

77

try {

78

data.resptext = '';

78

data.resptext = '';

79

}

79

}

80

catch(err) { data.resptext = ''; }

80

catch(err) { data.resptext = ''; }

81

82

try {

82

try {

83

var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss')

83

var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss')

84

data.dt = ts;

84

data.dt = ts;

85

}

85

}

86

catch(err) {

86

catch(err) {

87

logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task});

87

logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task});

88

data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date());

88

data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date());

89

}

89

}

90

91

try {

91

try {

92

data.namapel = result.nama_pel[0].trim();

92

data.namapel = result.nama_pel[0].trim();

93

}

93

}

94

catch(err) { data.namapel = 'UNKNOWN'; }

94

catch(err) { data.namapel = 'UNKNOWN'; }

95

96

try {

96

try {

97

data.msn = result.nsm[0].trim();

97

data.msn = result.nsm[0].trim();

98

}

98

}

99

catch(err) { data.msn = 'UNKNOWN'; }

99

catch(err) { data.msn = 'UNKNOWN'; }

100

101

try {

101

try {

102

data.idpel = result.idpel[0].trim();

102

data.idpel = result.idpel[0].trim();

103

}

103

}

104

catch(err) { data.idpel = 'UNKNOWN'; }

104

catch(err) { data.idpel = 'UNKNOWN'; }

105

106

try {

106

try {

107

data.tarifdaya = result.tarif[0].trim();

107

data.tarifdaya = result.tarif[0].trim();

108

}

108

}

109

catch(err) { data.tarifdaya = 'UNKNOWN'; }

109

catch(err) { data.tarifdaya = 'UNKNOWN'; }

110

111

try {

111

try {

112

data.admin = parseInt(result.adminfee[0].trim());

112

data.admin = parseInt(result.adminfee[0].trim());

113

}

113

}

114

catch(err) { data.admin = 0; }

114

catch(err) { data.admin = 0; }

115

116

try {

116

try {

117

data.adm = parseInt(result.admin_fee[0].trim());

117

data.adm = parseInt(result.admin_fee[0].trim());

118

}

118

}

119

catch(err) { data.adm = 0; }

119

catch(err) { data.adm = 0; }

120

121

try {

121

try {

122

data.hargapelanggan = parseInt(result.amount_trx[0].trim());

122

data.hargapelanggan = parseInt(result.amount_trx[0].trim());

123

}

123

}

124

catch(err) { data.hargapelanggan = 0; }

124

catch(err) { data.hargapelanggan = 0; }

125

126

try {

126

try {

127

data.jumlahkwh = result.jml_daya[0].trim();

127

data.jumlahkwh = result.jml_daya[0].trim();

128

}

128

}

129

catch(err) { data.jumlahkwh = 0; }

129

catch(err) { data.jumlahkwh = 0; }

130

131

try {

131

try {

132

data.token = result.token[0].trim();

132

data.token = result.token[0].trim();

133

}

133

}

134

catch(err) { data.token = 0; }

134

catch(err) { data.token = 0; }

135

136

try {

136

try {

137

data.ppn = result.ppn_fee[0].trim();

137

data.ppn = result.ppn_fee[0].trim();

138

}

138

}

139

catch(err) { data.ppn_fee = 0; }

139

catch(err) { data.ppn_fee = 0; }

140

141

try {

141

try {

142

data.ppj = result.ppj_fee[0].trim();

142

data.ppj = result.ppj_fee[0].trim();

143

}

143

}

144

catch(err) { data.ppj = 0; }

144

catch(err) { data.ppj = 0; }

145

146

try {

146

try {

147

data.angsuran = result.angsuran_fee[0].trim();

147

data.angsuran = result.angsuran_fee[0].trim();

148

}

148

}

149

catch(err) { data.angsuran = 0; }

149

catch(err) { data.angsuran = 0; }

150

151

try {

151

try {

152

data.meterai = result.materai_fee[0].trim();

152

data.meterai = result.materai_fee[0].trim();

153

}

153

}

154

catch(err) { data.materai_fee = 0; }

154

catch(err) { data.materai_fee = 0; }

155

156

return data;

156

return data;

157

}

157

}

158

159

function saveTokenToMongoDb(result) {

159

function saveTokenToMongoDb(result) {

160

if (!mongodb) {

160

if (!mongodb) {

161

return;

161

return;

162

}

162

}

163

164

if (!config.mongodbstruk) {

164

if (!config.mongodbstruk) {

165

return;

165

return;

166

}

166

}

167

168

if (!config.mongodbstruk.collection) {

168

if (!config.mongodbstruk.collection) {

169

return;

169

return;

170

}

170

}

171

172

var data = prepareResultData(result);

172

var data = prepareResultData(result);

173

174

try {

174

try {

175

mongodb.collection(config.mongodbstruk.collection).insertOne(data);

175

mongodb.collection(config.mongodbstruk.collection).insertOne(data);

176

}

176

}

177

catch(err) {

177

catch(err) {

178

logger.warn('Error when inserting data to mongodb', {err: err, data: data});

178

logger.warn('Error when inserting data to mongodb', {err: err, data: data});

179

}

179

}

180

}

180

}

181

182

function putTaskToCache(task) {

182

function putTaskToCache(task) {

183

var key = config.globals.gateway_name + '.rid:' + task.requestId;

183

var key = config.globals.gateway_name + '.rid:' + task.requestId;

184

185

try {

185

try {

186

tasks.set(key, task);

186

tasks.set(key, task);

187

}

187

}

188

catch(err) {

188

catch(err) {

189

logger.warn('Error writing to task to cache', {err: err, key: key, task: task});

189

logger.warn('Error writing to task to cache', {err: err, key: key, task: task});

190

}

190

}

191

}

191

}

192

193

function topupRequest(task) {

193

function topupRequest(task) {

194

aaa.insertTaskToMongoDb(task);

194

aaa.insertTaskToMongoDb(task);

195

putTaskToCache(task);

195

putTaskToCache(task);

196

197

var ts = strftime('%Y%m%d%H%M%S', new Date());

197

var ts = strftime('%Y%m%d%H%M%S', new Date());

198

199

var data =

199

var data =

200

config.h2h_out.userid

200

config.h2h_out.userid

201

+ '|' + config.h2h_out.password

201

+ '|' + config.h2h_out.password

202

+ '|' + task['remoteProduct']

202

+ '|' + task['remoteProduct']

203

+ '|' + task['destination'] + '|0';

203

+ '|' + task['destination'] + '|0';

204

205

var options = {

205

var options = {

206

url: config.h2h_out.partner,

206

url: config.h2h_out.partner,

207

qs: {

207

qs: {

208

ts: ts,

208

ts: ts,

209

data: data,

209

data: data,

210

reffid: task['requestId']

210

reffid: task['requestId']

211

}

211

}

212

};

212

};

213

logger.info('Creating http request', {options: options});

213

logger.info('Creating http request', {options: options});

214

215

request(options, function (error, response, body) {

215

request(options, function (error, response, body) {

216

var responseCode = '40';

216

var responseCode = '40';

217

var responseMessage = 'Gateway Error';

217

var responseMessage = 'Gateway Error';

218

219

if (error) {

219

if (error) {

220

221

logger.warn('HTTP REQUEST ERROR', error);

221

logger.warn('HTTP REQUEST ERROR', error);

222

callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')');

222

callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')');

223

224

} else if (response.statusCode != 200) {

224

} else if (response.statusCode != 200) {

225

226

var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')';

226

var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')';

227

logger.warn(error_message);

227

logger.warn(error_message);

228

callbackReport(task['requestId'], '91', error_message);

228

callbackReport(task['requestId'], '91', error_message);

229

230

} else {

230

} else {

231

232

logger.info('DIRECT RESPONSE', {requestId: task.requestId, body: body});

232

logger.info('DIRECT RESPONSE', {requestId: task.requestId, body: body});

233

234

xml2js(body, function (err, result) {

234

xml2js(body, function (err, result) {

235

if (err) {

235

if (err) {

236

logger.warn('Error parsing xml response', {requestId: task.requestId, err: err, body: body});

236

logger.warn('Error parsing xml response', {requestId: task.requestId, err: err, body: body});

237

callbackReport(task['requestId'], '40', body);

237

callbackReport(task['requestId'], '40', body);

238

} else {

238

} else {

239

var directResponse = result;

239

var directResponse = result;

240

logger.info(directResponse);

240

logger.info(directResponse);

241

242

saveTokenToMongoDb(directResponse.Result);

242

saveTokenToMongoDb(directResponse.Result);

243

244

try {

244

try {

245

var result_price;

245

var result_price;

246

try {

246

try {

247

result_price = directResponse.Result.Price[0].trim();

247

result_price = directResponse.Result.Price[0].trim();

248

}

248

}

249

catch(err) {

249

catch(err) {

250

result_price = 0;

250

result_price = 0;

251

}

251

}

252

253

var result_error_message;

253

var result_error_message;

254

try {

254

try {

255

result_error_message = directResponse.Result.ErrorMsg[0].trim();

255

result_error_message = directResponse.Result.ErrorMsg[0].trim();

256

}

256

}

257

catch(err) {

257

catch(err) {

258

result_error_message = '';

258

result_error_message = '';

259

}

259

}

260

261

var resultCode = directResponse.Result.ResultCode[0].trim();

261

var resultCode = directResponse.Result.ResultCode[0].trim();

262

263

responseMessage =

263

responseMessage =

264

'ResultCode: ' + resultCode

264

'ResultCode: ' + resultCode

265

+ ' | ErrorMsg: ' + result_error_message

265

+ ' | ErrorMsg: ' + result_error_message

266

+ ' | DateTime: ' + directResponse.Result.DateTime[0].trim()

266

+ ' | DateTime: ' + directResponse.Result.DateTime[0].trim()

267

+ ' | nsm: ' + directResponse.Result.nsm[0].trim()

267

+ ' | nsm: ' + directResponse.Result.nsm[0].trim()

268

+ ' | idpel: ' + directResponse.Result.idpel[0].trim()

268

+ ' | idpel: ' + directResponse.Result.idpel[0].trim()

269

+ ' | reffid: ' + directResponse.Result.reffid[0].trim()

269

+ ' | reffid: ' + directResponse.Result.reffid[0].trim()

270

+ ' | TransID: ' + directResponse.Result.TransID[0].trim()

270

+ ' | TransID: ' + directResponse.Result.TransID[0].trim()

271

+ ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim()

271

+ ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim()

272

+ ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim()

272

+ ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim()

273

+ ' | token: ' + directResponse.Result.token[0].trim()

273

+ ' | token: ' + directResponse.Result.token[0].trim()

274

+ ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim()

274

+ ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim()

275

+ ' | Price: ' + result_price

275

+ ' | Price: ' + result_price

276

+ ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim()

276

+ ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim()

277

;

277

;

278

279

logger.info('Response message: ' + responseMessage);

279

logger.info('Response message: ' + responseMessage);

280

281

if ( (resultCode == '0099') && (result_error_message.search(/METER .* YANG ANDA MASUKAN SALAH/) >= 0) ) {

282

callbackReport(task.requestId, '14', responseMessage);

283

return;

284

}

285

else if ( (resultCode == '0099') && (result_error_message.search(/INQUIRY TIMEOUT, SILAHKAN DICOBA KEMBALI/) >= 0) ) {

286

callbackReport(task.requestId, '91', responseMessage);

287

return;

288

}

289

281

if (aaa) {

290

if (aaa) {

282

// update balance

291

// update balance

283

aaa.updateBalance(directResponse.Result.EndBalance[0]);

292

aaa.updateBalance(directResponse.Result.EndBalance[0]);

284

}

293

}

285

294

286

if (resultCode == '0000') {

295

if (resultCode == '0000') {

287

var nama_pelanggan = directResponse.Result.nama_pel[0].trim();

296

var nama_pelanggan = directResponse.Result.nama_pel[0].trim();

288

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

297

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

289

var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() + 'VA/' + directResponse.Result.jml_daya[0].trim();

298

var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() + 'VA/' + directResponse.Result.jml_daya[0].trim();

290

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

299

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

291

300

292

responseMessage = 'SN=' + sn + '; ' + responseMessage;

301

responseMessage = 'SN=' + sn + '; ' + responseMessage;

293

logger.info('New response message: ' + responseMessage);

302

logger.info('New response message: ' + responseMessage);

294

}

303

}

295

304

296

if (pendingResultCode.indexOf(resultCode) != -1) {

305

if (pendingResultCode.indexOf(resultCode) != -1) {

297

callbackReport(task['requestId'], '68', responseMessage);

306

callbackReport(task['requestId'], '68', responseMessage);

298

307

299

/*

308

/*

300

309

301

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

310

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

302

setTimeout(function () {

311

setTimeout(function () {

303

cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport);

312

cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport);

304

}, sleep_before_retry);

313

}, sleep_before_retry);

305

314

306

*/

315

*/

307

316

308

return;

317

return;

309

}

318

}

310

319

311

responseCode = resultCode.replace(/^00/, "");

320

responseCode = resultCode.replace(/^00/, "");

312

321

313

if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') {

322

if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') {

314

responseCode = '91';

323

responseCode = '91';

315

}

324

}

316

325

317

}

326

}

318

catch(err) {

327

catch(err) {

319

responseCode = '40';

328

responseCode = '40';

320

responseMessage = 'Invalid response from gateway';

329

responseMessage = 'Invalid response from gateway';

321

}

330

}

322

}

331

}

323

332

324

callbackReport(task['requestId'], responseCode, responseMessage);

333

callbackReport(task['requestId'], responseCode, responseMessage);

325

});

334

});

326

}

335

}

327

336

328

//callbackReport(task['requestId'], responseCode, responseMessage);

337

//callbackReport(task['requestId'], responseCode, responseMessage);

329

});

338

});

330

}

339

}

331

340

332

function callbackFromWebReport(status) {

341

function callbackFromWebReport(status) {

333

if (!status) {

342

if (!status) {

334

logger.warn('Advice from webreport return empty status');

343

logger.warn('Advice from webreport return empty status');

335

return;

344

return;

336

}

345

}

337

346

338

logger.info('Got advice result from webreport', {status: status});

347

logger.info('Got advice result from webreport', {status: status});

339

348

340

var responseCode = '68';

349

var responseCode = '68';

341

350

342

var result_price = 0;

351

var result_price = 0;

343

try {

352

try {

344

result_price = directResponse.Result.Price[0].trim();

353

result_price = directResponse.Result.Price[0].trim();

345

}

354

}

346

catch(err) {}

355

catch(err) {}

347

356

348

var errorMsg = '';

357

var errorMsg = '';

349

try {

358

try {

350

errorMsg = status.response.errormsg[0];

359

errorMsg = status.response.errormsg[0];

351

}

360

}

352

catch(err) {}

361

catch(err) {}

353

362

354

var responseMessage = '';

363

var responseMessage = '';

355

try {

364

try {

356

responseMessage =

365

responseMessage =

357

'Hasil advice dari webreport '

366

'Hasil advice dari webreport '

358

+ 'ResultCode: ' + status.response.resultcode[0]

367

+ 'ResultCode: ' + status.response.resultcode[0]

359

}

368

}

360

catch(err) {

369

catch(err) {

361

logger.warn('Error parsing ResultCode from webreport advice.', {err: err});

370

logger.warn('Error parsing ResultCode from webreport advice.', {err: err});

362

}

371

}

363

372

364

try {

373

try {

365

responseMessage =

374

responseMessage =

366

responseMessage

375

responseMessage

367

+ ' | ErrorMsg: ' + errorMsg

376

+ ' | ErrorMsg: ' + errorMsg

368

}

377

}

369

catch(err) {

378

catch(err) {

370

logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err});

379

logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err});

371

}

380

}

372

381

373

try {

382

try {

374

responseMessage =

383

responseMessage =

375

responseMessage

384

responseMessage

376

+ ' | TrxDate: ' + status.trxDate;

385

+ ' | TrxDate: ' + status.trxDate;

377

}

386

}

378

catch(err) {

387

catch(err) {

379

logger.warn('Error parsing TrxDate from webreport advice.', {err: err});

388

logger.warn('Error parsing TrxDate from webreport advice.', {err: err});

380

}

389

}

381

390

382

try {

391

try {

383

responseMessage =

392

responseMessage =

384

responseMessage

393

responseMessage

385

+ ' | UpdateDate: ' + status.updateDate;

394

+ ' | UpdateDate: ' + status.updateDate;

386

395

387

}

396

}

388

catch(err) {

397

catch(err) {

389

logger.warn('Error parsing UpdateDate from webreport advice.', {err: err});

398

logger.warn('Error parsing UpdateDate from webreport advice.', {err: err});

390

}

399

}

391

400

392

try {

401

try {

393

responseMessage =

402

responseMessage =

394

responseMessage

403

responseMessage

395

+ ' | nsm: ' + status.response.nsm[0];

404

+ ' | nsm: ' + status.response.nsm[0];

396

}

405

}

397

catch(err) {

406

catch(err) {

398

logger.warn('Error parsing nsm from webreport advice.', {err: err});

407

logger.warn('Error parsing nsm from webreport advice.', {err: err});

399

}

408

}

400

409

401

try {

410

try {

402

responseMessage =

411

responseMessage =

403

responseMessage

412

responseMessage

404

+ ' | idpel: ' + status.response.idpel[0];

413

+ ' | idpel: ' + status.response.idpel[0];

405

}

414

}

406

catch(err) {

415

catch(err) {

407

logger.warn('Error parsing idpel from webreport advice.', {err: err});

416

logger.warn('Error parsing idpel from webreport advice.', {err: err});

408

}

417

}

409

418

410

try {

419

try {

411

responseMessage =

420

responseMessage =

412

responseMessage

421

responseMessage

413

+ ' | reffid: ' + status.response.reffid[0].trim();

422

+ ' | reffid: ' + status.response.reffid[0].trim();

414

}

423

}

415

catch(err) {

424

catch(err) {

416

logger.warn('Error parsing reffid from webreport advice.', {err: err});

425

logger.warn('Error parsing reffid from webreport advice.', {err: err});

417

}

426

}

418

427

419

try {

428

try {

420

responseMessage =

429

responseMessage =

421

responseMessage

430

responseMessage

422

+ ' | TransID: ' + status.response.transid[0].trim();

431

+ ' | TransID: ' + status.response.transid[0].trim();

423

}

432

}

424

catch(err) {

433

catch(err) {

425

logger.warn('Error parsing TransID from webreport advice.', {err: err});

434

logger.warn('Error parsing TransID from webreport advice.', {err: err});

426

}

435

}

427

436

428

try {

437

try {

429

responseMessage =

438

responseMessage =

430

responseMessage

439

responseMessage

431

+ ' | reff_switching: ' + status.response.reff_switching[0];

440

+ ' | reff_switching: ' + status.response.reff_switching[0];

432

}

441

}

433

catch(err) {

442

catch(err) {

434

logger.warn('Error parsing reff_switching from webreport advice.', {err: err});

443

logger.warn('Error parsing reff_switching from webreport advice.', {err: err});

435

}

444

}

436

445

437

try {

446

try {

438

responseMessage =

447

responseMessage =

439

responseMessage

448

responseMessage

440

+ ' | amount_trx: ' + status.response.amount_trx[0];

449

+ ' | amount_trx: ' + status.response.amount_trx[0];

441

}

450

}

442

catch(err) {

451

catch(err) {

443

logger.warn('Error parsing amount_trx from webreport advice.', {err: err});

452

logger.warn('Error parsing amount_trx from webreport advice.', {err: err});

444

}

453

}

445

454

446

try {

455

try {

447

responseMessage =

456

responseMessage =

448

responseMessage

457

responseMessage

449

+ ' | token: ' + status.response.token[0];

458

+ ' | token: ' + status.response.token[0];

450

}

459

}

451

catch(err) {

460

catch(err) {

452

logger.warn('Error parsing token from webreport advice.', {err: err});

461

logger.warn('Error parsing token from webreport advice.', {err: err});

453

}

462

}

454

463

455

try {

464

try {

456

responseMessage =

465

responseMessage =

457

responseMessage

466

responseMessage

458

+ ' | PrevBalance: ' + status.response.prevbalance[0];

467

+ ' | PrevBalance: ' + status.response.prevbalance[0];

459

}

468

}

460

catch(err) {

469

catch(err) {

461

logger.warn('Error parsing PrevBalance from webreport advice.', {err: err});

470

logger.warn('Error parsing PrevBalance from webreport advice.', {err: err});

462

}

471

}

463

472

464

try {

473

try {

465

responseMessage =

474

responseMessage =

466

responseMessage

475

responseMessage

467

+ ' | Price: ' + status.amount;

476

+ ' | Price: ' + status.amount;

468

}

477

}

469

catch(err) {

478

catch(err) {

470

logger.warn('Error parsing Price from webreport advice.', {err: err});

479

logger.warn('Error parsing Price from webreport advice.', {err: err});

471

}

480

}

472

481

473

try {

482

try {

474

responseMessage =

483

responseMessage =

475

responseMessage

484

responseMessage

476

+ ' | EndBalance: ' + status.response.endbalance[0];

485

+ ' | EndBalance: ' + status.response.endbalance[0];

477

}

486

}

478

catch(err) {

487

catch(err) {

479

logger.warn('Error parsing EndBalance from webreport advice.', {err: err});

488

logger.warn('Error parsing EndBalance from webreport advice.', {err: err});

480

}

489

}

481

490

482

491

483

if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) {

492

if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) {

484

responseCode = '00';

493

responseCode = '00';

485

494

486

var nama_pelanggan = status.response.nama_pel[0] ;

495

var nama_pelanggan = status.response.nama_pel[0] ;

487

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

496

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

488

497

489

var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0];

498

var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0];

490

responseMessage = 'SN=' + sn + '; ' + responseMessage;

499

responseMessage = 'SN=' + sn + '; ' + responseMessage;

491

500

492

} else if ((status.status == 'P') || (status.status == 'W')) {

501

} else if ((status.status == 'P') || (status.status == 'W')) {

493

502

494

callbackReport(status.response.reffid[0].trim(), '68', responseMessage);

503

callbackReport(status.response.reffid[0].trim(), '68', responseMessage);

495

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

504

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

496

505

497

setTimeout(function () {

506

setTimeout(function () {

498

507

499

cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport);

508

cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport);

500

509

501

}, sleep_before_retry);

510

}, sleep_before_retry);

502

return;

511

return;

503

512

504

} else {

513

} else {

505

responseCode = status.response.resultcode[0].replace(/^00/, "");

514

responseCode = status.response.resultcode[0].replace(/^00/, "");

506

if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) {

515

if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) {

507

responseCode = '40';

516

responseCode = '40';

508

}

517

}

509

}

518

}

510

519

511

520

512

callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage);

521

callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage);

513

}

522

}

514

523

515

function createHttpReportServer() {

524

function createHttpReportServer() {

516

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

525

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

517

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

526

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

518

var path = url.parse(request.url).pathname;

527

var path = url.parse(request.url).pathname;

519

528

520

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

529

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

521

response.end('OK');

530

response.end('OK');

522

531

523

var requestId = qs.reffid;

532

var requestId = qs.reffid;

524

var resultCode = qs.rescode;

533

var resultCode = qs.rescode;

525

534

526

if (requestId && resultCode && resultCode != '0') {

535

if (requestId && resultCode && resultCode != '0') {

527

if (pendingResultCode.indexOf(resultCode) >= 0) {

536

if (pendingResultCode.indexOf(resultCode) >= 0) {

528

callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg);

537

callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg);

529

} else {

538

} else {

530

callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg);

539

callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg);

531

}

540

}

532

return;

541

return;

533

}

542

}

534

543

535

var trxid;

544

var trxid;

536

try {

545

try {

537

trxid = qs.transid;

546

trxid = qs.transid;

538

}

547

}

539

catch(err) {

548

catch(err) {

540

}

549

}

541

550

542

/*

551

/*

543

if (trxid) {

552

if (trxid) {

544

logger.info('Requesting advice from webreport', {trxid: trxid})

553

logger.info('Requesting advice from webreport', {trxid: trxid})

545

cekstatus.advice({trxid: trxid}, callbackFromWebReport);

554

cekstatus.advice({trxid: trxid}, callbackFromWebReport);

546

}

555

}

547

*/

556

*/

548

557

549

});

558

});

550

559

551

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

560

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

552

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

561

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

553

});

562

});

554

}

563

}

555

564

556

function start(options) {

565

function start(options) {

557

if (!options) {

566

if (!options) {

558

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

567

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

559

process.exit(1);

568

process.exit(1);

560

}

569

}

561

570

562

if (options.config) {

571

if (options.config) {

563

config = options.config;

572

config = options.config;

564

} else {

573

} else {

565

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

574

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

566

process.exit(1);

575

process.exit(1);

567

}

576

}

568

577

569

if (options.aaa) {

578

if (options.aaa) {

570

aaa = options.aaa;

579

aaa = options.aaa;

571

callbackReport = options.aaa.callbackReportWithPushToMongoDb;

580

callbackReport = options.aaa.callbackReportWithPushToMongoDb;

572

} else {

581

} else {

573

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

582

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

574

process.exit(1);

583

process.exit(1);

575

}

584

}

576

585

577

if (options && options.logger) {

586

if (options && options.logger) {

578

logger = options.logger;

587

logger = options.logger;

579

} else {

588

} else {

580

logger = new winston.Logger({

589

logger = new winston.Logger({

581

transports: [

590

transports: [

582

new (winston.transports.Console)()

591

new (winston.transports.Console)()

583

]

592

]

584

});

593

});

585

}

594

}

586

595

587

cekstatus.setLogger(logger);

596

cekstatus.setLogger(logger);

588

597

589

createHttpReportServer();

598

createHttpReportServer();

590

initMongoClient();

599

initMongoClient();

591

}

600

}

592

601

593

exports.start = start;

602

exports.start = start;

594

exports.topupRequest = topupRequest;

603

exports.topupRequest = topupRequest;

595

604

GITLAB

Reload97 / sate24-to-sc

penanganan beberapa rc 0099

 var fs = require('fs');
 var https = require('https');
 var http = require('http');
 var url = require('url');
 var request = require('request');
 var xml2js = require('xml2js').parseString;
 var strftime = require('strftime');
 var math = require('mathjs');
 var winston = require('winston');
 var cekstatus = require('./cekstatus.js');
 var mongoClient = require('mongodb').MongoClient;
 var LRU = require('lru-cache');
 var config;
 var httpServer;
 var aaa;
 var logger;
 var callbackReport;
 var mongodb;
 var tasks = LRU(10000);
 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
 var sleep_before_retry = 30000;
 var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];
 var logTag = __filename.split('/').reverse()[0];
 function initMongoClient() {
     if (!config.mongodbstruk || !config.mongodbstruk.url) {
         return;
     }
     try {
         var url = config.mongodbstruk.url;
         mongoClient.connect(url, function(err, db) {
             if (err) {
                 logger.warn('Failed to connect to mongodb', {err: err});
                 return;
             }
             mongodb = db;
             logger.info('MongoDB connected');
         });
     }
     catch(err) {
         logger.warn('Exception when connecting to mongodb', {err: err, url: url});
     }
 }
 function prepareResultData(result) {
     var task;
     var data = {};
     data.gateway = config.globals.gateway_name;
     try {
         data.requestId = result.reffid[0].trim();
         var key = config.globals.gateway_name + '.rid:' + data.requestId;
         task = tasks.get(key);
     }
     catch(err) { data.requestId = null; }
     try {
         data.status = result.ResultCode[0].trim();
     }
     catch(err) { data.status = '68' }
     try {
         data.rcmessage = result.ErrorMsg[0].trim();
     }
     catch(err) { data.rcmessage = ''; }
     try {
         data.resptext = '';
     }
     catch(err) { data.resptext = ''; }
     try {
         var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss')
         data.dt = ts;
     }
     catch(err) {
         logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task});
         data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date());
     }
     try {
         data.namapel = result.nama_pel[0].trim();
     }
     catch(err) { data.namapel = 'UNKNOWN'; }
     try {
         data.msn = result.nsm[0].trim();
     }
     catch(err) { data.msn = 'UNKNOWN'; }
     try {
         data.idpel = result.idpel[0].trim();
     }
     catch(err) { data.idpel = 'UNKNOWN'; }
     try {
         data.tarifdaya = result.tarif[0].trim();
     }
     catch(err) { data.tarifdaya = 'UNKNOWN'; }
     try {
         data.admin = parseInt(result.adminfee[0].trim());
     }
     catch(err) { data.admin = 0; }
     try {
         data.adm = parseInt(result.admin_fee[0].trim());
     }
     catch(err) { data.adm = 0; }
     try {
         data.hargapelanggan = parseInt(result.amount_trx[0].trim());
     }
     catch(err) { data.hargapelanggan = 0; }
     try {
         data.jumlahkwh = result.jml_daya[0].trim();
     }
     catch(err) { data.jumlahkwh = 0; }
     try {
         data.token = result.token[0].trim();
     }
     catch(err) { data.token = 0; }
     try {
         data.ppn = result.ppn_fee[0].trim();
     }
     catch(err) { data.ppn_fee = 0; }
     try {
         data.ppj = result.ppj_fee[0].trim();
     }
     catch(err) { data.ppj = 0; }
     try {
         data.angsuran = result.angsuran_fee[0].trim();
     }
     catch(err) { data.angsuran = 0; }
     try {
         data.meterai = result.materai_fee[0].trim();
     }
     catch(err) { data.materai_fee = 0; }
     return data;
 }
 function saveTokenToMongoDb(result) {
     if (!mongodb) {
         return;
     }
     if (!config.mongodbstruk) {
         return;
     }
     if (!config.mongodbstruk.collection) {
         return;
     }
     var data = prepareResultData(result);
     try {
         mongodb.collection(config.mongodbstruk.collection).insertOne(data);
     }
     catch(err) {
         logger.warn('Error when inserting data to mongodb', {err: err, data: data});
     }
 }
 function putTaskToCache(task) {
     var key = config.globals.gateway_name + '.rid:' + task.requestId;
     try {
         tasks.set(key, task);
     }
     catch(err) {
         logger.warn('Error writing to task to cache', {err: err, key: key, task: task});
     }
 }
 function topupRequest(task) {
     aaa.insertTaskToMongoDb(task);
     putTaskToCache(task);
     var ts = strftime('%Y%m%d%H%M%S', new Date());
     var data =
         config.h2h_out.userid
         + '|' + config.h2h_out.password
         + '|' + task['remoteProduct']
         + '|' + task['destination'] + '|0';
     var options = {
         url: config.h2h_out.partner,
         qs: {
             ts: ts,
             data: data,
             reffid: task['requestId']
         }
     };
     logger.info('Creating http request', {options: options});
     request(options, function (error, response, body) {
         var responseCode = '40';
         var responseMessage = 'Gateway Error';
         if (error) {
             logger.warn('HTTP REQUEST ERROR', error);
             callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')');
         } else if (response.statusCode != 200) {
             var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')';
             logger.warn(error_message);
             callbackReport(task['requestId'], '91', error_message);
         } else {
             logger.info('DIRECT RESPONSE', {requestId: task.requestId, body: body});
             xml2js(body, function (err, result) {
                 if (err) {
                     logger.warn('Error parsing xml response', {requestId: task.requestId, err: err, body: body});
                     callbackReport(task['requestId'], '40', body);
                 } else {
                     var directResponse = result;
                     logger.info(directResponse);
                     saveTokenToMongoDb(directResponse.Result);
                     try {
                         var result_price;
                         try {
                             result_price = directResponse.Result.Price[0].trim();
                         }
                         catch(err) {
                             result_price = 0;
                         }
                         var result_error_message;
                         try {
                             result_error_message = directResponse.Result.ErrorMsg[0].trim();
                         }
                         catch(err) {
                             result_error_message = '';
                         }
                         var resultCode = directResponse.Result.ResultCode[0].trim();
                         responseMessage =
                             'ResultCode: ' + resultCode
                             + ' | ErrorMsg: ' + result_error_message
                             + ' | DateTime: ' + directResponse.Result.DateTime[0].trim()
                             + ' | nsm: ' + directResponse.Result.nsm[0].trim()
                             + ' | idpel: ' + directResponse.Result.idpel[0].trim()
                             + ' | reffid: ' + directResponse.Result.reffid[0].trim()
                             + ' | TransID: ' + directResponse.Result.TransID[0].trim()
                             + ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim()
                             + ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim()
                             + ' | token: ' + directResponse.Result.token[0].trim()
                             + ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim()
                             + ' | Price: ' + result_price
                             + ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim()
                             ;
                         logger.info('Response message: ' + responseMessage);
+                        if ( (resultCode == '0099') && (result_error_message.search(/METER .* YANG ANDA MASUKAN SALAH/) >= 0) ) {
+                            callbackReport(task.requestId, '14', responseMessage);
+                            return;
+                        }
+                        else if ( (resultCode == '0099') && (result_error_message.search(/INQUIRY TIMEOUT, SILAHKAN DICOBA KEMBALI/) >= 0) ) {
+                            callbackReport(task.requestId, '91', responseMessage);
+                            return;
+                        }
                         if (aaa) {
                             // update balance
                             aaa.updateBalance(directResponse.Result.EndBalance[0]);
                         }
                         if (resultCode == '0000') {
                             var nama_pelanggan = directResponse.Result.nama_pel[0].trim();
                             nama_pelanggan =  nama_pelanggan.replace(/-\/-/g, '-');
                             var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() +  'VA/' + directResponse.Result.jml_daya[0].trim();
                             sn = sn.replace(/\s/g, '-');
                             responseMessage = 'SN=' + sn + '; ' + responseMessage;
                             logger.info('New response message: ' + responseMessage);
                         }
                         if (pendingResultCode.indexOf(resultCode) != -1) {
                             callbackReport(task['requestId'], '68', responseMessage);
                             /*
                             logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');
                             setTimeout(function () {
                                 cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport);
                             }, sleep_before_retry);
                             */
                             return;
                         }
                         responseCode = resultCode.replace(/^00/, "");
                         if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') {
                             responseCode = '91';
                         }
                     }
                     catch(err) {
                         responseCode = '40';
                         responseMessage = 'Invalid response from gateway';
                     }
                 }
                 callbackReport(task['requestId'], responseCode, responseMessage);
             });
         }
         //callbackReport(task['requestId'], responseCode, responseMessage);
     });
 }
 function callbackFromWebReport(status) {
     if (!status) {
         logger.warn('Advice from webreport return empty status');
         return;
     }
     logger.info('Got advice result from webreport', {status: status});
     var responseCode = '68';
     var result_price = 0;
     try {
         result_price = directResponse.Result.Price[0].trim();
     }
     catch(err) {}
     var errorMsg = '';
     try {
         errorMsg = status.response.errormsg[0];
     }
     catch(err) {}
     var responseMessage = '';
     try {
         responseMessage =
             'Hasil advice dari webreport '
             + 'ResultCode: ' + status.response.resultcode[0]
     }
     catch(err) {
         logger.warn('Error parsing ResultCode from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | ErrorMsg: ' + errorMsg
     }
     catch(err) {
         logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | TrxDate: ' + status.trxDate;
     }
     catch(err) {
         logger.warn('Error parsing TrxDate from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | UpdateDate: ' + status.updateDate;
     }
     catch(err) {
         logger.warn('Error parsing UpdateDate from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | nsm: ' + status.response.nsm[0];
     }
     catch(err) {
         logger.warn('Error parsing nsm from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | idpel: ' + status.response.idpel[0];
     }
     catch(err) {
         logger.warn('Error parsing idpel from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | reffid: ' + status.response.reffid[0].trim();
     }
     catch(err) {
         logger.warn('Error parsing reffid from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | TransID: ' + status.response.transid[0].trim();
     }
     catch(err) {
         logger.warn('Error parsing TransID from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | reff_switching: ' + status.response.reff_switching[0];
     }
     catch(err) {
         logger.warn('Error parsing reff_switching from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | amount_trx: ' + status.response.amount_trx[0];
     }
     catch(err) {
         logger.warn('Error parsing amount_trx from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | token: ' + status.response.token[0];
     }
     catch(err) {
         logger.warn('Error parsing token from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | PrevBalance: ' + status.response.prevbalance[0];
     }
     catch(err) {
         logger.warn('Error parsing PrevBalance from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | Price: ' + status.amount;
     }
     catch(err) {
         logger.warn('Error parsing Price from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | EndBalance: ' + status.response.endbalance[0];
     }
     catch(err) {
         logger.warn('Error parsing EndBalance from webreport advice.', {err: err});
     }
     if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) {
         responseCode = '00';
         var nama_pelanggan = status.response.nama_pel[0] ;
         nama_pelanggan =  nama_pelanggan.replace(/-\/-/g, '-');
         var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0];
         responseMessage = 'SN=' + sn + '; ' + responseMessage;
     } else if ((status.status == 'P') || (status.status == 'W')) {
         callbackReport(status.response.reffid[0].trim(), '68', responseMessage);
         logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');
         setTimeout(function () {
             cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport);
         }, sleep_before_retry);
         return;
     } else {
         responseCode = status.response.resultcode[0].replace(/^00/, "");
         if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) {
             responseCode = '40';
         }
     }
     callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage);
 }
 function createHttpReportServer() {
     var httpServer = http.createServer(function(request, response) {
         var qs = url.parse(request.url, true).query;
         var path = url.parse(request.url).pathname;
         logger.info('Got reverse report from partner', {path: path, qs: qs});
         response.end('OK');
         var requestId = qs.reffid;
         var resultCode = qs.rescode;
         if (requestId && resultCode && resultCode != '0') {
             if (pendingResultCode.indexOf(resultCode) >= 0) {
                 callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg);
             } else {
                 callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg);
             }
             return;
         }
         var  trxid;
         try {
             trxid = qs.transid;
         }
         catch(err) {
         }
         /*
         if (trxid) {
             logger.info('Requesting advice from webreport', {trxid: trxid})
             cekstatus.advice({trxid: trxid}, callbackFromWebReport);
         }
         */
     });
     httpServer.listen(config.h2h_out.listen_port, function() {
         logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
     });
 }
 function start(options) {
     if (!options) {
         console.log('Undefined options, terminating....');
         process.exit(1);
     }
     if (options.config) {
         config = options.config;
     } else {
         console.log('Undefined options.config, terminating....')
         process.exit(1);
     }
     if (options.aaa) {
         aaa = options.aaa;
         callbackReport = options.aaa.callbackReportWithPushToMongoDb;
     } else {
         console.log('Undefined options.aaa, terminating....')
         process.exit(1);
     }
     if (options && options.logger) {
         logger = options.logger;
     } else {
         logger = new winston.Logger({
             transports: [
               new (winston.transports.Console)()
             ]
         });
     }
     cekstatus.setLogger(logger);
     createHttpReportServer();
     initMongoClient();
 }
 exports.start = start;
 exports.topupRequest = topupRequest;