feat(core): custom keywords for stream and error

packages/core/src/plugins/tools/schema.coffee

@@ -4,12 +4,18 @@ schema. Thus, it mst be defined after every module which modify the config
 object.
 ###
 
+stream = require 'stream'
 {merge} = require 'mixme'
 Ajv = require('ajv').default
 ajv_keywords = require 'ajv-keywords'
 ajv_formats = require "ajv-formats"
 utils = require '../../utils'
 
+instanceofDef = require 'ajv-keywords/dist/definitions/instanceof'
+instanceofDef.CONSTRUCTORS['Error'] = Error
+instanceofDef.CONSTRUCTORS['stream.Writable'] = stream.Writable
+instanceofDef.CONSTRUCTORS['stream.Readable'] = stream.Readable
+
 parse = (uri) ->
  matches = /^(\w+:)\/\/(.*)/.exec uri
  throw utils.error 'NIKITA_SCHEMA_MALFORMED_URI', [

packages/core/test/plugins/tools/schema.coffee

@@ -1,6 +1,7 @@
 
 {tags} = require '../../test'
 nikita = require '../../../src'
+stream = require 'stream'
 
 describe 'plugins.tools.schema', ->
  return unless tags.api
@@ -63,6 +64,84 @@ describe 'plugins.tools.schema', ->
  error = await action.tools.schema.validate action
  error.code.should.eql 'NIKITA_SCHEMA_VALIDATION_CONFIG'
 
+ describe 'keywords', ->
+
+ it 'Error with valid property', ->
+ nikita ({registry}) ->
+ await registry.register ['test'],
+ metadata:
+ schema:
+ config:
+ type: 'object'
+ properties:
+ err:
+ instanceof: 'Error'
+ handler: ({config})-> config.err.message
+ @test err: new Error 'catchme'
+ .should.be.fulfilledWith 'catchme'
+
+ it 'Error with invalid property', ->
+ nikita ({registry}) ->
+ await registry.register ['test'],
+ metadata:
+ schema:
+ config:
+ type: 'object'
+ properties:
+ err:
+ instanceof: 'Error'
+ handler: ({config})-> config.err.message
+ @test err: 'catchme'
+ .should.be.rejectedWith
+ message: [
+ 'NIKITA_SCHEMA_VALIDATION_CONFIG:'
+ 'one error was found in the configuration of action `test`: #/definitions/config/properties/err/instanceof'
+ 'config/err should pass "instanceof" keyword validation.'
+ ].join ' '
+
+ it 'stream with valid property', ->
+ nikita ({registry}) ->
+ await registry.register ['test'],
+ metadata:
+ schema:
+ config:
+ type: 'object'
+ properties:
+ writable:
+ instanceof: 'stream.Writable'
+ readable:
+ instanceof: 'stream.Readable'
+ handler: ({config})-> 'ok'
+ @test
+ writable: new stream.Writable()
+ readable: new stream.Readable()
+ .should.be.fulfilledWith 'ok'
+
+ it 'stream with invalid property', ->
+ nikita ({registry}) ->
+ await registry.register ['test'],
+ metadata:
+ schema:
+ config:
+ type: 'object'
+ properties:
+ writable:
+ instanceof: 'stream.Writable'
+ readable:
+ instanceof: 'stream.Readable'
+ handler: ({config})-> config.err.message
+ @test
+ writable: 'invalid'
+ readable: 'invalid'
+ .should.be.rejectedWith
+ message: [
+ 'NIKITA_SCHEMA_VALIDATION_CONFIG:'
+ 'multiple errors where found in the configuration of action `test`:'
+ '#/definitions/config/properties/readable/instanceof config/readable should pass "instanceof" keyword validation;'
+ '#/definitions/config/properties/writable/instanceof'
+ 'config/writable should pass "instanceof" keyword validation.'
+ ].join ' '
+
  describe '$ref', ->
 
  it 'invalid ref definition', ->