Komodo / komodo-center-httpget-x

Download as
Browse Code ยป

Commit 2751dda4b561200af27c704a1bba4916eac502ee

Authored by Adhidarma Hadiwinoto
1 parent e40a13db30
Exists in master and in 1 other branch dev

Fix .listener.partner.trust_proxy selector

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

lib/partner-listener/index.js
Diff comments   View file @ 2751dda
1 const MODULE_NAME = 'PARTNER-LISTENER'; 1 const MODULE_NAME = 'PARTNER-LISTENER';
2 2
3 const DEFAULT_LISTENER_FROM_PARTNER_PORT = 25614; 3 const DEFAULT_LISTENER_FROM_PARTNER_PORT = 25614;
4 4
5 const express = require('express'); 5 const express = require('express');
6 6
7 const config = require('komodo-sdk/config'); 7 const config = require('komodo-sdk/config');
8 const logger = require('tektrans-logger'); 8 const logger = require('tektrans-logger');
9 9
10 const middlewareCommon = require('../middlewares/common'); 10 const middlewareCommon = require('../middlewares/common');
11 11
12 const routerInquiry = require('./routers/inquiry'); 12 const routerInquiry = require('./routers/inquiry');
13 const routerPay = require('./routers/pay'); 13 const routerPay = require('./routers/pay');
14 const routerTopup = require('./routers/topup'); 14 const routerTopup = require('./routers/topup');
15 const routerTrxStatus = require('./routers/trx-status'); 15 const routerTrxStatus = require('./routers/trx-status');
16 16
17 const app = express(); 17 const app = express();
18 18
19 if (config.listener && config.listener.partner && config.listener.partner.trust_proxy) { 19 if (config.listener && config.listener.partner && config.listener.partner.trust_proxy) {
20 logger.verbose(`${MODULE_NAME} 01156CE1: Proxies trusted`, { trusted: config.listener.partner.trust_proxy }); 20 logger.info(`${MODULE_NAME} 01156CE1: Proxies trusted`, { trusted: config.listener.partner.trust_proxy });
21 app.set('trust proxy', config.partner.listener.trust_proxy); 21 app.set('trust proxy', config.listener.partner.trust_proxy);
22 } 22 }
23 23
24 app.use((req, res, next) => { 24 app.use((req, res, next) => {
25 res.locals.httpgetx_subsystem = MODULE_NAME; 25 res.locals.httpgetx_subsystem = MODULE_NAME;
26 next(); 26 next();
27 }); 27 });
28 28
29 app.use(express.json({ extended: true })); 29 app.use(express.json({ extended: true }));
30 app.use(express.urlencoded({ extended: true })); 30 app.use(express.urlencoded({ extended: true }));
31 app.use(middlewareCommon); 31 app.use(middlewareCommon);
32 32
33 app.use('/ping', (req, res) => { 33 app.use('/ping', (req, res) => {
34 res.json({ 34 res.json({
35 error: false, 35 error: false,
36 xid: res.locals.xid, 36 xid: res.locals.xid,
37 from_ip: req.ip, 37 from_ip: req.ip,
38 ts: new Date(), 38 ts: new Date(),
39 request: { 39 request: {
40 method: req.method, 40 method: req.method,
41 userAgent: req.get('user-agent'), 41 userAgent: req.get('user-agent'),
42 contentType: req.get('content-type'), 42 contentType: req.get('content-type'),
43 qs: req.query, 43 qs: req.query,
44 body: req.body, 44 body: req.body,
45 }, 45 },
46 }); 46 });
47 }); 47 });
48 app.use('/inquiry', routerInquiry); 48 app.use('/inquiry', routerInquiry);
49 app.use('/pay', routerPay); 49 app.use('/pay', routerPay);
50 app.use('/topup', routerTopup); 50 app.use('/topup', routerTopup);
51 app.use('/trx-status', routerTrxStatus); 51 app.use('/trx-status', routerTrxStatus);
52 app.use('/', routerTopup); 52 app.use('/', routerTopup);
53 53
54 app.use((req, res) => { 54 app.use((req, res) => {
55 const { xid } = res.locals; 55 const { xid } = res.locals;
56 res.status(404).end(`KOMODO-HTTP-GET-X CENTER.\n404: Method not found.\n\nXID: ${xid}.\n`); 56 res.status(404).end(`KOMODO-HTTP-GET-X CENTER.\n404: Method not found.\n\nXID: ${xid}.\n`);
57 }); 57 });
58 58
59 app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => { 59 app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => {
60 logger.info(`Listen from partner request on port ${config.listener.partner.port}`); 60 logger.info(`Listen from partner request on port ${config.listener.partner.port}`);
61 }).on('error', (e) => { 61 }).on('error', (e) => {
62 logger.error(`Can not listen request from partner on port ${config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT}. ${e.toString()}`); 62 logger.error(`Can not listen request from partner on port ${config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT}. ${e.toString()}`);
63 process.exit(1); 63 process.exit(1);
64 }); 64 });
65 65