Blame view
lib/core-callback/index.js
1.21 KB
56ec0ab1f
|
1 |
const MODULE_NAME = 'CORE-CALLBACK'; |
f2c18879a
|
2 3 4 5 |
const DEFAULT_LISTENER_FROM_CORE = 25613; const express = require('express'); const config = require('komodo-sdk/config'); |
810fa18da
|
6 |
const logger = require('tektrans-logger'); |
f2c18879a
|
7 8 |
const middlewareCommon = require('../middlewares/common'); const sender = require('./sender'); |
d05e75946
|
9 |
const dumperReq = require('./dumper/req'); |
cd4feda87
|
10 |
const matrix = require('../matrix'); |
f2c18879a
|
11 12 13 14 15 16 |
const app = express(); app.use(express.json({ extended: true })); app.use(express.urlencoded({ extended: true })); app.use((req, res, next) => { |
56ec0ab1f
|
17 |
res.locals.httpgetx_subsystem = MODULE_NAME; |
f2c18879a
|
18 19 20 21 |
next(); }); app.use(middlewareCommon); |
d05e75946
|
22 |
app.use(dumperReq); |
f2c18879a
|
23 24 |
app.use((req, res) => { |
b403448ad
|
25 |
matrix.core.received += 1; |
f2c18879a
|
26 |
res.end('OK'); |
f03c75812
|
27 28 29 |
const data = req.method === 'GET' ? req.query : req.body; sender(data, res.locals.xid); |
f2c18879a
|
30 31 32 33 |
}); const port = (config.listener && config.listener.core && config.listener.core.port) || DEFAULT_LISTENER_FROM_CORE; |
ef88c7300
|
34 35 |
const server = app.listen(port, () => { logger.info(`${MODULE_NAME} 0375DC4E: Listen from CORE callback`, { port: server.address().port }); |
f2c18879a
|
36 |
}).on('error', (e) => { |
56ec0ab1f
|
37 |
logger.error(`${MODULE_NAME} A90E42D5: Can not listen CORE callback on port ${port}. ${e.toString()}`); |
f2c18879a
|
38 39 |
process.exit(1); }); |