support to register a hemera plugin with custom options

Author: StarpTech

lib/index.js

@@ -28,7 +28,13 @@ async function register(server, options) {
   )
 
   if (options.plugins) {
-    options.plugins.forEach(plugin => hemera.use(plugin))
+    options.plugins.forEach(plugin => {
+      if (plugin.options) {
+        hemera.use(plugin.register, plugin.options)
+      } else {
+        hemera.use(plugin)
+      }
+    })
   }
 
   const hemeraInterface = request => {

package.json

@@ -30,6 +30,7 @@
     "eslint": "^4.19.0",
     "eslint-config-hemera": "^0.0.2",
     "hapi": "^17.2.3",
+    "hemera-plugin": "^1.1.1",
     "hemera-testsuite": "^4.0.0",
     "istanbul": "^0.4.5",
     "joi": "^13.1.2",

test/hemera-plugin.js

@@ -4,6 +4,7 @@ const Hapi = require('hapi')
 const HemeraTestsuite = require('hemera-testsuite')
 const hemeraInternalSymbols = require('nats-hemera/lib/symbols')
 const Code = require('code')
+const Hp = require('hemera-plugin')
 const HapiHemera = require('../lib')
 
 const expect = Code.expect
@@ -26,11 +27,10 @@ describe('Hemera plugin registration', function() {
   it('Should be able to register a plugin', async () => {
     const server = new Hapi.Server()
 
-    const myPlugin = async function myPlugin(hemera, options) {}
-
-    myPlugin[Symbol.for('dependencies')] = []
-    myPlugin[Symbol.for('name')] = 'myPlugin'
-    myPlugin[Symbol.for('options')] = { a: 1 }
+    const myPlugin = Hp(async function myPlugin(hemera, options) {}, {
+      name: 'myPlugin',
+      options: { a: 1 }
+    })
 
     await server.register({
       plugin: HapiHemera,
@@ -48,4 +48,35 @@ describe('Hemera plugin registration', function() {
 
     await server.stop()
   })
+
+  it('Should be able to register a plugin with options', async () => {
+    const server = new Hapi.Server()
+
+    const myPlugin = Hp(
+      async function myPlugin(hemera, options) {
+        expect(options).to.be.equals({ a: 1, b: 2 })
+      },
+      {
+        name: 'myPlugin',
+        options: { a: 1 }
+      }
+    )
+
+    await server.register({
+      plugin: HapiHemera,
+      options: {
+        plugins: [{ register: myPlugin, options: { b: 2 } }],
+        nats: {
+          url: noAuthUrl
+        }
+      }
+    })
+
+    expect(server.hemera).to.exist()
+    expect(server.hemera[hemeraInternalSymbols.registeredPlugins]).to.be.equals(
+      ['myPlugin']
+    )
+
+    await server.stop()
+  })
 })