Blame view

lib/core-callback/index.js 1.21 KB
56ec0ab1f   Adhidarma Hadiwinoto   Tune on callback-...
1
  const MODULE_NAME = 'CORE-CALLBACK';
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
2
3
4
5
  const DEFAULT_LISTENER_FROM_CORE = 25613;
  
  const express = require('express');
  const config = require('komodo-sdk/config');
810fa18da   Adhidarma Hadiwinoto   Migrate to tektra...
6
  const logger = require('tektrans-logger');
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
7
8
  const middlewareCommon = require('../middlewares/common');
  const sender = require('./sender');
d05e75946   Adhidarma Hadiwinoto   CORE-CALLBACK dumper
9
  const dumperReq = require('./dumper/req');
cd4feda87   Adhidarma Hadiwinoto   APISERVER and MATRIX
10
  const matrix = require('../matrix');
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
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   Adhidarma Hadiwinoto   Tune on callback-...
17
      res.locals.httpgetx_subsystem = MODULE_NAME;
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
18
19
20
21
      next();
  });
  
  app.use(middlewareCommon);
d05e75946   Adhidarma Hadiwinoto   CORE-CALLBACK dumper
22
  app.use(dumperReq);
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
23
24
  
  app.use((req, res) => {
b403448ad   Adhidarma Hadiwinoto   Refactor some matrix
25
      matrix.core.received += 1;
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
26
      res.end('OK');
f03c75812   Adhidarma Hadiwinoto   Fix core-callback...
27
28
29
  
      const data = req.method === 'GET' ? req.query : req.body;
      sender(data, res.locals.xid);
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
30
31
32
33
  });
  
  const port = (config.listener && config.listener.core && config.listener.core.port)
      || DEFAULT_LISTENER_FROM_CORE;
ef88c7300   Adhidarma Hadiwinoto   Use server.addres...
34
35
  const server = app.listen(port, () => {
      logger.info(`${MODULE_NAME} 0375DC4E: Listen from CORE callback`, { port: server.address().port });
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
36
  }).on('error', (e) => {
56ec0ab1f   Adhidarma Hadiwinoto   Tune on callback-...
37
      logger.error(`${MODULE_NAME} A90E42D5: Can not listen CORE callback on port ${port}. ${e.toString()}`);
f2c18879a   Adhidarma Hadiwinoto   INQUIRY finished
38
39
      process.exit(1);
  });