Hemera with Hapi

hemera-hapi.js

'use strict'

const Hapi = require('hapi')

const server = new Hapi.Server()
server.connection({ port: 80 })

server.register({
  register: require('hapi-hemera'),
  options: {
    hemera: {
      name: 'test',
      load: {
        sampleInterval: 1
      },
      logLevel: 'info'
    },
    nats: 'nats://localhost:4222',
    plugins: [
      require('hemera-joi'),
      require('hemera-stats')
    ]
  }
}).then(() => {
  return server.start()
}).then(() => {
  console.log(`Server running at: ${server.info.uri}`);

  // hemera can be used when the plugin was initialized

  let Joi = server.hemera.exposition['hemera-joi'].joi

  server.hemera.add({
    topic: 'math',
    cmd: 'add',
    a: Joi.number().required(),
    b: Joi.number().required()
  }, function (req, cb) {
    cb(null, parseInt(req.a) + parseInt(req.b))
  })

  server.route({
    method: 'GET',
    path: '/api/add',
    handler: function (request, reply) {

      request.hemera.act({
          topic: 'math',
          cmd: 'add',
          a: request.query.a,
          b: request.query.b,
          refresh: !!request.query.refresh
        }, function (err, result) {

          if (err) {
            return reply(Boom.wrap(err.cause, 400))
          }

          return reply(result)
        })
    }
  })
})
.catch(console.error)