# Source: richfaces-queue.js

    /*
     * JBoss, Home of Professional Open Source
     * Copyright 2013, Red Hat, Inc. and individual contributors
     * by the @authors tag. See the copyright.txt in the distribution for a
     * full listing of individual contributors.
     *
     * This is free software; you can redistribute it and/or modify it
     * under the terms of the GNU Lesser General Public License as
     * published by the Free Software Foundation; either version 2.1 of
     * the License, or (at your option) any later version.
     *
     * This software is distributed in the hope that it will be useful,
     * but WITHOUT ANY WARRANTY; without even the implied warranty of
     * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
     * Lesser General Public License for more details.
     *
     * You should have received a copy of the GNU Lesser General Public
     * License along with this software; if not, write to the Free
     * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
     * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
     */

    /**
     * @author Pavel Yaschenko
     */

    (function($, rf, jsf) {

        /**
         * RichFaces Ajax container
         * @class
         * @memberOf RichFaces
         * @static
         * @name ajaxContainer
         * */
        rf.ajaxContainer = rf.ajaxContainer || {};

        if (rf.ajaxContainer.jsfRequest) {
            return;
        }

        /**
         * JSF 2.0 original method that sends an asynchronous ajax request to the server
         * see jsf.ajax.request method for parameter's description
         * @function
         * @name RichFaces.ajaxContainer.jsfRequest
         *
         * */
        rf.ajaxContainer.jsfRequest = jsf.ajax.request;

        /**
         * RichFaces wrapper function of JSF 2.0 original method jsf.ajax.request
         * @function
         * @name jsf.ajax.request
         *
         * @param {string|DOMElement} source - The DOM element or an id that triggered this ajax request
         * @param {object} [event] - The DOM event that triggered this ajax request
         * @param {object} [options] - The set name/value pairs that can be sent as request parameters to control client and/or server side request processing
         * */
        jsf.ajax.request = function(source, event, options) {
            rf.queue.push(source, event, options);
        };

        rf.ajaxContainer.jsfResponse = jsf.ajax.response;

        rf.ajaxContainer.isIgnoreResponse = function() {
            return rf.queue.isIgnoreResponse();
        };

        jsf.ajax.response = function(request, context) {
            rf.queue.response(request, context);
        };

        var QUEUE_MODE_PULL = 'pull';
        var QUEUE_MODE_PUSH = 'push';
        var QUEUE_MODE = QUEUE_MODE_PULL;
        var DEFAULT_QUEUE_ID = "org.richfaces.queue.global";

        /**
         * RichFaces Queue API container
         * @class
         * @memberOf RichFaces
         * @static
         * @name queue
         * */
        rf.queue = (function() {

            var defaultQueueOptions = {};
            //defaultQueueOptions[DEFAULT_QUEUE_ID] = {requestDelay:0, ignoreDupResponse:false, timeout:0};
            var eventHandlers = {};

            var QueueEntry = function(queue, source, event, options) {
                this.queue = queue;
                this.source = source;
                this.options = $.extend({}, options || {});
                this.queueOptions = {}
                var id;

                // find default options for QueueEntry
                if (this.options.queueId) {
                    if (defaultQueueOptions[this.options.queueId]) {
                        id = this.options.queueId;
                    }
                    delete this.options.queueId;
                } else {
                    var element = rf.getDomElement(source);
                    var form;
                    if (element) {
                        element = $(element).closest("form");
                        if (element.length > 0) {
                            form = element.get(0);
                        }
                    }
                    if (form && form.id && defaultQueueOptions[form.id]) {
                        id = form.id;
                    } else {
                        id = DEFAULT_QUEUE_ID;
                    }
                }
                if (id) {
                    this.queueOptions = defaultQueueOptions[id] || {};
                    if (this.queueOptions.queueId) {
                        this.queueOptions = $.extend({}, (defaultQueueOptions[this.queueOptions.queueId] || {}), this.queueOptions);
                    } else {
                        // TODO: clean duplicated code
                        var element = rf.getDomElement(source);
                        var form;
                        if (element) {
                            element = $(element).closest("form");
                            if (element.length > 0) {
                                form = element.get(0);
                            }
                        }
                        if (form && form.id && defaultQueueOptions[form.id]) {
                            id = form.id;
                        } else {
                            id = DEFAULT_QUEUE_ID;
                        }
                        if (id) {
                            this.queueOptions = $.extend({}, (defaultQueueOptions[id] || {}), this.queueOptions);
                        }
                    }
                }

                if (this.queueOptions.status && this.options.rfExt && !this.options.rfExt.status) {
                    this.options.rfExt.status = this.queueOptions.status;
                }

                if (typeof this.queueOptions.requestGroupingId == "undefined") {
                    this.queueOptions.requestGroupingId = typeof this.source == "string" ? this.source : this.source.id;
                }

                // Remove the layerX and layerY events (generated in WebKit browsers)
                if (event && event instanceof Object) {
                    if ('layerX' in event) delete event.layerX;
                    if ('layerY' in event) delete event.layerY;
                }

                // copy of event should be created otherwise IE will fail
                this.event = $.extend({}, event);

                //requestGroupingId is mutable, thus we need special field for it
                this.requestGroupingId = this.queueOptions.requestGroupingId;
                this.eventsCount = 1;
            };

            $.extend(QueueEntry.prototype, {
                    // now unused functions: ondrop, clearEntry
                    isIgnoreDupResponses: function() {
                        return this.queueOptions.ignoreDupResponses;
                    },

                    getRequestGroupId: function() {
                        return this.requestGroupingId;
                    },

                    setRequestGroupId: function(id) {
                        this.requestGroupingId = id;
                    },

                    resetRequestGroupId: function() {
                        this.requestGroupingId = undefined;
                    },

                    setReadyToSubmit: function(isReady) {
                        this.readyToSubmit = isReady;
                    },

                    getReadyToSubmit: function() {
                        return this.readyToSubmit;
                    },

                    ondrop: function() {
                        var callback = this.queueOptions.onqueuerequestdrop;
                        if (callback) {
                            callback.call(this.queue, this.source, this.options, this.event);
                        }
                    },

                    onRequestDelayPassed: function() {
                        this.readyToSubmit = true;
                        submitFirstEntry.call(this.queue);
                    },

                    startTimer: function() {
                        var delay = this.queueOptions.requestDelay;
                        if (typeof delay != "number") {
                            delay = this.queueOptions.requestDelay || 0;
                        }

                        rf.log.debug("Queue will wait " + (delay || 0) + "ms before submit");

                        if (delay) {
                            var _this = this;
                            this.timer = window.setTimeout(function() {
                                try {
                                    _this.onRequestDelayPassed();
                                } finally {
                                    _this.timer = undefined;
                                    _this = undefined;
                                }
                            }, delay);
                        } else {
                            this.onRequestDelayPassed();
                        }
                    },

                    stopTimer: function() {
                        if (this.timer) {
                            window.clearTimeout(this.timer);
                            this.timer = undefined;
                        }
                    },

                    clearEntry: function() { //???
                        this.stopTimer();
                        if (this.request) {
                            this.request.shouldNotifyQueue = false;
                            this.request = undefined;
                        }
                    },

                    getEventsCount: function() {
                        return this.eventsCount;
                    },

                    setEventsCount: function(newCount) {
                        this.eventsCount = newCount;
                    }
                });

            // TODO: add this two variables to richfaces and report bug to jsf about constants
            var JSF_EVENT_TYPE = 'event';
            var JSF_EVENT_SUCCESS = 'success';
            var JSF_EVENT_COMPLETE = 'complete';

            var items = [];
            var lastRequestedEntry;

            //TODO: instance of this function will be created for each queue
            var onError = function (data) {
                var message = "richfaces.queue: ajax submit error";
                if (data) {
                    var description = data.message || data.description;
                    if (description) {
                        message += ": " + description;
                    }
                }
                rf.log.warn(message);

                lastRequestedEntry = null;
                //TODO: what if somebody is going to clear queue on error?
                submitFirstEntry();
            };

            var removeStaleEntriesFromQueue = function () {
                var entry;
                var foundValidEntry = false;
                while (items.length > 0 && !foundValidEntry) {
                    entry = items[0];
                    var element = rf.getDomElement(entry.source);
                    if (element == null || $(element).closest("form").length == 0) {
                        var removedEntry = items.shift();
                        removedEntry.stopTimer();
                        rf.log.debug("richfaces.queue: removing stale entry from the queue (source element: " + element + ")");
                    } else {
                        foundValidEntry = true;
                    }
                }
            }

            var onComplete = function (data) {
                if (data.type == JSF_EVENT_TYPE && data.status == JSF_EVENT_SUCCESS) { // or JSF_EVENT_COMPLETE will be rather
                    rf.log.debug("richfaces.queue: ajax submit successfull");
                    lastRequestedEntry = null;
                    removeStaleEntriesFromQueue();
                    submitFirstEntry();
                }
            };

            jsf.ajax.addOnEvent(onComplete);
            jsf.ajax.addOnError(onError);

            var submitFirstEntry = function() {
                if (QUEUE_MODE == QUEUE_MODE_PULL && lastRequestedEntry) {
                    rf.log.debug("richfaces.queue: Waiting for previous submit results");
                    return;
                }
                if (isEmpty()) {
                    rf.log.debug("richfaces.queue: Nothing to submit");
                    return;
                }
                var entry;
                if (items[0].getReadyToSubmit()) {
                	try {
                        entry = lastRequestedEntry = items.shift();
                        rf.log.debug("richfaces.queue: will submit request NOW");
                        var o = lastRequestedEntry.options;
                        o["AJAX:EVENTS_COUNT"] = lastRequestedEntry.eventsCount;
                        rf.ajaxContainer.jsfRequest(lastRequestedEntry.source, lastRequestedEntry.event, o);

                        // call event handlers
                        if (o.queueonsubmit) {
                            o.queueonsubmit.call(entry);
                        }
                        callEventHandler("onrequestdequeue", entry);
                	} catch (error) {
                        onError(error);
                	}
                }
            };

            var isEmpty = function() {
                return (getSize() == 0)
            };
            var getSize = function() {
                return items.length;
            };

            var getLastEntry = function () {
                var lastIdx = items.length - 1;
                return items[lastIdx];
            };

            var updateLastEntry = function (entry) {
                var lastIdx = items.length - 1;
                items[lastIdx] = entry;
            };

            var callEventHandler = function (handlerName, entry) {
                var handler = entry.queueOptions[handlerName];
                if (handler) {
                    if (typeof(handler) == "string") {
                        new Function(handler).call(null, entry);
                    } else {
                        handler.call(null, entry);
                    }
                }
                var opts, handler2;
                if (entry.queueOptions.queueId &&
                    (opts = defaultQueueOptions[entry.queueOptions.queueId]) &&
                    (handler2 = opts[handlerName])
                    && handler2 != handler) {
                    // the same about context
                    handler2.call(null, entry);
                }
            }

            var pushEntry = function (entry) {
                items.push(entry);
                rf.log.debug("New request added to queue. Queue requestGroupingId changed to " + entry.getRequestGroupId());
                // call event handlers
                callEventHandler("onrequestqueue", entry);
            }

            return {
                /**
                 * @constant
                 * @name RichFaces.queue.DEFAULT_QUEUE_ID
                 * @type string
                 * */
                DEFAULT_QUEUE_ID: DEFAULT_QUEUE_ID,

                /**
                 * Get current queue size
                 * @function
                 * @name RichFaces.queue.getSize
                 *
                 * @return {number} size of items in the queue
                 * */
                getSize: getSize,

                /**
                 * Check if queue is empty
                 * @function
                 * @name RichFaces.queue.isEmpty
                 *
                 * @return {boolean} returns true if queue is empty
                 * */
                isEmpty: isEmpty,

                /**
                 * Extract and submit first QueueEntry in the queue if QueueEntry is ready to submit
                 * @function
                 * @name RichFaces.queue.submitFirst
                 * */
                submitFirst: function () {
                    if (!isEmpty()) {
                        var entry = items[0];
                        entry.stopTimer();
                        entry.setReadyToSubmit(true);
                        submitFirstEntry();
                    }
                },

                /**
                 * Create and push QueueEntry to the queue for ajax requests
                 * @function
                 * @name RichFaces.queue.push
                 *
                 * @param {string|DOMElement} source - The DOM element or an id that triggered this ajax request
                 * @param {object} [event] - The DOM event that triggered this ajax request
                 * @param {object} [options] - The set name/value pairs that can be sent as request parameters to control client and/or server side request processing
                 * */
                push: function (source, event, options) {
                    var entry = new QueueEntry(this, source, event, options);
                    var requestGroupingId = entry.getRequestGroupId();

                    var lastEntry = getLastEntry();

                    if (lastEntry) {
                        if (lastEntry.getRequestGroupId() == requestGroupingId) {
                            rf.log.debug("Similar request currently in queue");

                            rf.log.debug("Combine similar requests and reset timer");

                            lastEntry.stopTimer();
                            entry.setEventsCount(lastEntry.getEventsCount() + 1);

                            updateLastEntry(entry);
                            callEventHandler("onrequestqueue", entry);
                        } else {
                            rf.log.debug("Last queue entry is not the last anymore. Stopping requestDelay timer and marking entry as ready for submission")

                            lastEntry.stopTimer();
                            lastEntry.resetRequestGroupId();
                            lastEntry.setReadyToSubmit(true);

                            pushEntry(entry);
                            submitFirstEntry();
                        }
                    } else {
                        pushEntry(entry);
                    }

                    // start timer
                    entry.startTimer();

                },

                response: function (request, context) {
                    if (this.isIgnoreResponse()) {
                        lastRequestedEntry = null;
                        submitFirstEntry();
                    } else {
                        rf.ajaxContainer.jsfResponse(request, context);
                    }
                },

                isIgnoreResponse: function () {
                    var entry = items[0];
                    return entry && lastRequestedEntry.isIgnoreDupResponses()
                        && lastRequestedEntry.queueOptions.requestGroupingId == entry.queueOptions.requestGroupingId;
                },

                /**
                 * Remove all QueueEntry from the queue
                 * @function
                 * @name RichFaces.queue.clear
                 * */
                clear: function () {
                    var lastEntry = getLastEntry();
                    if (lastEntry) {
                        lastEntry.stopTimer();
                    }
                    items = [];
                },

                /**
                 * Set queue default options
                 * @function
                 * @name RichFaces.queue.setQueueOptions
                 *
                 * @param {string||object} [id] - Queue id for storing options or hash with options for multiple options set
                 * @param {object} options - Queue options object
                 * */
                setQueueOptions: function (id, options) {
                    var tid = typeof id;
                    if (tid == "string") {
                        // add named queue options
                        if (defaultQueueOptions[id]) {
                            throw "Queue already registered";
                        } else {
                            defaultQueueOptions[id] = options;
                        }
                    } else if (tid == "object") {
                        // first parameter is hash with queue names and options
                        $.extend(defaultQueueOptions, id);
                    }
                    return rf.queue;
                },

                getQueueOptions: function (id) {
                    return defaultQueueOptions[id] || {};
                }
            }
        }());
    }(RichFaces.jQuery, RichFaces, jsf));