floca-amqp-client
Advanced tools
Comparing version 0.9.5 to 0.10.1
@@ -6,16 +6,16 @@ 'use strict' | ||
var Fire = require('./Fire') | ||
let Fire = require('./Fire') | ||
var Cerobee = require('clerobee') | ||
var clerobee = new Cerobee( 16 ) | ||
let Cerobee = require('clerobee') | ||
let clerobee = new Cerobee( 16 ) | ||
var Communication = require( 'harcon' ).Communication | ||
let Communication = require( 'harcon' ).Communication | ||
Communication.setupSecurity( 16 ) | ||
function responseAsArray ( responseComms, attribute ) { | ||
var res = responseComms.map( function (responseComm) { return responseComm[attribute || 'response'] } ).filter( function (resp) { return resp }) | ||
let res = responseComms.map( function (responseComm) { return responseComm[attribute || 'response'] } ).filter( function (resp) { return resp }) | ||
return res.length === 0 ? null : res | ||
} | ||
function indexBy ( array, attributeName ) { | ||
var result = {} | ||
let result = {} | ||
@@ -30,3 +30,3 @@ array.forEach( function (object) { | ||
function mapValues ( object, converter ) { | ||
var result = {} | ||
let result = {} | ||
@@ -46,3 +46,3 @@ for ( let key of Object.keys( object ) ) | ||
var connector = Connector.prototype | ||
let connector = Connector.prototype | ||
@@ -52,3 +52,3 @@ connector.conformResponse = function ( error, responseComms ) { | ||
var err, res | ||
let err, res | ||
@@ -58,3 +58,3 @@ if ( Array.isArray(responseComms) ) { | ||
if ( this.namedResponses ) { | ||
var indexed = indexBy(responseComms, 'responder') | ||
let indexed = indexBy(responseComms, 'responder') | ||
if ( err ) { | ||
@@ -94,5 +94,5 @@ err = new Fire( mapValues( indexed, function ( response ) { | ||
var responses = comm.responseComms.map(function (c) { return Communication.importCommunication( c ) }) | ||
let responses = comm.responseComms.map(function (c) { return Communication.importCommunication( c ) }) | ||
var response = self.conformResponse( comm.err ? new Error(comm.err) : null, responses ) | ||
let response = self.conformResponse( comm.err ? new Error(comm.err) : null, responses ) | ||
self.messages[ reComm.originalId ]( response.err, response.res ) | ||
@@ -133,3 +133,3 @@ delete self.messages[ reComm.originalId ] | ||
var fns = [] | ||
let fns = [] | ||
res[ 0 ].forEach( function (division) { | ||
@@ -210,3 +210,3 @@ fns.push( function (cb) { self.createOut( division, cb ) } ) | ||
var comm = Communication.newCommunication( null, null, clerobee.generate(), self.harconName, self.name, division, event, params, callback ) | ||
let comm = Communication.newCommunication( null, null, clerobee.generate(), self.harconName, self.name, division, event, params, callback ) | ||
comm.expose = true | ||
@@ -213,0 +213,0 @@ if ( options && options.terms ) |
{ | ||
"name": "floca-amqp-client", | ||
"version": "0.9.5", | ||
"version": "0.10.1", | ||
"description": "AMQP client for floca-based projects", | ||
@@ -28,3 +28,3 @@ "keywords": [ | ||
"clerobee": "^0.5.1", | ||
"harcon": "^3.8.1", | ||
"harcon": "^3.9.1", | ||
"isa.js": "^1.6.1", | ||
@@ -36,4 +36,4 @@ "proback.js": "^1.1.2", | ||
"chai": "^3.5.0", | ||
"floca": "^0.30.0", | ||
"floca-amqp": "^0.10.1", | ||
"floca": "^0.31.0", | ||
"floca-amqp": "^0.11.0", | ||
"gulp": "^3.9.1", | ||
@@ -40,0 +40,0 @@ "gulp-eslint": "^2.0.0", |
15311
Updatedharcon@^3.9.1