taskbuffer/ts/taskbuffer.classes.helpers.ts

160 lines
4.5 KiB
TypeScript
Raw Normal View History

2016-05-04 00:49:43 +00:00
import plugins = require("./taskbuffer.plugins");
2016-08-01 14:10:00 +00:00
import { Task, ITaskFunction } from "./taskbuffer.classes.task";
2016-05-04 00:49:43 +00:00
2016-08-03 12:51:43 +00:00
import {Promise} from "q";
export {Promise} from "q";
export let emptyTaskFunction: ITaskFunction = function (x) {
let done = plugins.Q.defer();
2016-05-04 00:49:43 +00:00
done.resolve();
return done.promise;
};
2016-08-01 14:10:00 +00:00
export let isTask = function (taskArg): boolean {
if (
taskArg instanceof Task
2016-05-04 00:49:43 +00:00
&& typeof taskArg.task === "function"
2016-08-01 14:10:00 +00:00
) {
2016-05-04 00:49:43 +00:00
return true;
} else {
return false;
}
};
2016-08-01 14:10:00 +00:00
export let isTaskTouched = (taskArg: Task, touchedTasksArray: Task[]): boolean => {
2016-05-06 00:05:45 +00:00
let result = false;
2016-08-01 14:10:00 +00:00
for (let keyArg in touchedTasksArray) {
if (taskArg === touchedTasksArray[keyArg]) {
2016-05-06 00:05:45 +00:00
result = true;
}
}
return result;
}
export let runTask = function (taskArg: Task, optionsArg: {x?, touchedTasksArray?: Task[] }) {
let done = plugins.Q.defer();
// set running params
2016-08-01 11:17:15 +00:00
taskArg.running = true;
2016-08-01 14:10:00 +00:00
done.promise.then(function () { taskArg.running = false });
// handle options
let options = plugins.lodash.merge(
{x:undefined,touchedTasksArray: []},
optionsArg
)
let x = options.x;
let touchedTasksArray: Task[] = options.touchedTasksArray;
touchedTasksArray.push(taskArg);
// run the task cascade
let localDeferred = plugins.Q.defer();
localDeferred.promise
2016-08-01 14:10:00 +00:00
.then(() => {
if (taskArg.preTask && !isTaskTouched(taskArg.preTask, touchedTasksArray)) {
return runTask(taskArg.preTask, {x:x, touchedTasksArray: touchedTasksArray })
} else {
2016-05-06 00:05:45 +00:00
let done2 = plugins.Q.defer();
done2.resolve(x);
return done2.promise;
}
})
.then(x => {
return taskArg.taskFunction(x);
})
.then(x => {
2016-08-01 14:10:00 +00:00
if (taskArg.afterTask && !isTaskTouched(taskArg.afterTask, touchedTasksArray)) {
return runTask(taskArg.afterTask, {x:x, touchedTasksArray: touchedTasksArray });
} else {
2016-05-06 00:05:45 +00:00
let done2 = plugins.Q.defer();
done2.resolve(x);
return done2.promise;
}
})
.then(x => {
done.resolve(x);
2016-08-03 09:28:13 +00:00
}).catch((err) => {
console.log(err);
2016-05-06 00:05:45 +00:00
});
localDeferred.resolve();
2016-05-04 00:49:43 +00:00
return done.promise;
2016-05-05 17:21:01 +00:00
};
2016-08-01 14:10:00 +00:00
export interface cycleObject {
cycleCounter:number,
deferred:plugins.Q.Deferred<any>
}
export class CycleCounter {
task:Task;
cycleObjectArray:cycleObject[] = [];
constructor(taskArg:Task){
this.task = taskArg;
};
getPromiseForCycle(cycleCountArg:number){
let done = plugins.Q.defer();
let cycleObject:cycleObject = {
cycleCounter:cycleCountArg,
deferred:done
};
this.cycleObjectArray.push(cycleObject);
return done.promise;
};
2016-08-03 12:51:43 +00:00
informOfCycle(x){
2016-08-01 14:10:00 +00:00
let newCycleObjectArray:cycleObject[] = [];
this.cycleObjectArray.forEach(cycleObjectArg => {
cycleObjectArg.cycleCounter--;
if(cycleObjectArg.cycleCounter <= 0){
2016-08-03 12:51:43 +00:00
cycleObjectArg.deferred.resolve(x);
2016-08-01 14:10:00 +00:00
} else {
newCycleObjectArray.push(cycleObjectArg);
};
});
this.cycleObjectArray = newCycleObjectArray;
2016-05-06 00:05:45 +00:00
}
2016-08-01 14:10:00 +00:00
}
export class BufferRunner {
task:Task;
// initialze by default
bufferCounter:number = 0;
bufferMax:number = 1;
running:boolean = false;
constructor(taskArg: Task) {
this.task = taskArg;
};
private _run(x) {
let recursiveBufferRunner = (x) => {
2016-08-01 14:10:00 +00:00
if (this.bufferCounter >= 0) {
this.running = true;
this.task.running = true;
runTask(this.task,{x:x})
.then((x) => {
2016-08-01 14:10:00 +00:00
this.bufferCounter--;
2016-08-03 12:51:43 +00:00
this.task.cycleCounter.informOfCycle(x);
recursiveBufferRunner(x);
2016-08-01 14:10:00 +00:00
});
} else {
this.running = false;
this.task.running = false;
}
};
recursiveBufferRunner(x);
2016-08-01 14:10:00 +00:00
};
setBufferMax(bufferMaxArg:number){
this.bufferMax = bufferMaxArg;
};
2016-08-03 12:51:43 +00:00
trigger(x): Promise<any> {
2016-08-01 14:10:00 +00:00
if(!(this.bufferCounter >= this.bufferMax)){
this.bufferCounter++
};
2016-08-03 12:51:43 +00:00
let returnPromise:Promise<any> = this.task.cycleCounter.getPromiseForCycle(this.bufferCounter + 1);
2016-08-01 14:10:00 +00:00
if(!this.running){
this._run(x);
2016-08-01 14:10:00 +00:00
}
return returnPromise;
};
2016-08-01 11:17:15 +00:00
};