1.0.18

dist/index.d.ts

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

dist/index.js

@@ -6,6 +6,8 @@ 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_taskmanager_1 = require("./taskbuffer.classes.taskmanager");
+exports.TaskManager = taskbuffer_classes_taskmanager_1.TaskManager;
 // import for naming only
 require("./taskbuffer.classes.helpers");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLHFFQUE0RDtBQUFwRCx5Q0FBQSxJQUFJLENBQUE7QUFDWiwrRUFBd0Q7QUFBaEQsbURBQUEsU0FBUyxDQUFBO0FBQ2pCLHFGQUE4RDtBQUF0RCx5REFBQSxZQUFZLENBQUE7QUFFcEIseUJBQXlCO0FBQ3pCLHdDQUFxQyJ9
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLHFFQUE0RDtBQUFwRCx5Q0FBQSxJQUFJLENBQUE7QUFDWiwrRUFBd0Q7QUFBaEQsbURBQUEsU0FBUyxDQUFBO0FBQ2pCLHFGQUE4RDtBQUF0RCx5REFBQSxZQUFZLENBQUE7QUFDcEIsbUZBQThEO0FBQXJELHVEQUFBLFdBQVcsQ0FBQTtBQUVwQix5QkFBeUI7QUFDekIsd0NBQXFDIn0=

dist/taskbuffer.classes.helpers.d.ts

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

dist/taskbuffer.classes.task.d.ts

@@ -6,6 +6,8 @@ export declare class Task {
     name: string;
     taskFunction: ITaskFunction;
     buffered: boolean;
+    bufferMax: number;
+    execDelay: number;
     preTask: Task;
     afterTask: Task;
     running: boolean;
@@ -14,11 +16,34 @@ export declare class Task {
     idle: boolean;
     private _state;
     constructor(optionsArg: {
+        /**
+         * the task function to run, must return promise
+         */
         taskFunction: ITaskFunction;
+        /**
+         * any other task to run before
+         */
         preTask?: Task;
+        /**
+         * any other task to run after
+         */
         afterTask?: Task;
+        /**
+         * wether this task should run buffered
+         */
         buffered?: boolean;
+        /**
+         * the maximum buffer
+         */
         bufferMax?: number;
+        /**
+         * the execution delay, before the task is executed
+         * only makes sense when running in buffered mode
+         */
+        execDelay?: number;
+        /**
+         * the name of the task
+         */
         name?: string;
     });
     /**

dist/taskbuffer.classes.task.js

@@ -10,14 +10,14 @@ class Task {
         this.cycleCounter = new helpers.CycleCounter(this);
         this.idle = true;
         this._state = 'ready';
-        let options = optionsArg;
         this.taskFunction = optionsArg.taskFunction;
-        this.preTask = options.preTask;
-        this.afterTask = options.afterTask;
+        this.preTask = optionsArg.preTask;
+        this.afterTask = optionsArg.afterTask;
         this.idle = !this.running;
-        this.buffered = options.buffered;
-        this.bufferRunner.setBufferMax(options.bufferMax);
-        this.name = options.name;
+        this.buffered = optionsArg.buffered;
+        this.bufferMax = optionsArg.bufferMax;
+        this.execDelay = optionsArg.execDelay;
+        this.name = optionsArg.name;
     }
     /**
      * trigger the task. Will trigger buffered if this.buffered is true
@@ -55,4 +55,4 @@ class Task {
     }
 }
 exports.Task = Task;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2suanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy90YXNrYnVmZmVyLmNsYXNzZXMudGFzay50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLGdEQUErQztBQUMvQyx3REFBdUQ7QUFNdkQ7SUFjRSxZQUFhLFVBT1o7UUFkRCx3QkFBd0I7UUFDeEIsWUFBTyxHQUFZLEtBQUssQ0FBQTtRQUN4QixpQkFBWSxHQUFHLElBQUksT0FBTyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUM3QyxpQkFBWSxHQUFHLElBQUksT0FBTyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUM3QyxTQUFJLEdBQVksSUFBSSxDQUFBO1FBQ1osV0FBTSxHQUFXLE9BQU8sQ0FBQTtRQVU5QixJQUFJLE9BQU8sR0FBRyxVQUFVLENBQUE7UUFDeEIsSUFBSSxDQUFDLFlBQVksR0FBRyxVQUFVLENBQUMsWUFBWSxDQUFBO1FBQzNDLElBQUksQ0FBQyxPQUFPLEdBQUcsT0FBTyxDQUFDLE9BQU8sQ0FBQTtRQUM5QixJQUFJLENBQUMsU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUE7UUFDbEMsSUFBSSxDQUFDLElBQUksR0FBRyxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7UUFDekIsSUFBSSxDQUFDLFFBQVEsR0FBRyxPQUFPLENBQUMsUUFBUSxDQUFBO1FBQ2hDLElBQUksQ0FBQyxZQUFZLENBQUMsWUFBWSxDQUFDLE9BQU8sQ0FBQyxTQUFTLENBQUMsQ0FBQTtRQUNqRCxJQUFJLENBQUMsSUFBSSxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQUE7SUFDMUIsQ0FBQztJQUVEOztPQUVHO0lBQ0gsT0FBTyxDQUFFLENBQUU7UUFDVCxFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztZQUNsQixNQUFNLENBQUMsSUFBSSxDQUFDLGVBQWUsQ0FBQyxDQUFDLENBQUMsQ0FBQTtRQUNoQyxDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDTixNQUFNLENBQUMsSUFBSSxDQUFDLGlCQUFpQixDQUFDLENBQUMsQ0FBQyxDQUFBO1FBQ2xDLENBQUM7SUFDSCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxpQkFBaUIsQ0FBRSxDQUFFO1FBQ25CLE1BQU0sQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLElBQUksRUFBRSxFQUFFLENBQUMsRUFBRSxDQUFDLEVBQUUsQ0FBQyxDQUFBO0lBQ3hDLENBQUM7SUFFRDs7T0FFRztJQUNILGVBQWUsQ0FBRSxDQUFFO1FBQ2pCLE1BQU0sQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUMsQ0FBQTtJQUNyQyxDQUFDO0lBRUQsSUFBSSxLQUFLO1FBQ1AsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUE7SUFDcEIsQ0FBQztJQUNELElBQUksS0FBSyxDQUFFLFFBQWdCO1FBQ3pCLEVBQUUsQ0FBQyxDQUFDLFFBQVEsS0FBSyxRQUFRLENBQUMsQ0FBQyxDQUFDO1lBQzFCLElBQUksQ0FBQyxNQUFNLEdBQUcsUUFBUSxDQUFBO1FBQ3hCLENBQUM7UUFBQyxJQUFJLENBQUMsQ0FBQztZQUNOLE9BQU8sQ0FBQyxTQUFTLENBQUMsS0FBSyxDQUFDLGFBQWEsR0FBRyxRQUFRLEdBQUcsbUJBQW1CLENBQUMsQ0FBQTtRQUN6RSxDQUFDO0lBQ0gsQ0FBQztDQUNGO0FBbkVELG9CQW1FQyJ9
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2suanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy90YXNrYnVmZmVyLmNsYXNzZXMudGFzay50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLGdEQUErQztBQUMvQyx3REFBdUQ7QUFNdkQ7SUFxQkUsWUFBWSxVQThCWDtRQXRDRCx3QkFBd0I7UUFDeEIsWUFBTyxHQUFZLEtBQUssQ0FBQTtRQUN4QixpQkFBWSxHQUFHLElBQUksT0FBTyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUM3QyxpQkFBWSxHQUFHLElBQUksT0FBTyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUU3QyxTQUFJLEdBQVksSUFBSSxDQUFBO1FBQ1osV0FBTSxHQUFXLE9BQU8sQ0FBQTtRQWlDOUIsSUFBSSxDQUFDLFlBQVksR0FBRyxVQUFVLENBQUMsWUFBWSxDQUFBO1FBQzNDLElBQUksQ0FBQyxPQUFPLEdBQUcsVUFBVSxDQUFDLE9BQU8sQ0FBQTtRQUNqQyxJQUFJLENBQUMsU0FBUyxHQUFHLFVBQVUsQ0FBQyxTQUFTLENBQUE7UUFDckMsSUFBSSxDQUFDLElBQUksR0FBRyxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7UUFDekIsSUFBSSxDQUFDLFFBQVEsR0FBRyxVQUFVLENBQUMsUUFBUSxDQUFBO1FBQ25DLElBQUksQ0FBQyxTQUFTLEdBQUcsVUFBVSxDQUFDLFNBQVMsQ0FBQTtRQUNyQyxJQUFJLENBQUMsU0FBUyxHQUFHLFVBQVUsQ0FBQyxTQUFTLENBQUE7UUFDckMsSUFBSSxDQUFDLElBQUksR0FBRyxVQUFVLENBQUMsSUFBSSxDQUFBO0lBQzdCLENBQUM7SUFFRDs7T0FFRztJQUNILE9BQU8sQ0FBQyxDQUFFO1FBQ1IsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxDQUFDLENBQUM7WUFDbEIsTUFBTSxDQUFDLElBQUksQ0FBQyxlQUFlLENBQUMsQ0FBQyxDQUFDLENBQUE7UUFDaEMsQ0FBQztRQUFDLElBQUksQ0FBQyxDQUFDO1lBQ04sTUFBTSxDQUFDLElBQUksQ0FBQyxpQkFBaUIsQ0FBQyxDQUFDLENBQUMsQ0FBQTtRQUNsQyxDQUFDO0lBQ0gsQ0FBQztJQUVEOztPQUVHO0lBQ0gsaUJBQWlCLENBQUMsQ0FBRTtRQUNsQixNQUFNLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxJQUFJLEVBQUUsRUFBRSxDQUFDLEVBQUUsQ0FBQyxFQUFFLENBQUMsQ0FBQTtJQUN4QyxDQUFDO0lBRUQ7O09BRUc7SUFDSCxlQUFlLENBQUMsQ0FBRTtRQUNoQixNQUFNLENBQUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUE7SUFDckMsQ0FBQztJQUVELElBQUksS0FBSztRQUNQLE1BQU0sQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFBO0lBQ3BCLENBQUM7SUFFRCxJQUFJLEtBQUssQ0FBQyxRQUFnQjtRQUN4QixFQUFFLENBQUMsQ0FBQyxRQUFRLEtBQUssUUFBUSxDQUFDLENBQUMsQ0FBQztZQUMxQixJQUFJLENBQUMsTUFBTSxHQUFHLFFBQVEsQ0FBQTtRQUN4QixDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDTixPQUFPLENBQUMsU0FBUyxDQUFDLEtBQUssQ0FBQyxhQUFhLEdBQUcsUUFBUSxHQUFHLG1CQUFtQixDQUFDLENBQUE7UUFDekUsQ0FBQztJQUNILENBQUM7Q0FDRjtBQWxHRCxvQkFrR0MifQ==

dist/taskbuffer.classes.taskmanager.d.ts

@@ -2,7 +2,7 @@ import { Task } from './taskbuffer.classes.task';
 import { Objectmap } from 'lik';
 export declare class TaskManager {
     taskMap: Objectmap<Task>;
-    private cronJobArray;
+    private cronJobMap;
     constructor();
     /**
      * checks if a task is already present
@@ -24,12 +24,13 @@ export declare class TaskManager {
      * triggers a task in the TaskManagerByName
      * @param taskNameArg
      */
-    triggerTaskByName(taskNameArg: string): void;
+    triggerTaskByName(taskNameArg: string): Promise<any>;
     /**
      * schedules the task by name
      * @param taskNameArg
      */
     scheduleTaskByName(taskNameArg: string, cronStringArg: string): void;
+    descheduleTaskByName(taskNameArg: string): void;
     /**
      * returns all schedules of a specific task
      * @param taskNameArg

dist/taskbuffer.classes.taskmanager.js

@@ -4,7 +4,7 @@ const plugins = require("./taskbuffer.plugins");
 class TaskManager {
     constructor() {
         this.taskMap = new plugins.lik.Objectmap();
-        this.cronJobArray = [];
+        this.cronJobMap = new plugins.lik.Objectmap();
         // nothing here
     }
     /**
@@ -45,7 +45,7 @@ class TaskManager {
         if (!taskToTrigger) {
             throw new Error(`There is no task with the name of ${taskNameArg}`);
         }
-        taskToTrigger.trigger();
+        return taskToTrigger.trigger();
     }
     /**
      * schedules the task by name
@@ -55,15 +55,23 @@ class TaskManager {
         let taskToSchedule = this.getTaskByName(taskNameArg);
         let job = new plugins.cron.CronJob({
             cronTime: cronStringArg,
-            onTick: taskToSchedule.trigger,
+            onTick: () => {
+                this.triggerTaskByName(taskNameArg);
+            },
             start: true
         });
-        this.cronJobArray.push({
+        this.cronJobMap.add({
             taskNameArg: taskToSchedule.name,
             cronString: cronStringArg,
             job: job
         });
     }
+    descheduleTaskByName(taskNameArg) {
+        let descheduledCron = this.cronJobMap.findOneAndRemove((itemArg) => {
+            return itemArg.taskNameArg === taskNameArg;
+        });
+        descheduledCron.job.stop();
+    }
     /**
      * returns all schedules of a specific task
      * @param taskNameArg
@@ -72,4 +80,4 @@ class TaskManager {
     }
 }
 exports.TaskManager = TaskManager;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsZ0RBQStDO0FBTS9DO0lBR0U7UUFGQSxZQUFPLEdBQUcsSUFBSSxPQUFPLENBQUMsR0FBRyxDQUFDLFNBQVMsRUFBUSxDQUFBO1FBQ25DLGlCQUFZLEdBQWUsRUFBRSxDQUFBO1FBRW5DLGVBQWU7SUFDakIsQ0FBQztJQUVEOzs7T0FHRztJQUNILGFBQWEsQ0FBRSxXQUFXO1FBQ3hCLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLE9BQU87WUFDL0IsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLEtBQUssV0FBVyxDQUFBO1FBQ3JDLENBQUMsQ0FBQyxDQUFBO0lBQ0osQ0FBQztJQUVEOzs7T0FHRztJQUNILE9BQU8sQ0FBRSxPQUFhO1FBQ3BCLEVBQUUsQ0FBQyxDQUFDLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7WUFDbEIsTUFBTSxJQUFJLEtBQUssQ0FBQyxpREFBaUQsQ0FBQyxDQUFBO1FBQ3BFLENBQUM7UUFDRCxJQUFJLENBQUMsT0FBTyxDQUFDLEdBQUcsQ0FBQyxPQUFPLENBQUMsQ0FBQTtJQUMzQixDQUFDO0lBRUQ7Ozs7T0FJRztJQUNILGtCQUFrQixDQUFFLE9BQWEsRUFBRSxhQUFxQjtRQUN0RCxJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ3JCLElBQUksUUFBUSxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQUE7UUFDM0IsSUFBSSxDQUFDLGtCQUFrQixDQUFDLFFBQVEsRUFBRSxhQUFhLENBQUMsQ0FBQTtJQUNsRCxDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsaUJBQWlCLENBQUUsV0FBbUI7UUFDcEMsSUFBSSxhQUFhLEdBQUcsSUFBSSxDQUFDLGFBQWEsQ0FBQyxXQUFXLENBQUMsQ0FBQTtRQUNuRCxFQUFFLENBQUMsQ0FBQyxDQUFDLGFBQWEsQ0FBQyxDQUFDLENBQUM7WUFDbkIsTUFBTSxJQUFJLEtBQUssQ0FBQyxxQ0FBcUMsV0FBVyxFQUFFLENBQUMsQ0FBQTtRQUNyRSxDQUFDO1FBQ0QsYUFBYSxDQUFDLE9BQU8sRUFBRSxDQUFBO0lBQ3pCLENBQUM7SUFFRDs7O09BR0c7SUFDSCxrQkFBa0IsQ0FBRSxXQUFtQixFQUFFLGFBQXFCO1FBQzVELElBQUksY0FBYyxHQUFHLElBQUksQ0FBQyxhQUFhLENBQUMsV0FBVyxDQUFDLENBQUE7UUFDcEQsSUFBSSxHQUFHLEdBQUcsSUFBSSxPQUFPLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztZQUNqQyxRQUFRLEVBQUUsYUFBYTtZQUN2QixNQUFNLEVBQUUsY0FBYyxDQUFDLE9BQU87WUFDOUIsS0FBSyxFQUFFLElBQUk7U0FDWixDQUFDLENBQUE7UUFDRixJQUFJLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQztZQUNyQixXQUFXLEVBQUUsY0FBYyxDQUFDLElBQUk7WUFDaEMsVUFBVSxFQUFFLGFBQWE7WUFDekIsR0FBRyxFQUFFLEdBQUc7U0FDVCxDQUFDLENBQUE7SUFDSixDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsdUJBQXVCLENBQUUsV0FBbUI7SUFFNUMsQ0FBQztDQUNGO0FBNUVELGtDQTRFQyJ9
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5jbGFzc2VzLnRhc2ttYW5hZ2VyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsZ0RBQStDO0FBTS9DO0lBR0U7UUFGQSxZQUFPLEdBQUcsSUFBSSxPQUFPLENBQUMsR0FBRyxDQUFDLFNBQVMsRUFBUSxDQUFBO1FBQ25DLGVBQVUsR0FBRyxJQUFJLE9BQU8sQ0FBQyxHQUFHLENBQUMsU0FBUyxFQUFZLENBQUE7UUFFeEQsZUFBZTtJQUNqQixDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsYUFBYSxDQUFFLFdBQVc7UUFDeEIsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUMsT0FBTztZQUMvQixNQUFNLENBQUMsT0FBTyxDQUFDLElBQUksS0FBSyxXQUFXLENBQUE7UUFDckMsQ0FBQyxDQUFDLENBQUE7SUFDSixDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsT0FBTyxDQUFFLE9BQWE7UUFDcEIsRUFBRSxDQUFDLENBQUMsQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQztZQUNsQixNQUFNLElBQUksS0FBSyxDQUFDLGlEQUFpRCxDQUFDLENBQUE7UUFDcEUsQ0FBQztRQUNELElBQUksQ0FBQyxPQUFPLENBQUMsR0FBRyxDQUFDLE9BQU8sQ0FBQyxDQUFBO0lBQzNCLENBQUM7SUFFRDs7OztPQUlHO0lBQ0gsa0JBQWtCLENBQUUsT0FBYSxFQUFFLGFBQXFCO1FBQ3RELElBQUksQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLENBQUE7UUFDckIsSUFBSSxRQUFRLEdBQUcsT0FBTyxDQUFDLElBQUksQ0FBQTtRQUMzQixJQUFJLENBQUMsa0JBQWtCLENBQUMsUUFBUSxFQUFFLGFBQWEsQ0FBQyxDQUFBO0lBQ2xELENBQUM7SUFFRDs7O09BR0c7SUFDSCxpQkFBaUIsQ0FBRSxXQUFtQjtRQUNwQyxJQUFJLGFBQWEsR0FBRyxJQUFJLENBQUMsYUFBYSxDQUFDLFdBQVcsQ0FBQyxDQUFBO1FBQ25ELEVBQUUsQ0FBQyxDQUFDLENBQUMsYUFBYSxDQUFDLENBQUMsQ0FBQztZQUNuQixNQUFNLElBQUksS0FBSyxDQUFDLHFDQUFxQyxXQUFXLEVBQUUsQ0FBQyxDQUFBO1FBQ3JFLENBQUM7UUFDRCxNQUFNLENBQUMsYUFBYSxDQUFDLE9BQU8sRUFBRSxDQUFBO0lBQ2hDLENBQUM7SUFFRDs7O09BR0c7SUFDSCxrQkFBa0IsQ0FBRSxXQUFtQixFQUFFLGFBQXFCO1FBQzVELElBQUksY0FBYyxHQUFHLElBQUksQ0FBQyxhQUFhLENBQUMsV0FBVyxDQUFDLENBQUE7UUFDcEQsSUFBSSxHQUFHLEdBQUcsSUFBSSxPQUFPLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztZQUNqQyxRQUFRLEVBQUUsYUFBYTtZQUN2QixNQUFNLEVBQUU7Z0JBQ04sSUFBSSxDQUFDLGlCQUFpQixDQUFDLFdBQVcsQ0FBQyxDQUFBO1lBQ3JDLENBQUM7WUFDRCxLQUFLLEVBQUUsSUFBSTtTQUNaLENBQUMsQ0FBQTtRQUNGLElBQUksQ0FBQyxVQUFVLENBQUMsR0FBRyxDQUFDO1lBQ2xCLFdBQVcsRUFBRSxjQUFjLENBQUMsSUFBSTtZQUNoQyxVQUFVLEVBQUUsYUFBYTtZQUN6QixHQUFHLEVBQUUsR0FBRztTQUNULENBQUMsQ0FBQTtJQUNKLENBQUM7SUFFRCxvQkFBb0IsQ0FBRSxXQUFtQjtRQUN2QyxJQUFJLGVBQWUsR0FBRyxJQUFJLENBQUMsVUFBVSxDQUFDLGdCQUFnQixDQUFDLENBQUMsT0FBTztZQUM3RCxNQUFNLENBQUMsT0FBTyxDQUFDLFdBQVcsS0FBSyxXQUFXLENBQUE7UUFDNUMsQ0FBQyxDQUFDLENBQUE7UUFDRixlQUFlLENBQUMsR0FBRyxDQUFDLElBQUksRUFBRSxDQUFBO0lBQzVCLENBQUM7SUFDRDs7O09BR0c7SUFDSCx1QkFBdUIsQ0FBRSxXQUFtQjtJQUU1QyxDQUFDO0NBQ0Y7QUFwRkQsa0NBb0ZDIn0=

package.json

@@ -1,6 +1,6 @@
 {
   "name": "taskbuffer",
-  "version": "1.0.16",
+  "version": "1.0.18",
   "description": "flexible task management. TypeScript ready!",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
@@ -29,7 +29,7 @@
     "@types/lodash": "4.x.x",
     "beautylog": "^6.1.10",
     "cron": "^1.2.1",
-    "lik": "^1.0.31",
+    "lik": "^1.0.32",
     "lodash": "^4.17.4",
     "rxjs": "^5.4.1",
     "smartdelay": "^1.0.3",

test/test.1.task.ts

@@ -63,37 +63,37 @@ 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 () => {
+tap.test('expect testTask to be an instance of Task', async () => {
   expect(testTask).to.be.instanceof(taskbuffer.Task)
 })
 
-tap.test('testTask.idle is true', async () => {
+tap.test('expect 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 () => {
+tap.test('testTask.running should be of 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 () => {
+tap.test('testTask.trigger() should return Promise', async () => {
   expect(testTask.trigger()).to.be.instanceof(Promise)
 })
 
-tap.test('testTask.trigger() returned Promise expect be fullfilled', async () => {
+tap.test('testTask.trigger() returned Promise should be fullfilled', async () => {
   await testTask.trigger()
 })
 
-tap.test('expect run a task without pre and afterTask', async () => {
+tap.test('expect to run a task without pre and afterTask errorless', async () => {
   let localTestTask = new taskbuffer.Task({ taskFunction: async () => { console.log('only once') } })
   await localTestTask.trigger()
 })
 
-tap.test('expect run buffered', async () => {
+tap.test('expect task to run in buffered mode', async () => {
   let localTestTask = new taskbuffer.Task({
     taskFunction: async () => { await smartdelay.delayFor(3000) },
     buffered: true,

test/test.4.taskmanager.ts

@@ -0,0 +1,40 @@
+import { expect, tap } from 'tapbundle'
+import taskbuffer = require('../dist/index')
+
+import * as smartq from 'smartq'
+import * as smartdelay from 'smartdelay'
+
+let myTaskManager: taskbuffer.TaskManager
+let taskRunCounter = 0
+let taskDone = smartq.defer()
+
+tap.test('should create an instance of TaskManager', async () => {
+  myTaskManager = new taskbuffer.TaskManager()
+  expect(myTaskManager).to.be.instanceof(taskbuffer.TaskManager)
+})
+
+tap.test('should run the task as expected', async () => {
+  let referenceBoolean = false
+  myTaskManager.addTask(new taskbuffer.Task({
+    name: 'myTask',
+    taskFunction: async () => {
+      console.log('Task executed!')
+      referenceBoolean = true
+      taskRunCounter++
+      if (taskRunCounter === 10) {
+        taskDone.resolve()
+      }
+    }
+  }))
+  await myTaskManager.triggerTaskByName('myTask')
+  // tslint:disable-next-line:no-unused-expression
+  expect(referenceBoolean).to.be.true
+})
+
+tap.test('should schedule task', async () => {
+  myTaskManager.scheduleTaskByName('myTask', '* * * * * *')
+  await taskDone.promise
+  myTaskManager.descheduleTaskByName('myTask')
+})
+
+tap.start()

test/test.5.task.paramflow.ts

@@ -46,17 +46,17 @@ tap.test('should let a value flow through a task', async () => {
   expect(result).to.equal(12)
 })
 
-tap.test('should let a values flow between tasks', async () => {
+tap.test('expect values to 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 () => {
+tap.test('expect values to 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 () => {
+tap.test('expect values to flow between tasks in Taskchain', async () => {
   let result = await flowTask3.trigger(12)
   expect(result).to.equal(12)
 })

ts/index.ts

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

ts/taskbuffer.classes.helpers.ts

@@ -28,12 +28,18 @@ export let isTaskTouched = (taskArg: Task, touchedTasksArray: Task[]): boolean =
   return result
 }
 
-export let runTask = function (taskArg: Task, optionsArg: { x?, touchedTasksArray?: Task[] }) {
+export let runTask = async (taskArg: Task, optionsArg: { x?, touchedTasksArray?: Task[] }) => {
   let done = plugins.q.defer()
 
+  // pay respect to execDelay
+  if (taskArg.execDelay) {
+    await plugins.smartdelay.delayFor(taskArg.execDelay)
+  }
+
   //  set running params
   taskArg.running = true
-  done.promise.then(function () { taskArg.running = false })
+
+  done.promise.then(async () => { taskArg.running = false })
 
   // handle options
   let options = plugins.lodash.merge(
@@ -75,7 +81,7 @@ export let runTask = function (taskArg: Task, optionsArg: { x?, touchedTasksArra
       console.log(err)
     })
   localDeferred.resolve()
-  return done.promise
+  return await done.promise
 }
 
 export interface cycleObject {
@@ -116,18 +122,13 @@ export class BufferRunner {
   task: Task
   // initialze by default
   bufferCounter: number = 0
-  bufferMax: number = 1
   running: boolean = false
   constructor(taskArg: Task) {
     this.task = taskArg
   }
 
-  setBufferMax (bufferMaxArg: number) {
-    this.bufferMax = bufferMaxArg
-  }
-
   trigger (x): Promise<any> {
-    if (!(this.bufferCounter >= this.bufferMax)) {
+    if (!(this.bufferCounter >= this.task.bufferMax)) {
       this.bufferCounter++
     }
     let returnPromise: Promise<any> = this.task.cycleCounter.getPromiseForCycle(this.bufferCounter + 1)

ts/taskbuffer.classes.task.ts

@@ -6,9 +6,15 @@ export interface ITaskFunction {
 }
 
 export class Task {
+  // man datory properties
   name: string
   taskFunction: ITaskFunction
   buffered: boolean
+
+  bufferMax: number
+  execDelay: number
+
+  // tasks to run before and after
   preTask: Task
   afterTask: Task
 
@@ -16,31 +22,55 @@ export class Task {
   running: boolean = false
   bufferRunner = new helpers.BufferRunner(this)
   cycleCounter = new helpers.CycleCounter(this)
+
   idle: boolean = true
   private _state: string = 'ready'
 
-  constructor (optionsArg: {
-    taskFunction: ITaskFunction,
-    preTask?: Task,
-    afterTask?: Task,
-    buffered?: boolean,
-    bufferMax?: number,
+  constructor(optionsArg: {
+    /**
+     * the task function to run, must return promise
+     */
+    taskFunction: ITaskFunction
+    /**
+     * any other task to run before
+     */
+    preTask?: Task
+    /**
+     * any other task to run after
+     */
+    afterTask?: Task
+    /**
+     * wether this task should run buffered
+     */
+    buffered?: boolean
+    /**
+     * the maximum buffer
+     */
+    bufferMax?: number
+    /**
+     * the execution delay, before the task is executed
+     * only makes sense when running in buffered mode
+     */
+    execDelay?: number
+    /**
+     * the name of the task
+     */
     name?: string
   }) {
-    let options = optionsArg
     this.taskFunction = optionsArg.taskFunction
-    this.preTask = options.preTask
-    this.afterTask = options.afterTask
+    this.preTask = optionsArg.preTask
+    this.afterTask = optionsArg.afterTask
     this.idle = !this.running
-    this.buffered = options.buffered
-    this.bufferRunner.setBufferMax(options.bufferMax)
-    this.name = options.name
+    this.buffered = optionsArg.buffered
+    this.bufferMax = optionsArg.bufferMax
+    this.execDelay = optionsArg.execDelay
+    this.name = optionsArg.name
   }
 
   /**
    * 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 {
@@ -51,21 +81,22 @@ export class Task {
   /**
    * 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 {

ts/taskbuffer.classes.taskmanager.ts

@@ -6,7 +6,7 @@ import { Objectmap } from 'lik'
 
 export class TaskManager {
   taskMap = new plugins.lik.Objectmap<Task>()
-  private cronJobArray: ICronJob[] = []
+  private cronJobMap = new plugins.lik.Objectmap<ICronJob>()
   constructor () {
     // nothing here
   }
@@ -47,12 +47,12 @@ export class TaskManager {
    * triggers a task in the TaskManagerByName
    * @param taskNameArg
    */
-  triggerTaskByName (taskNameArg: string) {
+  triggerTaskByName (taskNameArg: string): Promise<any> {
     let taskToTrigger = this.getTaskByName(taskNameArg)
     if (!taskToTrigger) {
       throw new Error(`There is no task with the name of ${taskNameArg}`)
     }
-    taskToTrigger.trigger()
+    return taskToTrigger.trigger()
   }
 
   /**
@@ -63,16 +63,24 @@ export class TaskManager {
     let taskToSchedule = this.getTaskByName(taskNameArg)
     let job = new plugins.cron.CronJob({
       cronTime: cronStringArg,
-      onTick: taskToSchedule.trigger,
+      onTick: () => {
+        this.triggerTaskByName(taskNameArg)
+      },
       start: true
     })
-    this.cronJobArray.push({
+    this.cronJobMap.add({
       taskNameArg: taskToSchedule.name,
       cronString: cronStringArg,
       job: job
     })
   }
 
+  descheduleTaskByName (taskNameArg: string) {
+    let descheduledCron = this.cronJobMap.findOneAndRemove((itemArg) => {
+      return itemArg.taskNameArg === taskNameArg
+    })
+    descheduledCron.job.stop()
+  }
   /**
    * returns all schedules of a specific task
    * @param taskNameArg

yarn.lock

@@ -236,9 +236,9 @@ 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"
+lik@^1.0.32:
+  version "1.0.32"
+  resolved "https://registry.yarnpkg.com/lik/-/lik-1.0.32.tgz#41ee6c8edd483eaa11bd089775263955f5555060"
   dependencies:
     "@types/lodash" "^4.14.62"
     "@types/minimatch" "2.x.x"