Komodo / komodo-gw-st24

Download as
Browse Code ยป

Commit ea8bfdadbbc3286082c57bac226b7dbe2aded741

Authored by Adhidarma Hadiwinoto
1 parent 36b5eef4d1
Exists in master

hapus ; pada sn dari respon

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

1 "use strict"; 1 "use strict";
2 2
3 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; 3 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
4 4
5 const url = require('url'); 5 const url = require('url');
6 const https = require('https'); 6 const https = require('https');
7 const xmlrpc = require('xmlrpc'); 7 const xmlrpc = require('xmlrpc');
8 8
9 const config = require('komodo-sdk/config'); 9 const config = require('komodo-sdk/config');
10 const logger = require('komodo-sdk/logger'); 10 const logger = require('komodo-sdk/logger');
11 const matrix = require('komodo-sdk/matrix'); 11 const matrix = require('komodo-sdk/matrix');
12 const pull = require('komodo-sdk/gateway/pull'); 12 const pull = require('komodo-sdk/gateway/pull');
13 13
14 const st24 = require('./st24'); 14 const st24 = require('./st24');
15 const partnerRc = require('./partner-rc.json'); 15 const partnerRc = require('./partner-rc.json');
16 16
17 if (config.partner.use_sslv3) { 17 if (config.partner.use_sslv3) {
18 https.globalAgent.options.secureProtocol = 'SSLv3_method'; 18 https.globalAgent.options.secureProtocol = 'SSLv3_method';
19 } 19 }
20 20
21 function buy(task) { 21 function buy(task) {
22 const partnerUrl = url.parse(config.partner.url); 22 const partnerUrl = url.parse(config.partner.url);
23 const clientOptions = { 23 const clientOptions = {
24 host: partnerUrl.hostname, 24 host: partnerUrl.hostname,
25 port: partnerUrl.port, 25 port: partnerUrl.port,
26 path: partnerUrl.pathname 26 path: partnerUrl.pathname
27 }; 27 };
28 28
29 let client; 29 let client;
30 if (partnerUrl.protocol == 'https:') { 30 if (partnerUrl.protocol == 'https:') {
31 client = xmlrpc.createSecureClient(clientOptions); 31 client = xmlrpc.createSecureClient(clientOptions);
32 } else { 32 } else {
33 client = xmlrpc.createClient(clientOptions); 33 client = xmlrpc.createClient(clientOptions);
34 } 34 }
35 35
36 const params = { 36 const params = {
37 MSISDN: config.partner.msisdn || config.partner.userid, 37 MSISDN: config.partner.msisdn || config.partner.userid,
38 REQUESTID: task.trx_id, 38 REQUESTID: task.trx_id,
39 PIN: config.partner.pin || config.partner.password, 39 PIN: config.partner.pin || config.partner.password,
40 NOHP: task.destination, 40 NOHP: task.destination,
41 NOM: task.remote_product 41 NOM: task.remote_product
42 }; 42 };
43 43
44 const xmlrpcMethod = 'topUpRequest'; 44 const xmlrpcMethod = 'topUpRequest';
45 logger.info('Preparing XMLRPC request', {method: xmlrpcMethod, params: params, partnerUrl: partnerUrl.href}); 45 logger.info('Preparing XMLRPC request', {method: xmlrpcMethod, params: params, partnerUrl: partnerUrl.href});
46 46
47 client.methodCall(xmlrpcMethod, [ params ], function (err, value) { 47 client.methodCall(xmlrpcMethod, [ params ], function (err, value) {
48 48
49 if (err) { 49 if (err) {
50 50
51 let msg = 'XMLRPC Client Error: ' + err; 51 let msg = 'XMLRPC Client Error: ' + err;
52 let rc = '68'; 52 let rc = '68';
53 53
54 if ( 54 if (
55 err.code === 'ECONNREFUSED' 55 err.code === 'ECONNREFUSED'
56 || err.code === 'EHOSTUNREACH' 56 || err.code === 'EHOSTUNREACH'
57 || (err.code === 'ETIMEDOUT' && err.syscall === "connect") 57 || (err.code === 'ETIMEDOUT' && err.syscall === "connect")
58 || (err.code === 'EPROTO' && err.syscall === "write") 58 || (err.code === 'EPROTO' && err.syscall === "write")
59 ) { 59 ) {
60 rc = '91'; 60 rc = '91';
61 } 61 }
62 62
63 logger.warn(msg, {method: xmlrpcMethod, trx_id: task.trx_id, destination: task.destination, err: err}); 63 logger.warn(msg, {method: xmlrpcMethod, trx_id: task.trx_id, destination: task.destination, err: err});
64 report({ 64 report({
65 trx_id: task.trx_id, 65 trx_id: task.trx_id,
66 rc: rc, 66 rc: rc,
67 message: 'INTERNAL: ' + msg, 67 message: 'INTERNAL: ' + msg,
68 misc: { 68 misc: {
69 task: task 69 task: task
70 } 70 }
71 }); 71 });
72 72
73 return; 73 return;
74 } 74 }
75 75
76 logger.info('Got XMLRPC response from partner for', {method: xmlrpcMethod, trx_id: task.trx_id, destination: task.destination, response: value}); 76 logger.info('Got XMLRPC response from partner for', {method: xmlrpcMethod, trx_id: task.trx_id, destination: task.destination, response: value});
77 matrix.last_topupRequest_ack = value; 77 matrix.last_topupRequest_ack = value;
78 78
79 report({ 79 report({
80 trx_id: task.trx_id, 80 trx_id: task.trx_id,
81 rc: partnerRc[value.RESPONSECODE] || '40', 81 rc: partnerRc[value.RESPONSECODE] || '40',
82 message: value.MESSAGE, 82 message: value.MESSAGE,
83 sn: value.SN || st24.extractSnFromMessage(value.MESSAGE), 83 sn: (value.SN || '').replace(/;$/, '') || st24.extractSnFromMessage(value.MESSAGE),
84 amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE), 84 amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE),
85 raw: value, 85 raw: value,
86 misc: { 86 misc: {
87 task: task 87 task: task
88 } 88 }
89 }); 89 });
90 }); 90 });
91 } 91 }
92 92
93 function advice(task) { 93 function advice(task) {
94 } 94 }
95 95
96 function report(data) { 96 function report(data) {
97 matrix.last_report_to_core = data; 97 matrix.last_report_to_core = data;
98 pull.report(data); 98 pull.report(data);
99 } 99 }
100 100
101 exports.buy = buy; 101 exports.buy = buy;
102 exports.advice = advice; 102 exports.advice = advice;
103 exports.report = report; 103 exports.report = report;
104 104
lib/reverse-report.js
Diff comments   View file @ ea8bfda
1 "use strict"; 1 "use strict";
2 2
3 const xmlrpc = require('xmlrpc'); 3 const xmlrpc = require('xmlrpc');
4 4
5 const config = require('komodo-sdk/config'); 5 const config = require('komodo-sdk/config');
6 const logger = require('komodo-sdk/logger'); 6 const logger = require('komodo-sdk/logger');
7 const matrix = require('komodo-sdk/matrix'); 7 const matrix = require('komodo-sdk/matrix');
8 const pull = require('komodo-sdk/gateway/pull'); 8 const pull = require('komodo-sdk/gateway/pull');
9 9
10 const st24 = require('./st24'); 10 const st24 = require('./st24');
11 const partner = require('./partner'); 11 const partner = require('./partner');
12 const partnerRc = require('./partner-rc.json'); 12 const partnerRc = require('./partner-rc.json');
13 13
14 function create() { 14 function create() {
15 const server = xmlrpc.createServer({ 15 const server = xmlrpc.createServer({
16 port: config.reverse_report_port 16 port: config.reverse_report_port
17 }); 17 });
18 18
19 logger.info('Reverse report server listen on port ' + config.reverse_report_port); 19 logger.info('Reverse report server listen on port ' + config.reverse_report_port);
20 20
21 server.on('NotFound', function (method, params) { 21 server.on('NotFound', function (method, params) {
22 logger.warn('REVERSEREPORT: Unknown method recevied on XMLRPC server', {method: method, params: params}); 22 logger.warn('REVERSEREPORT: Unknown method recevied on XMLRPC server', {method: method, params: params});
23 }); 23 });
24 24
25 server.on('topUpReport', function (err, params, callback) { 25 server.on('topUpReport', function (err, params, callback) {
26 26
27 logger.info('REVERSEREPORT: Got XMLRPC topUpReport request from partner', {method: 'topUpReport', params: params}); 27 logger.info('REVERSEREPORT: Got XMLRPC topUpReport request from partner', {method: 'topUpReport', params: params});
28 matrix.last_topupReport_params = params; 28 matrix.last_topupReport_params = params;
29 29
30 const paramsCount = params.length; 30 const paramsCount = params.length;
31 for (let i = 0; i < paramsCount; i++) { 31 for (let i = 0; i < paramsCount; i++) {
32 let value = params[i]; 32 let value = params[i];
33 33
34 partner.report({ 34 partner.report({
35 trx_id: value.REQUESTID, 35 trx_id: value.REQUESTID,
36 rc: partnerRc[value.RESPONSECODE] || '40', 36 rc: partnerRc[value.RESPONSECODE] || '40',
37 message: value.MESSAGE, 37 message: value.MESSAGE,
38 sn: value.SN || st24.extractSnFromMessage(value.MESSAGE), 38 sn: (value.SN || '').replace(/;$/, '') || st24.extractSnFromMessage(value.MESSAGE),
39 amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE), 39 amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE),
40 raw: value, 40 raw: value,
41 misc: { 41 misc: {
42 } 42 }
43 }); 43 });
44 } 44 }
45 45
46 callback(null, 'ACK REPORT OK'); 46 callback(null, 'ACK REPORT OK');
47 }) 47 })
48 } 48 }
49 49
50 create(); 50 create();
51 51