Commit 1b0dac94be692dbf7d8211762c2a9ba78b193f53
1 parent
f5666b5a5e
Exists in
master
and in
1 other branch
Add log on trust proxy
Showing 1 changed file with 1 additions and 0 deletions Inline Diff
lib/partner-listener/index.js
| 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.partner && config.partner.trust_proxy) { | 19 | if (config.partner && config.partner.trust_proxy) { |
| 20 | logger.verbose(`${MODULE_NAME} 01156CE1: Proxies trusted`, { trusted: config.partner.trust_proxy }); | ||
| 20 | app.set('trust proxy', config.partner.trust_proxy); | 21 | app.set('trust proxy', config.partner.trust_proxy); |
| 21 | } | 22 | } |
| 22 | 23 | ||
| 23 | app.use((req, res, next) => { | 24 | app.use((req, res, next) => { |
| 24 | res.locals.httpgetx_subsystem = MODULE_NAME; | 25 | res.locals.httpgetx_subsystem = MODULE_NAME; |
| 25 | next(); | 26 | next(); |
| 26 | }); | 27 | }); |
| 27 | 28 | ||
| 28 | app.use(express.json({ extended: true })); | 29 | app.use(express.json({ extended: true })); |
| 29 | app.use(express.urlencoded({ extended: true })); | 30 | app.use(express.urlencoded({ extended: true })); |
| 30 | app.use(middlewareCommon); | 31 | app.use(middlewareCommon); |
| 31 | 32 | ||
| 32 | app.use('/ping', (req, res) => { | 33 | app.use('/ping', (req, res) => { |
| 33 | res.json({ | 34 | res.json({ |
| 34 | error: false, | 35 | error: false, |
| 35 | xid: res.locals.xid, | 36 | xid: res.locals.xid, |
| 36 | from_ip: req.ip, | 37 | from_ip: req.ip, |
| 37 | ts: new Date(), | 38 | ts: new Date(), |
| 38 | request: { | 39 | request: { |
| 39 | method: req.method, | 40 | method: req.method, |
| 40 | userAgent: req.get('user-agent'), | 41 | userAgent: req.get('user-agent'), |
| 41 | contentType: req.get('content-type'), | 42 | contentType: req.get('content-type'), |
| 42 | qs: req.query, | 43 | qs: req.query, |
| 43 | body: req.body, | 44 | body: req.body, |
| 44 | }, | 45 | }, |
| 45 | }); | 46 | }); |
| 46 | }); | 47 | }); |
| 47 | app.use('/inquiry', routerInquiry); | 48 | app.use('/inquiry', routerInquiry); |
| 48 | app.use('/pay', routerPay); | 49 | app.use('/pay', routerPay); |
| 49 | app.use('/topup', routerTopup); | 50 | app.use('/topup', routerTopup); |
| 50 | app.use('/trx-status', routerTrxStatus); | 51 | app.use('/trx-status', routerTrxStatus); |
| 51 | app.use('/', routerTopup); | 52 | app.use('/', routerTopup); |
| 52 | 53 | ||
| 53 | app.use((req, res) => { | 54 | app.use((req, res) => { |
| 54 | const { xid } = res.locals; | 55 | const { xid } = res.locals; |
| 55 | 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`); |
| 56 | }); | 57 | }); |
| 57 | 58 | ||
| 58 | app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => { | 59 | app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => { |
| 59 | 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}`); |
| 60 | }).on('error', (e) => { | 61 | }).on('error', (e) => { |
| 61 | 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()}`); |
| 62 | process.exit(1); | 63 | process.exit(1); |
| 63 | }); | 64 | }); |
| 64 | 65 |