noflo - npm Package Compare versions

Comparing version 0.3.3 to 0.3.4

bin/noflo.js

@@ -53,6 +53,4 @@ (function() {
     var identifier;
-
     identifier = function(data) {
       var result;
-
       result = '';
@@ -103,3 +101,2 @@ if (data.subgraph) {
     var arg, baseDir, loader, shell, _i, _len, _ref, _results;
-
     if (options.interactive) {
@@ -117,7 +114,5 @@ process.argv = [process.argv[0], process.argv[1]];
         var todo;
-
         todo = components.length;
         return _.each(components, function(path, component) {
           var instance;
-
           return instance = loader.load(component, function(instance) {
@@ -124,0 +119,0 @@ return showComponent(component, path, instance, function() {

lib/ArrayPort.js

@@ -42,3 +42,2 @@ (function() {
       var _this = this;
-
       if (socketId == null) {
@@ -67,3 +66,2 @@ socketId = null;
       var _this = this;
-
       if (socketId == null) {
@@ -92,3 +90,2 @@ socketId = null;
       var _this = this;
-
       if (socketId == null) {
@@ -111,3 +108,2 @@ socketId = null;
       var socket, _i, _len, _ref;
-
       if (socketId == null) {
@@ -141,3 +137,2 @@ socketId = null;
         _this = this;
-
       if (socketId == null) {
@@ -144,0 +139,0 @@ socketId = null;

lib/AsyncComponent.js

@@ -15,3 +15,2 @@ (function() {
       var _this = this;
-
       this.inPortName = inPortName != null ? inPortName : "in";
@@ -70,3 +69,2 @@ this.outPortName = outPortName != null ? outPortName : "out";
       var _this = this;
-
       this.incrementLoad();
@@ -102,3 +100,2 @@ return this.doAsync(data, function(err) {
       var _this = this;
-
       if (this.load === 0) {
@@ -121,3 +118,2 @@ throw new Error("load cannot be negative");
       var event, processedData;
-
       if (this.load > 0) {
@@ -124,0 +120,0 @@ return;

lib/ComponentLoader.js

@@ -38,3 +38,2 @@ (function() {
         _this = this;
-
       components = {};
@@ -52,3 +51,2 @@ this.checked.push(moduleDef.name);
           var cPath, name;
-
           if (_.isEmpty(depComponents)) {
@@ -69,3 +67,2 @@ return done();
         var cPath, gPath, name, prefix, _ref, _ref1;
-
         prefix = _this.getModulePrefix(def.name);
@@ -102,3 +99,2 @@ if (def.noflo.components) {
         _this = this;
-
       corePath = path.resolve(__dirname, '../src/components');
@@ -110,3 +106,2 @@ if (path.extname(__filename) === '.coffee') {
         var component, componentExtension, componentName, coreComponents, _i, _len, _ref;
-
         coreComponents = {};
@@ -134,3 +129,2 @@ if (err) {
         _this = this;
-
       if (this.components !== null) {
@@ -145,3 +139,2 @@ return callback(this.components);
         var cPath, name;
-
         for (name in coreComponents) {
@@ -159,3 +152,2 @@ cPath = coreComponents[name];
           var cPath, name;
-
           for (name in components) {
@@ -177,3 +169,2 @@ cPath = components[name];
         _this = this;
-
       if (!this.components) {
@@ -201,3 +192,2 @@ this.listComponents(function(components) {
       var graph, graphImplementation, graphSocket;
-
       graphImplementation = require(this.components['Graph']);
@@ -216,3 +206,2 @@ graphSocket = internalSocket.createSocket();
       var find, found;
-
       found = null;
@@ -237,3 +226,2 @@ find = function(packageData) {
       var _this = this;
-
       return this.getPackagePath(packageId, function(err, packageFile) {
@@ -253,3 +241,2 @@ if (err) {
         var data;
-
         if (err) {
@@ -267,3 +254,2 @@ return callback(err);
         var packageData;
-
         if (err) {
@@ -285,3 +271,2 @@ return callback(err);
       var _this = this;
-
       return this.readPackage(packageId, function(err, packageData) {
@@ -305,3 +290,2 @@ if (err) {
       var _this = this;
-
       return this.readPackage(packageId, function(err, packageData) {
@@ -308,0 +292,0 @@ if (err) {

lib/Fbp.js

@@ -44,3 +44,2 @@ (function() {
       var fbp, file, index, match, name, original, _ref;
-
       while (true) {
@@ -64,3 +63,2 @@ match = string.match(this.matchSubgraph);
       var char, checkTerminator, component, connection, currentString, exported, index, initial, json, port, _i, _len;
-
       currentString = "";
@@ -160,3 +158,2 @@ string = this.compileSubgraphs("\n" + string);
       var exportedPort;
-
       exportedPort = {};
@@ -163,0 +160,0 @@ exportedPort["private"] = exported[1].toLowerCase();

lib/Graph.js

@@ -42,3 +42,2 @@ (function() {
       var node;
-
       if (!metadata) {
@@ -62,3 +61,2 @@ metadata = {};
       var edge, initializer, node, _i, _j, _len, _len1, _ref, _ref1;
-
       node = this.getNode(id);
@@ -90,3 +88,2 @@ _ref = this.edges;
       var node, _i, _len, _ref;
-
       _ref = this.nodes;
@@ -103,3 +100,2 @@ for (_i = 0, _len = _ref.length; _i < _len; _i++) {
       var edge;
-
       edge = {
@@ -122,3 +118,2 @@ from: {
       var edge, index, _i, _j, _len, _len1, _ref, _ref1, _results;
-
       _ref = this.edges;
@@ -158,3 +153,2 @@ for (index = _i = 0, _len = _ref.length; _i < _len; index = ++_i) {
       var initializer;
-
       initializer = {
@@ -177,3 +171,2 @@ from: {
       var cleanID, cleanPort, dot, edge, id, initializer, node, _i, _j, _k, _len, _len1, _len2, _ref, _ref1, _ref2;
-
       cleanID = function(id) {
@@ -208,3 +201,2 @@ return id.replace(/\s*/g, "");
       var edge, initializer, yuml, _i, _j, _len, _len1, _ref, _ref1;
-
       yuml = [];
@@ -226,3 +218,2 @@ _ref = this.initializers;
       var edge, exported, initializer, json, node, _i, _j, _k, _l, _len, _len1, _len2, _len3, _ref, _ref1, _ref2, _ref3;
-
       json = {
@@ -284,3 +275,2 @@ properties: {
       var json;
-
       json = JSON.stringify(this.toJSON(), null, 4);
@@ -307,3 +297,2 @@ return fs.writeFile("" + file + ".json", json, "utf-8", function(err, data) {
     var conn, def, exported, graph, id, _i, _j, _len, _len1, _ref, _ref1, _ref2;
-
     graph = new Graph(definition.properties.name);
@@ -343,3 +332,2 @@ _ref = definition.processes;
       var definition;
-
       if (err) {
@@ -358,3 +346,2 @@ throw err;
     var definition, parser;
-
     parser = new fbp.Fbp;
@@ -361,0 +348,0 @@ definition = parser.parse(fbpData);

lib/InternalSocket.js

@@ -54,3 +54,2 @@ (function() {
       var fromStr, toStr;
-
       fromStr = function(from) {
@@ -57,0 +56,0 @@ return "" + from.process.id + "() " + (from.port.toUpperCase());

lib/Network.js

@@ -31,3 +31,2 @@ (function() {
       var _this = this;
-
       this.processes = {};
@@ -62,3 +61,2 @@ this.connections = [];
         _this = this;
-
       connections = 0;
@@ -116,3 +114,2 @@ started = false;
         _this = this;
-
       if (this.processes[node.id]) {
@@ -181,3 +178,2 @@ return;
         _this = this;
-
       if (!process.isReady()) {
@@ -221,3 +217,2 @@ process.once('ready', function() {
       var _this = this;
-
       socket.on('connect', function() {
@@ -260,3 +255,2 @@ return _this.emit('connect', {
       var buffer, inports, outports, port, _i, _j, _len, _len1;
-
       buffer = this.portBuffer[id];
@@ -292,3 +286,2 @@ inports = buffer.ins;
         _this = this;
-
       if (!edge.from.node) {
@@ -309,3 +302,2 @@ return this.addInitial(edge);
           var fromPort, next;
-
           _this.addEdge(edge, callback);
@@ -337,3 +329,2 @@ fromPort = from.component.outPorts[edge.from.port];
           var next;
-
           _this.addEdge(edge, callback);
@@ -363,3 +354,2 @@ fromPort = from.component.outPorts[edge.from.port];
       var connection, _i, _len, _ref, _results;
-
       _ref = this.connections;
@@ -389,3 +379,2 @@ _results = [];
         _this = this;
-
       socket = internalSocket.createSocket();
@@ -425,3 +414,2 @@ this.subscribeSocket(socket);
       var initial, _i, _len, _ref;
-
       _ref = this.initials;
@@ -428,0 +416,0 @@ for (_i = 0, _len = _ref.length; _i < _len; _i++) {

lib/NoFlo.js

 (function() {
-  var Network, arrayport, asynccomponent, component, componentLoader, graph, internalSocket, port;
+  var LoggingComponent, Network, arrayport, asynccomponent, component, componentLoader, graph, internalSocket, port;
 
@@ -20,5 +20,6 @@ internalSocket = require("./InternalSocket");
 
+  LoggingComponent = require("./LoggingComponent").LoggingComponent;
+
   exports.createNetwork = function(graph, callback) {
     var network, networkReady, toAddNodes;
-
     network = new Network(graph);
@@ -38,7 +39,5 @@ networkReady = function(network) {
       var connect, node, toAdd, _i, _len, _ref, _results;
-
       toAdd = graph.edges.length + graph.initializers.length;
       connect = function() {
         var edge, initializer, _i, _j, _len, _len1, _ref, _ref1, _results;
-
         if (toAdd === 0) {
@@ -104,2 +103,4 @@ return networkReady(network);
 
+  exports.LoggingComponent = LoggingComponent;
+
   exports.Port = port.Port;
@@ -106,0 +107,0 @@

lib/Port.js

@@ -13,3 +13,2 @@ (function() {
       var _this = this;
-
       this.type = type;
@@ -27,3 +26,2 @@ if (!this.type) {
         var conn, datum, group, _i, _j, _k, _l, _len, _len1, _len2, _len3, _ref, _ref1, _ref2, _ref3;
-
         if (_this.downstreamIsGettingReady) {
@@ -66,3 +64,2 @@ _this.downstreamIsGettingReady = false;
       var _this = this;
-
       if (localId == null) {
@@ -103,3 +100,2 @@ localId = null;
       var _this = this;
-
       if (this.downstreamIsGettingReady) {
@@ -123,3 +119,2 @@ this.groups.push(group);
       var _this = this;
-
       if (this.downstreamIsGettingReady) {
@@ -153,3 +148,2 @@ this.data.push(data);
       var buffer;
-
       if (this.downstreamIsGettingReady) {
@@ -156,0 +150,0 @@ buffer = {

lib/shell.js

@@ -49,3 +49,2 @@ (function() {
     var graph;
-
     graph = noflo.graph.createGraph(req.params[0]);
@@ -196,3 +195,2 @@ app.setPrompt(req.params[0]);
     var convertUptime, prettyUptime;
-
     if (!app.network) {
@@ -204,3 +202,2 @@ app.styles.red("No graph is loaded");
       var days, hours, minutes, seconds, secs, timedef;
-
       seconds = uptime / 1000;
@@ -220,3 +217,2 @@ days = Math.floor(seconds / 86400);
       var prettyDate, timedef;
-
       timedef = convertUptime(uptime);
@@ -223,0 +219,0 @@ prettyDate = "Graph uptime is";

package.json

@@ -14,3 +14,3 @@ {
   ],
-  "version": "0.3.3",
+  "version": "0.3.4",
   "licenses": [
@@ -60,2 +60,2 @@ {
   }
-}
+}

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

Worsened metrics

Total package byte prevSize

292012

decreased by-84.77%

Number of package files

139

decreased by-35.35%

Lines of code

2414

decreased by-8.97%

No dependency changes