taskbuffer/test/test.ts

import "typings-test";
import taskbuffer = require("../dist/index");
import should = require("should");
import q = require("q")

// 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 () {
            should(testTask).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 () {
            should(testTask.running).be.type("boolean");
            should(testTask.running).be.false();
        });
        it("testTask.trigger() should return Promise", function () {
            should(testTask.trigger()).be.Promise();
        });
        it("testTask.trigger() returned Promise should be fullfilled", function (done) {
            testTask.trigger()
                .then(done);
        });
        it("should run a task without pre and afterTask", function (done) {
            let localTestTask = new taskbuffer.Task({ taskFunction: testTaskFunction });
            localTestTask.trigger().then(done);
        });

        it("should 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("should 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("should 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) => {
                should.equal(x,12);
                done();
            }).catch(done);
        });
        it("should let a values flow between tasks",function(done){
            flowTask2.trigger(12).then((x) => {
                should.equal(x,12);
                done();
            }).catch(done);
        });

        it("should let a values flow between tasks when buffered",function(done){
            flowTaskBuffered.trigger(12).then((x) => {
                should.equal(x,12);
                done();
            }).catch(done);
        });

        it("should let a values flow between tasks in Taskchain",function(done){
            flowTask3.trigger(12).then((x) => {
                should.equal(x,12);
                done();
            }).catch(done);
        });
    })
});