@buggyorg/graphtools - npm Package Compare versions

Comparing version 0.2.7 to 0.2.8

lib/backtrack.js

		@@ -1,62 +0,19 @@
		'use strict';

		Object.defineProperty(exports, "__esModule", {
		value: true
		});
		exports.backtrackPortGraph = backtrackPortGraph;
		exports.backtrackNetworkGraph = backtrackNetworkGraph;
		import _ from 'lodash';

		var _lodash = require('lodash');

		var _lodash2 = _interopRequireDefault(_lodash);

		function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

		function backtrackPortGraph(graph, node, fn) {
		var getPredecessors = function getPredecessors() {
		return (0, _lodash2.default)([]).map(function (e) {
		return e.v;
		});
		};
		return backtrack(graph, node, fn, getPredecessors);
		}

		function backtrackNetworkGraph(graph, node, fn) {
		var getPredecessors = function getPredecessors(cur) {
		return (0, _lodash2.default)([]).filter(function (e) {
		return e.v === cur.node + '_PORT_' + cur.port;
		}).map(function (e) {
		return graph.predecessors(e.v);
		}).flatten().map(function (e) {
		return graph.predecessors(e);
		}).flatten();
		};
		return backtrack(graph, node, fn, getPredecessors);
		}

		function backtrack(graph, node, fn, predecessor) {
		export default function backtrack(graph, node, fn) {
		// inPorts [ {port: name, payload: ?}]
		var inPorts = fn(node, graph.node(node), undefined);
		var callStack = _lodash2.default.map(inPorts, function (portData) {
		return { node: node, port: portData.port, payload: portData.payload, path: [node] };
		});
		var endPoints = [];
		var inPorts = fn(graph.node(node), undefined);
		var callStack = _.map(inPorts, portData => ({ node: node, port: portData.port, payload: portData.payload }));
		while (callStack.length !== 0) {
		var cur = callStack.pop();
		console.log(cur);
		var inEdges = graph.inEdges(cur.node);
		var inNodes = predecessor(cur).plant(inEdges).value();
		var newCallStackElements = (0, _lodash2.default)(inNodes).map(function (n) {
		var result = fn(n, graph.node(n), cur.payload);
		console.log(result);
		return _lodash2.default.map(result, function (res) {
		return { node: n, port: res.port, payload: res.payload, path: _lodash2.default.concat(cur.path, n) };
		});
		}).flatten().value();
		if (newCallStackElements.length === 0) {
		endPoints.push(cur);
		}
		callStack = _lodash2.default.concat(callStack, newCallStackElements);
		var portEdges = _.filter(inEdges, e => e.v === cur.node + '_PORT_' + cur.port);
		var inNodes = _(portEdges).map(e => graph.predecessors(e.v)).flatten().map(e => graph.predecessors(e)).flatten().value();
		var newCallStackElements = _.map(inNodes, n => {
		var result = fn(graph.node(n), cur.payload);
		return _.map(result, port => ({ node: n, port: port }));
		});
		callStack = _.concat(callStack, _.flatten(newCallStackElements));
		}
		return endPoints;
		}

lib/walkPort.js

		@@ -67,3 +67,3 @@ 'use strict';
		nodes = nodes.map(function (n) {
		return n.split('_')[3];
		return n.split('_')[n.split('_').length - 1];
		});
		@@ -70,0 +70,0 @@ return nodes;

package.json

		{
		"name": "@buggyorg/graphtools",
		"version": "0.2.7",
		"version": "0.2.8",
		"description": "Tools for processing buggy graphs.",
		@@ -5,0 +5,0 @@ "main": "lib/api.js",

src/walkPort.js

		@@ -39,3 +39,3 @@
		nodes = nodes.map(function (n) {
		return n.split('_')[3]
		return n.split('_')[n.split('_').length - 1]
		})
		@@ -42,0 +42,0 @@ return nodes

@buggyorg/graphtools - npm Package Compare versions

Worsened metrics