Commit ef88c73001881ce5f8d8017f4a8444a311ed208b
1 parent
0408bedd1d
Exists in
master
and in
1 other branch
Use server.address().port on core callback listen log
Showing 1 changed file with 2 additions and 2 deletions Inline Diff
lib/core-callback/index.js
| 1 | const MODULE_NAME = 'CORE-CALLBACK'; | 1 | const MODULE_NAME = 'CORE-CALLBACK'; |
| 2 | 2 | ||
| 3 | const DEFAULT_LISTENER_FROM_CORE = 25613; | 3 | const DEFAULT_LISTENER_FROM_CORE = 25613; |
| 4 | 4 | ||
| 5 | const express = require('express'); | 5 | const express = require('express'); |
| 6 | const config = require('komodo-sdk/config'); | 6 | const config = require('komodo-sdk/config'); |
| 7 | const logger = require('tektrans-logger'); | 7 | const logger = require('tektrans-logger'); |
| 8 | const middlewareCommon = require('../middlewares/common'); | 8 | const middlewareCommon = require('../middlewares/common'); |
| 9 | const sender = require('./sender'); | 9 | const sender = require('./sender'); |
| 10 | const dumperReq = require('./dumper/req'); | 10 | const dumperReq = require('./dumper/req'); |
| 11 | const matrix = require('../matrix'); | 11 | const matrix = require('../matrix'); |
| 12 | 12 | ||
| 13 | const app = express(); | 13 | const app = express(); |
| 14 | 14 | ||
| 15 | app.use(express.json({ extended: true })); | 15 | app.use(express.json({ extended: true })); |
| 16 | app.use(express.urlencoded({ extended: true })); | 16 | app.use(express.urlencoded({ extended: true })); |
| 17 | 17 | ||
| 18 | app.use((req, res, next) => { | 18 | app.use((req, res, next) => { |
| 19 | res.locals.httpgetx_subsystem = MODULE_NAME; | 19 | res.locals.httpgetx_subsystem = MODULE_NAME; |
| 20 | next(); | 20 | next(); |
| 21 | }); | 21 | }); |
| 22 | 22 | ||
| 23 | app.use(middlewareCommon); | 23 | app.use(middlewareCommon); |
| 24 | app.use(dumperReq); | 24 | app.use(dumperReq); |
| 25 | 25 | ||
| 26 | app.use((req, res) => { | 26 | app.use((req, res) => { |
| 27 | matrix.core.received += 1; | 27 | matrix.core.received += 1; |
| 28 | res.end('OK'); | 28 | res.end('OK'); |
| 29 | 29 | ||
| 30 | const data = req.method === 'GET' ? req.query : req.body; | 30 | const data = req.method === 'GET' ? req.query : req.body; |
| 31 | sender(data, res.locals.xid); | 31 | sender(data, res.locals.xid); |
| 32 | }); | 32 | }); |
| 33 | 33 | ||
| 34 | const port = (config.listener && config.listener.core && config.listener.core.port) | 34 | const port = (config.listener && config.listener.core && config.listener.core.port) |
| 35 | || DEFAULT_LISTENER_FROM_CORE; | 35 | || DEFAULT_LISTENER_FROM_CORE; |
| 36 | 36 | ||
| 37 | app.listen(port, () => { | 37 | const server = app.listen(port, () => { |
| 38 | logger.info(`${MODULE_NAME} 0375DC4E: Listen from CORE callback on port ${port}`); | 38 | logger.info(`${MODULE_NAME} 0375DC4E: Listen from CORE callback`, { port: server.address().port }); |
| 39 | }).on('error', (e) => { | 39 | }).on('error', (e) => { |
| 40 | logger.error(`${MODULE_NAME} A90E42D5: Can not listen CORE callback on port ${port}. ${e.toString()}`); | 40 | logger.error(`${MODULE_NAME} A90E42D5: Can not listen CORE callback on port ${port}. ${e.toString()}`); |
| 41 | process.exit(1); | 41 | process.exit(1); |
| 42 | }); | 42 | }); |
| 43 | 43 |