1.0.16

.gitlab-ci.yml

@@ -1,20 +1,31 @@
-image: hosttoday/ht-docker-node:npmts
+# gitzone standard
+image: hosttoday/ht-docker-node:npmci
+
+cache:
+  paths:
+  - .yarn/
+  key: "$CI_BUILD_STAGE"
 
 stages:
 - test
 - release
+- trigger
+- pages
 
 testLEGACY:
   stage: test
   script:
     - npmci test legacy
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
     - docker
+  allow_failure: true
 
 testLTS:
   stage: test
   script:
     - npmci test lts
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
     - docker
     
@@ -22,15 +33,39 @@ testSTABLE:
   stage: test
   script:
     - npmci test stable
+  coverage: /\d+.?\d+?\%\s*coverage/
   tags:
     - docker
 
 release:
   stage: release
-  environment: npmjs-com_registry
   script:
     - npmci publish
   only:
     - tags
   tags:
-    - docker
+    - docker
+
+trigger:
+  stage: trigger
+  script:
+    - npmci trigger
+  only:
+    - tags
+  tags:
+    - docker
+
+pages:
+  image: hosttoday/ht-docker-node:npmci
+  stage: pages
+  script:
+    - npmci command yarn global add npmpage
+    - npmci command npmpage
+  tags:
+    - docker
+  only:
+    - tags
+  artifacts:
+    expire_in: 1 week
+    paths:
+    - public

dist/index.d.ts

@@ -1,5 +1,4 @@
 export { Task, ITaskFunction } from './taskbuffer.classes.task';
 export { Taskchain } from './taskbuffer.classes.taskchain';
 export { Taskparallel } from './taskbuffer.classes.taskparallel';
-export { Taskspace } from './taskbuffer.classes.taskspace';
 import './taskbuffer.classes.helpers';

dist/index.js

@@ -1,12 +1,11 @@
 "use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
 var taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
 exports.Task = taskbuffer_classes_task_1.Task;
 var taskbuffer_classes_taskchain_1 = require("./taskbuffer.classes.taskchain");
 exports.Taskchain = taskbuffer_classes_taskchain_1.Taskchain;
 var taskbuffer_classes_taskparallel_1 = require("./taskbuffer.classes.taskparallel");
 exports.Taskparallel = taskbuffer_classes_taskparallel_1.Taskparallel;
-var taskbuffer_classes_taskspace_1 = require("./taskbuffer.classes.taskspace");
-exports.Taskspace = taskbuffer_classes_taskspace_1.Taskspace;
 // import for naming only
 require("./taskbuffer.classes.helpers");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEscUVBQTZEO0FBQXJELHlDQUFBLElBQUksQ0FBQTtBQUNaLCtFQUF5RDtBQUFqRCxtREFBQSxTQUFTLENBQUE7QUFDakIscUZBQStEO0FBQXZELHlEQUFBLFlBQVksQ0FBQTtBQUNwQiwrRUFBeUQ7QUFBakQsbURBQUEsU0FBUyxDQUFBO0FBRWpCLHlCQUF5QjtBQUN6Qix3Q0FBcUMifQ==
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLHFFQUE0RDtBQUFwRCx5Q0FBQSxJQUFJLENBQUE7QUFDWiwrRUFBd0Q7QUFBaEQsbURBQUEsU0FBUyxDQUFBO0FBQ2pCLHFGQUE4RDtBQUF0RCx5REFBQSxZQUFZLENBQUE7QUFFcEIseUJBQXlCO0FBQ3pCLHdDQUFxQyJ9

dist/taskbuffer.classes.helpers.d.ts

@@ -24,7 +24,7 @@ export declare class BufferRunner {
     bufferMax: number;
     running: boolean;
     constructor(taskArg: Task);
-    private _run(x);
     setBufferMax(bufferMaxArg: number): void;
     trigger(x: any): Promise<any>;
+    private _run(x);
 }

dist/taskbuffer.classes.task.js

@@ -1,4 +1,5 @@
 "use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
 const plugins = require("./taskbuffer.plugins");
 const helpers = require("./taskbuffer.classes.helpers");
 class Task {
@@ -28,9 +29,7 @@ class Task {
         else {
             return this.triggerUnBuffered(x);
         }
-        ;
     }
-    ;
     /**
      * trigger task unbuffered.
      */
@@ -56,4 +55,4 @@ class Task {
     }
 }
 exports.Task = Task;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2suanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy90YXNrYnVmZmVyLmNsYXNzZXMudGFzay50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsZ0RBQStDO0FBQy9DLHdEQUF1RDtBQU12RDtJQWNFLFlBQVksVUFPWDtRQWRELHdCQUF3QjtRQUN4QixZQUFPLEdBQVksS0FBSyxDQUFBO1FBQ3hCLGlCQUFZLEdBQUcsSUFBSSxPQUFPLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxDQUFBO1FBQzdDLGlCQUFZLEdBQUcsSUFBSSxPQUFPLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxDQUFBO1FBQzdDLFNBQUksR0FBWSxJQUFJLENBQUE7UUFDWixXQUFNLEdBQVcsT0FBTyxDQUFBO1FBVTlCLElBQUksT0FBTyxHQUFHLFVBQVUsQ0FBQTtRQUN4QixJQUFJLENBQUMsWUFBWSxHQUFHLFVBQVUsQ0FBQyxZQUFZLENBQUE7UUFDM0MsSUFBSSxDQUFDLE9BQU8sR0FBRyxPQUFPLENBQUMsT0FBTyxDQUFBO1FBQzlCLElBQUksQ0FBQyxTQUFTLEdBQUcsT0FBTyxDQUFDLFNBQVMsQ0FBQTtRQUNsQyxJQUFJLENBQUMsSUFBSSxHQUFHLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtRQUN6QixJQUFJLENBQUMsUUFBUSxHQUFHLE9BQU8sQ0FBQyxRQUFRLENBQUE7UUFDaEMsSUFBSSxDQUFDLFlBQVksQ0FBQyxZQUFZLENBQUMsT0FBTyxDQUFDLFNBQVMsQ0FBQyxDQUFBO1FBQ2pELElBQUksQ0FBQyxJQUFJLEdBQUcsT0FBTyxDQUFDLElBQUksQ0FBQTtJQUMxQixDQUFDO0lBRUQ7O09BRUc7SUFDSCxPQUFPLENBQUMsQ0FBRTtRQUNSLEVBQUUsQ0FBQyxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDO1lBQ2xCLE1BQU0sQ0FBQyxJQUFJLENBQUMsZUFBZSxDQUFDLENBQUMsQ0FBQyxDQUFBO1FBQ2hDLENBQUM7UUFDRCxJQUFJLENBQUMsQ0FBQztZQUNKLE1BQU0sQ0FBQyxJQUFJLENBQUMsaUJBQWlCLENBQUMsQ0FBQyxDQUFDLENBQUE7UUFDbEMsQ0FBQztRQUFBLENBQUM7SUFDSixDQUFDO0lBQUEsQ0FBQztJQUVGOztPQUVHO0lBQ0gsaUJBQWlCLENBQUMsQ0FBRTtRQUNsQixNQUFNLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxJQUFJLEVBQUUsRUFBRSxDQUFDLEVBQUUsQ0FBQyxFQUFFLENBQUMsQ0FBQTtJQUN4QyxDQUFDO0lBRUQ7O09BRUc7SUFDSCxlQUFlLENBQUMsQ0FBRTtRQUNoQixNQUFNLENBQUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUE7SUFDckMsQ0FBQztJQUVELElBQUksS0FBSztRQUNQLE1BQU0sQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFBO0lBQ3BCLENBQUM7SUFDRCxJQUFJLEtBQUssQ0FBQyxRQUFnQjtRQUN4QixFQUFFLENBQUMsQ0FBQyxRQUFRLEtBQUssUUFBUSxDQUFDLENBQUMsQ0FBQztZQUMxQixJQUFJLENBQUMsTUFBTSxHQUFHLFFBQVEsQ0FBQTtRQUN4QixDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDTixPQUFPLENBQUMsU0FBUyxDQUFDLEtBQUssQ0FBQyxhQUFhLEdBQUcsUUFBUSxHQUFHLG1CQUFtQixDQUFDLENBQUE7UUFDekUsQ0FBQztJQUNILENBQUM7Q0FDRjtBQXBFRCxvQkFvRUMifQ==
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2suanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy90YXNrYnVmZmVyLmNsYXNzZXMudGFzay50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLGdEQUErQztBQUMvQyx3REFBdUQ7QUFNdkQ7SUFjRSxZQUFhLFVBT1o7UUFkRCx3QkFBd0I7UUFDeEIsWUFBTyxHQUFZLEtBQUssQ0FBQTtRQUN4QixpQkFBWSxHQUFHLElBQUksT0FBTyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUM3QyxpQkFBWSxHQUFHLElBQUksT0FBTyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUM3QyxTQUFJLEdBQVksSUFBSSxDQUFBO1FBQ1osV0FBTSxHQUFXLE9BQU8sQ0FBQTtRQVU5QixJQUFJLE9BQU8sR0FBRyxVQUFVLENBQUE7UUFDeEIsSUFBSSxDQUFDLFlBQVksR0FBRyxVQUFVLENBQUMsWUFBWSxDQUFBO1FBQzNDLElBQUksQ0FBQyxPQUFPLEdBQUcsT0FBTyxDQUFDLE9BQU8sQ0FBQTtRQUM5QixJQUFJLENBQUMsU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUE7UUFDbEMsSUFBSSxDQUFDLElBQUksR0FBRyxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7UUFDekIsSUFBSSxDQUFDLFFBQVEsR0FBRyxPQUFPLENBQUMsUUFBUSxDQUFBO1FBQ2hDLElBQUksQ0FBQyxZQUFZLENBQUMsWUFBWSxDQUFDLE9BQU8sQ0FBQyxTQUFTLENBQUMsQ0FBQTtRQUNqRCxJQUFJLENBQUMsSUFBSSxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQUE7SUFDMUIsQ0FBQztJQUVEOztPQUVHO0lBQ0gsT0FBTyxDQUFFLENBQUU7UUFDVCxFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztZQUNsQixNQUFNLENBQUMsSUFBSSxDQUFDLGVBQWUsQ0FBQyxDQUFDLENBQUMsQ0FBQTtRQUNoQyxDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDTixNQUFNLENBQUMsSUFBSSxDQUFDLGlCQUFpQixDQUFDLENBQUMsQ0FBQyxDQUFBO1FBQ2xDLENBQUM7SUFDSCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxpQkFBaUIsQ0FBRSxDQUFFO1FBQ25CLE1BQU0sQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLElBQUksRUFBRSxFQUFFLENBQUMsRUFBRSxDQUFDLEVBQUUsQ0FBQyxDQUFBO0lBQ3hDLENBQUM7SUFFRDs7T0FFRztJQUNILGVBQWUsQ0FBRSxDQUFFO1FBQ2pCLE1BQU0sQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUMsQ0FBQTtJQUNyQyxDQUFDO0lBRUQsSUFBSSxLQUFLO1FBQ1AsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUE7SUFDcEIsQ0FBQztJQUNELElBQUksS0FBSyxDQUFFLFFBQWdCO1FBQ3pCLEVBQUUsQ0FBQyxDQUFDLFFBQVEsS0FBSyxRQUFRLENBQUMsQ0FBQyxDQUFDO1lBQzFCLElBQUksQ0FBQyxNQUFNLEdBQUcsUUFBUSxDQUFBO1FBQ3hCLENBQUM7UUFBQyxJQUFJLENBQUMsQ0FBQztZQUNOLE9BQU8sQ0FBQyxTQUFTLENBQUMsS0FBSyxDQUFDLGFBQWEsR0FBRyxRQUFRLEdBQUcsbUJBQW1CLENBQUMsQ0FBQTtRQUN6RSxDQUFDO0lBQ0gsQ0FBQztDQUNGO0FBbkVELG9CQW1FQyJ9

dist/taskbuffer.classes.taskchain.js

@@ -1,4 +1,7 @@
 "use strict";
+// TaskChain chains tasks
+// and extends Task
+Object.defineProperty(exports, "__esModule", { value: true });
 const plugins = require("./taskbuffer.plugins");
 const taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
 class Taskchain extends taskbuffer_classes_task_1.Task {
@@ -35,19 +38,16 @@ class Taskchain extends taskbuffer_classes_task_1.Task {
         if (optionsArg.log === true) {
             this._oraObject.start();
         }
-        ;
     }
     addTask(taskArg) {
         this.taskArray.push(taskArg);
     }
-    ;
     removeTask(taskArg) {
-        // TODO
+        // TODO:
     }
-    ;
     shiftTask() {
+        // TODO:
     }
-    ;
 }
 exports.Taskchain = Taskchain;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2tjaGFpbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrY2hhaW4udHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLGdEQUFnRDtBQUNoRCx1RUFBaUQ7QUFHakQsZUFBdUIsU0FBUSw4QkFBSTtJQUdqQyxZQUFZLFVBTVg7UUFDQyxJQUFJLE9BQU8sR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FDaEM7WUFDRSxJQUFJLEVBQUUsbUJBQW1CO1lBQ3pCLEdBQUcsRUFBRSxLQUFLO1NBQ1gsRUFDRCxVQUFVLEVBQ1Y7WUFDRSxZQUFZLEVBQUUsQ0FBQyxDQUFNO2dCQUNuQixJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFBLENBQUMsdUNBQXVDO2dCQUNwRSxJQUFJLFdBQVcsR0FBRyxDQUFDLENBQUEsQ0FBQyxpREFBaUQ7Z0JBQ3JFLElBQUksWUFBWSxHQUFHLENBQUMsQ0FBQztvQkFDbkIsRUFBRSxDQUFDLENBQUMsT0FBTyxJQUFJLENBQUMsU0FBUyxDQUFFLFdBQVcsQ0FBRSxLQUFLLFdBQVcsQ0FBQyxDQUFDLENBQUM7d0JBQ3pELElBQUksQ0FBQyxVQUFVLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxJQUFJLEdBQUcsZ0JBQWdCLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBRSxXQUFXLENBQUUsQ0FBQyxJQUFJLENBQUMsQ0FBQTt3QkFDdkYsSUFBSSxDQUFDLFNBQVMsQ0FBRSxXQUFXLENBQUUsQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDOzZCQUNyQyxJQUFJLENBQUMsQ0FBQyxDQUFDOzRCQUNOLE9BQU8sQ0FBQyxTQUFTLENBQUMsRUFBRSxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUUsV0FBVyxDQUFFLENBQUMsSUFBSSxDQUFDLENBQUE7NEJBQ3hELFdBQVcsRUFBRSxDQUFBOzRCQUNiLFlBQVksQ0FBQyxDQUFDLENBQUMsQ0FBQTt3QkFDakIsQ0FBQyxDQUFDLENBQUE7b0JBQ04sQ0FBQztvQkFBQyxJQUFJLENBQUMsQ0FBQzt3QkFDTixJQUFJLENBQUMsVUFBVSxDQUFDLEtBQUssQ0FBQyxhQUFhLEdBQUcsSUFBSSxDQUFDLElBQUksR0FBRywwQkFBMEIsQ0FBQyxDQUFBO3dCQUM3RSxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUMsQ0FBQyxDQUFBO29CQUNqQixDQUFDO2dCQUNILENBQUMsQ0FBQTtnQkFDRCxZQUFZLENBQUMsQ0FBQyxDQUFDLENBQUE7Z0JBQ2YsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7WUFDckIsQ0FBQztTQUNGLENBQ0YsQ0FBQTtRQUNELEtBQUssQ0FBQyxPQUFPLENBQUMsQ0FBQTtRQUNkLElBQUksQ0FBQyxTQUFTLEdBQUcsVUFBVSxDQUFDLFNBQVMsQ0FBQTtRQUNyQyxJQUFJLENBQUMsVUFBVSxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsR0FBRyxDQUFBO1FBQ3ZDLEVBQUUsQ0FBQyxDQUFDLFVBQVUsQ0FBQyxHQUFHLEtBQUssSUFBSSxDQUFDLENBQUMsQ0FBQztZQUM1QixJQUFJLENBQUMsVUFBVSxDQUFDLEtBQUssRUFBRSxDQUFBO1FBQ3pCLENBQUM7UUFBQSxDQUFDO0lBQ0osQ0FBQztJQUNELE9BQU8sQ0FBQyxPQUFhO1FBQ25CLElBQUksQ0FBQyxTQUFTLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFBO0lBQzlCLENBQUM7SUFBQSxDQUFDO0lBQ0YsVUFBVSxDQUFDLE9BQWE7UUFDdEIsT0FBTztJQUNULENBQUM7SUFBQSxDQUFDO0lBQ0YsU0FBUztJQUVULENBQUM7SUFBQSxDQUFDO0NBQ0g7QUF2REQsOEJBdURDIn0=
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2tjaGFpbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrY2hhaW4udHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHlCQUF5QjtBQUN6QixtQkFBbUI7O0FBRW5CLGdEQUErQztBQUMvQyx1RUFBZ0Q7QUFHaEQsZUFBdUIsU0FBUSw4QkFBSTtJQUdqQyxZQUFZLFVBTVg7UUFDQyxJQUFJLE9BQU8sR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FDaEM7WUFDRSxJQUFJLEVBQUUsbUJBQW1CO1lBQ3pCLEdBQUcsRUFBRSxLQUFLO1NBQ1gsRUFDRCxVQUFVLEVBQ1Y7WUFDRSxZQUFZLEVBQUUsQ0FBQyxDQUFNO2dCQUNuQixJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFBLENBQUMsdUNBQXVDO2dCQUNwRSxJQUFJLFdBQVcsR0FBRyxDQUFDLENBQUEsQ0FBQyxpREFBaUQ7Z0JBQ3JFLElBQUksWUFBWSxHQUFHLENBQUMsQ0FBQztvQkFDbkIsRUFBRSxDQUFDLENBQUMsT0FBTyxJQUFJLENBQUMsU0FBUyxDQUFFLFdBQVcsQ0FBRSxLQUFLLFdBQVcsQ0FBQyxDQUFDLENBQUM7d0JBQ3pELElBQUksQ0FBQyxVQUFVLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxJQUFJLEdBQUcsZ0JBQWdCLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBRSxXQUFXLENBQUUsQ0FBQyxJQUFJLENBQUMsQ0FBQTt3QkFDdkYsSUFBSSxDQUFDLFNBQVMsQ0FBRSxXQUFXLENBQUUsQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDOzZCQUNyQyxJQUFJLENBQUMsQ0FBQyxDQUFDOzRCQUNOLE9BQU8sQ0FBQyxTQUFTLENBQUMsRUFBRSxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUUsV0FBVyxDQUFFLENBQUMsSUFBSSxDQUFDLENBQUE7NEJBQ3hELFdBQVcsRUFBRSxDQUFBOzRCQUNiLFlBQVksQ0FBQyxDQUFDLENBQUMsQ0FBQTt3QkFDakIsQ0FBQyxDQUFDLENBQUE7b0JBQ04sQ0FBQztvQkFBQyxJQUFJLENBQUMsQ0FBQzt3QkFDTixJQUFJLENBQUMsVUFBVSxDQUFDLEtBQUssQ0FBQyxhQUFhLEdBQUcsSUFBSSxDQUFDLElBQUksR0FBRywwQkFBMEIsQ0FBQyxDQUFBO3dCQUM3RSxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUMsQ0FBQyxDQUFBO29CQUNqQixDQUFDO2dCQUNILENBQUMsQ0FBQTtnQkFDRCxZQUFZLENBQUMsQ0FBQyxDQUFDLENBQUE7Z0JBQ2YsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7WUFDckIsQ0FBQztTQUNGLENBQ0YsQ0FBQTtRQUNELEtBQUssQ0FBQyxPQUFPLENBQUMsQ0FBQTtRQUNkLElBQUksQ0FBQyxTQUFTLEdBQUcsVUFBVSxDQUFDLFNBQVMsQ0FBQTtRQUNyQyxJQUFJLENBQUMsVUFBVSxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsR0FBRyxDQUFBO1FBQ3ZDLEVBQUUsQ0FBQyxDQUFDLFVBQVUsQ0FBQyxHQUFHLEtBQUssSUFBSSxDQUFDLENBQUMsQ0FBQztZQUM1QixJQUFJLENBQUMsVUFBVSxDQUFDLEtBQUssRUFBRSxDQUFBO1FBQ3pCLENBQUM7SUFDSCxDQUFDO0lBQ0QsT0FBTyxDQUFFLE9BQWE7UUFDcEIsSUFBSSxDQUFDLFNBQVMsQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUE7SUFDOUIsQ0FBQztJQUNELFVBQVUsQ0FBRSxPQUFhO1FBQ3ZCLFFBQVE7SUFDVixDQUFDO0lBQ0QsU0FBUztRQUNQLFFBQVE7SUFDVixDQUFDO0NBQ0Y7QUF2REQsOEJBdURDIn0=

dist/taskbuffer.classes.taskmanager.d.ts

@@ -0,0 +1,43 @@
+import { Task } from './taskbuffer.classes.task';
+import { Objectmap } from 'lik';
+export declare class TaskManager {
+    taskMap: Objectmap<Task>;
+    private cronJobArray;
+    constructor();
+    /**
+     * checks if a task is already present
+     * @param taskNameArg
+     */
+    getTaskByName(taskNameArg: any): Task;
+    /**
+     * adds a Task to the TaskManager
+     * @param taskArg
+     */
+    addTask(taskArg: Task): void;
+    /**
+     * adds and schedules a task at once
+     * @param taskArg
+     * @param cronStringArg
+     */
+    addAndScheduleTask(taskArg: Task, cronStringArg: string): void;
+    /**
+     * triggers a task in the TaskManagerByName
+     * @param taskNameArg
+     */
+    triggerTaskByName(taskNameArg: string): void;
+    /**
+     * schedules the task by name
+     * @param taskNameArg
+     */
+    scheduleTaskByName(taskNameArg: string, cronStringArg: string): void;
+    /**
+     * returns all schedules of a specific task
+     * @param taskNameArg
+     */
+    getSchedulesForTaskName(taskNameArg: string): void;
+}
+export interface ICronJob {
+    cronString: string;
+    taskNameArg: string;
+    job: any;
+}

dist/taskbuffer.classes.taskmanager.js

@@ -1,2 +1,75 @@
 "use strict";
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiIifQ==
+Object.defineProperty(exports, "__esModule", { value: true });
+const plugins = require("./taskbuffer.plugins");
+class TaskManager {
+    constructor() {
+        this.taskMap = new plugins.lik.Objectmap();
+        this.cronJobArray = [];
+        // nothing here
+    }
+    /**
+     * checks if a task is already present
+     * @param taskNameArg
+     */
+    getTaskByName(taskNameArg) {
+        return this.taskMap.find((itemArg) => {
+            return itemArg.name === taskNameArg;
+        });
+    }
+    /**
+     * adds a Task to the TaskManager
+     * @param taskArg
+     */
+    addTask(taskArg) {
+        if (!taskArg.name) {
+            throw new Error('taskArg needs a name to be added to taskManager');
+        }
+        this.taskMap.add(taskArg);
+    }
+    /**
+     * adds and schedules a task at once
+     * @param taskArg
+     * @param cronStringArg
+     */
+    addAndScheduleTask(taskArg, cronStringArg) {
+        this.addTask(taskArg);
+        let taskName = taskArg.name;
+        this.scheduleTaskByName(taskName, cronStringArg);
+    }
+    /**
+     * triggers a task in the TaskManagerByName
+     * @param taskNameArg
+     */
+    triggerTaskByName(taskNameArg) {
+        let taskToTrigger = this.getTaskByName(taskNameArg);
+        if (!taskToTrigger) {
+            throw new Error(`There is no task with the name of ${taskNameArg}`);
+        }
+        taskToTrigger.trigger();
+    }
+    /**
+     * schedules the task by name
+     * @param taskNameArg
+     */
+    scheduleTaskByName(taskNameArg, cronStringArg) {
+        let taskToSchedule = this.getTaskByName(taskNameArg);
+        let job = new plugins.cron.CronJob({
+            cronTime: cronStringArg,
+            onTick: taskToSchedule.trigger,
+            start: true
+        });
+        this.cronJobArray.push({
+            taskNameArg: taskToSchedule.name,
+            cronString: cronStringArg,
+            job: job
+        });
+    }
+    /**
+     * returns all schedules of a specific task
+     * @param taskNameArg
+     */
+    getSchedulesForTaskName(taskNameArg) {
+    }
+}
+exports.TaskManager = TaskManager;
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsZ0RBQStDO0FBTS9DO0lBR0U7UUFGQSxZQUFPLEdBQUcsSUFBSSxPQUFPLENBQUMsR0FBRyxDQUFDLFNBQVMsRUFBUSxDQUFBO1FBQ25DLGlCQUFZLEdBQWUsRUFBRSxDQUFBO1FBRW5DLGVBQWU7SUFDakIsQ0FBQztJQUVEOzs7T0FHRztJQUNILGFBQWEsQ0FBRSxXQUFXO1FBQ3hCLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLE9BQU87WUFDL0IsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLEtBQUssV0FBVyxDQUFBO1FBQ3JDLENBQUMsQ0FBQyxDQUFBO0lBQ0osQ0FBQztJQUVEOzs7T0FHRztJQUNILE9BQU8sQ0FBRSxPQUFhO1FBQ3BCLEVBQUUsQ0FBQyxDQUFDLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7WUFDbEIsTUFBTSxJQUFJLEtBQUssQ0FBQyxpREFBaUQsQ0FBQyxDQUFBO1FBQ3BFLENBQUM7UUFDRCxJQUFJLENBQUMsT0FBTyxDQUFDLEdBQUcsQ0FBQyxPQUFPLENBQUMsQ0FBQTtJQUMzQixDQUFDO0lBRUQ7Ozs7T0FJRztJQUNILGtCQUFrQixDQUFFLE9BQWEsRUFBRSxhQUFxQjtRQUN0RCxJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ3JCLElBQUksUUFBUSxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQUE7UUFDM0IsSUFBSSxDQUFDLGtCQUFrQixDQUFDLFFBQVEsRUFBRSxhQUFhLENBQUMsQ0FBQTtJQUNsRCxDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsaUJBQWlCLENBQUUsV0FBbUI7UUFDcEMsSUFBSSxhQUFhLEdBQUcsSUFBSSxDQUFDLGFBQWEsQ0FBQyxXQUFXLENBQUMsQ0FBQTtRQUNuRCxFQUFFLENBQUMsQ0FBQyxDQUFDLGFBQWEsQ0FBQyxDQUFDLENBQUM7WUFDbkIsTUFBTSxJQUFJLEtBQUssQ0FBQyxxQ0FBcUMsV0FBVyxFQUFFLENBQUMsQ0FBQTtRQUNyRSxDQUFDO1FBQ0QsYUFBYSxDQUFDLE9BQU8sRUFBRSxDQUFBO0lBQ3pCLENBQUM7SUFFRDs7O09BR0c7SUFDSCxrQkFBa0IsQ0FBRSxXQUFtQixFQUFFLGFBQXFCO1FBQzVELElBQUksY0FBYyxHQUFHLElBQUksQ0FBQyxhQUFhLENBQUMsV0FBVyxDQUFDLENBQUE7UUFDcEQsSUFBSSxHQUFHLEdBQUcsSUFBSSxPQUFPLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztZQUNqQyxRQUFRLEVBQUUsYUFBYTtZQUN2QixNQUFNLEVBQUUsY0FBYyxDQUFDLE9BQU87WUFDOUIsS0FBSyxFQUFFLElBQUk7U0FDWixDQUFDLENBQUE7UUFDRixJQUFJLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQztZQUNyQixXQUFXLEVBQUUsY0FBYyxDQUFDLElBQUk7WUFDaEMsVUFBVSxFQUFFLGFBQWE7WUFDekIsR0FBRyxFQUFFLEdBQUc7U0FDVCxDQUFDLENBQUE7SUFDSixDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsdUJBQXVCLENBQUUsV0FBbUI7SUFFNUMsQ0FBQztDQUNGO0FBNUVELGtDQTRFQyJ9

dist/taskbuffer.classes.taskparallel.d.ts

@@ -1,4 +1,4 @@
-import { Task } from "./taskbuffer.classes.task";
+import { Task } from './taskbuffer.classes.task';
 export declare class Taskparallel extends Task {
     taskArray: Task[];
     constructor(optionsArg: {

dist/taskbuffer.classes.taskparallel.js

@@ -1,4 +1,5 @@
 "use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
 const plugins = require("./taskbuffer.plugins");
 const taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
 class Taskparallel extends taskbuffer_classes_task_1.Task {
@@ -20,4 +21,4 @@ class Taskparallel extends taskbuffer_classes_task_1.Task {
     }
 }
 exports.Taskparallel = Taskparallel;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2twYXJhbGxlbC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrcGFyYWxsZWwudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLGdEQUErQztBQUUvQyx1RUFBZ0Q7QUFFaEQsa0JBQTBCLFNBQVEsOEJBQUk7SUFFbEMsWUFBWSxVQUVYO1FBQ0csSUFBSSxPQUFPLEdBQUcsT0FBTyxDQUFDLE1BQU0sQ0FBQyxLQUFLLENBQzlCLFVBQVUsRUFDVjtZQUNJLFlBQVksRUFBRTtnQkFDVixJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFDO2dCQUM3QixJQUFJLFlBQVksR0FBbUIsRUFBRSxDQUFDLENBQUMsMkRBQTJEO2dCQUNsRyxJQUFJLENBQUMsU0FBUyxDQUFDLE9BQU8sQ0FBQyxVQUFVLE9BQU87b0JBQ3BDLFlBQVksQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sRUFBRSxDQUFDLENBQUM7Z0JBQ3pDLENBQUMsQ0FBQyxDQUFBO2dCQUNGLE9BQU8sQ0FBQyxHQUFHLENBQUMsWUFBWSxDQUFDO3FCQUNwQixJQUFJLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDO2dCQUN4QixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztZQUN4QixDQUFDO1NBQ0osQ0FDSixDQUFDO1FBQ0YsS0FBSyxDQUFDLE9BQU8sQ0FBQyxDQUFDO1FBQ2YsSUFBSSxDQUFDLFNBQVMsR0FBRyxVQUFVLENBQUMsU0FBUyxDQUFDO0lBQzFDLENBQUM7Q0FDSjtBQXZCRCxvQ0F1QkMifQ==
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2twYXJhbGxlbC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrcGFyYWxsZWwudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFBQSxnREFBK0M7QUFFL0MsdUVBQWdEO0FBRWhELGtCQUEwQixTQUFRLDhCQUFJO0lBRXBDLFlBQWEsVUFFWjtRQUNDLElBQUksT0FBTyxHQUFHLE9BQU8sQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUNoQyxVQUFVLEVBQ1Y7WUFDRSxZQUFZLEVBQUU7Z0JBQ1osSUFBSSxJQUFJLEdBQUcsT0FBTyxDQUFDLENBQUMsQ0FBQyxLQUFLLEVBQUUsQ0FBQTtnQkFDNUIsSUFBSSxZQUFZLEdBQW1CLEVBQUUsQ0FBQSxDQUFDLDJEQUEyRDtnQkFDakcsSUFBSSxDQUFDLFNBQVMsQ0FBQyxPQUFPLENBQUMsVUFBVSxPQUFPO29CQUN0QyxZQUFZLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxPQUFPLEVBQUUsQ0FBQyxDQUFBO2dCQUN0QyxDQUFDLENBQUMsQ0FBQTtnQkFDRixPQUFPLENBQUMsR0FBRyxDQUFDLFlBQVksQ0FBQztxQkFDdEIsSUFBSSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQTtnQkFDckIsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7WUFDckIsQ0FBQztTQUNGLENBQ0YsQ0FBQTtRQUNELEtBQUssQ0FBQyxPQUFPLENBQUMsQ0FBQTtRQUNkLElBQUksQ0FBQyxTQUFTLEdBQUcsVUFBVSxDQUFDLFNBQVMsQ0FBQTtJQUN2QyxDQUFDO0NBQ0Y7QUF2QkQsb0NBdUJDIn0=

dist/taskbuffer.classes.taskspace.d.ts

@@ -1,2 +0,0 @@
-export declare class Taskspace {
-}

dist/taskbuffer.classes.taskspace.js

@@ -1,5 +0,0 @@
-"use strict";
-class Taskspace {
-}
-exports.Taskspace = Taskspace;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2tzcGFjZS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrc3BhY2UudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUdBO0NBRUM7QUFGRCw4QkFFQyJ9

dist/taskbuffer.plugins.d.ts

@@ -1,6 +1,9 @@
 import 'typings-global';
 import * as beautylog from 'beautylog';
+declare let cron: any;
+import * as lik from 'lik';
 import * as lodash from 'lodash';
 import * as rxjs from 'rxjs';
 import * as q from 'smartq';
-export { beautylog, lodash, rxjs, q };
+import * as smartdelay from 'smartdelay';
+export { beautylog, cron, lik, lodash, rxjs, q, smartdelay };

dist/taskbuffer.plugins.js

@@ -1,11 +1,18 @@
 "use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
 require("typings-global");
 const beautylog = require("beautylog");
 exports.beautylog = beautylog;
+let cron = require('cron');
+exports.cron = cron;
+const lik = require("lik");
+exports.lik = lik;
 const lodash = require("lodash");
 exports.lodash = lodash;
 const rxjs = require("rxjs");
 exports.rxjs = rxjs;
 const q = require("smartq");
 exports.q = q;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSwwQkFBdUI7QUFDdkIsdUNBQXNDO0FBTWxDLDhCQUFTO0FBTGIsaUNBQWdDO0FBTTVCLHdCQUFNO0FBTFYsNkJBQTRCO0FBTXhCLG9CQUFJO0FBTFIsNEJBQTJCO0FBTXZCLGNBQUMifQ==
+const smartdelay = require("smartdelay");
+exports.smartdelay = smartdelay;
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsMEJBQXVCO0FBQ3ZCLHVDQUFzQztBQVNsQyw4QkFBUztBQVJiLElBQUksSUFBSSxHQUFHLE9BQU8sQ0FBQyxNQUFNLENBQUMsQ0FBQTtBQVN0QixvQkFBSTtBQVJSLDJCQUEwQjtBQVN0QixrQkFBRztBQVJQLGlDQUFnQztBQVM1Qix3QkFBTTtBQVJWLDZCQUE0QjtBQVN4QixvQkFBSTtBQVJSLDRCQUEyQjtBQVN2QixjQUFDO0FBUkwseUNBQXdDO0FBU3BDLGdDQUFVIn0=

npmextra.json

@@ -1,5 +1,13 @@
 {
   "npmts":{
-    "mode":"default"
+    "mode":"default",
+    "testConfig": {
+      "parallel": false
+    }
+  },
+  "npmci": {
+    "globalNpmTools": [
+      "npmts"
+    ]
   }
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "taskbuffer",
-  "version": "1.0.12",
+  "version": "1.0.16",
   "description": "flexible task management. TypeScript ready!",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
@@ -25,16 +25,18 @@
   },
   "homepage": "https://gitlab.com/pushrocks/taskbuffer#readme",
   "dependencies": {
+    "@types/cron": "^1.2.1",
     "@types/lodash": "4.x.x",
-    "beautylog": "^6.1.1",
+    "beautylog": "^6.1.10",
+    "cron": "^1.2.1",
+    "lik": "^1.0.31",
     "lodash": "^4.17.4",
-    "rxjs": "^5.1.1",
+    "rxjs": "^5.4.1",
+    "smartdelay": "^1.0.3",
     "smartq": "^1.1.1",
-    "typings-global": "^1.0.14"
+    "typings-global": "^1.0.17"
   },
   "devDependencies": {
-    "npmts-g": "^6.0.0",
-    "smartchai": "^1.0.1",
-    "typings-test": "^1.0.3"
+    "tapbundle": "^1.0.14"
   }
 }

test/test.1.task.ts

@@ -0,0 +1,108 @@
+import { expect, tap } from 'tapbundle'
+import taskbuffer = require('../dist/index')
+
+import * as q from 'smartq'
+import * as smartdelay from 'smartdelay'
+
+// setup some testData to work with
+let testTask: taskbuffer.Task
+
+let testPreTask = new taskbuffer.Task({
+  taskFunction: function () {
+    let done = q.defer()
+    console.log('preTask executed')
+    done.resolve()
+    return done.promise
+  },
+  preTask: testTask
+})
+
+// some more tasks to test with
+let task1Counter = 0 // how often task 1 is being executed
+let task1 = new taskbuffer.Task({
+  name: 'Task 1',
+  taskFunction: () => {
+    let done = q.defer()
+    console.log('Task1 started')
+    setTimeout(() => {
+      task1Counter++
+      console.log('Task1 executed')
+      done.resolve()
+    }, 5000)
+    return done.promise
+  }
+})
+
+let task2 = new taskbuffer.Task({
+  name: 'Task 1',
+  taskFunction: () => {
+    let done = q.defer()
+    console.log('Task2 started')
+    setTimeout(() => {
+      console.log('Task2 executed')
+      done.resolve()
+    }, 5000)
+    return done.promise
+  }
+})
+
+let task3 = new taskbuffer.Task({
+  name: 'Task 3',
+  taskFunction: () => {
+    let done = q.defer()
+    console.log('Task3 started')
+    setTimeout(() => {
+      console.log('Task3 executed')
+      done.resolve()
+    }, 5000)
+    return done.promise
+  }
+})
+
+tap.test('new Task() should return a new task', async () => {
+  testTask = new taskbuffer.Task({ taskFunction: async () => { console.log('executed twice') }, preTask: testPreTask })
+})
+
+tap.test('testTask should be and instance of Task', async () => {
+  expect(testTask).to.be.instanceof(taskbuffer.Task)
+})
+
+tap.test('testTask.idle is true', async () => {
+  if (!testTask.idle) {
+    throw new Error('testTask.idle is not true')
+  }
+
+})
+
+tap.test('testTask.running is type boolean and initially false', async () => {
+  expect(testTask.running).to.be.a('boolean')
+  // tslint:disable-next-line:no-unused-expression
+  expect(testTask.running).to.be.false
+})
+
+tap.test('testTask.trigger() expect return Promise', async () => {
+  expect(testTask.trigger()).to.be.instanceof(Promise)
+})
+
+tap.test('testTask.trigger() returned Promise expect be fullfilled', async () => {
+  await testTask.trigger()
+})
+
+tap.test('expect run a task without pre and afterTask', async () => {
+  let localTestTask = new taskbuffer.Task({ taskFunction: async () => { console.log('only once') } })
+  await localTestTask.trigger()
+})
+
+tap.test('expect run buffered', async () => {
+  let localTestTask = new taskbuffer.Task({
+    taskFunction: async () => { await smartdelay.delayFor(3000) },
+    buffered: true,
+    bufferMax: 2
+  })
+  localTestTask.trigger()
+  localTestTask.trigger()
+  localTestTask.trigger()
+  await localTestTask.trigger()
+})
+
+tap.start()

test/test.2.taskchain.ts

@@ -0,0 +1,48 @@
+import { expect, tap } from 'tapbundle'
+import taskbuffer = require('../dist/index')
+
+import * as smartq from 'smartq'
+import * as smartdelay from 'smartdelay'
+
+let task1Executed = false
+let task1 = new taskbuffer.Task({
+  taskFunction: async () => {
+    await smartdelay.delayFor(2000)
+    task1Executed = true
+  }
+})
+
+let task2Executed = false
+let task2 = new taskbuffer.Task({
+  taskFunction: async () => {
+    await smartdelay.delayFor(2000)
+    task2Executed = true
+  }
+})
+
+let task3Executed = false
+let task3 = new taskbuffer.Task({
+  taskFunction: async () => {
+    await smartdelay.delayFor(2000)
+    task3Executed = true
+  }
+})
+
+tap.test('expect run tasks in sequence', async () => {
+  let testTaskchain = new taskbuffer.Taskchain({
+    name: 'Taskchain1',
+    taskArray: [ task1, task2, task3 ]
+  })
+  let testPromise = testTaskchain.trigger()
+  await smartdelay.delayFor(2100)
+  // tslint:disable-next-line:no-unused-expression
+  expect(task1Executed).to.be.true
+  // tslint:disable-next-line:no-unused-expression
+  expect(task2Executed).to.be.false
+  await smartdelay.delayFor(2100)
+  // tslint:disable-next-line:no-unused-expression
+  expect(task2Executed).to.be.true
+  await testPromise
+})
+
+tap.start()

test/test.3.taskparallel.ts

@@ -0,0 +1,38 @@
+import { expect, tap } from 'tapbundle'
+import taskbuffer = require('../dist/index')
+
+import * as smartq from 'smartq'
+import * as smartdelay from 'smartdelay'
+
+let task1Executed = false
+let task1 = new taskbuffer.Task({
+  taskFunction: async () => {
+    await smartdelay.delayFor(2000)
+    task1Executed = true
+  }
+})
+
+let task2Executed = false
+let task2 = new taskbuffer.Task({
+  taskFunction: async () => {
+    await smartdelay.delayFor(2000)
+    task2Executed = true
+  }
+})
+
+let task3Executed = false
+let task3 = new taskbuffer.Task({
+  taskFunction: async () => {
+    await smartdelay.delayFor(2000)
+    task3Executed = true
+  }
+})
+
+tap.test('expect run in Parallel', async () => {
+  let testTaskparallel = new taskbuffer.Taskparallel({
+    taskArray: [ task1, task2, task3 ]
+  })
+  await testTaskparallel.trigger()
+})
+
+tap.start()

test/test.5.task.paramflow.ts

@@ -0,0 +1,64 @@
+import { expect, tap } from 'tapbundle'
+import taskbuffer = require('../dist/index')
+
+import * as q from 'smartq'
+import * as smartdelay from 'smartdelay'
+
+let flowTask1 = new taskbuffer.Task({
+  taskFunction: (x: number) => {
+    let done = q.defer()
+    console.log('flowTask1')
+    console.log(x)
+    done.resolve(x)
+    return done.promise
+  }
+})
+
+let flowTaskBuffered = new taskbuffer.Task({
+  taskFunction: (x: number) => {
+    let done = q.defer()
+    console.log('flowTask1')
+    console.log(x)
+    done.resolve(x)
+    return done.promise
+  },
+  buffered: true,
+  bufferMax: 1
+})
+
+let flowTask2 = new taskbuffer.Task({
+  taskFunction: (x: number) => {
+    let done = q.defer()
+    console.log('flowTask2')
+    console.log(x)
+    done.resolve(x)
+    return done.promise
+  },
+  preTask: flowTask1
+})
+
+let flowTask3 = new taskbuffer.Taskchain({
+  taskArray: [ flowTask1, flowTask2 ]
+})
+
+tap.test('should let a value flow through a task', async () => {
+  let result = await flowTask1.trigger(12)
+  expect(result).to.equal(12)
+})
+
+tap.test('should let a values flow between tasks', async () => {
+  let result = await flowTask2.trigger(12)
+  expect(result).to.equal(12)
+})
+
+tap.test('expect let a values flow between tasks when buffered', async () => {
+  let result = await flowTaskBuffered.trigger(12)
+  expect(result).to.equal(12)
+})
+
+tap.test('should let a values flow between tasks in Taskchain', async () => {
+  let result = await flowTask3.trigger(12)
+  expect(result).to.equal(12)
+})
+
+tap.start()

test/test.d.ts

@@ -1 +0,0 @@
-import 'typings-test';

test/test.ts

@@ -1,223 +0,0 @@
-import 'typings-test'
-import taskbuffer = require('../dist/index')
-import { expect } from 'smartchai'
-import * as q from 'smartq'
-
-// setup some testData to work with
-let testTask: taskbuffer.Task
-let testTaskFunction = function () {
-  let done = q.defer()
-  console.log('main function executed!')
-  done.resolve()
-  return done.promise
-}
-
-let testTaskFunctionTimeout = function () {
-  let done = q.defer()
-  console.log('main function started!')
-  setTimeout(() => {
-    console.log('main function ended!')
-    done.resolve()
-  }, 2000)
-  return done.promise
-}
-
-let testPreTask = new taskbuffer.Task({
-  taskFunction: function () {
-    let done = q.defer()
-    console.log('preTask executed')
-    done.resolve()
-    return done.promise
-  },
-  preTask: testTask
-})
-
-
-// some more tasks to wirj with
-let task1 = new taskbuffer.Task({
-  name: 'Task 1',
-  taskFunction: () => {
-    let done = q.defer()
-    console.log('Task1 started')
-    setTimeout(() => {
-      console.log('Task1 executed')
-      done.resolve()
-    }, 5000)
-    return done.promise
-  }
-})
-let task2 = new taskbuffer.Task({
-  name: 'Task 1',
-  taskFunction: () => {
-    let done = q.defer()
-    console.log('Task2 started')
-    setTimeout(() => {
-      console.log('Task2 executed')
-      done.resolve()
-    }, 5000)
-    return done.promise
-  }
-})
-let task3 = new taskbuffer.Task({
-  name: 'Task 3',
-  taskFunction: () => {
-    let done = q.defer()
-    console.log('Task3 started')
-    setTimeout(() => {
-      console.log('Task3 executed')
-      done.resolve()
-    }, 5000)
-    return done.promise
-  }
-})
-
-// the actual tests
-describe('taskbuffer', function () {
-  describe('.Task', function () {
-    it('new Task() should return a new task', function () {
-      testTask = new taskbuffer.Task({ taskFunction: testTaskFunction, preTask: testPreTask })
-    })
-    it('testTask should be and instance of Task', function () {
-      expect(testTask).to.be.instanceof(taskbuffer.Task)
-    })
-    it('testTask.idle is true', function () {
-      if (!testTask.idle) {
-        throw new Error('testTask.idle is not true')
-      }
-
-    })
-    it('testTask.running is type boolean and initially false', function () {
-      expect(testTask.running).to.be.a('boolean')
-      expect(testTask.running).to.be.false
-    })
-    it('testTask.trigger() expect return Promise', function () {
-      expect(testTask.trigger()).to.be.instanceof(Promise)
-    })
-    it('testTask.trigger() returned Promise expect be fullfilled', function (done) {
-      testTask.trigger()
-        .then(done)
-    })
-    it('expect run a task without pre and afterTask', function (done) {
-      let localTestTask = new taskbuffer.Task({ taskFunction: testTaskFunction })
-      localTestTask.trigger().then(done)
-    })
-
-    it('expect run buffered', function (done) {
-      this.timeout(10000)
-      let localTestTask = new taskbuffer.Task({
-        taskFunction: testTaskFunctionTimeout,
-        buffered: true,
-        bufferMax: 2
-      })
-      localTestTask.trigger()
-      localTestTask.trigger()
-      localTestTask.trigger()
-      localTestTask.trigger().then(() => {
-        done()
-      })
-    })
-  })
-  describe('Taskchain', function () {
-    let testTaskchain
-    let testTaskArray = [
-      new taskbuffer.Task({
-        name: 'task1',
-        taskFunction: function () {
-          let done = q.defer()
-          setTimeout(done.resolve, 2000)
-          return done.promise
-        }
-      }),
-      new taskbuffer.Task({
-        name: 'task2',
-        taskFunction: function () {
-          let done = q.defer()
-          setTimeout(done.resolve, 2000)
-          return done.promise
-        }
-      })
-    ]
-    it('expect run tasks in sequence', function (done) {
-      this.timeout(5000)
-      testTaskchain = new taskbuffer.Taskchain({
-        name: 'Taskchain1',
-        taskArray: testTaskArray
-      })
-      testTaskchain.trigger().then(done)
-    })
-  })
-  describe('taskparallel', function () {
-    it('expect run in Parallel', function (done) {
-      this.timeout(7000)
-      let testTaskparallel = new taskbuffer.Taskparallel({
-        taskArray: [ task1, task2, task3 ]
-      })
-      testTaskparallel.trigger().then(() => {
-        done()
-      })
-    })
-  })
-  describe('some flowtests', function () {
-    let flowTask1 = new taskbuffer.Task({
-      taskFunction: (x: number) => {
-        let done = q.defer()
-        console.log('flowTask1')
-        console.log(x)
-        done.resolve(x)
-        return done.promise
-      }
-    })
-
-    let flowTaskBuffered = new taskbuffer.Task({
-      taskFunction: (x: number) => {
-        let done = q.defer()
-        console.log('flowTask1')
-        console.log(x)
-        done.resolve(x)
-        return done.promise
-      },
-      buffered: true,
-      bufferMax: 1
-    })
-
-    let flowTask2 = new taskbuffer.Task({
-      taskFunction: (x: number) => {
-        let done = q.defer()
-        console.log('flowTask2')
-        console.log(x)
-        done.resolve(x)
-        return done.promise
-      },
-      preTask: flowTask1
-    })
-    let flowTask3 = new taskbuffer.Taskchain({
-      taskArray: [ flowTask1, flowTask2 ]
-    })
-    it('should let a value flow through a task', function (done) {
-      flowTask1.trigger(12).then((x) => {
-        expect(x).to.equal(12)
-        done()
-      }).catch(done)
-    })
-    it('should let a values flow between tasks', function (done) {
-      flowTask2.trigger(12).then((x) => {
-        expect(x).to.equal(12)
-        done()
-      }).catch(done)
-    })
-
-    it('expect let a values flow between tasks when buffered', function (done) {
-      flowTaskBuffered.trigger(12).then((x) => {
-        expect(x).to.equal(12)
-        done()
-      }).catch(done)
-    })
-
-    it('should let a values flow between tasks in Taskchain', function (done) {
-      flowTask3.trigger(12).then((x) => {
-        expect(x).to.equal(12)
-        done()
-      }).catch(done)
-    })
-  })
-})

ts/index.ts

@@ -1,7 +1,6 @@
-export {Task,ITaskFunction} from './taskbuffer.classes.task';
-export {Taskchain} from './taskbuffer.classes.taskchain';
-export {Taskparallel} from './taskbuffer.classes.taskparallel';
-export {Taskspace} from './taskbuffer.classes.taskspace';
+export {Task,ITaskFunction} from './taskbuffer.classes.task'
+export {Taskchain} from './taskbuffer.classes.taskchain'
+export {Taskparallel} from './taskbuffer.classes.taskparallel'
 
 // import for naming only
 import './taskbuffer.classes.helpers'

ts/taskbuffer.classes.helpers.ts

@@ -1,4 +1,4 @@
-import plugins = require('./taskbuffer.plugins');
+import plugins = require('./taskbuffer.plugins')
 import { Task, ITaskFunction } from './taskbuffer.classes.task'
 
 export let emptyTaskFunction: ITaskFunction = function (x) {
@@ -18,7 +18,6 @@ export let isTask = function (taskArg: Task): boolean {
   }
 }
 
-
 export let isTaskTouched = (taskArg: Task, touchedTasksArray: Task[]): boolean => {
   let result = false
   for (let keyArg in touchedTasksArray) {
@@ -79,7 +78,6 @@ export let runTask = function (taskArg: Task, optionsArg: { x?, touchedTasksArra
   return done.promise
 }
 
-
 export interface cycleObject {
   cycleCounter: number,
   deferred: plugins.q.Deferred<any>
@@ -90,8 +88,8 @@ export class CycleCounter {
   cycleObjectArray: cycleObject[] = []
   constructor(taskArg: Task) {
     this.task = taskArg
-  };
-  getPromiseForCycle(cycleCountArg: number) {
+  }
+  getPromiseForCycle (cycleCountArg: number) {
     let done = plugins.q.defer()
     let cycleObject: cycleObject = {
       cycleCounter: cycleCountArg,
@@ -99,8 +97,8 @@ export class CycleCounter {
     }
     this.cycleObjectArray.push(cycleObject)
     return done.promise
-  };
-  informOfCycle(x) {
+  }
+  informOfCycle (x) {
     let newCycleObjectArray: cycleObject[] = []
     this.cycleObjectArray.forEach(cycleObjectArg => {
       cycleObjectArg.cycleCounter--
@@ -108,7 +106,7 @@ export class CycleCounter {
         cycleObjectArg.deferred.resolve(x)
       } else {
         newCycleObjectArray.push(cycleObjectArg)
-      };
+      }
     })
     this.cycleObjectArray = newCycleObjectArray
   }
@@ -122,8 +120,24 @@ export class BufferRunner {
   running: boolean = false
   constructor(taskArg: Task) {
     this.task = taskArg
-  };
-  private _run(x) {
+  }
+
+  setBufferMax (bufferMaxArg: number) {
+    this.bufferMax = bufferMaxArg
+  }
+
+  trigger (x): Promise<any> {
+    if (!(this.bufferCounter >= this.bufferMax)) {
+      this.bufferCounter++
+    }
+    let returnPromise: Promise<any> = this.task.cycleCounter.getPromiseForCycle(this.bufferCounter + 1)
+    if (!this.running) {
+      this._run(x)
+    }
+    return returnPromise
+  }
+
+  private _run (x) {
     let recursiveBufferRunner = (x) => {
       if (this.bufferCounter >= 0) {
         this.running = true
@@ -140,18 +154,6 @@ export class BufferRunner {
       }
     }
     recursiveBufferRunner(x)
-  };
-  setBufferMax(bufferMaxArg: number) {
-    this.bufferMax = bufferMaxArg
-  };
-  trigger(x): Promise<any> {
-    if (!(this.bufferCounter >= this.bufferMax)) {
-      this.bufferCounter++
-    };
-    let returnPromise: Promise<any> = this.task.cycleCounter.getPromiseForCycle(this.bufferCounter + 1)
-    if (!this.running) {
-      this._run(x)
-    }
-    return returnPromise
-  };
-};
+  }
+
+}

ts/taskbuffer.classes.task.ts

@@ -2,11 +2,11 @@ import * as plugins from './taskbuffer.plugins'
 import * as helpers from './taskbuffer.classes.helpers'
 
 export interface ITaskFunction {
-  (x?: any): PromiseLike<any>;
+  (x?: any): PromiseLike<any>
 }
 
 export class Task {
-  name: string;
+  name: string
   taskFunction: ITaskFunction
   buffered: boolean
   preTask: Task
@@ -19,7 +19,7 @@ export class Task {
   idle: boolean = true
   private _state: string = 'ready'
 
-  constructor(optionsArg: {
+  constructor (optionsArg: {
     taskFunction: ITaskFunction,
     preTask?: Task,
     afterTask?: Task,
@@ -40,37 +40,36 @@ export class Task {
   /**
    * trigger the task. Will trigger buffered if this.buffered is true
    */
-  trigger(x?): Promise<any> {
+  trigger (x?): Promise<any> {
     if (this.buffered) {
       return this.triggerBuffered(x)
-    }
-    else {
+    } else {
       return this.triggerUnBuffered(x)
-    };
-  };
+    }
+  }
 
   /**
    * trigger task unbuffered.
    */
-  triggerUnBuffered(x?): Promise<any> {
+  triggerUnBuffered (x?): Promise<any> {
     return helpers.runTask(this, { x: x })
   }
 
   /**
    * trigger task buffered.
    */
-  triggerBuffered(x?): Promise<any> {
+  triggerBuffered (x?): Promise<any> {
     return this.bufferRunner.trigger(x)
   }
 
-  get state(): string {
+  get state (): string {
     return this._state
   }
-  set state(stateArg: string) {
+  set state (stateArg: string) {
     if (stateArg === 'locked') {
       this._state = 'locked'
     } else {
       plugins.beautylog.error('state type ' + stateArg + ' could not be set')
     }
   }
-}
+}

ts/taskbuffer.classes.taskchain.ts

@@ -1,6 +1,9 @@
-import * as plugins from './taskbuffer.plugins';
-import { Task } from './taskbuffer.classes.task';
-import helpers = require('./taskbuffer.classes.helpers');
+// TaskChain chains tasks
+// and extends Task
+
+import * as plugins from './taskbuffer.plugins'
+import { Task } from './taskbuffer.classes.task'
+import helpers = require('./taskbuffer.classes.helpers')
 
 export class Taskchain extends Task {
   taskArray: Task[]
@@ -46,15 +49,15 @@ export class Taskchain extends Task {
     this._oraObject = plugins.beautylog.ora
     if (optionsArg.log === true) {
       this._oraObject.start()
-    };
+    }
   }
-  addTask(taskArg: Task) {
+  addTask (taskArg: Task) {
     this.taskArray.push(taskArg)
-  };
-  removeTask(taskArg: Task) {
-    // TODO
-  };
-  shiftTask() {
-
-  };
+  }
+  removeTask (taskArg: Task) {
+    // TODO:
+  }
+  shiftTask () {
+    // TODO:
+  }
 }

ts/taskbuffer.classes.taskmanager.ts

@@ -1 +1,89 @@
-import * as plugins from './taskbuffer.plugins'
+import * as plugins from './taskbuffer.plugins'
+import { Task } from './taskbuffer.classes.task'
+
+// interfaces
+import { Objectmap } from 'lik'
+
+export class TaskManager {
+  taskMap = new plugins.lik.Objectmap<Task>()
+  private cronJobArray: ICronJob[] = []
+  constructor () {
+    // nothing here
+  }
+
+  /**
+   * checks if a task is already present
+   * @param taskNameArg
+   */
+  getTaskByName (taskNameArg): Task {
+    return this.taskMap.find((itemArg) => {
+      return itemArg.name === taskNameArg
+    })
+  }
+
+  /**
+   * adds a Task to the TaskManager
+   * @param taskArg
+   */
+  addTask (taskArg: Task): void {
+    if (!taskArg.name) {
+      throw new Error('taskArg needs a name to be added to taskManager')
+    }
+    this.taskMap.add(taskArg)
+  }
+
+  /**
+   * adds and schedules a task at once
+   * @param taskArg
+   * @param cronStringArg
+   */
+  addAndScheduleTask (taskArg: Task, cronStringArg: string) {
+    this.addTask(taskArg)
+    let taskName = taskArg.name
+    this.scheduleTaskByName(taskName, cronStringArg)
+  }
+
+  /**
+   * triggers a task in the TaskManagerByName
+   * @param taskNameArg
+   */
+  triggerTaskByName (taskNameArg: string) {
+    let taskToTrigger = this.getTaskByName(taskNameArg)
+    if (!taskToTrigger) {
+      throw new Error(`There is no task with the name of ${taskNameArg}`)
+    }
+    taskToTrigger.trigger()
+  }
+
+  /**
+   * schedules the task by name
+   * @param taskNameArg
+   */
+  scheduleTaskByName (taskNameArg: string, cronStringArg: string) {
+    let taskToSchedule = this.getTaskByName(taskNameArg)
+    let job = new plugins.cron.CronJob({
+      cronTime: cronStringArg,
+      onTick: taskToSchedule.trigger,
+      start: true
+    })
+    this.cronJobArray.push({
+      taskNameArg: taskToSchedule.name,
+      cronString: cronStringArg,
+      job: job
+    })
+  }
+
+  /**
+   * returns all schedules of a specific task
+   * @param taskNameArg
+   */
+  getSchedulesForTaskName (taskNameArg: string) {
+
+  }
+}
+
+export interface ICronJob {
+  cronString: string
+  taskNameArg: string
+  job: any
+}

ts/taskbuffer.classes.taskparallel.ts

@@ -1,29 +1,28 @@
-import * as plugins from "./taskbuffer.plugins"
-import * as helpers from "./taskbuffer.classes.helpers"
-import { Task } from "./taskbuffer.classes.task"
+import * as plugins from './taskbuffer.plugins'
+import * as helpers from './taskbuffer.classes.helpers'
+import { Task } from './taskbuffer.classes.task'
 
 export class Taskparallel extends Task {
-    taskArray: Task[];
-    constructor(optionsArg: {
-        taskArray: Task[]
-    }){
-        let options = plugins.lodash.merge(
-            optionsArg,
-            {
-                taskFunction: () => {
-                    let done = plugins.q.defer();
-                    let promiseArray: Promise<any>[] = []; // stores promises of all tasks, since they run in parallel
-                    this.taskArray.forEach(function (taskArg) {
-                        promiseArray.push(taskArg.trigger());
-                    })
-                    Promise.all(promiseArray)
-                        .then(done.resolve);
-                    return done.promise;
-                }
-            }
-        );
-        super(options);
-        this.taskArray = optionsArg.taskArray;
-    }
+  taskArray: Task[]
+  constructor (optionsArg: {
+    taskArray: Task[]
+  }) {
+    let options = plugins.lodash.merge(
+      optionsArg,
+      {
+        taskFunction: () => {
+          let done = plugins.q.defer()
+          let promiseArray: Promise<any>[] = [] // stores promises of all tasks, since they run in parallel
+          this.taskArray.forEach(function (taskArg) {
+            promiseArray.push(taskArg.trigger())
+          })
+          Promise.all(promiseArray)
+            .then(done.resolve)
+          return done.promise
+        }
+      }
+    )
+    super(options)
+    this.taskArray = optionsArg.taskArray
+  }
 }
-

ts/taskbuffer.classes.taskspace.ts

@@ -1,6 +0,0 @@
-import * as plugins from "./taskbuffer.plugins"
-import * as helpers from "./taskbuffer.classes.helpers"
-
-export class Taskspace {
-    
-}

ts/taskbuffer.plugins.ts

@@ -1,12 +1,18 @@
 import 'typings-global'
 import * as beautylog from 'beautylog'
+let cron = require('cron')
+import * as lik from 'lik'
 import * as lodash from 'lodash'
 import * as rxjs from 'rxjs'
 import * as q from 'smartq'
+import * as smartdelay from 'smartdelay'
 
 export {
     beautylog,
+    cron,
+    lik,
     lodash,
     rxjs,
-    q
-}
+    q,
+    smartdelay
+}

yarn.lock

@@ -9,36 +9,50 @@
     "@types/chai" "*"
     "@types/promises-a-plus" "*"
 
-"@types/chai@*", "@types/chai@^3.4.34":
-  version "3.4.34"
-  resolved "https://registry.yarnpkg.com/@types/chai/-/chai-3.4.34.tgz#d5335792823bb09cddd5e38c3d211b709183854d"
+"@types/chai-string@^1.1.30":
+  version "1.1.30"
+  resolved "https://registry.yarnpkg.com/@types/chai-string/-/chai-string-1.1.30.tgz#4d8744b31a5a2295fc01c981ed1e2d4c8a070f0a"
+  dependencies:
+    "@types/chai" "*"
 
-"@types/lodash@4.x.x":
-  version "4.14.52"
-  resolved "https://registry.yarnpkg.com/@types/lodash/-/lodash-4.14.52.tgz#de5c7ab14da1289733233c9b0ec6f9e377db90f5"
+"@types/chai@*", "@types/chai@^3.4.35":
+  version "3.5.2"
+  resolved "https://registry.yarnpkg.com/@types/chai/-/chai-3.5.2.tgz#c11cd2817d3a401b7ba0f5a420f35c56139b1c1e"
 
-"@types/mocha@^2.2.31":
-  version "2.2.39"
-  resolved "https://registry.yarnpkg.com/@types/mocha/-/mocha-2.2.39.tgz#f68d63db8b69c38e9558b4073525cf96c4f7a829"
+"@types/cron@^1.2.1":
+  version "1.2.1"
+  resolved "https://registry.yarnpkg.com/@types/cron/-/cron-1.2.1.tgz#95c1e432d6106ca34c92f0743638bc786c073faa"
 
-"@types/node@*":
-  version "7.0.5"
-  resolved "https://registry.yarnpkg.com/@types/node/-/node-7.0.5.tgz#96a0f0a618b7b606f1ec547403c00650210bfbb7"
+"@types/lodash@4.x.x", "@types/lodash@^4.14.55", "@types/lodash@^4.14.62":
+  version "4.14.66"
+  resolved "https://registry.yarnpkg.com/@types/lodash/-/lodash-4.14.66.tgz#3dbb83477becf130611f8fac82a8fdb199805981"
+
+"@types/minimatch@2.x.x":
+  version "2.0.29"
+  resolved "https://registry.yarnpkg.com/@types/minimatch/-/minimatch-2.0.29.tgz#5002e14f75e2d71e564281df0431c8c1b4a2a36a"
+
+"@types/node@*", "@types/node@^7.0.29":
+  version "7.0.31"
+  resolved "https://registry.yarnpkg.com/@types/node/-/node-7.0.31.tgz#80ea4d175599b2a00149c29a10a4eb2dff592e86"
 
 "@types/promises-a-plus@*":
   version "0.0.27"
   resolved "https://registry.yarnpkg.com/@types/promises-a-plus/-/promises-a-plus-0.0.27.tgz#c64651134614c84b8f5d7114ce8901d36a609780"
 
-"@types/q@0.x.x":
-  version "0.0.32"
-  resolved "https://registry.yarnpkg.com/@types/q/-/q-0.0.32.tgz#bd284e57c84f1325da702babfc82a5328190c0c5"
+"@types/q@1.x.x":
+  version "1.0.1"
+  resolved "https://registry.yarnpkg.com/@types/q/-/q-1.0.1.tgz#dbccb01bd8f0f801a12a4604c7d7af59bb02ae2f"
 
-"@types/shelljs@^0.3.33":
-  version "0.3.33"
-  resolved "https://registry.yarnpkg.com/@types/shelljs/-/shelljs-0.3.33.tgz#df613bddb88225ed09ce5c835f620dcaaf155e6b"
+"@types/shelljs@^0.6.0":
+  version "0.6.0"
+  resolved "https://registry.yarnpkg.com/@types/shelljs/-/shelljs-0.6.0.tgz#090b705c102ce7fc5c0c5ea9b524418ff15840df"
   dependencies:
     "@types/node" "*"
 
+"@types/which@^1.0.28":
+  version "1.0.28"
+  resolved "https://registry.yarnpkg.com/@types/which/-/which-1.0.28.tgz#016e387629b8817bed653fe32eab5d11279c8df6"
+
 ansi-256-colors@^1.1.0:
   version "1.1.0"
   resolved "https://registry.yarnpkg.com/ansi-256-colors/-/ansi-256-colors-1.1.0.tgz#910de50efcc7c09e3d82f2f87abd6b700c18818a"
@@ -55,35 +69,39 @@ assertion-error@^1.0.1:
   version "1.0.2"
   resolved "https://registry.yarnpkg.com/assertion-error/-/assertion-error-1.0.2.tgz#13ca515d86206da0bac66e834dd397d87581094c"
 
-balanced-match@^0.4.1:
-  version "0.4.2"
-  resolved "https://registry.yarnpkg.com/balanced-match/-/balanced-match-0.4.2.tgz#cb3f3e3c732dc0f01ee70b403f302e61d7709838"
+balanced-match@^1.0.0:
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/balanced-match/-/balanced-match-1.0.0.tgz#89b4d199ab2bee49de164ea02b89ce462d71b767"
 
-beautycolor@^1.0.5:
+beautycolor@^1.0.7:
   version "1.0.7"
   resolved "https://registry.yarnpkg.com/beautycolor/-/beautycolor-1.0.7.tgz#a4715738ac4c8221371e9cbeb5a6cc6d11ecbf7c"
   dependencies:
     ansi-256-colors "^1.1.0"
     typings-global "^1.0.14"
 
-beautylog@^6.1.1:
-  version "6.1.1"
-  resolved "https://registry.yarnpkg.com/beautylog/-/beautylog-6.1.1.tgz#2a83603ad7e2a0a09701ac63d7d3064a588dc779"
+beautylog@^6.1.10:
+  version "6.1.10"
+  resolved "https://registry.yarnpkg.com/beautylog/-/beautylog-6.1.10.tgz#9c27e566937684cb689f9372d98cfa5415d50b72"
   dependencies:
-    "@types/lodash" "4.x.x"
-    beautycolor "^1.0.5"
+    "@types/lodash" "^4.14.55"
+    beautycolor "^1.0.7"
     figlet "^1.2.0"
     lodash "^4.17.4"
     ora "^1.1.0"
     smartenv "^2.0.0"
-    smartq "^1.0.4"
+    smartq "^1.1.1"
     typings-global "^1.0.14"
 
-brace-expansion@^1.0.0:
-  version "1.1.6"
-  resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-1.1.6.tgz#7197d7eaa9b87e648390ea61fc66c84427420df9"
+bindings@^1.2.1:
+  version "1.2.1"
+  resolved "https://registry.yarnpkg.com/bindings/-/bindings-1.2.1.tgz#14ad6113812d2d37d72e67b4cacb4bb726505f11"
+
+brace-expansion@^1.1.7:
+  version "1.1.8"
+  resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-1.1.8.tgz#c07b211c7c952ec1f8efd51a77ef0d1d3990a292"
   dependencies:
-    balanced-match "^0.4.1"
+    balanced-match "^1.0.0"
     concat-map "0.0.1"
 
 chai-as-promised@^6.0.0:
@@ -92,6 +110,10 @@ chai-as-promised@^6.0.0:
   dependencies:
     check-error "^1.0.2"
 
+chai-string@^1.3.0:
+  version "1.4.0"
+  resolved "https://registry.yarnpkg.com/chai-string/-/chai-string-1.4.0.tgz#359140c051d36a4e4b1a5fc6b910152f438a8d49"
+
 chai@^3.5.0:
   version "3.5.0"
   resolved "https://registry.yarnpkg.com/chai/-/chai-3.5.0.tgz#4d02637b067fe958bdbfdd3a40ec56fef7373247"
@@ -128,12 +150,30 @@ concat-map@0.0.1:
   version "0.0.1"
   resolved "https://registry.yarnpkg.com/concat-map/-/concat-map-0.0.1.tgz#d8a96bd77fd68df7793a73036a3ba0d5405d477b"
 
+cron@^1.2.1:
+  version "1.2.1"
+  resolved "https://registry.yarnpkg.com/cron/-/cron-1.2.1.tgz#3a86c09b41b8f261ac863a7cc85ea4735857eab2"
+  dependencies:
+    moment-timezone "^0.5.x"
+
 deep-eql@^0.1.3:
   version "0.1.3"
   resolved "https://registry.yarnpkg.com/deep-eql/-/deep-eql-0.1.3.tgz#ef558acab8de25206cd713906d74e56930eb69f2"
   dependencies:
     type-detect "0.1.1"
 
+early@^2.1.1:
+  version "2.1.1"
+  resolved "https://registry.yarnpkg.com/early/-/early-2.1.1.tgz#841e23254ea5dc54d8afaeee82f5ab65c00ee23c"
+  dependencies:
+    beautycolor "^1.0.7"
+    smartq "^1.1.1"
+    typings-global "^1.0.16"
+
+es6-error@^4.0.2:
+  version "4.0.2"
+  resolved "https://registry.yarnpkg.com/es6-error/-/es6-error-4.0.2.tgz#eec5c726eacef51b7f6b73c20db6e1b13b069c98"
+
 escape-string-regexp@^1.0.2:
   version "1.0.5"
   resolved "https://registry.yarnpkg.com/escape-string-regexp/-/escape-string-regexp-1.0.5.tgz#1b61c0562190a8dff6ae3bb2cf0200ca130b86d4"
@@ -147,13 +187,13 @@ fs.realpath@^1.0.0:
   resolved "https://registry.yarnpkg.com/fs.realpath/-/fs.realpath-1.0.0.tgz#1504ad2523158caa40db4a2787cb01411994ea4f"
 
 glob@^7.0.0:
-  version "7.1.1"
-  resolved "https://registry.yarnpkg.com/glob/-/glob-7.1.1.tgz#805211df04faaf1c63a3600306cdf5ade50b2ec8"
+  version "7.1.2"
+  resolved "https://registry.yarnpkg.com/glob/-/glob-7.1.2.tgz#c19c9df9a028702d678612384a6552404c636d15"
   dependencies:
     fs.realpath "^1.0.0"
     inflight "^1.0.4"
     inherits "2"
-    minimatch "^3.0.2"
+    minimatch "^3.0.4"
     once "^1.3.0"
     path-is-absolute "^1.0.0"
 
@@ -175,10 +215,43 @@ inherits@2:
   resolved "https://registry.yarnpkg.com/inherits/-/inherits-2.0.3.tgz#633c2c83e3da42a502f52466022480f4208261de"
 
 interpret@^1.0.0:
-  version "1.0.1"
-  resolved "https://registry.yarnpkg.com/interpret/-/interpret-1.0.1.tgz#d579fb7f693b858004947af39fa0db49f795602c"
+  version "1.0.3"
+  resolved "https://registry.yarnpkg.com/interpret/-/interpret-1.0.3.tgz#cbc35c62eeee73f19ab7b10a801511401afc0f90"
 
-lodash@^4.17.2, lodash@^4.17.4:
+isexe@^2.0.0:
+  version "2.0.0"
+  resolved "https://registry.yarnpkg.com/isexe/-/isexe-2.0.0.tgz#e8fbf374dc556ff8947a10dcb0572d633f2cfa10"
+
+leakage@^0.3.0:
+  version "0.3.0"
+  resolved "https://registry.yarnpkg.com/leakage/-/leakage-0.3.0.tgz#15d698abdc76bbc6439601f4f3020e77e2d50c39"
+  dependencies:
+    es6-error "^4.0.2"
+    left-pad "^1.1.3"
+    memwatch-next "^0.3.0"
+    minimist "^1.2.0"
+    pretty-bytes "^4.0.2"
+
+left-pad@^1.1.3:
+  version "1.1.3"
+  resolved "https://registry.yarnpkg.com/left-pad/-/left-pad-1.1.3.tgz#612f61c033f3a9e08e939f1caebeea41b6f3199a"
+
+lik@^1.0.31:
+  version "1.0.31"
+  resolved "https://registry.yarnpkg.com/lik/-/lik-1.0.31.tgz#5c7635d880cdbb28aeb1259223fd948797616bcd"
+  dependencies:
+    "@types/lodash" "^4.14.62"
+    "@types/minimatch" "2.x.x"
+    "@types/q" "1.x.x"
+    lodash "^4.17.4"
+    minimatch "^3.0.3"
+    q "^1.5.0"
+    rxjs "^5.3.0"
+    smartq "^1.1.1"
+    tapbundle "^1.0.14"
+    typings-global "^1.0.14"
+
+lodash@^4.17.4:
   version "4.17.4"
   resolved "https://registry.yarnpkg.com/lodash/-/lodash-4.17.4.tgz#78203a4d1c328ae1d86dca6460e369b57f4055ae"
 
@@ -188,24 +261,40 @@ log-symbols@^1.0.2:
   dependencies:
     chalk "^1.0.0"
 
+memwatch-next@^0.3.0:
+  version "0.3.0"
+  resolved "https://registry.yarnpkg.com/memwatch-next/-/memwatch-next-0.3.0.tgz#2111050f9a906e0aa2d72a4ec0f0089c78726f8f"
+  dependencies:
+    bindings "^1.2.1"
+    nan "^2.3.2"
+
 mimic-fn@^1.0.0:
   version "1.1.0"
   resolved "https://registry.yarnpkg.com/mimic-fn/-/mimic-fn-1.1.0.tgz#e667783d92e89dbd342818b5230b9d62a672ad18"
 
-minimatch@^3.0.2:
-  version "3.0.3"
-  resolved "https://registry.yarnpkg.com/minimatch/-/minimatch-3.0.3.tgz#2a4e4090b96b2db06a9d7df01055a62a77c9b774"
+minimatch@^3.0.3, minimatch@^3.0.4:
+  version "3.0.4"
+  resolved "https://registry.yarnpkg.com/minimatch/-/minimatch-3.0.4.tgz#5166e286457f03306064be5497e8dbb0c3d32083"
   dependencies:
-    brace-expansion "^1.0.0"
+    brace-expansion "^1.1.7"
 
-npmts-g@^6.0.0:
-  version "6.0.0"
-  resolved "https://registry.yarnpkg.com/npmts-g/-/npmts-g-6.0.0.tgz#491fd50f110967f1b68f14237e7ea5157bf4ddb3"
+minimist@^1.2.0:
+  version "1.2.0"
+  resolved "https://registry.yarnpkg.com/minimist/-/minimist-1.2.0.tgz#a35008b20f41383eec1fb914f4cd5df79a264284"
+
+moment-timezone@^0.5.x:
+  version "0.5.13"
+  resolved "https://registry.yarnpkg.com/moment-timezone/-/moment-timezone-0.5.13.tgz#99ce5c7d827262eb0f1f702044177f60745d7b90"
   dependencies:
-    "@types/shelljs" "^0.3.33"
-    semver "^5.3.0"
-    shelljs "^0.7.5"
-    typings-global "^1.0.14"
+    moment ">= 2.9.0"
+
+"moment@>= 2.9.0":
+  version "2.18.1"
+  resolved "https://registry.yarnpkg.com/moment/-/moment-2.18.1.tgz#c36193dd3ce1c2eed2adb7c802dbbc77a81b1c0f"
+
+nan@^2.3.2:
+  version "2.6.2"
+  resolved "https://registry.yarnpkg.com/nan/-/nan-2.6.2.tgz#e4ff34e6c95fdfb5aecc08de6596f43605a7db45"
 
 once@^1.3.0:
   version "1.4.0"
@@ -214,14 +303,14 @@ once@^1.3.0:
     wrappy "1"
 
 onetime@^2.0.0:
-  version "2.0.0"
-  resolved "https://registry.yarnpkg.com/onetime/-/onetime-2.0.0.tgz#52aa8110e52fc5126ffc667bd8ec21c2ed209ce6"
+  version "2.0.1"
+  resolved "https://registry.yarnpkg.com/onetime/-/onetime-2.0.1.tgz#067428230fd67443b2794b22bba528b6867962d4"
   dependencies:
     mimic-fn "^1.0.0"
 
 ora@^1.1.0:
-  version "1.1.0"
-  resolved "https://registry.yarnpkg.com/ora/-/ora-1.1.0.tgz#69aaa4a209630e43b142c5f7ff41820da87e2faf"
+  version "1.3.0"
+  resolved "https://registry.yarnpkg.com/ora/-/ora-1.3.0.tgz#80078dd2b92a934af66a3ad72a5b910694ede51a"
   dependencies:
     chalk "^1.1.1"
     cli-cursor "^2.1.0"
@@ -232,9 +321,17 @@ path-is-absolute@^1.0.0:
   version "1.0.1"
   resolved "https://registry.yarnpkg.com/path-is-absolute/-/path-is-absolute-1.0.1.tgz#174b9268735534ffbc7ace6bf53a5a9e1b5c5f5f"
 
-q@^1.4.1:
-  version "1.4.1"
-  resolved "https://registry.yarnpkg.com/q/-/q-1.4.1.tgz#55705bcd93c5f3673530c2c2cbc0c2b3addc286e"
+path-parse@^1.0.5:
+  version "1.0.5"
+  resolved "https://registry.yarnpkg.com/path-parse/-/path-parse-1.0.5.tgz#3c1adf871ea9cd6c9431b6ea2bd74a0ff055c4c1"
+
+pretty-bytes@^4.0.2:
+  version "4.0.2"
+  resolved "https://registry.yarnpkg.com/pretty-bytes/-/pretty-bytes-4.0.2.tgz#b2bf82e7350d65c6c33aa95aaa5a4f6327f61cd9"
+
+q@^1.5.0:
+  version "1.5.0"
+  resolved "https://registry.yarnpkg.com/q/-/q-1.5.0.tgz#dd01bac9d06d30e6f219aecb8253ee9ebdc308f1"
 
 rechoir@^0.6.2:
   version "0.6.2"
@@ -243,8 +340,10 @@ rechoir@^0.6.2:
     resolve "^1.1.6"
 
 resolve@^1.1.6:
-  version "1.2.0"
-  resolved "https://registry.yarnpkg.com/resolve/-/resolve-1.2.0.tgz#9589c3f2f6149d1417a40becc1663db6ec6bc26c"
+  version "1.3.3"
+  resolved "https://registry.yarnpkg.com/resolve/-/resolve-1.3.3.tgz#655907c3469a8680dc2de3a275a8fdd69691f0e5"
+  dependencies:
+    path-parse "^1.0.5"
 
 restore-cursor@^2.0.0:
   version "2.0.0"
@@ -253,9 +352,9 @@ restore-cursor@^2.0.0:
     onetime "^2.0.0"
     signal-exit "^3.0.2"
 
-rxjs@^5.1.1:
-  version "5.1.1"
-  resolved "https://registry.yarnpkg.com/rxjs/-/rxjs-5.1.1.tgz#fc48922965bc6c5efbcc0fe46e90a3af64137a7b"
+rxjs@^5.3.0, rxjs@^5.4.1:
+  version "5.4.1"
+  resolved "https://registry.yarnpkg.com/rxjs/-/rxjs-5.4.1.tgz#b62f757f279445d265a18a58fb0a70dc90e91626"
   dependencies:
     symbol-observable "^1.0.1"
 
@@ -263,9 +362,9 @@ semver@^5.3.0:
   version "5.3.0"
   resolved "https://registry.yarnpkg.com/semver/-/semver-5.3.0.tgz#9b2ce5d3de02d17c6012ad326aa6b4d0cf54f94f"
 
-shelljs@^0.7.4, shelljs@^0.7.5:
-  version "0.7.6"
-  resolved "https://registry.yarnpkg.com/shelljs/-/shelljs-0.7.6.tgz#379cccfb56b91c8601e4793356eb5382924de9ad"
+shelljs@^0.7.6:
+  version "0.7.8"
+  resolved "https://registry.yarnpkg.com/shelljs/-/shelljs-0.7.8.tgz#decbcf874b0d1e5fb72e14b164a9683048e9acb3"
   dependencies:
     glob "^7.0.0"
     interpret "^1.0.0"
@@ -275,31 +374,49 @@ signal-exit@^3.0.2:
   version "3.0.2"
   resolved "https://registry.yarnpkg.com/signal-exit/-/signal-exit-3.0.2.tgz#b5fdc08f1287ea1178628e415e25132b73646c6d"
 
-smartchai@^1.0.1:
-  version "1.0.1"
-  resolved "https://registry.yarnpkg.com/smartchai/-/smartchai-1.0.1.tgz#cde7776212fa5145d62dc4195405929807a3e0e5"
+smartchai@^1.0.3:
+  version "1.0.3"
+  resolved "https://registry.yarnpkg.com/smartchai/-/smartchai-1.0.3.tgz#de6d010bb8b5aef24cb70b31a5f5334e8c41b72f"
   dependencies:
-    "@types/chai" "^3.4.34"
+    "@types/chai" "^3.4.35"
     "@types/chai-as-promised" "0.0.29"
+    "@types/chai-string" "^1.1.30"
     chai "^3.5.0"
     chai-as-promised "^6.0.0"
+    chai-string "^1.3.0"
+
+smartdelay@^1.0.3:
+  version "1.0.3"
+  resolved "https://registry.yarnpkg.com/smartdelay/-/smartdelay-1.0.3.tgz#5fd44dad77262d110702f0293efa80c072cfb579"
+  dependencies:
+    smartq "^1.1.1"
+    typings-global "^1.0.16"
 
 smartenv@^2.0.0:
-  version "2.0.0"
-  resolved "https://registry.yarnpkg.com/smartenv/-/smartenv-2.0.0.tgz#ede4e2044efcf9bec318388bb1dab53024ee3d16"
+  version "2.0.6"
+  resolved "https://registry.yarnpkg.com/smartenv/-/smartenv-2.0.6.tgz#b38c679b0c151b9af548f68c3a072c29d1417e8d"
   dependencies:
-    "@types/q" "0.x.x"
-    lodash "^4.17.2"
-    q "^1.4.1"
+    lodash "^4.17.4"
+    smartq "^1.1.1"
     typings-global "^1.0.14"
 
-smartq@^1.0.4, smartq@^1.1.1:
+smartq@^1.1.0, smartq@^1.1.1:
   version "1.1.1"
   resolved "https://registry.yarnpkg.com/smartq/-/smartq-1.1.1.tgz#efb358705260d41ae18aef7ffd815f7b6fe17dd3"
   dependencies:
     typed-promisify "^0.3.0"
     typings-global "^1.0.14"
 
+smartshell@^1.0.6:
+  version "1.0.6"
+  resolved "https://registry.yarnpkg.com/smartshell/-/smartshell-1.0.6.tgz#27b1c79029784abe72ac7e91fe698b7ebecc6629"
+  dependencies:
+    "@types/shelljs" "^0.6.0"
+    "@types/which" "^1.0.28"
+    shelljs "^0.7.6"
+    smartq "^1.1.0"
+    which "^1.2.12"
+
 strip-ansi@^3.0.0:
   version "3.0.1"
   resolved "https://registry.yarnpkg.com/strip-ansi/-/strip-ansi-3.0.1.tgz#6a385fb8853d952d5ff05d0e8aaf94278dc63dcf"
@@ -314,6 +431,17 @@ symbol-observable@^1.0.1:
   version "1.0.4"
   resolved "https://registry.yarnpkg.com/symbol-observable/-/symbol-observable-1.0.4.tgz#29bf615d4aa7121bdd898b22d4b3f9bc4e2aa03d"
 
+tapbundle@^1.0.14:
+  version "1.0.14"
+  resolved "https://registry.yarnpkg.com/tapbundle/-/tapbundle-1.0.14.tgz#75827e335fcb02216f0267a26a26d702ddc02e3c"
+  dependencies:
+    early "^2.1.1"
+    leakage "^0.3.0"
+    smartchai "^1.0.3"
+    smartdelay "^1.0.3"
+    smartq "^1.1.1"
+    typings-global "^1.0.16"
+
 type-detect@0.1.1:
   version "0.1.1"
   resolved "https://registry.yarnpkg.com/type-detect/-/type-detect-0.1.1.tgz#0ba5ec2a885640e470ea4e8505971900dac58822"
@@ -326,19 +454,19 @@ typed-promisify@^0.3.0:
   version "0.3.0"
   resolved "https://registry.yarnpkg.com/typed-promisify/-/typed-promisify-0.3.0.tgz#1ba0af5e444c87d8047406f18ce49092a1191853"
 
-typings-global@*, typings-global@^1.0.14:
-  version "1.0.14"
-  resolved "https://registry.yarnpkg.com/typings-global/-/typings-global-1.0.14.tgz#ab682720a03d6b9278869fb5c30c30d7dc61d12c"
+typings-global@^1.0.14, typings-global@^1.0.16, typings-global@^1.0.17:
+  version "1.0.17"
+  resolved "https://registry.yarnpkg.com/typings-global/-/typings-global-1.0.17.tgz#41edc331ccec3168289adc8849e1e255efbe7152"
   dependencies:
+    "@types/node" "^7.0.29"
     semver "^5.3.0"
-    shelljs "^0.7.4"
+    smartshell "^1.0.6"
 
-typings-test@^1.0.3:
-  version "1.0.3"
-  resolved "https://registry.yarnpkg.com/typings-test/-/typings-test-1.0.3.tgz#fbab895eb3f0c44842e73db059f65946b971e369"
+which@^1.2.12:
+  version "1.2.14"
+  resolved "https://registry.yarnpkg.com/which/-/which-1.2.14.tgz#9a87c4378f03e827cecaf1acdf56c736c01c14e5"
   dependencies:
-    "@types/mocha" "^2.2.31"
-    typings-global "*"
+    isexe "^2.0.0"
 
 wrappy@1:
   version "1.0.2"