Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

exocom-dev

Package Overview
Dependencies
Maintainers
1
Versions
24
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

exocom-dev - npm Package Compare versions

Comparing version 0.14.0 to 0.14.1

4

dist/cli.js

@@ -26,3 +26,5 @@ // Generated by LiveScript 1.5.0

var x$, exocom;
x$ = exocom = new ExoCom();
x$ = exocom = new ExoCom({
serviceMessages: process.env.SERVICE_MESSAGES
});
x$.on('zmq-bound', onZmqBound);

@@ -29,0 +31,0 @@ x$.on('http-bound', onHttpBound);

// Generated by LiveScript 1.5.0
var removeValue, requireYaml, ClientRegistry;
var jsonic, removeValue, requireYaml, ClientRegistry;
jsonic = require('jsonic');
removeValue = require('remove-value');

@@ -8,3 +9,13 @@ requireYaml = require('require-yaml');

var prototype = ClientRegistry.prototype, constructor = ClientRegistry;
function ClientRegistry(){
function ClientRegistry(arg$){
var ref$, res$, i$, len$, service;
this.serviceMessages = (ref$ = (arg$ != null
? arg$
: {}).serviceMessages) != null ? ref$ : '{}';
res$ = {};
for (i$ = 0, len$ = (ref$ = jsonic(this.serviceMessages)).length; i$ < len$; ++i$) {
service = ref$[i$];
res$[service.name] = service.receives;
}
this.receives = res$;
this.clients = {};

@@ -35,4 +46,3 @@ this.routes = {};

};
service.receives || (service.receives = this._lookUpServiceMessages(service.type));
for (i$ = 0, len$ = (ref$ = service.receives).length; i$ < len$; ++i$) {
for (i$ = 0, len$ = (ref$ = this.receives[service.name] || {}).length; i$ < len$; ++i$) {
message = ref$[i$];

@@ -58,3 +68,3 @@ externalMessage = this.externalMessageName({

serviceName = arg$.serviceName, host = arg$.host;
for (i$ = 0, len$ = (ref$ = this._lookUpServiceMessages(this.clients[serviceName].type)).length; i$ < len$; ++i$) {
for (i$ = 0, len$ = (ref$ = this.receives[serviceName] || {}).length; i$ < len$; ++i$) {
message = ref$[i$];

@@ -70,7 +80,2 @@ externalMessage = this.externalMessageName({

};
ClientRegistry.prototype._lookUpServiceMessages = function(serviceName){
var serviceMessages;
serviceMessages = require('../../service-messages.yml');
return serviceMessages[serviceName].receives;
};
ClientRegistry.prototype.subscribersTo = function(messageName){

@@ -77,0 +82,0 @@ switch (false) {

@@ -14,3 +14,6 @@ // Generated by LiveScript 1.5.0

var prototype = extend$((import$(ExoCom, superclass).displayName = 'ExoCom', ExoCom), superclass).prototype, constructor = ExoCom;
function ExoCom(){
function ExoCom(arg$){
this.serviceMessages = (arg$ != null
? arg$
: {}).serviceMessages;
this.sendMessage = bind$(this, 'sendMessage', prototype);

@@ -21,3 +24,5 @@ this.removeRoutingConfig = bind$(this, 'removeRoutingConfig', prototype);

this.getConfig = bind$(this, 'getConfig', prototype);
this.clientRegistry = new ClientRegistry;
this.clientRegistry = new ClientRegistry({
serviceMessages: this.serviceMessages
});
this.listenerSubsystem = new ListenerSubsystem(this);

@@ -24,0 +29,0 @@ this.messageCache = new MessageCache();

{
"name": "exocom-dev",
"version": "0.14.0",
"version": "0.14.1",
"author": "Kevin Goslar",

@@ -11,2 +11,3 @@ "dependencies": {

"express": "4.14.0",
"jsonic": "0.2.2",
"nanoseconds": "0.1.0",

@@ -39,3 +40,3 @@ "nitroglycerin": "1.1.2",

"record-http": "0.6.1",
"request": "2.75.0"
"request": "2.76.0"
},

@@ -42,0 +43,0 @@ "engines": {

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