horpyna - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

dist/index.js

@@ -53,3 +53,3 @@ require("source-map-support").install();
 /* 1 */
-/***/ function(module, exports) {
+/***/ function(module, exports, __webpack_require__) {
 
@@ -62,11 +62,333 @@ "use strict";
 
-	function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+	var _component = __webpack_require__(2);
 
-	var Horpyna = function Horpyna() {
-	  _classCallCheck(this, Horpyna);
+	var _component2 = _interopRequireDefault(_component);
+
+	function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+	exports.default = {
+	  Component: _component2.default
 	};
 
-	exports.default = Horpyna;
+/***/ },
+/* 2 */
+/***/ function(module, exports, __webpack_require__) {
 
+	"use strict";
+
+	Object.defineProperty(exports, "__esModule", {
+	  value: true
+	});
+
+	var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+	var _root = __webpack_require__(3);
+
+	var _root2 = _interopRequireDefault(_root);
+
+	var _statuses = __webpack_require__(5);
+
+	var STATUS = _interopRequireWildcard(_statuses);
+
+	var _Relation = __webpack_require__(4);
+
+	var Relation = _interopRequireWildcard(_Relation);
+
+	function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
+
+	function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+	function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+	var Component = function () {
+	  function Component(componentFunction) {
+	    _classCallCheck(this, Component);
+
+	    if (typeof componentFunction === "function") {
+	      this.componentFunction = componentFunction;
+	    } else {
+	      throw new Error();
+	    }
+	    this.connectedChildrenComponents = [];
+	    this.connectedParentComponents = [];
+
+	    this.status = STATUS.INIT;
+	    this.rootComponent = new _root2.default();
+	    this.rootComponent.addComponent(this);
+	  }
+
+	  /**
+	   * triggered once from root component. It start all process.
+	   * It need to have connection ready.
+	   * @returns Promise promise is resolved when every component in tree is done.
+	   */
+
+
+	  _createClass(Component, [{
+	    key: "run",
+	    value: function run(input) {
+	      var _this = this;
+
+	      return this.rootComponent.run(function () {
+	        return _this._runComponentFunction(input);
+	      });
+	    }
+
+	    /**
+	     * Start to run component logic from this.componentFunction.
+	     */
+
+	  }, {
+	    key: "_runComponentFunction",
+	    value: function _runComponentFunction(input) {
+	      this.status = STATUS.PROCESS;
+	      this.componentFunction({ input: input }, this._prepareResponseFunction());
+	    }
+
+	    /**
+	     * When parent component is done, it inform his child components about it. Which allow them to start
+	     * By default child component start when all parent components are done.
+	     */
+
+	  }, {
+	    key: "_onParentReady",
+	    value: function _onParentReady() {
+	      if (this.rootComponent.status === STATUS.PROCESS) {
+	        if (Relation.hasComponentsStatus(this.connectedParentComponents, STATUS.DONE)) {
+	          this.status = STATUS.PROCESS;
+	          this.componentFunction(this._getParentsOutput(), this._prepareResponseFunction());
+	        }
+	      }
+	    }
+
+	    /**
+	     * gather all parents outputs
+	     */
+
+	  }, {
+	    key: "_getParentsOutput",
+	    value: function _getParentsOutput() {
+	      if (this.connectedParentComponents.length === 1) {
+	        return { input: this.connectedParentComponents[0].output };
+	      } else {
+	        return { input: this.connectedParentComponents.map(function (component) {
+	            return component.output;
+	          }) };
+	      }
+	    }
+
+	    /**
+	     * Get function to run at the end in componentFunction. It inform other components that this one is ready
+	     * @returns {Function}
+	     */
+
+	  }, {
+	    key: "_prepareResponseFunction",
+	    value: function _prepareResponseFunction() {
+	      var _this2 = this;
+
+	      return {
+	        send: function send(output) {
+	          _this2.status = STATUS.DONE;
+	          _this2.output = output;
+	          _this2.connectedChildrenComponents.forEach(function (component) {
+	            return component._onParentReady();
+	          });
+	          _this2.rootComponent.onAnyDone();
+	        },
+	        finish: function finish(output) {
+	          _this2.status = STATUS.DONE;
+	          _this2.output = output;
+	          _this2.rootComponent.finish(output);
+	        }
+	      };
+	    }
+
+	    /**
+	     * child component add parent component
+	     * @param component parent component
+	     */
+
+	  }, {
+	    key: "bind",
+	    value: function bind(component) {
+	      this.connectedParentComponents.push(component);
+	      component._bindChild(this);
+	    }
+
+	    /**
+	     * Allow parent component to add child component, should be triggered only by this.connect
+	     * @param component child component
+	     */
+
+	  }, {
+	    key: "_bindChild",
+	    value: function _bindChild(component) {
+	      this.connectedChildrenComponents.push(component);
+	      this.rootComponent.merge(component.rootComponent);
+	      component.rootComponent = this.rootComponent;
+	    }
+	  }]);
+
+	  return Component;
+	}();
+
+	exports.default = Component;
+
+/***/ },
+/* 3 */
+/***/ function(module, exports, __webpack_require__) {
+
+	"use strict";
+
+	Object.defineProperty(exports, "__esModule", {
+	  value: true
+	});
+
+	var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+	var _Relation = __webpack_require__(4);
+
+	var Relation = _interopRequireWildcard(_Relation);
+
+	var _statuses = __webpack_require__(5);
+
+	var STATUS = _interopRequireWildcard(_statuses);
+
+	var _bluebird = __webpack_require__(6);
+
+	var _bluebird2 = _interopRequireDefault(_bluebird);
+
+	function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+	function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
+
+	function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+	var Root = function () {
+	  function Root() {
+	    _classCallCheck(this, Root);
+
+	    this.components = [];
+	    this.status = STATUS.INIT;
+	  }
+
+	  /**
+	   * root component function, it is triggered by any child component after finish
+	   */
+
+
+	  _createClass(Root, [{
+	    key: "onAnyDone",
+	    value: function onAnyDone() {
+	      /**
+	       * if all components are done then finish promise
+	       *
+	       * Now chain is finished when component run method finish
+	       */
+	      //if(Relation.hasComponentsStatus(this.components, [STATUS.DONE, STATUS.INIT])) {
+	      //  this.finish();
+	      //}
+	    }
+	  }, {
+	    key: "addComponent",
+	    value: function addComponent(component) {
+	      this.components.push(component);
+	    }
+
+	    /**
+	     * triggered once from root component. It start all process.
+	     * It need to have connection ready.
+	     * @returns Promise promise is resolved when every component in tree is done.
+	     */
+
+	  }, {
+	    key: "run",
+	    value: function run(callback) {
+	      var _this = this;
+
+	      this.promise = new _bluebird2.default(function (resolve) {
+	        _this.resolve = resolve;
+	        _this.status = STATUS.PROCESS;
+	        callback();
+	      });
+	      return this.promise;
+	    }
+	  }, {
+	    key: "finish",
+	    value: function finish(output) {
+	      this.status = STATUS.DONE;
+	      this.resolve(output);
+	    }
+
+	    /**
+	     * allow to join two rootComponents to one
+	     * @param childRootComponent
+	     */
+
+	  }, {
+	    key: "merge",
+	    value: function merge(childRootComponent) {
+	      this.components = this.components.concat(childRootComponent.components);
+	    }
+	  }]);
+
+	  return Root;
+	}();
+
+	exports.default = Root;
+
+/***/ },
+/* 4 */
+/***/ function(module, exports, __webpack_require__) {
+
+	"use strict";
+
+	Object.defineProperty(exports, "__esModule", {
+	  value: true
+	});
+	exports.hasComponentsStatus = hasComponentsStatus;
+
+	var _statuses = __webpack_require__(5);
+
+	var STATUS = _interopRequireWildcard(_statuses);
+
+	function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
+
+	function hasComponentsStatus(components, statuses) {
+	  if (statuses.length === undefined) {
+	    statuses = [statuses];
+	  }
+	  var doneCount = components.reduce(function (doneCount, component) {
+	    if (statuses.indexOf(component.status) !== -1) {
+	      return ++doneCount;
+	    } else {
+	      return doneCount;
+	    }
+	  }, 0);
+	  return doneCount === components.length;
+	} /**
+	   * help to calculate relatives components state
+	   */
+
+/***/ },
+/* 5 */
+/***/ function(module, exports) {
+
+	"use strict";
+
+	Object.defineProperty(exports, "__esModule", {
+	  value: true
+	});
+	var INIT = exports.INIT = "init";
+	var PROCESS = exports.PROCESS = "processing";
+	var DONE = exports.DONE = "done";
+
+/***/ },
+/* 6 */
+/***/ function(module, exports) {
+
+	module.exports = require("bluebird");
+
 /***/ }
 /******/ ])));

gulpfile.js

@@ -43,3 +43,3 @@ var gulp = require('gulp');
 
-gulp.task('_test', shell.task(['./node_modules/.bin/mocha  --check-leaks --timeout 3000 tests/server']));
+gulp.task('_test', shell.task(['./node_modules/.bin/mocha --compilers js:babel-register --check-leaks --timeout 3000 tests']));
 gulp.task('_coverage-test-server', shell.task(['./node_modules/.bin/istanbul cover ./node_modules/.bin/_mocha tests/server --print both --recursive -- -u exports -R spec && open coverage/lcov-report/index.html']));
@@ -46,0 +46,0 @@

package.json

 {
   "name": "horpyna",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "promised modules flow control core library",
@@ -36,2 +36,3 @@ "main": "index.js",
     "chai": "^3.5.0",
+    "chai-as-promised": "^5.3.0",
     "chai-things": "^0.2.0",
@@ -51,2 +52,3 @@ "del": "^2.2.0",
     "path": "^0.12.7",
+    "sinon": "^1.17.4",
     "source-map-support": "^0.4.0",
@@ -53,0 +55,0 @@ "supertest": "^1.2.0",

README.md

@@ -1,1 +0,15 @@
-# HORPYNA
+# HORPYNA
+
+Create basic component:
+
+
+    import Horpyna from "horpyna";
+    var component = new Horpyna.Component();
+
+Run component:
+
+    component.run();
+
+
+
+

src/index.js

@@ -1,5 +0,5 @@
-class Horpyna {
+import Component from "./components/component";
 
-}
-
-export default Horpyna;
+export default {
+  Component
+};

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

71547

increased by123.39%

Number of package files

27

increased by28.57%

Lines of code

792

increased by231.38%

Number of lines in readme file

16

increased by1500%

Worsened metrics

Dev dependency count

27

increased by8%

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes