Comparing version 0.9.11 to 0.9.12
@@ -44,3 +44,3 @@ var async = require('async'); | ||
if(this.systemFirestarter){ | ||
var args = [ this.systemFirestarter.division, this.systemFirestarter.name + '.' + arguments[0] ]; | ||
var args = [ null, this.systemFirestarter.division, this.systemFirestarter.name + '.' + arguments[0] ]; | ||
for(var i=1; i<arguments.length; i+=1) | ||
@@ -47,0 +47,0 @@ args.push( arguments[i] ); |
@@ -0,1 +1,8 @@ | ||
if( !Array.prototype.remove ) | ||
Array.prototype.remove = function( obj ){ | ||
var idx = this.findIndex( obj ); | ||
if( idx > -1 ) | ||
this.splice( idx, 1 ); | ||
return this; | ||
}; | ||
if (!Array.prototype.contains) | ||
@@ -2,0 +9,0 @@ Array.prototype.contains = function (object) { |
@@ -151,9 +151,10 @@ var Communication = require('./Communication'); | ||
var self = this; | ||
var division = arguments[ 0 ]; | ||
var event = arguments[ 1 ]; | ||
var externalId = arguments[ 0 ]; | ||
var division = arguments[ 1 ]; | ||
var event = arguments[ 2 ]; | ||
var hasCallback = isFunction( arguments[ arguments.length-1 ] ); | ||
var params = self.sliceArguments.apply( self, arguments ).slice( 2, hasCallback ? arguments.length-1 : arguments.length ); | ||
var params = self.sliceArguments.apply( self, arguments ).slice( 3, hasCallback ? arguments.length-1 : arguments.length ); | ||
var callback = hasCallback ? arguments[ arguments.length-1 ] : null; | ||
var comm = Communication.newCommunication( null, null, null, division, this.name, event, params, callback ); | ||
var comm = Communication.newCommunication( null, null, externalId, division, this.name, event, params, callback ); | ||
@@ -177,4 +178,5 @@ this.logger.harconlog(null, 'Initiate ignition', {comm: comm} ); | ||
var self = this; | ||
var division = arguments[ 0 ]; | ||
var event = arguments[ 1 ]; | ||
var externalId = arguments[ 0 ]; | ||
var division = arguments[ 1 ]; | ||
var event = arguments[ 2 ]; | ||
if( isString(event) ) | ||
@@ -186,4 +188,5 @@ return this.simpleIgnite.apply( this, arguments ); | ||
var ids = []; | ||
var _arguments = self.sliceArguments.apply( self, arguments ).slice( 3 ); | ||
event.forEach( function(ev){ | ||
var args = [division, ev].concat( self.sliceArguments.apply( self, arguments ).slice( 2 ) ); | ||
var args = [externalId, division, ev].concat( _arguments ); | ||
ids.push( this.simpleIgnite.apply( this, args ) ); | ||
@@ -190,0 +193,0 @@ } ); |
@@ -38,3 +38,3 @@ var Firestarter = require('./Firestarter'); | ||
} : function(){ | ||
var args = [ self.division ].concat( self.sliceArguments.apply( self, arguments ) ); | ||
var args = [ null, self.division ].concat( self.sliceArguments.apply( self, arguments ) ); | ||
self.ignite.apply( self, args ); | ||
@@ -41,0 +41,0 @@ }; |
{ | ||
"name": "harcon", | ||
"version": "0.9.11", | ||
"version": "0.9.12", | ||
"description": "Messaging/Service Bus for the harmonic convergence of node-based enterprise entities.", | ||
@@ -48,3 +48,3 @@ "keywords": [ | ||
}, | ||
"_id": "harcon@0.9.11" | ||
"_id": "harcon@0.9.12" | ||
} |
@@ -16,3 +16,3 @@ var chai = require("chai"); | ||
before(function(done){ | ||
var logger = Logger.createWinstonLogger( { file: 'test.log', level: 'info' } ); | ||
var logger = Logger.createWinstonLogger( { file: 'mochatest.log', level: 'debug' } ); | ||
@@ -46,3 +46,3 @@ // Initializes the Harcon system | ||
// Sending a greetings message with 2 parameters and waiting for the proper answer | ||
inflicter.ignite( '', 'greet.simple', 'whatsup?', 'how do you do?', function(err, res){ | ||
inflicter.ignite( '0', '', 'greet.simple', 'whatsup?', 'how do you do?', function(err, res){ | ||
console.log( err, res ); | ||
@@ -61,3 +61,3 @@ should.not.exist(err); should.exist(res); | ||
// Sending a morning message and waiting for the proper answer | ||
inflicter.ignite( '', 'morning.wakeup', function(err, res){ | ||
inflicter.ignite( '0', '', 'morning.wakeup', function(err, res){ | ||
console.log( err, res ); | ||
@@ -73,3 +73,3 @@ | ||
// Sending a morning message and waiting for the proper answer | ||
inflicter.ignite( '', 'cave.echo', function(err, res){ | ||
inflicter.ignite( '0', '', 'cave.echo', function(err, res){ | ||
console.log( err, res ); | ||
@@ -86,3 +86,3 @@ | ||
// Sending a morning message and waiting for the proper answer | ||
inflicter.ignite( 'click', 'greet.simple', 'Hi', 'Ca vas?', function(err, res){ | ||
inflicter.ignite( '0', 'click', 'greet.simple', 'Hi', 'Ca vas?', function(err, res){ | ||
console.log( err, res ); | ||
@@ -89,0 +89,0 @@ |
Sorry, the diff of this file is not supported yet
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
695679
9510