Changeset 522 for Dev/trunk/src/client

Timestamp:

03/17/14 21:50:17 (11 years ago)

Author:

hendrikvanantwerpen

Message:

• Add option to deploy source to Heroku (for debugging).
• Rewrite xhr so requests are not serialized anymore.
• Give more sane errors on request errors to Couch (like network errors and such).

File:

• Dev/trunk/src/client/qed-client/xhr.js (modified) (4 diffs)

Dev/trunk/src/client/qed-client/xhr.js

@@ -2 +2 @@
     "./session",
     "dojo/Deferred",
+    "dojo/_base/array",
     "dojo/_base/lang",
-    "dojo/on",
-    "dojo/_base/xhr"
-], function(session, Deferred, lang, on, xhr) {
+    "dojo/_base/xhr",
+    "dojo/on"
+], function(session, Deferred, array, lang, xhr, on) {
 
-    var user = session.get();
+
     var queue = [];
-    
-    on(session, 'change', function(newUser){
+    var user;
+    var generation = 0;
+
+    on(session, 'change', setUser);
+    setUser(session.get());
+
+    function setUser(newUser) {
         user = newUser;
-        retry();
-    });
-
-    function retry() {
-        if (user && queue.length > 0) {
-            var item = queue.shift();
-            console.log("Retry",item.options.url);
-            real_request(item);
+        generation += 1;
+        if ( user ) {
+            // we make a local copy, just in case the requests cause
+            // events to happen
+            var q = queue;
+            queue = [];
+            array.forEach(q,real_request);
+        } else {
+            session.restore();
         }
     }
-    
+
     function real_request(item) {
+        var req_generation = generation;
         var req = xhr(item.method,lang.mixin(item.options||{},{
             failOk: true
@@ -29 +37 @@
         item.promise.ioArgs = req.ioArgs;
 
-        req.then(function(result){
+        console.log("Do request",item.options.url);
+        req.then(function(result) {
             item.dfd.resolve(result);
-            retry();
         }, function(error){
             if ( error.response.status === 401 ) {
-                queue.unshift(item);
-                session.restore();
+                if ( user ) {
+                    if ( req_generation === generation ) {
+                        console.log("Retry after reauthentication",item.options.url);
+                        // we need to reauth
+                        queue.push(item);
+                        setUser(null);
+                    } else {
+                        console.log("Retry immediately",item.options.url);
+                        // we already did, redo request right away
+                        real_request(item);
+                    }
+                } else {
+                    console.log("Retry when authenticated",item.options.url);
+                    queue.push(item);
+                }
             } else {
                 item.dfd.reject(error);
-                retry();
             }
         });
     }
     
-    var _request = function(method, options) {
+    var _xhr = function(method, options) {
         var item = {
             method: method,
@@ -50 +70 @@
         };
         item.promise = lang.delegate(item.dfd.promise);
-        // only do the request directly if we are authenticated and
-        // there are no earlier requests queued.
-        if ( user && queue.length === 0 ) {
-            console.log("Request",options.url);
+        // only do the request directly if we are authenticated
+        if ( user ) {
+            console.log("Immediate",options.url);
             real_request(item);
         } else {
-            console.log("Push",options.url);
+            console.log("Delay until authenticated",options.url);
             queue.push(item);
         }
@@ -62 +81 @@
     };
 
-    return _request;
+    return _xhr;
 });