Commit debbc65a184febc31b127e160ad03eb05c29b242
1 parent
fa9f83e2c9
Exists in
master
and in
1 other branch
Ping
Showing 1 changed file with 15 additions and 0 deletions Inline Diff
lib/partner-listener/index.js
| 1 | const DEFAULT_LISTENER_FROM_PARTNER_PORT = 25614; | 1 | const DEFAULT_LISTENER_FROM_PARTNER_PORT = 25614; |
| 2 | 2 | ||
| 3 | const express = require('express'); | 3 | const express = require('express'); |
| 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 | 7 | ||
| 8 | const middlewareCommon = require('../middlewares/common'); | 8 | const middlewareCommon = require('../middlewares/common'); |
| 9 | 9 | ||
| 10 | const routerInquiry = require('./routers/inquiry'); | 10 | const routerInquiry = require('./routers/inquiry'); |
| 11 | const routerPay = require('./routers/pay'); | 11 | const routerPay = require('./routers/pay'); |
| 12 | const routerTopup = require('./routers/topup'); | 12 | const routerTopup = require('./routers/topup'); |
| 13 | const routerTrxStatus = require('./routers/trx-status'); | 13 | const routerTrxStatus = require('./routers/trx-status'); |
| 14 | 14 | ||
| 15 | const app = express(); | 15 | const app = express(); |
| 16 | 16 | ||
| 17 | app.use(express.json({ extended: true })); | 17 | app.use(express.json({ extended: true })); |
| 18 | app.use(express.urlencoded({ extended: true })); | 18 | app.use(express.urlencoded({ extended: true })); |
| 19 | app.use(middlewareCommon); | 19 | app.use(middlewareCommon); |
| 20 | 20 | ||
| 21 | app.use('/ping', (req, res) => { | ||
| 22 | res.json({ | ||
| 23 | error: false, | ||
| 24 | xid: res.locals.xid, | ||
| 25 | from_ip: req.ip, | ||
| 26 | ts: new Date(), | ||
| 27 | request: { | ||
| 28 | method: req.method, | ||
| 29 | userAgent: req.get('user-agent'), | ||
| 30 | contentType: req.get('content-type'), | ||
| 31 | qs: req.query, | ||
| 32 | body: req.body, | ||
| 33 | }, | ||
| 34 | }); | ||
| 35 | }); | ||
| 21 | app.use('/inquiry', routerInquiry); | 36 | app.use('/inquiry', routerInquiry); |
| 22 | app.use('/pay', routerPay); | 37 | app.use('/pay', routerPay); |
| 23 | app.use('/topup', routerTopup); | 38 | app.use('/topup', routerTopup); |
| 24 | app.use('/trx-status', routerTrxStatus); | 39 | app.use('/trx-status', routerTrxStatus); |
| 25 | 40 | ||
| 26 | app.use((req, res) => { | 41 | app.use((req, res) => { |
| 27 | const { xid } = res.locals; | 42 | const { xid } = res.locals; |
| 28 | res.status(404).end(`KOMODO-HTTP-GET-X CENTER.\n404: Method not found.\n\nXID: ${xid}.\n`); | 43 | res.status(404).end(`KOMODO-HTTP-GET-X CENTER.\n404: Method not found.\n\nXID: ${xid}.\n`); |
| 29 | }); | 44 | }); |
| 30 | 45 | ||
| 31 | app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => { | 46 | app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => { |
| 32 | logger.info(`Listen from partner request on port ${config.listener.partner.port}`); | 47 | logger.info(`Listen from partner request on port ${config.listener.partner.port}`); |
| 33 | }).on('error', (e) => { | 48 | }).on('error', (e) => { |
| 34 | logger.error(`Can not listen request from partner on port ${config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT}. ${e.toString()}`); | 49 | logger.error(`Can not listen request from partner on port ${config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT}. ${e.toString()}`); |
| 35 | process.exit(1); | 50 | process.exit(1); |
| 36 | }); | 51 | }); |
| 37 | 52 |