queue.js.svn-base

嵌入式无线路由系统openwrt的web配置工具

/*

Class: FlashSYS.Queue
  Ajax queue builder

Copyright:
  Copyright (C) 2008 OpenRB.com

Arguments:
  queue - (array of objects) the queue itself
  options - (object)

Options:
  urlCb - (function) callback for request url
  stepCb - (function) executed after every request
  endCb - (function) executed when all queue elements are loaded

*/
FlashSYS.Queue = new Class({
  Implements: [Options],

  queue: [],
  options: {
    urlCb: $empty,
    stepCb: $empty,
    endCb: $empty
  },

  initialize: function(queue, options) {
    this.queue = queue;
    this.setOptions(options);

    this.step();
    return this;
  },
  /*

  Function: step
    Get first queue element and make request, exit if queue is empty

  */
  step: function() {
    // queue is empty, stop execution
    if (this.queue.length == 0) {
      this.options.endCb();
      return;
    }
    // get first element of the queue
    var params = this.queue.shift();

    var fsRequest = new Request({
      'url': this.options.urlCb(params),
      'data': { 'data': JSON.encode(params) },
      'extra': params,
      'onSuccess': this.loadSuccess.bind(this),
      'onFailure': this.loadFailed.bind(this, params)
    }).send();
  },
  /*

  Function: loadSuccess
    Executed when got data from AJAX request without any error

  Arguments:
    responseText - (string) module response text
    xml - (string) xml response, not used
    params - (object) extra parameters from load function

  */
  loadSuccess: function(responseText, xml, params) {
    this.options.stepCb(responseText, params);
    this.step();
  },
  /*

  Function: loadFailed
    Executed when there was an error during load

  Arguments:
    params - (object) extra parameters from load function

  */
  loadFailed: function(params) {
    this.options.stepCb(null, params);
    this.step();
  }
});