New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

floca-amqp-client

Package Overview
Dependencies
Maintainers
2
Versions
128
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

floca-amqp-client - npm Package Compare versions

Comparing version 0.9.5 to 0.10.1

28

lib/Connector.js

@@ -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",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc