Comparing version 1.1.0 to 1.1.1
@@ -22,2 +22,4 @@ var Communication = require('./Communication'); | ||
function isLast(array, value){ | ||
if( array.length === 0 ) return false; | ||
var element = array.pop(); | ||
@@ -66,3 +68,3 @@ var found = Array.isArray(value) ? value.indexOf(element)>-1 : element===value; | ||
var found = isLast( params, ['callback','cb'] ) || isLast( params, 'ignite' ) || isLast( params, 'terms' ); | ||
var found = isLast( params, ['callback','cb'] ) && isLast( params, 'ignite' ) && isLast( params, 'terms' ); | ||
@@ -164,4 +166,8 @@ return params; | ||
var serviceFn = this.getServiceFn( comm ); | ||
var callbackFn = function(err, res){ callback( err, comm.twist(self.name, err, res) ); }; | ||
if( this.parametersOf( serviceFn ).length !== comm.params.length ) | ||
return callbackFn( new Error('Mind the parameter list!') ); | ||
var igniteFn = function( ){ self.burst( comm, arguments ); }; | ||
var callbackFn = function(err, res){ callback( err, comm.twist(self.name, err, res) ); }; | ||
var params = [].concat( comm.params ).concat( serviceFn.length > comm.params.length+2 ? comm.terms : [] ).concat( serviceFn.length > comm.params.length+1 ? igniteFn : [] ).concat( callbackFn ); | ||
@@ -168,0 +174,0 @@ |
@@ -22,5 +22,6 @@ var Firestarter = require('./Firestarter'); | ||
*/ | ||
function Firestormstarter( barrel, object, logger ){ | ||
function Firestormstarter( config, barrel, object, logger ){ | ||
var self = this; | ||
this.config = config || {}; | ||
this.division = object.division || ''; | ||
@@ -27,0 +28,0 @@ this.auditor = object.auditor; |
@@ -21,3 +21,3 @@ var Communication = require('./Communication'); | ||
*/ | ||
function Flamestarter( barrel, division, name, eventName, fn, logger ){ | ||
function Flamestarter( config, barrel, division, name, eventName, fn, logger ){ | ||
this.isRegex = isRegExp( eventName ); | ||
@@ -28,2 +28,3 @@ this.isString = isString( eventName ); | ||
this.config = config || {}; | ||
this.path = this.isString ? eventName.split( '.' ) : []; | ||
@@ -30,0 +31,0 @@ this.pathLength = this.path.length; |
@@ -8,3 +8,3 @@ var Communication = require('../lib/Communication'); | ||
var VERSION = exports.VERSION = '1.1.0'; | ||
var VERSION = exports.VERSION = '1.1.1'; | ||
@@ -175,3 +175,3 @@ var _ = require('lodash'); | ||
object.inflicterContext = this.inflicterContext; | ||
var fss = new Firestormstarter( this.barrel, object, this.logger ); | ||
var fss = new Firestormstarter( this.options, this.barrel, object, this.logger ); | ||
fss.sliceArguments = this.sliceArguments; | ||
@@ -204,3 +204,3 @@ | ||
inflicter.addict = function( division, name, eventName, fn ){ | ||
var flamestarter = new Flamestarter( this.barrel, division, name, eventName, fn, this.logger ); | ||
var flamestarter = new Flamestarter( this.options, this.barrel, division, name, eventName, fn, this.logger ); | ||
flamestarter.sliceArguments = this.sliceArguments; | ||
@@ -207,0 +207,0 @@ |
{ | ||
"name": "harcon", | ||
"version": "1.1.0", | ||
"version": "1.1.1", | ||
"description": "Messaging/Service Bus for the harmonic convergence of node-based enterprise entities.", | ||
@@ -49,3 +49,3 @@ "keywords": [ | ||
}, | ||
"_id": "harcon@1.1.0" | ||
"_id": "harcon@1.1.1" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
972852
16794