taskbuffer/test/test.ts

import "typings-test";
import taskbuffer = require("../dist/index");
let 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 testPreTask = new taskbuffer.Task({
    taskFunction:function(){
        let done = q.defer();
        console.log("preTask executed");
        done.resolve();
        return done.promise;
    },
    preTask:testTask
});

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(){
            testTask.should.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(){
            testTask.running.should.be.type("boolean");
            testTask.running.should.be.false();
        });
        it("testTask.trigger() should return Promise",function(){
            testTask.trigger().should.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);
        });
    });
    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(){
        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;
            }
        });
        it("should run in Parallel",function(done){
            this.timeout("7000");
            let testTaskparallel = new taskbuffer.Taskparallel({
                taskArray:[task1,task2,task3]
            });
            testTaskparallel.trigger().then(() => {
                done();
            });
        })
    })
});