hastic-server/server/src/index.ts

import { router as analyticUnitsRouter } from './routes/analytic_units_router';
import { router as segmentsRouter } from './routes/segments_router';
import { router as panelRouter } from './routes/panel_router';
import { router as thresholdRouter } from './routes/threshold_router';

import * as AnalyticsController from './controllers/analytics_controller';

import * as ProcessService from './services/process_service';

import { HASTIC_PORT, PACKAGE_VERSION, GIT_INFO, ZMQ_CONNECTION_STRING } from './config';

import * as Koa from 'koa';
import * as Router from 'koa-router';
import * as bodyParser from 'koa-bodyparser';


AnalyticsController.init();
ProcessService.registerExitHandler(AnalyticsController.terminate);

var app = new Koa();

app.on('error', (err, ctx) => {
  console.log('got server error:');
  console.log(err);
});


app.use(bodyParser())

app.use(async function(ctx, next) {
  ctx.set('Access-Control-Allow-Origin', '*');
  ctx.set('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE, PATCH, OPTIONS');
  ctx.set('Access-Control-Allow-Headers', 'Origin, X-Requested-With, Content-Type, Accept');
  await next();
});


var rootRouter = new Router();
rootRouter.use('/analyticUnits', analyticUnitsRouter.routes(), analyticUnitsRouter.allowedMethods());
rootRouter.use('/segments', segmentsRouter.routes(), segmentsRouter.allowedMethods());
rootRouter.use('/panel', panelRouter.routes(), panelRouter.allowedMethods());
rootRouter.use('/threshold', thresholdRouter.routes(), thresholdRouter.allowedMethods());

rootRouter.get('/', async (ctx) => {
  ctx.response.body = {
    server: 'OK',
    analyticsReady: AnalyticsController.isAnalyticReady(),
    nodeVersion: process.version,
    packageVersion: PACKAGE_VERSION,
    npmUserAgent: process.env.npm_config_user_agent,
    docker: process.env.INSIDE_DOCKER !== undefined,
    zmqConectionString: ZMQ_CONNECTION_STRING,
    serverPort: HASTIC_PORT,
    git: GIT_INFO
  };
});

app
  .use(rootRouter.routes())
  .use(rootRouter.allowedMethods());

app.listen(HASTIC_PORT, () => {
  console.log(`Server is running on :${HASTIC_PORT}`);
});