index.js

const HydraIntegrationPlugin = require('hydra-integration').HydraIntegrationPlugin
const HydraHttpPlugin = require('hydra-plugin-http').HydraHttpPlugin
const config = require('config')
const hydra = require('hydra')
const service = require('restana')()
const pipeline = require('./lib/pipeline')

hydra.use(new HydraIntegrationPlugin())
hydra.use(new HydraHttpPlugin())

service.use((req, res, next) => {
  const token = req.headers.authorization || ''
  if (!token.endsWith(config.service.accessToken || '')) {
    res.statusCode = 403
    res.statusMessage = 'Forbidden'
  }

  next()
})

const prefix = config.service.routesPrefix
service.get('/_health', require('./actions/health')(hydra))
service.get(`${prefix}/srvs`, require('./actions/all-srv')(hydra))
service.get(`${prefix}/srvs/:service/routes`, require('./actions/srv-routes')(hydra))
service.get(`${prefix}/srvs/:service/health`, require('./actions/srv-health')(hydra))
service.get(`${prefix}/nodes`, require('./actions/all-node')(hydra))

const proxy = require('./actions/proxy-router')(hydra, config, pipeline)
service.all('/*', proxy);

(async () => {
  await service.start(config.service.hydra.servicePort)
  await hydra.init(config.service)
  await hydra.registerService()
  await hydra.integration.sync(service)
})().catch(console.error)

// supporting tests coverage
if (process.env.NODE_ENV === 'testing') {
  /* global describe it */
  require('./tests')(hydra, describe, it)
}