exocom-dev
Advanced tools
Comparing version 0.14.0 to 0.14.1
@@ -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": { |
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
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
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
35669
884
13
3
+ Addedjsonic@0.2.2
+ Addedjsonic@0.2.2(transitive)