Komodo / komodo-gw-st24

Download as
Browse Code ยป

Commit c548d3223378b8b20530ac4bf2d78caa97ee4c03

Authored by Adhidarma Hadiwinoto
1 parent 4dbd28377b
Exists in master

quickfix typo

Showing 1 changed file with 1 additions and 1 deletions Inline Diff

lib/reverse-report.js
Diff comments   View file @ c548d32
1 "use strict"; 1 "use strict";
2 2
3 const xmlrpc = require('xmlrpc'); 3 const xmlrpc = require('xmlrpc');
4 const stringify = require("json-stringify-pretty-compact"); 4 const stringify = require("json-stringify-pretty-compact");
5 5
6 const config = require('komodo-sdk/config'); 6 const config = require('komodo-sdk/config');
7 const logger = require('komodo-sdk/logger'); 7 const logger = require('komodo-sdk/logger');
8 const matrix = require('komodo-sdk/matrix'); 8 const matrix = require('komodo-sdk/matrix');
9 const pull = require('komodo-sdk/gateway/pull'); 9 const pull = require('komodo-sdk/gateway/pull');
10 10
11 const st24 = require('./st24'); 11 const st24 = require('./st24');
12 const partner = require('./partner'); 12 const partner = require('./partner');
13 const partnerRc = require('./partner-rc.json'); 13 const partnerRc = require('./partner-rc.json');
14 14
15 function create() { 15 function create() {
16 if (!config || !config.reverse_report_port) { 16 if (!config || !config.reverse_report_port) {
17 logger.info('Not creating reverse report server because of undefined config.reverse_report_port'); 17 logger.info('Not creating reverse report server because of undefined config.reverse_report_port');
18 return; 18 return;
19 } 19 }
20 20
21 const server = xmlrpc.createServer({ port: config.reverse_report_port }); 21 const server = xmlrpc.createServer({ port: config.reverse_report_port });
22 22
23 logger.info('Reverse report server listen on port ' + config.reverse_report_port); 23 logger.info('Reverse report server listen on port ' + config.reverse_report_port);
24 24
25 server.on('NotFound', function (method, params) { 25 server.on('NotFound', function (method, params) {
26 logger.warn('REVERSEREPORT: Unknown method recevied on XMLRPC server', {method: method, params: params}); 26 logger.warn('REVERSEREPORT: Unknown method recevied on XMLRPC server', {method: method, params: params});
27 }); 27 });
28 28
29 server.on('topUpReport', function (err, params, callback) { 29 server.on('topUpReport', function (err, params, callback) {
30 30
31 logger.info('REVERSEREPORT: Got XMLRPC topUpReport request from partner', {method: 'topUpReport', params: params}); 31 logger.info('REVERSEREPORT: Got XMLRPC topUpReport request from partner', {method: 'topUpReport', params: params});
32 matrix.last_topupReport_params = params; 32 matrix.last_topupReport_params = params;
33 33
34 const paramsCount = params.length; 34 const paramsCount = params.length;
35 for (let i = 0; i < paramsCount; i++) { 35 for (let i = 0; i < paramsCount; i++) {
36 let value = params[i]; 36 let value = params[i];
37 37
38 partner.report({ 38 partner.report({
39 trx_id: value.REQUESTID, 39 trx_id: value.REQUESTID,
40 rc: partnerRc[value.RESPONSECODE] || '40', 40 rc: partnerRc[value.RESPONSECODE] || '40',
41 //message: value.MESSAGE, 41 //message: value.MESSAGE,
42 message: 'topUpReport: ' + stringify(value); 42 message: 'topUpReport: ' + stringify(value),
43 sn: (value.SN || '').replace(/;$/, '') || st24.extractSnFromMessage(value.MESSAGE), 43 sn: (value.SN || '').replace(/;$/, '') || st24.extractSnFromMessage(value.MESSAGE),
44 amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE), 44 amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE),
45 balance: st24.extractBalanceFromMsg(value.MESSAGE, config.balance_pattern), 45 balance: st24.extractBalanceFromMsg(value.MESSAGE, config.balance_pattern),
46 raw: value, 46 raw: value,
47 misc: { 47 misc: {
48 } 48 }
49 }); 49 });
50 } 50 }
51 51
52 callback(null, 'ACK REPORT OK'); 52 callback(null, 'ACK REPORT OK');
53 }) 53 })
54 } 54 }
55 55
56 create(); 56 create();
57 57