/**!
* project-site: http://plugins.jquery.com/project/AjaxManager
* repository: http://github.com/aFarkas/Ajaxmanager
* @author Alexander Farkas
* @version 3.01
* Copyright 2010, Alexander Farkas
* Dual licensed under the MIT or GPL Version 2 licenses.
*/

(function(jQuery) {
    var managed = {},
		cache = {}
	;
    jQuery.manageAjax = (function() {
        function create(name, opts) {
            managed[name] = new jQuery.manageAjax._manager(name, opts);
            return managed[name];
        }

        var publicFns = {
            create: create
        };

        return publicFns;
    })();

    jQuery.manageAjax._manager = function(name, opts) {
        this.requests = {};
        this.inProgress = 0;
        this.name = name;
        this.qName = name;

        this.opts = jQuery.extend({}, jQuery.ajaxSettings, jQuery.manageAjax.defaults, opts);
        if (opts.queue && opts.queue !== true && typeof opts.queue === 'string' && opts.queue !== 'clear') {
            this.qName = opts.queue;
        }
    };

    jQuery.manageAjax._manager.prototype = {
        add: function(o) {
            o = jQuery.extend({}, this.opts, o);

            var origCom = o.complete,
				origSuc = o.success,
				beforeSend = o.beforeSend,
				origError = o.error,
				strData = (typeof o.data == 'string') ? o.data : jQuery.param(o.data || {}),
				xhrID = o.type + o.url + strData,
				that = this,
				ajaxFn = this._createAjax(xhrID, o, origSuc, origCom)
			;

            if (this.requests[xhrID] && o.preventDoubbleRequests) {
                return;
            }
            ajaxFn.xhrID = xhrID;
            o.xhrID = xhrID;

            o.beforeSend = function(xhr, opts) {
                var ret = beforeSend.call(this, xhr, opts);
                if (ret === false) {
                    that._removeXHR(xhrID);
                }
                xhr = null;
                return ret;
            };
            o.complete = function(xhr, status) {
                that._complete.call(that, this, origCom, xhr, status, xhrID, o);
                xhr = null;
            };

            o.success = function(data, status, xhr) {
                that._success.call(that, this, origSuc, data, status, xhr, o);
                xhr = null;
            };

            //always add some error callback
            o.error = function(ahr, status, errorStr) {
                ahr = (ahr || {});
                var httpStatus = ahr.status,
					content = ahr.responseXML || ahr.responseText
				;
                if (origError) {
                    origError.call(this, ahr, status, errorStr, o);
                } else {
                    setTimeout(function() {
                        throw status + ':: status: ' + httpStatus + ' | URL: ' + o.url + ' | data: ' + strData + ' | thrown: ' + errorStr + ' | response: ' + content;
                    }, 0);
                }
                ahr = null;
            };

            if (o.queue === 'clear') {
                jQuery(document).clearQueue(this.qName);
            }

            if (o.queue) {
                jQuery.queue(document, this.qName, ajaxFn);
                if (this.inProgress < o.maxRequests) {
                    jQuery.dequeue(document, this.qName);
                }
                return xhrID;
            }
            return ajaxFn();
        },
        _createAjax: function(id, o, origSuc, origCom) {
            var that = this;
            return function() {
                if (o.beforeCreate.call(o.context || that, id, o) === false) { return; }
                that.inProgress++;
                if (o.cacheResponse && cache[id]) {
                    that.requests[id] = {};
                    setTimeout(function() {
                        that._complete.call(that, o.context || o, origCom, {}, 'success', id, o);
                        that._success.call(that, o.context || o, origSuc, cache[id], 'success', {}, o);
                    }, 0);
                } else {
                    that.requests[id] = jQuery.ajax(o);
                }
                if (that.inProgress === 1) {
                    jQuery.event.trigger(that.name + 'AjaxStart');
                }
                return id;
            };
        },
        _removeXHR: function(xhrID) {
            if (this.opts.queue) {
                jQuery.dequeue(document, this.qName);
            }
            this.inProgress--;
            this.requests[xhrID] = null;
            delete this.requests[xhrID];
        },
        _isAbort: function(xhr, o) {
            var ret = !!(o.abortIsNoSuccess && (!xhr || xhr.readyState === 0 || this.lastAbort === o.xhrID));
            xhr = null;
            return ret;
        },
        _complete: function(context, origFn, xhr, status, xhrID, o) {
            if (this._isAbort(xhr, o)) {
                status = 'abort';
                o.abort.call(context, xhr, status, o);
            }
            origFn.call(context, xhr, status, o);

            jQuery.event.trigger(this.name + 'AjaxComplete', [xhr, status, o]);

            if (o.domCompleteTrigger) {
                jQuery(o.domCompleteTrigger)
					.trigger(this.name + 'DOMComplete', [xhr, status, o])
					.trigger('DOMComplete', [xhr, status, o])
				;
            }

            this._removeXHR(xhrID);
            if (!this.inProgress) {
                jQuery.event.trigger(this.name + 'AjaxStop');
            }
            xhr = null;
        },
        _success: function(context, origFn, data, status, xhr, o) {
            var that = this;
            if (this._isAbort(xhr, o)) {
                xhr = null;
                return;
            }
            if (o.abortOld) {
                jQuery.each(this.requests, function(name) {
                    if (name === o.xhrID) {
                        return false;
                    }
                    that.abort(name);
                });
            }
            if (o.cacheResponse && !cache[o.xhrID]) {
                cache[o.xhrID] = data;
            }
            origFn.call(context, data, status, xhr, o);
            jQuery.event.trigger(this.name + 'AjaxSuccess', [xhr, o, data]);
            if (o.domSuccessTrigger) {
                jQuery(o.domSuccessTrigger)
					.trigger(this.name + 'DOMSuccess', [data, o])
					.trigger('DOMSuccess', [data, o])
				;
            }
            xhr = null;
        },
        getData: function(id) {
            if (id) {
                var ret = this.requests[id];
                if (!ret && this.opts.queue) {
                    ret = jQuery.grep(jQuery(document).queue(this.qName), function(fn, i) {
                        return (fn.xhrID === id);
                    })[0];
                }
                return ret;
            }
            return {
                requests: this.requests,
                queue: (this.opts.queue) ? jQuery(document).queue(this.qName) : [],
                inProgress: this.inProgress
            };
        },
        abort: function(id) {
            var xhr;
            if (id) {
                xhr = this.getData(id);

                if (xhr && xhr.abort) {
                    this.lastAbort = id;
                    xhr.abort();
                    this.lastAbort = false;
                } else {
                    jQuery(document).queue(
						this.qName, jQuery.grep(jQuery(document).queue(this.qName), function(fn, i) {
						    return (fn !== xhr);
						})
					);
                }
                xhr = null;
                return;
            }

            var that = this,
				ids = []
			;
            jQuery.each(this.requests, function(id) {
                ids.push(id);
            });
            jQuery.each(ids, function(i, id) {
                that.abort(id);
            });
        },
        clear: function(shouldAbort) {
            jQuery(document).clearQueue(this.qName);
            if (shouldAbort) {
                this.abort();
            }
        }
    };
    jQuery.manageAjax._manager.prototype.getXHR = jQuery.manageAjax._manager.prototype.getData;
    jQuery.manageAjax.defaults = {
        complete: jQuery.noop,
        success: jQuery.noop,
        beforeSend: jQuery.noop,
        beforeCreate: jQuery.noop,
        abort: jQuery.noop,
        abortIsNoSuccess: true,
        maxRequests: 1,
        cacheResponse: false,
        domCompleteTrigger: false,
        domSuccessTrigger: false,
        preventDoubbleRequests: true,
        queue: false // true, false, clear
    };

    jQuery.each(jQuery.manageAjax._manager.prototype, function(n, fn) {
        if (n.indexOf('_') === 0 || !jQuery.isFunction(fn)) { return; }
        jQuery.manageAjax[n] = function(name, o) {
            if (!managed[name]) {
                if (n === 'add') {
                    jQuery.manageAjax.create(name, o);
                } else {
                    return;
                }
            }
            var args = Array.prototype.slice.call(arguments, 1);
            managed[name][n].apply(managed[name], args);
        };
    });

})(jQuery);