Reload97 / sate24-to-trugee

Download as
Browse Code ยป

Commit 31002b52f3e32b680adf17bfa032ea9cafe38661

Authored by Adhidarma Hadiwinoto
1 parent d11a8cb48b
Exists in master

mulai adaptasi ke trugee

Showing 4 changed files with 9 additions and 370 deletions Inline Diff

1 var iniparser = require('iniparser'); 1 var iniparser = require('iniparser');
2 var config = iniparser.parseSync('./config.ini'); 2 var config = iniparser.parseSync('./config.ini');
3 3
4 var aaaHost = config.globals.aaa_host; 4 var aaaHost = config.globals.aaa_host;
5 5
6 HttpServer = require('sate24/httpserver.js'); 6 HttpServer = require('sate24/httpserver.js');
7 var httpServer = HttpServer.start(config); 7 var httpServer = HttpServer.start(config);
8 8
9 var aaa = require('sate24/aaa.js'); 9 var aaa = require('sate24/aaa.js');
10 var partner = require('./partner-datacell.js'); 10 var partner = require('./partner-trugee.js');
11 11
12 partner.start(config, aaa.callbackReport); 12 partner.start(config, aaa.callbackReport);
13 aaa.start(config, partner); 13 aaa.start(config, partner);
14 14
1 { 1 {
2 "name": "sate24-to-datacell", 2 "name": "sate24-to-trugee",
3 "version": "0.0.1", 3 "version": "0.0.1",
4 "description": "ST24 to Datacell", 4 "description": "ST24 to Trugee",
5 "main": "index.js", 5 "main": "index.js",
6 "scripts": { 6 "scripts": {
7 "test": "mocha" 7 "test": "mocha"
8 }, 8 },
9 "repository": { 9 "repository": {
10 "type": "git", 10 "type": "git",
11 "url": "git@gitlab.kodesumber.com:reload97/sate24-to-datacell.git" 11 "url": "git@gitlab.kodesumber.com:reload97/sate24-to-trugee.git"
12 }, 12 },
13 "keywords": [ 13 "keywords": [
14 "datacell", 14 "datacell",
15 "ppob", 15 "ppob",
16 "st24" 16 "st24"
17 ], 17 ],
18 "author": "Adhidarma Hadiwinoto <gua@adhisimon.org>", 18 "author": "Adhidarma Hadiwinoto <gua@adhisimon.org>",
19 "license": "BSD", 19 "license": "BSD",
20 "dependencies": { 20 "dependencies": {
21 "sate24": "git+http://git@gitlab.kodesumber.com/reload97/node-sate24.git", 21 "sate24": "git+http://git@gitlab.kodesumber.com/reload97/node-sate24.git",
22 "iniparser": "~1.0.5", 22 "iniparser": "~1.0.5",
23 "base64-xor": "~0.10.0", 23 "base64-xor": "~0.10.0",
24 "request": "~2.60.0", 24 "request": "~2.60.0",
25 "mathjs": "~1.7.1", 25 "mathjs": "~1.7.1",
26 "xml": "~1.0.0", 26 "xml": "~1.0.0",
27 "xml2js": "~0.4.9", 27 "xml2js": "~0.4.9",
28 "strftime": "~0.9.2" 28 "strftime": "~0.9.2"
29 } 29 }
30 } 30 }
31 31
partner-datacell.js
View file @ 31002b5
1 var http = require('http'); File was deleted
2 var url = require('url');
3 var math = require('mathjs');
4 var xml = require('xml');
5 var xml2js = require('xml2js').parseString;
6 var strftime = require('strftime');
7 var xor = require('base64-xor');
8 var request = require('request');
9
10 var config;
11 var callbackReport;
12
13 var max_retry = 2;
14 var sleep_before_retry = 2000;
15
16 var trx_balances = {};
17 var trx_prices = {};
18
19 function calculateSignature(userid, password, msisdn, timestamp) {
20 var a = msisdn.substr(msisdn.length - 4) + timestamp;
21 var b = userid.substr(0, 4) + password;
22
23 return xor.encode(a,b);
24 }
25
26 function calculateBalanceSignature(userid, password, timestamp) {
27 var a = '0000' + timestamp;
28 var b = userid.substr(0, 4) + password;
29
30 return xor.encode(a,b);
31 }
32
33
34 function createPayload(task) {
35 var timestamp = strftime('%H%M%S');
36
37 var payload = {
38 datacell: [
39 { perintah: 'charge'},
40 {oprcode: task['remoteProduct']},
41 {userid: config.h2h_out.userid},
42 {time: timestamp},
43 {msisdn: task['destination']},
44 {ref_trxid: task['requestId']},
45 {sgn: calculateSignature(config.h2h_out.userid, config.h2h_out.password, task['destination'], timestamp)}
46 ]
47 };
48
49 console.log(payload);
50 return "<?xml version=\"1.0\" ?>\n" + xml(payload);
51 }
52
53 function topupRequest(task, retry) {
54 //balanceCheck();
55
56 var payload_xml = createPayload(task);
57 //console.log(payload_xml);
58
59 var postRequest = {
60 host: "202.152.62.2",
61 path: "/RELOAD97.php",
62 port: 7713,
63 method: "POST",
64 headers: {
65 'Content-Type': 'text/xml',
66 'Content-Length': Buffer.byteLength(payload_xml)
67 }
68 };
69
70 var buffer = "";
71 var req = http.request( postRequest, function( res ) {
72
73 console.log('Status code: ' + res.statusCode );
74 var buffer = "";
75 res.on( "data", function( data ) { buffer = buffer + data; } );
76 res.on( "end", function( data ) {
77 topupResponseHandler(buffer);
78 });
79
80 });
81
82 req.on('error', function(e) {
83 console.log('problem with request: ' + e.message);
84 callbackReport(task['requestId'], '40', e.message);
85 });
86
87 req.write( payload_xml );
88 req.end();
89 }
90
91 function topupResponseHandler(body, request_id) {
92 xml2js(body, function (err, result) {
93 if (err) {
94 console.log(body);
95 callbackReport(request_id, '40', buffer);
96 return;
97 }
98
99 console.log(result);
100
101 request_id = result.datacell.ref_trxid[0].trim();
102
103 var response_code = '68';
104
105 var message = '';
106 try {
107 if (result.datacell.message && result.datacell.message.length > 0) {
108 message = result.datacell.message[0].trim();
109 } else if (result.datacell.msg && result.datacell.msg.length > 0) {
110 message = result.datacell.msg[0].trim();
111 }
112 }
113 catch(err) {
114 message = 'exception saat parsing message';
115 }
116
117 if (result.datacell.resultcode && result.datacell.resultcode[0] == '999') {
118 response_code = '40';
119 }
120
121 if (message.indexOf('Nomor tujuan salah') >= 0) {
122 response_code = '14';
123 } else if (message.indexOf('*GAGAL, transaksi yang sama sudah ada dalam 10 menit') >= 0) {
124 response_code = '55';
125 } else if (message.indexOf('saldo sdh dikembalikan') >= 0) {
126 response_code = '40'
127 } else if (message.indexOf('Trx dpt diulang') >= 0) {
128 response_code = '40'
129 } else if (message.indexOf('SUKSES SN Operator:') >= 0) {
130 response_code = '00';
131
132 var sn = parseSN(message);
133 console.log ('SN Operator: ' + sn);
134
135 /*
136 if (!sn) {
137
138 console.log('Missing real operator SN, using SN from suplier');
139 try {
140 sn = result.datacell.trxid[0].trim();
141 }
142 catch(err) {
143 sn = '';
144 }
145 }
146 */
147
148 if (sn) {
149 message = 'SN=' + sn + '; ' + message;
150 } else {
151 message = 'SN belum didapat. ' + message;
152 response_code = '68';
153 }
154 }
155
156
157 var price = priceFromMessage(message);
158 if (price != null) {
159 console.log('Harga: ' + price);
160 trx_prices[request_id] = price;
161 setTimeout(deleteTrxPrice, 3 * 24 * 3600 * 1000, request_id);
162 } else if (response_code == '00' && trx_prices[request_id] !== undefined) {
163 price = trx_prices[request_id];
164 console.log('Harga: ' + price);
165 message = message + ' -- Harga: ' + price;
166 }
167
168 var balance = balanceFromMessage(message);
169 if (balance != null) {
170 console.log('Saldo: ' + balance);
171 trx_balances[request_id] = balance;
172 setTimeout(deleteTrxBalance, 3 * 24 * 3600 * 1000, request_id);
173 } else if (response_code == '00' && trx_balances[request_id] !== undefined) {
174 balance = trx_balances[request_id];
175 console.log('Saldo: ' + balance);
176 message = message + ' -- Saldo: ' + balance;
177 }
178
179 callbackReport(request_id, response_code, message);
180 });
181 }
182
183 function deleteTrxPrice(request_id) {
184 delete trx_prices[request_id];
185 }
186
187 function deleteTrxBalance(request_id) {
188 delete trx_balances[request_id];
189 }
190
191 function parseSN(message) {
192 var results = message.match(/SN Operator: .+ SN Kami/);
193 if (!results || results.length <= 0) {
194 return '';
195 }
196
197 var result = results[0];
198 result = result.replace('SN Operator:', '');
199 result = result.replace('SN Kami', '');
200 result = result.trim();
201
202 if (result == '00') {
203 result = '';
204 }
205
206 return result;
207 }
208
209 function createServer() {
210
211 var httpServer = http.createServer(function(req, res) {
212 var parsed_url = url.parse(req.url, true, true);
213
214 console.log('Got request from partner ("' + req.url + '")');
215
216 var body = "";
217 req.on('data', function (chunk) {
218 body += chunk;
219 });
220
221 req.on('end', function () {
222 res.writeHead(200);
223 res.end('OK');
224
225 //console.log(body);
226
227 if (parsed_url.pathname == '/sn') {
228 console.log('Reverse report -- SN');
229 topupResponseHandler(body);
230
231 } else if (parsed_url.pathname = '/refund') {
232 console.log('Reverse report -- REFUND');
233 callbackReport(parsed_url.query.ref_trxid, '40', parsed_url.query.message);
234
235 } else {
236 console.log('Reverse report -- UNKNOWN');
237 console.log('Ignore unknown request on reverse url');
238 }
239 });
240 });
241
242 httpServer.listen(config.h2h_out.listen_port, function() {
243 console.log('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
244 });
245 }
246
247 function balanceCheck() {
248 var timestamp = strftime('%H%M%S');
249
250 var payload = {
251 datacell: [
252 {perintah: 'saldo'},
253 {userid: config.h2h_out.userid},
254 {time: timestamp},
255 {sgn: calculateBalanceSignature(config.h2h_out.userid, config.h2h_out.password, timestamp)}
256 ]
257 };
258
259 var postRequest = {
260 host: "202.152.62.2",
261 path: "/RELOAD97.php",
262 port: 7713,
263 method: "POST",
264 headers: {
265 'Content-Type': 'text/xml',
266 'Content-Length': Buffer.byteLength(payload_xml)
267 }
268 };
269
270 var buffer = "";
271 var req = http.request( postRequest, function( res ) {
272
273 console.log('Status code: ' + res.statusCode );
274 var buffer = "";
275 res.on( "data", function( data ) { buffer = buffer + data; } );
276 res.on( "end", function( data ) {
277 console.log('CHECK BALANCE RESULT:');
278 console.log(buffer);
279 });
280
281 });
282
283 req.on('error', function(e) {
284 console.log('problem with request: ' + e.message);
285 });
286
287 req.write( payload_xml );
288 req.end();
289
290 }
291
292 function balanceFromMessage(message) {
293 var matches = message.match(/Saldo: Rp (\d+)/);
294
295 if (!matches) {
296 return null;
297 }
298 if (matches.length < 2) {
299 return null;
300 }
301
302 return matches[1];
303 }
304
305 function priceFromMessage(message) {
306 var matches = message.match(/Harga: (\d+)/);
307
308 if (!matches) {
309 return null;
310 }
311 if (matches.length < 2) {
312 return null;
313 }
314
315 return matches[1];
316 }
317
318 function start(_config, _callbackReport) {
319 config = _config;
320 callbackReport = _callbackReport
321
322 createServer();
323 }
324
325 exports.start = start;
326 exports.topupRequest = topupRequest;
327 exports.balanceFromMessage = balanceFromMessage;
328 exports.priceFromMessage = priceFromMessage;
329 1 var http = require('http');
1 var assert = require("assert"); 1 var assert = require("assert");
2 2
3 describe('partner-datacell', function() { 3 describe('partner-trugee', function() {
4 var partner = require('./partner-datacell'); 4 var partner = require('./partner-trugee');
5 5
6 describe('#balanceFromMessage', function() { 6 describe('#calculateSignature', function() {
7 var message; 7 it('should return CQ4HBVFTVlJSXg==', function() {
8 8 assert.equal('CQ4HBVFTVlJSXg==', partner.calculateSignature('abcdef', '0812345678', '191001'));
9 it('should return 8306874', function() {
10 assert.equal(8306874, partner.balanceFromMessage('IR25 No: 085697273881 sudah diterima dan sdg diproses. SN Kami :243588112. Harga: 24750. Saldo: Rp 8306874.'));
11 });
12
13 it('should return 8351574', function() {
14 assert.equal(8351574, partner.balanceFromMessage('TEL20 No: 085372113774 sudah diterima dan sdg diproses. SN Kami :243586975. Harga: 19950. Saldo: Rp 8351574.'));
15 });
16
17 it('should return 0', function() {
18 assert.equal(0, partner.balanceFromMessage('TEL20 No: 085372113774 sudah diterima dan sdg diproses. SN Kami :243586975. Harga: 19950. Saldo: Rp 0.'));
19 });
20
21 it('should return null', function() {
22 assert.equal(null, partner.balanceFromMessage('XL25 No: 08174945541 SUKSES SN Operator: 970729963933 SN Kami: 243591297.'));
23 });
24 });
25
26 describe('#priceFromMessage', function() {
27 var message;
28
29 it('should return 24750', function() {
30 assert.equal(24750, partner.priceFromMessage('IR25 No: 085697273881 sudah diterima dan sdg diproses. SN Kami :243588112. Harga: 24750. Saldo: Rp 8306874.'));
31 });
32
33 it('should return 19950', function() {
34 assert.equal(19950, partner.priceFromMessage('TEL20 No: 085372113774 sudah diterima dan sdg diproses. SN Kami :243586975. Harga: 19950. Saldo: Rp 8351574.'));
35 });
36
37 it('should return 0', function() {
38 assert.equal(0, partner.priceFromMessage('TEL20 No: 085372113774 sudah diterima dan sdg diproses. SN Kami :243586975. Harga: 0. Saldo: Rp 8351574.'));
39 }); 9 });
40 10
41 it('should return null', function() {
42 assert.equal(null, partner.priceFromMessage('XL25 No: 08174945541 SUKSES SN Operator: 970729963933 SN Kami: 243591297.'));
43 });
44 }); 11 });
45 12
46 13
47 14
48 15
49 }); 16 });
50 17