Commit 4368b6966e75dc09d979f49383a0840be099a316

Authored by Adhidarma Hadiwinoto
1 parent e02146d472
Exists in master

parsesn

Showing 2 changed files with 14 additions and 1 deletions Inline Diff

1 var url = require('url'); 1 var url = require('url');
2 var math = require('mathjs'); 2 var math = require('mathjs');
3 var request = require('request'); 3 var request = require('request');
4 var xml = require("xml2js").parseString; 4 var xml = require("xml2js").parseString;
5 5
6 var config; 6 var config;
7 var callbackReport; 7 var callbackReport;
8 8
9 var max_retry = 3; 9 var max_retry = 3;
10 var sleep_before_retry = 3000; 10 var sleep_before_retry = 3000;
11 11
12 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; 12 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
13 13
14 function parseSN(message) { 14 function parseSN(message) {
15 var sn_regex = new RegExp(config.h2h_out.sn_pattern); 15 var sn_regex = new RegExp(config.h2h_out.sn_pattern);
16 var sn_match = message.match(sn_regex); 16 var sn_match = message.match(sn_regex);
17 17
18 if (sn_match <= 0) { 18 if (sn_match <= 0) {
19 console.log('SN Not found: ' + message); 19 console.log('SN Not found: ' + message);
20 return ''; 20 return '';
21 } 21 }
22 22
23 var sn = sn_match[0]; 23 var sn = sn_match[0];
24 var sn_remove_patterns = config.h2h_out.sn_remove_patterns.split(config.h2h_out.sn_remove_patterns_separator); 24 var sn_remove_patterns = config.h2h_out.sn_remove_patterns.split(config.h2h_out.sn_remove_patterns_separator);
25 25
26 var count = sn_remove_patterns.length; 26 var count = sn_remove_patterns.length;
27 27
28 for(var i = 0; i < count; i++) { 28 for(var i = 0; i < count; i++) {
29 sn = sn.replace(sn_remove_patterns[i], ''); 29 sn = sn.replace(sn_remove_patterns[i], '');
30 } 30 }
31 31
32 return sn.trim(); 32 return sn.trim();
33 } 33 }
34 34
35 35
36 function topupRequest(task, retry) { 36 function topupRequest(task, retry) {
37 if (config.globals.requests_count == undefined) { 37 if (config.globals.requests_count == undefined) {
38 config.globals.requests_count = 1; 38 config.globals.requests_count = 1;
39 } else { 39 } else {
40 config.globals.requests_count++; 40 config.globals.requests_count++;
41 } 41 }
42 42
43 if (config.globals.active_requests_count == undefined) { 43 if (config.globals.active_requests_count == undefined) {
44 config.globals.active_requests_count = 1; 44 config.globals.active_requests_count = 1;
45 } else { 45 } else {
46 config.globals.active_requests_count++; 46 config.globals.active_requests_count++;
47 } 47 }
48 48
49 if (config.globals.max_active_requests_count == undefined) { 49 if (config.globals.max_active_requests_count == undefined) {
50 config.globals.max_active_requests_count = config.globals.active_requests_count; 50 config.globals.max_active_requests_count = config.globals.active_requests_count;
51 } else { 51 } else {
52 config.globals.max_active_requests_count = math.max(config.globals.max_active_requests_count, config.globals.active_requests_count); 52 config.globals.max_active_requests_count = math.max(config.globals.max_active_requests_count, config.globals.active_requests_count);
53 } 53 }
54 54
55 55
56 if (retry === undefined) { 56 if (retry === undefined) {
57 retry = max_retry; 57 retry = max_retry;
58 } 58 }
59 59
60 var params = { 60 var params = {
61 userid: config.h2h_out.userid, 61 userid: config.h2h_out.userid,
62 pwd: config.h2h_out.password, 62 pwd: config.h2h_out.password,
63 memberreff: task['requestId'], 63 memberreff: task['requestId'],
64 produk: task['remoteProduct'], 64 produk: task['remoteProduct'],
65 tujuan: task['destination'] 65 tujuan: task['destination']
66 }; 66 };
67 console.log('PARAMS:'); 67 console.log('PARAMS:');
68 console.log(params); 68 console.log(params);
69 69
70 request.post({url: config.h2h_out.partner, form: params}, function(err, httpResponse, httpResponseBody) { 70 request.post({url: config.h2h_out.partner, form: params}, function(err, httpResponse, httpResponseBody) {
71 71
72 config.globals.active_requests_count--; 72 config.globals.active_requests_count--;
73 73
74 if (err) { 74 if (err) {
75 console.log('HTTP Request Error (' + task['requestId'] + '): '); 75 console.log('HTTP Request Error (' + task['requestId'] + '): ');
76 console.log(err); 76 console.log(err);
77 77
78 if (retry) { 78 if (retry) {
79 79
80 console.log('Retrying trx hit (' + retry + ')'); 80 console.log('Retrying trx hit (' + retry + ')');
81 setTimeout(function() { 81 setTimeout(function() {
82 topupRequest(task, retry - 1); 82 topupRequest(task, retry - 1);
83 }, sleep_before_retry); 83 }, sleep_before_retry);
84 84
85 } else { 85 } else {
86 callbackReport(task['requestId'], '40', 'Gangguan koneksi ke suplier'); 86 callbackReport(task['requestId'], '40', 'Gangguan koneksi ke suplier');
87 } 87 }
88 return; 88 return;
89 } 89 }
90 90
91 console.log('Server Response: '); 91 console.log('Server Response: ');
92 console.log(httpResponseBody); 92 console.log(httpResponseBody);
93 93
94 if (httpResponseBody.indexOf('502 Proxy Error') >= 0) { 94 if (httpResponseBody.indexOf('502 Proxy Error') >= 0) {
95 callbackReport(task['requestId'], '40', '502 Proxy error'); 95 callbackReport(task['requestId'], '40', '502 Proxy error');
96 return; 96 return;
97 } 97 }
98 98
99 xml(httpResponseBody, function(err, result) { 99 xml(httpResponseBody, function(err, result) {
100 if (err) { 100 if (err) {
101 console.log('Gagal parsing XML respon server'); 101 console.log('Gagal parsing XML respon server');
102 //topupRequest(task, retry - 1); 102 //topupRequest(task, retry - 1);
103 callbackReport(task['requestId'], '40', 'Gagal parsing XML pada respon server'); 103 callbackReport(task['requestId'], '40', 'Gagal parsing XML pada respon server');
104 return; 104 return;
105 } 105 }
106 106
107 console.log('Response Data:'); 107 console.log('Response Data:');
108 console.log(result); 108 console.log(result);
109 109
110 var response_code = result.respon.rc[0].replace(/^00/, ''); 110 var response_code = result.respon.rc[0].replace(/^00/, '');
111 111
112 var token = ''; 112 var token = '';
113 if (result.respon.token) { 113 if (result.respon.token) {
114 token = result.respon.token[0]; 114 token = result.respon.token[0];
115 } 115 }
116 116
117 var data_pelanggan = 'NO-DATA'; 117 var data_pelanggan = 'NO-DATA';
118 if (result.respon.data) { 118 if (result.respon.data) {
119 data_pelanggan = result.respon.data[0].replace(/ /g, '-'); 119 data_pelanggan = result.respon.data[0].replace(/ /g, '-');
120 } 120 }
121 121
122 var message = result.respon.pesan[0].replace(/\n/g, ' '); 122 var message = result.respon.pesan[0].replace(/\n/g, ' ');
123 123
124 124
125 if (response_code = '00') { 125 if (response_code = '00') {
126 126
127 var sn = ""; 127 var sn = "";
128 if (token && data_pelanggan) { 128 if (token && data_pelanggan) {
129 sn = token + '/' + data_pelanggan; 129 sn = token + '/' + data_pelanggan;
130 130
131 } else if (config.h2h_out.parse_sn == 'YES') { 131 } else if (config.h2h_out.parse_sn == 'YES') {
132 sn = parseSN(message); 132 sn = parseSN(message);
133 } 133 }
134 message = 'SN=' + sn + '; ' + message; 134 message = 'SN=' + sn + '; ' + message;
135 } 135 }
136 136
137 callbackReport(task['requestId'], response_code, message); 137 callbackReport(task['requestId'], response_code, message);
138 138
139 if (response_code == '54' || response_code == '68') { 139 if (response_code == '54' || response_code == '68') {
140 setTimeout(function() { 140 setTimeout(function() {
141 topupRequest(task, 5); 141 topupRequest(task, 5);
142 }, 60000); 142 }, 60000);
143 } 143 }
144 144
145 }); 145 });
146 }); 146 });
147 } 147 }
148 148
149 function start(_config, _callbackReport) { 149 function start(_config, _callbackReport) {
150 config = _config; 150 config = _config;
151 callbackReport = _callbackReport 151 callbackReport = _callbackReport
152 } 152 }
153 153
154 function parseSN(message) { 154 function parseSN(message) {
155 var sn_regex = new RegExp(config.h2h_out.sn_pattern); 155 var sn_regex = new RegExp(config.h2h_out.sn_pattern);
156 var sn_match = message.match(sn_regex); 156 var sn_match = message.match(sn_regex);
157 157
158 //console.log('SN MATCH:'); 158 //console.log('SN MATCH:');
159 //console.log(sn_match); 159 //console.log(sn_match);
160 160
161 if (sn_match <= 0) { 161 if (sn_match <= 0) {
162 console.log('SN Not found: ' + message); 162 console.log('SN Not found: ' + message);
163 return ''; 163 return '';
164 } 164 }
165 165
166 var sn = sn_match[0]; 166 var sn = sn_match[0];
167 var sn_remove_patterns = config.h2h_out.sn_remove_patterns.split(config.h2h_out.sn_remove_patterns_separator); 167 var sn_remove_patterns = config.h2h_out.sn_remove_patterns.split(config.h2h_out.sn_remove_patterns_separator);
168 //console.log('SN REMOVE PATTERNS:'); 168 //console.log('SN REMOVE PATTERNS:');
169 //console.log (sn_remove_patterns); 169 //console.log (sn_remove_patterns);
170 170
171 var count = sn_remove_patterns.length; 171 var count = sn_remove_patterns.length;
172 172
173 for(var i = 0; i < count; i++) { 173 for(var i = 0; i < count; i++) {
174 sn = sn.replace(sn_remove_patterns[i], ''); 174 sn = sn.replace(sn_remove_patterns[i], '');
175 } 175 }
176 176
177 return sn.trim(); 177 return sn.trim();
178 } 178 }
179 179
180 function parseResult(message) { 180 function parseResult(message) {
181 var data; 181 var data;
182 xml(message, function(err, result) { 182 xml(message, function(err, result) {
183 data = result; 183 data = result;
184 }); 184 });
185 return data; 185 return data;
186 } 186 }
187 187
188 exports.start = start; 188 exports.start = start;
189 exports.topupRequest = topupRequest; 189 exports.topupRequest = topupRequest;
190 exports.parseResult = parseResult; 190 exports.parseResult = parseResult;
191 exports.parseSN = parseSN;
191 192
1 var assert = require("assert"); 1 var assert = require("assert");
2 2
3 3
4 describe('aaa', function() { 4 describe('aaa', function() {
5 var aaa = require('./aaa'); 5 var aaa = require('./aaa');
6 6
7 describe("#unaliasResponseCode()", function() { 7 describe("#unaliasResponseCode()", function() {
8 it('should return 68', function() { 8 it('should return 68', function() {
9 assert.equal('68', aaa.unaliasResponseCode('01', '01:68')); 9 assert.equal('68', aaa.unaliasResponseCode('01', '01:68'));
10 }); 10 });
11 11
12 it('should return 68', function() { 12 it('should return 68', function() {
13 assert.equal('68', aaa.unaliasResponseCode('68', '01:68')); 13 assert.equal('68', aaa.unaliasResponseCode('68', '01:68'));
14 }); 14 });
15 15
16 it('should return 00', function() { 16 it('should return 00', function() {
17 assert.equal('00', aaa.unaliasResponseCode('00', '01:68')); 17 assert.equal('00', aaa.unaliasResponseCode('00', '01:68'));
18 }); 18 });
19 19
20 it('should return 40', function() { 20 it('should return 40', function() {
21 assert.equal('40', aaa.unaliasResponseCode('40', '')); 21 assert.equal('40', aaa.unaliasResponseCode('40', ''));
22 }); 22 });
23 23
24 it('should return 40', function() { 24 it('should return 40', function() {
25 assert.equal('40', aaa.unaliasResponseCode('40', '')); 25 assert.equal('40', aaa.unaliasResponseCode('40', ''));
26 }); 26 });
27 27
28 it('should return 40', function() { 28 it('should return 40', function() {
29 assert.equal('40', aaa.unaliasResponseCode('40')); 29 assert.equal('40', aaa.unaliasResponseCode('40'));
30 }); 30 });
31 31
32 }); 32 });
33 }); 33 });
34 34
35 describe('aaa', function() { 35 describe('httppulsakita', function() {
36 var partner = require('./httppulsakita'); 36 var partner = require('./httppulsakita');
37 37
38 describe("#parseResult()", function() { 38 describe("#parseResult()", function() {
39 message = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?><respon><tanggal>2015/6/16 15:43:35</tanggal><idagen>P0039</idagen><refid>AEE15B32987941D89FFF4BC7EF676C13</refid><produk>PLN20</produk><tujuan>14204279369</tujuan><rc>0000</rc><data> </data><token> </token><pesan>#14836 PLN20 ke:14204279369 SUKSES. SN:3520-2887-6627-6699-4826/TestDummyPanjang6955555/P1/7000VA/32,4. \ 39 message = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?><respon><tanggal>2015/6/16 15:43:35</tanggal><idagen>P0039</idagen><refid>AEE15B32987941D89FFF4BC7EF676C13</refid><produk>PLN20</produk><tujuan>14204279369</tujuan><rc>0000</rc><data> </data><token> </token><pesan>#14836 PLN20 ke:14204279369 SUKSES. SN:3520-2887-6627-6699-4826/TestDummyPanjang6955555/P1/7000VA/32,4. \
40 Sisa saldo Rp. 5,000,000 - Rp. 18,700 = Rp. 4,981,300</pesan></respon>'; 40 Sisa saldo Rp. 5,000,000 - Rp. 18,700 = Rp. 4,981,300</pesan></respon>';
41 41
42 data = partner.parseResult(message); 42 data = partner.parseResult(message);
43 console.log(data); 43 console.log(data);
44 44
45 it('should return 2015/6/16 15:43:35', function() { 45 it('should return 2015/6/16 15:43:35', function() {
46 assert.equal('2015/6/16 15:43:35', data.respon.tanggal); 46 assert.equal('2015/6/16 15:43:35', data.respon.tanggal);
47 }); 47 });
48 }); 48 });
49
50 /*
51 describe("parseSN()", function() {
52
53 message = "#14837 XR5 ke:081809903333 SUKSES. Isi pulsa XR5 berhasil untuk nomor 6281809903333 sebesar 5.000, refnum B93D0792A47841AE03B0000000000000 pada tgl 16/06/15 15:47. \
54 Sisa saldo Rp. 4,981,300 - Rp. 5,250 = Rp. 4,976,050";
55 it ('should return B93D0792A47841AE03B0000000000000', function() {
56 assert.equal('B93D0792A47841AE03B0000000000000', parseSN(message));
57 });
58
59 });
60 */
49 }); 61 });
50 62