function-tree - npm Package Compare versions

Comparing version 3.3.2 to 3.3.3-1742933933075

es/devtools/base.js

@@ -50,3 +50,3 @@ function _typeof(o) { "@babel/helpers - typeof"; return _typeof = "function" == typeof Symbol && "symbol" == typeof Symbol.iterator ? function (o) { return typeof o; } : function (o) { return o && "function" == typeof Symbol && o.constructor === Symbol && o !== Symbol.prototype ? "symbol" : typeof o; }, _typeof(o); }
     key: "onMessage",
-    value: function onMessage(event) {}
+    value: function onMessage(_event) {}
   }, {
@@ -257,2 +257,3 @@ key: "reconnect",
     value: function sendInitial() {}
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
   }, {
@@ -259,0 +260,0 @@ key: "createExecutionMessage",

es/executeTree.js

 import { FunctionTreeExecutionError } from './errors';
 function isPrimitive(primitive, type) {
-  return primitive._functionTreePrimitive && primitive.type === type;
+  return (primitive === null || primitive === void 0 ? void 0 : primitive._functionTreePrimitive) && primitive.type === type;
 }
@@ -23,3 +23,10 @@
               branchStart(funcDetails, result.path, newPayload);
-              runBranch(funcDetails.outputs[result.path].items, 0, newPayload, payload, outputResult);
+              var outputBranch = funcDetails.outputs[result.path];
+
+              // Check if the output branch itself is a parallel primitive
+              if (isPrimitive(outputBranch, 'parallel')) {
+                runBranch([outputBranch], 0, newPayload, payload, outputResult);
+              } else {
+                runBranch(outputBranch.items, 0, newPayload, payload, outputResult);
+              }
             } else {
@@ -45,3 +52,3 @@ throw new FunctionTreeExecutionError(execution, funcDetails, payload, "function ".concat(funcDetails.name, " must use one of its possible outputs: ").concat(outputs.join(', '), "."));
         parallelStart(payload, itemLength);
-        currentItem.items.forEach(function (func, index) {
+        currentItem.items.forEach(function (func) {
           if (func["function"]) {
@@ -48,0 +55,0 @@ execution.runFunction(func, payload, prevPayload, processFunctionOutput(func, function (payload) {

es/fluent/index.js

@@ -31,3 +31,5 @@ var __extends = (this && this.__extends) || (function () {
         actions.forEach(function (element) {
-            typeFirst && Object.defineProperty(element, 'name', { value: action[0] });
+            if (typeFirst) {
+                Object.defineProperty(element, 'name', { value: action[0] });
+            }
         });
@@ -34,0 +36,0 @@ (_a = this.sequenceArray).push.apply(_a, actions);

es/staticTree.js

@@ -34,3 +34,3 @@ function _typeof(o) { "@babel/helpers - typeof"; return _typeof = "function" == typeof Symbol && "symbol" == typeof Symbol.iterator ? function (o) { return typeof o; } : function (o) { return o && "function" == typeof Symbol && o.constructor === Symbol && o !== Symbol.prototype ? "symbol" : typeof o; }, _typeof(o); }
 }
-function analyze(name, functions, item, isParallel) {
+function analyze(name, functions, item, _isParallel) {
   if (item instanceof Primitive) {
@@ -37,0 +37,0 @@ var instance = item.toJSON();

fluent/index.d.ts

@@ -26,24 +26,22 @@ import { Primitive } from '../'
   branch<TPaths, TOutput = {}>(
-    action: ((
+    action: (
       props: TContext & IBranchContext<TPaths, TProps>
-    ) => TOutput | Promise<TOutput>)
+    ) => TOutput | Promise<TOutput>
   ): {
-    paths: (
-      paths: {
-        [key in keyof TPaths]: (
-          props: SequenceBuilder<TContext, TProps & TPaths[key]>
-        ) => SequenceBuilder<TContext, TProps & TPaths[key]>
-      }
-    ) => SequenceBuilder<TContext, TProps & TOutput>
+    paths: (paths: {
+      [key in keyof TPaths]: (
+        props: SequenceBuilder<TContext, TProps & TPaths[key]>
+      ) => SequenceBuilder<TContext, TProps & TPaths[key]>
+    }) => SequenceBuilder<TContext, TProps & TOutput>
   }
   parallel<TOutput>(
     name: string,
-    chain: ((
+    chain: (
       props: SequenceBuilder<TContext, TProps>
-    ) => SequenceBuilder<TContext, TOutput>)
+    ) => SequenceBuilder<TContext, TOutput>
   ): SequenceBuilder<TContext, TProps & TOutput>
   parallel<TOutput>(
-    chain: ((
+    chain: (
       props: SequenceBuilder<TContext, TProps>
-    ) => SequenceBuilder<TContext, TOutput>)
+    ) => SequenceBuilder<TContext, TOutput>
   ): SequenceBuilder<TContext, TProps & TOutput>
@@ -56,9 +54,7 @@ sequence<TOutput = void>(
   ): {
-    paths: (
-      paths: {
-        [key in keyof TPaths]: (
-          input: SequenceBuilder<TContext, TProps & TPaths[key]>
-        ) => SequenceBuilder<TContext, TProps & TPaths[key]>
-      }
-    ) => SequenceBuilder<TContext, TProps>
+    paths: (paths: {
+      [key in keyof TPaths]: (
+        input: SequenceBuilder<TContext, TProps & TPaths[key]>
+      ) => SequenceBuilder<TContext, TProps & TPaths[key]>
+    }) => SequenceBuilder<TContext, TProps>
   }
@@ -68,9 +64,7 @@ debounce<TPaths extends { continue: {}; discard: {} }>(
   ): {
-    paths: (
-      paths: {
-        [key in keyof TPaths]: (
-          input: SequenceBuilder<TContext, TProps & TPaths[key]>
-        ) => SequenceBuilder<TContext, TProps & TPaths[key]>
-      }
-    ) => SequenceBuilder<TContext, TProps>
+    paths: (paths: {
+      [key in keyof TPaths]: (
+        input: SequenceBuilder<TContext, TProps & TPaths[key]>
+      ) => SequenceBuilder<TContext, TProps & TPaths[key]>
+    }) => SequenceBuilder<TContext, TProps>
   }
@@ -80,9 +74,7 @@ equals<TPaths extends { [key: string]: {} }, TValue>(
   ): {
-    paths: (
-      paths: {
-        [key in keyof TPaths]: (
-          input: SequenceBuilder<TContext, TProps & TPaths[key]>
-        ) => SequenceBuilder<TContext, TProps & TPaths[key]>
-      }
-    ) => SequenceBuilder<TContext, TProps>
+    paths: (paths: {
+      [key in keyof TPaths]: (
+        input: SequenceBuilder<TContext, TProps & TPaths[key]>
+      ) => SequenceBuilder<TContext, TProps & TPaths[key]>
+    }) => SequenceBuilder<TContext, TProps>
   }
@@ -94,3 +86,3 @@ wait(ms: number): ContinueSequenceBuilder<TContext, TProps>
   TContext = {},
-  TProps = {}
+  TProps = {},
 > extends SequenceBuilder<TContext, TProps> {
@@ -126,3 +118,3 @@ continue(
   Props,
-  Output = Props
+  Output = Props,
 >(
@@ -129,0 +121,0 @@ arg: (

lib/devtools/base.js

@@ -57,3 +57,3 @@ "use strict";
     key: "onMessage",
-    value: function onMessage(event) {}
+    value: function onMessage(_event) {}
   }, {
@@ -264,2 +264,3 @@ key: "reconnect",
     value: function sendInitial() {}
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
   }, {
@@ -266,0 +267,0 @@ key: "createExecutionMessage",

lib/executeTree.js

@@ -9,3 +9,3 @@ "use strict";
 function isPrimitive(primitive, type) {
-  return primitive._functionTreePrimitive && primitive.type === type;
+  return (primitive === null || primitive === void 0 ? void 0 : primitive._functionTreePrimitive) && primitive.type === type;
 }
@@ -30,3 +30,10 @@
               branchStart(funcDetails, result.path, newPayload);
-              runBranch(funcDetails.outputs[result.path].items, 0, newPayload, payload, outputResult);
+              var outputBranch = funcDetails.outputs[result.path];
+
+              // Check if the output branch itself is a parallel primitive
+              if (isPrimitive(outputBranch, 'parallel')) {
+                runBranch([outputBranch], 0, newPayload, payload, outputResult);
+              } else {
+                runBranch(outputBranch.items, 0, newPayload, payload, outputResult);
+              }
             } else {
@@ -52,3 +59,3 @@ throw new _errors.FunctionTreeExecutionError(execution, funcDetails, payload, "function ".concat(funcDetails.name, " must use one of its possible outputs: ").concat(outputs.join(', '), "."));
         parallelStart(payload, itemLength);
-        currentItem.items.forEach(function (func, index) {
+        currentItem.items.forEach(function (func) {
           if (func["function"]) {
@@ -55,0 +62,0 @@ execution.runFunction(func, payload, prevPayload, processFunctionOutput(func, function (payload) {

lib/fluent/index.js

@@ -18,3 +18,8 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.SequenceWithPropsFactory = exports.SequenceFactory = exports.SequenceWithProps = exports.Sequence = exports.sequenceFactory = exports.ContinueSequenceBuilder = exports.SequenceBuilder = void 0;
+exports.ContinueSequenceBuilder = exports.SequenceBuilder = void 0;
+exports.sequenceFactory = sequenceFactory;
+exports.Sequence = Sequence;
+exports.SequenceWithProps = SequenceWithProps;
+exports.SequenceFactory = SequenceFactory;
+exports.SequenceWithPropsFactory = SequenceWithPropsFactory;
 var __1 = require("../../");
@@ -35,3 +40,5 @@ var factories_1 = require("../../factories/");
         actions.forEach(function (element) {
-            typeFirst && Object.defineProperty(element, 'name', { value: action[0] });
+            if (typeFirst) {
+                Object.defineProperty(element, 'name', { value: action[0] });
+            }
         });
@@ -122,11 +129,8 @@ (_a = this.sequenceArray).push.apply(_a, actions);
 }
-exports.sequenceFactory = sequenceFactory;
 function Sequence(arg) {
     return sequenceFactory(arg);
 }
-exports.Sequence = Sequence;
 function SequenceWithProps(arg) {
     return sequenceFactory(arg);
 }
-exports.SequenceWithProps = SequenceWithProps;
 function SequenceFactory() {
@@ -138,3 +142,2 @@ function returned(arg) {
 }
-exports.SequenceFactory = SequenceFactory;
 function SequenceWithPropsFactory() {
@@ -146,3 +149,2 @@ function returned(arg) {
 }
-exports.SequenceWithPropsFactory = SequenceWithPropsFactory;
 //# sourceMappingURL=index.js.map

lib/staticTree.js

@@ -40,3 +40,3 @@ "use strict";
 }
-function analyze(name, functions, item, isParallel) {
+function analyze(name, functions, item, _isParallel) {
   if (item instanceof _primitives.Primitive) {
@@ -43,0 +43,0 @@ var instance = item.toJSON();

package.json

 {
   "name": "function-tree",
-  "version": "3.3.2",
+  "version": "3.3.3-1742933933075",
   "description": "When a function is not enough",
@@ -16,4 +16,5 @@ "main": "index.js",
     "test": "npm run test:ts && cross-env NODE_ENV=test BABEL_ENV=test mocha --require @babel/register \"src/**/*.test.js\"",
-    "test:ts": "cross-env TS_NODE_IGNORE=false mocha --require ts-node/register \"src/**/*.spec.ts\"",
-    "test:watch": "npm run test -- --watch"
+    "test:ts": "cross-env NODE_OPTIONS=--import=tsx mocha \"src/**/*.spec.ts\"",
+    "test:watch": "npm run test -- --watch",
+    "typecheck": "tsc --noEmit"
   },
@@ -24,6 +25,2 @@ "dependencies": {
   },
-  "devDependencies": {
-    "mock-socket": "^6.0.4",
-    "npm-run-all": "^4.1.5"
-  },
   "directories": {
@@ -30,0 +27,0 @@ "test": "tests"

README.md

@@ -28,21 +28,19 @@ # function-tree
 
-ft
-  .run(
-    [
-      // returns a promise
-      function someFunc(context) {},
-      function someOtherFunc(context) {}
-    ],
-    {
-      foo: 'bar' // optional payload
-    }
-  )
-  .catch((error) => {
-    // Current payload with execution details,
-    // can be passed in to a new execution (will be indicated in debugger)
-    error.payload
+ft.run(
+  [
+    // returns a promise
+    function someFunc(context) {},
+    function someOtherFunc(context) {}
+  ],
+  {
+    foo: 'bar' // optional payload
+  }
+).catch((error) => {
+  // Current payload with execution details,
+  // can be passed in to a new execution (will be indicated in debugger)
+  error.payload
 
-    // A serialized version of the error. Name, message and stack, or custom error serialization
-    error.payload.error
-  })
+  // A serialized version of the error. Name, message and stack, or custom error serialization
+  error.payload.error
+})
 ```
@@ -73,3 +71,3 @@
   message: 'Some function-tree error'
-  stack: '...'  
+  stack: '...'
 }
@@ -92,3 +90,3 @@ ```
   payload: {foo: 'bar'},
-  stack: '...'  
+  stack: '...'
 }
@@ -259,3 +257,3 @@ ```
 // As an event (async)
-ft.on('error', function(error, execution, payload) {})
+ft.on('error', function (error, execution, payload) {})
 
@@ -262,0 +260,0 @@ // As callback for single execution

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

423137

0.45%

Dev dependency count

0

-100%

Lines of code

3975

0.25%

Worsened metrics

Number of low quality alerts

2

100%

Number of lines in readme file

470

-0.42%

No dependency changes