[lib] add locks feature

heapwolf · Sep 1, 2011 · 249a2a0 · 249a2a0
1 parent 9248cb1
commit 249a2a0
Showing 1 changed file with 42 additions and 1 deletion.
diff --git a/lib/Porter.js b/lib/Porter.js
@@ -35,8 +35,10 @@
       headers: {
         'Accept': 'application/json',
         'Content-Type': 'application/json'
-      }
+      },
+      delay: false
     };
+    this._locks = {};
 
     this.headers = this.options.headers;
 
@@ -89,6 +91,18 @@
 
       ajax.run = function(callbacks, validators) {
 
+        // Setup locks
+        if (!conf.ignoreLocks && conf.type !== 'GET' && self._locks[conf.url]) {
+          self._locks[conf.url].push({
+            conf: conf,
+            callbacks: callbacks,
+            validators: validators
+          });
+          return;
+        } else {
+          self._locks[conf.url] = [];
+        }
+
         // merge the global _listeners into this xhr.
         for(l in self._listeners) {
           if(self._listeners.hasOwnProperty(l)) {
@@ -160,6 +174,33 @@
             break;
             case 4:
 
+              // Release locks or run delayed requests
+              if (!conf.ignoreLocks && conf.type !== 'GET' &&
+                  self.options.delay !== false) {
+
+                setTimeout(function() {
+                  var data = self._locks[conf.url].shift();
+
+                  // If we have any request queued
+                  if (data) {
+                    var _locks = self._locks;
+
+                    // Temporally clear locks
+                    self._locks = {};
+
+                    // Do unlocked request
+                    var req = new self.ajax(data.conf);
+                    req.run(data.callbacks, data.validators);
+
+                    // Restore locks
+                    self._locks = _locks;
+                  } else {
+                    // Remove lock
+                    self._locks[conf.url] = null;
+                  }
+                }, self.options.delay);
+              }
+
               var response = ajax.xhr.responseText.trim(),
                   status = ajax.xhr.status,
                   statusText = ajax.xhr.statusText,