/*
* This file is part of the jquery plugin "asyncQueue".
* (c) Sebastien Roch <roch.sebastien@gmail.com>
* @author (parallel) Dmitry Farafonov
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
(function($){
    $.AsyncQueue = function() {
        var that = this,
            queue = [],
			completeFunc,
            failureFunc,
            paused = false,
            lastCallbackData,
            _run,
			_complete,
			inQueue = 0,
			defaultTimeOut = 10;

        _run = function() {
            var f = queue.shift();

            if (f) {
				inQueue++;
				setTimeout(function(){
					f.fn.apply(that, [that]);
				
					if (!f.isParallel)
						if (paused === false) {
							_run();
						}
					inQueue --;
					if (inQueue == 0 && queue.length == 0)
						_complete();
				}, f.timeOut);                
				
				if (f.isParallel)
					if (paused === false) {
						_run();
					}
            }
        };
		
		_complete = function(){
			if (completeFunc)
					completeFunc.apply(that, [that]);
		};

		this.onComplete = function(func) {
            completeFunc = func;
        };
		
		this.onFailure = function(func) {
            failureFunc = func;
        };

        this.add = function(func) {
			// TODO: add callback for queue[i] complete
			
			var obj = arguments[0];
			if (obj && Object.prototype.toString.call(obj) === "[object Array]") {
				var fn = arguments[1];
				var timeOut = (typeof(arguments[2]) != "undefined")? arguments[2] : defaultTimeOut;
				if (typeof(fn) == "function") {
					for(var i = 0; i < obj.length; i++) {
						var f = function(objx){
							queue.push({isParallel: true, fn: function(){fn.apply(that, [that, objx]);}, timeOut: timeOut});
						}(obj[i])
					}
				}
			} else {
				var fn = arguments[0];
				var timeOut = (typeof(arguments[1]) != "undefined")? arguments[2] : defaultTimeOut;
				queue.push({isParallel: false, fn: func, timeOut: timeOut});
			}
            return this;
        };
		
		this.addParallel = function(func, timeOut) {
			// TODO: add callback for queue[i] complete
			
            queue.push({isParallel: true, fn: func, timeOut: timeOut});
            return this;
        };

        this.storeData = function(dataObject) {
            lastCallbackData = dataObject;
            return this;
        };

        this.lastCallbackData = function () {
            return lastCallbackData;
        };

        this.run = function() {
            paused = false;
            _run();
        };

        this.pause = function () {
            paused = true;
            return this;
        };

        this.failure = function() {
            paused = true;
            if (failureFunc) {
                var args = [that];
                for(i = 0; i < arguments.length; i++) {
                    args.push(arguments[i]);
                }
                failureFunc.apply(that, args);
            }
        };
		
		this.size = function(){
			return queue.length;
		};

        return this;
    }
})(jQuery);