noflo - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

bin/noflo.js

 // Generated by CoffeeScript 1.3.1
 (function() {
-  var cli, noflo, nofloRoot;
+  var cli, noflo, nofloRoot, path;
 
@@ -11,2 +11,4 @@ nofloRoot = "" + __dirname + "/..";
 
+  path = require("path");
+
   cli.enable("help");
@@ -45,5 +47,3 @@
       }
-      if (arg.substr(0, 1) !== "/") {
-        arg = "" + (process.cwd()) + "/" + arg;
-      }
+      arg = path.resolve(process.cwd(), arg);
       _results.push(noflo.loadFile(arg, function(network) {
@@ -50,0 +50,0 @@ if (!options.interactive) {

components/MQ/SendMessage.js

@@ -34,3 +34,8 @@ // Generated by CoffeeScript 1.3.1
         }
-        return mq.publish(groups.join(':'), data);
+        if (mq.pub.connected) {
+          return mq.publish(groups.join(':'), data);
+        }
+        return mq.pub.once('connect', function() {
+          return mq.publish(groups.join(':'), data);
+        });
       });
@@ -37,0 +42,0 @@ this.inPorts["in"].on('endgroup', function() {

package.json

@@ -10,3 +10,3 @@ {
     ],
-    "version":      "0.0.4",
+    "version":      "0.0.5",
     "licenses":     [{
@@ -13,0 +13,0 @@ "type":         "MIT",

server/static/js/network.js

@@ -16,6 +16,10 @@ (function() {
     initialize: function(attributes) {
-      var _ref, _ref2;
-      if (attributes == null) attributes = {};
-      if ((_ref = attributes.nodes) == null) attributes.nodes = [];
-      return (_ref2 = attributes.edges) != null ? _ref2 : attributes.edges = [];
+      var _ref;
+      if (attributes == null) {
+        attributes = {};
+      }
+      if (attributes.nodes == null) {
+        attributes.nodes = [];
+      }
+      return (_ref = attributes.edges) != null ? _ref : attributes.edges = [];
     },
@@ -53,6 +57,10 @@ set: function(attributes) {
     initialize: function(attributes) {
-      var _ref, _ref2;
-      if (attributes == null) attributes = {};
-      if ((_ref = attributes.inPorts) == null) attributes.inPorts = [];
-      return (_ref2 = attributes.outPorts) != null ? _ref2 : attributes.outPorts = [];
+      var _ref;
+      if (attributes == null) {
+        attributes = {};
+      }
+      if (attributes.inPorts == null) {
+        attributes.inPorts = [];
+      }
+      return (_ref = attributes.outPorts) != null ? _ref : attributes.outPorts = [];
     },
@@ -171,4 +179,4 @@ set: function(attributes) {
     render: function() {
-      var element;
-      var _this = this;
+      var element,
+        _this = this;
       document.onselectstart = function() {
@@ -211,3 +219,5 @@ return false;
           edgeView = _ref[_i];
-          if (edgeView.connection !== info.connection) continue;
+          if (edgeView.connection !== info.connection) {
+            continue;
+          }
           console.log("DETACH", edgeView.model);
@@ -239,4 +249,4 @@ _results.push(edgeView.model.destroy({
     render: function() {
-      var element;
-      var _this = this;
+      var element,
+        _this = this;
       element = jQuery(this.el);
@@ -319,3 +329,5 @@ element.empty();
       var portOptions;
-      if (this.endPoint) return this;
+      if (this.endPoint) {
+        return this;
+      }
       portOptions = {
@@ -340,3 +352,5 @@ isSource: true,
       }
-      if (this.model.get('type') === 'array') portOptions.maxConnections = -1;
+      if (this.model.get('type') === 'array') {
+        portOptions.maxConnections = -1;
+      }
       this.endPoint = jsPlumb.addEndpoint(this.nodeView.el, portOptions, this.portDefaults);
@@ -358,3 +372,5 @@ return this;
       var source, target;
-      if (!this.model.get('from').node) return;
+      if (!this.model.get('from').node) {
+        return;
+      }
       source = this.model.get('from');
@@ -361,0 +377,0 @@ target = this.model.get('to');

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

2302884

increased by0.1%

Number of package files

268

increased by0.75%

Lines of code

8143

increased by0.79%

No dependency changes