Commit 45008e9867286daf0bc1fe88e6f469801f97b012
1 parent
06b2ccea23
Exists in
master
Hapus require tak terpakai
Showing 1 changed file with 0 additions and 1 deletions Inline Diff
lib/reverse-report.js
| 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'); | ||
| 10 | 9 | ||
| 11 | const st24 = require('./st24'); | 10 | const st24 = require('./st24'); |
| 12 | const partner = require('./partner'); | 11 | const partner = require('./partner'); |
| 13 | const partnerRc = require('./partner-rc.json'); | 12 | const partnerRc = require('./partner-rc.json'); |
| 14 | 13 | ||
| 15 | function create() { | 14 | function create() { |
| 16 | if (!config || !config.reverse_report_port) { | 15 | if (!config || !config.reverse_report_port) { |
| 17 | logger.info('Not creating reverse report server because of undefined config.reverse_report_port'); | 16 | logger.info('Not creating reverse report server because of undefined config.reverse_report_port'); |
| 18 | return; | 17 | return; |
| 19 | } | 18 | } |
| 20 | 19 | ||
| 21 | const server = xmlrpc.createServer({ port: config.reverse_report_port }); | 20 | const server = xmlrpc.createServer({ port: config.reverse_report_port }); |
| 22 | 21 | ||
| 23 | logger.info('Reverse report server listen on port ' + config.reverse_report_port); | 22 | logger.info('Reverse report server listen on port ' + config.reverse_report_port); |
| 24 | 23 | ||
| 25 | server.on('NotFound', function (method, params) { | 24 | server.on('NotFound', function (method, params) { |
| 26 | logger.warn('REVERSEREPORT: Unknown method recevied on XMLRPC server', {method: method, params: params}); | 25 | logger.warn('REVERSEREPORT: Unknown method recevied on XMLRPC server', {method: method, params: params}); |
| 27 | }); | 26 | }); |
| 28 | 27 | ||
| 29 | server.on('topUpReport', function (err, params, callback) { | 28 | server.on('topUpReport', function (err, params, callback) { |
| 30 | 29 | ||
| 31 | logger.info('REVERSEREPORT: Got XMLRPC topUpReport request from partner', {method: 'topUpReport', params: params}); | 30 | logger.info('REVERSEREPORT: Got XMLRPC topUpReport request from partner', {method: 'topUpReport', params: params}); |
| 32 | matrix.last_topupReport_params = params; | 31 | matrix.last_topupReport_params = params; |
| 33 | 32 | ||
| 34 | const paramsCount = params.length; | 33 | const paramsCount = params.length; |
| 35 | for (let i = 0; i < paramsCount; i++) { | 34 | for (let i = 0; i < paramsCount; i++) { |
| 36 | let value = params[i]; | 35 | let value = params[i]; |
| 37 | 36 | ||
| 38 | partner.report({ | 37 | partner.report({ |
| 39 | trx_id: value.REQUESTID, | 38 | trx_id: value.REQUESTID, |
| 40 | rc: partnerRc[value.RESPONSECODE] || '40', | 39 | rc: partnerRc[value.RESPONSECODE] || '40', |
| 41 | //message: value.MESSAGE, | 40 | //message: value.MESSAGE, |
| 42 | message: 'topUpReport: ' + stringify(value), | 41 | message: 'topUpReport: ' + stringify(value), |
| 43 | sn: (value.SN || '').replace(/;$/, '') || st24.extractSnFromMessage(value.MESSAGE), | 42 | sn: (value.SN || '').replace(/;$/, '') || st24.extractSnFromMessage(value.MESSAGE), |
| 44 | amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE), | 43 | amount: value.PRICE || st24.extractPriceFromMsg(value.MESSAGE), |
| 45 | balance: st24.extractBalanceFromMsg(value.MESSAGE, config.balance_pattern), | 44 | balance: st24.extractBalanceFromMsg(value.MESSAGE, config.balance_pattern), |
| 46 | raw: value, | 45 | raw: value, |
| 47 | misc: { | 46 | misc: { |
| 48 | } | 47 | } |
| 49 | }); | 48 | }); |
| 50 | } | 49 | } |
| 51 | 50 | ||
| 52 | callback(null, 'ACK REPORT OK'); | 51 | callback(null, 'ACK REPORT OK'); |
| 53 | }) | 52 | }) |
| 54 | } | 53 | } |
| 55 | 54 | ||
| 56 | create(); | 55 | create(); |
| 57 | 56 |