copyright updated and mop user status added
[brisk.git] / web / xhr.js
index fba8002..5503694 100644 (file)
@@ -1,7 +1,10 @@
 /*
  *  brisk - xhr.js
  *
- *  Copyright (C) 2006 matteo.nastasi@milug.org
+ *  Copyright (C) 2006-2011 Matteo Nastasi
+ *                          mailto: nastasi@alternativeoutput.it 
+ *                                  matteo.nastasi@milug.org
+ *                          web: http://www.alternativeoutput.it
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
  * not, write to the Free Software Foundation, Inc, 59 Temple Place -
  * Suite 330, Boston, MA 02111-1307, USA.
  *
- * $Id$
- *
  */
 
 var xhr_rd_cookiepath = "/brisk/";
-var xhr_rd = false;
+var xhr_rd = null;
 var xhr_rd_stopped = true;
 var xhr_rd_oldctx = "";
 var xhr_rd_newctx = "";
-
+var xhr_rd_delay = 0;
+var xhr_rd_delayed = null;
 var xhr_rd_cur_n = -1;
 var xhr_rd_old_n = -1;
 var xhr_rd_checkedlen = 0;
+var xhr_rd_watchdog = null;
 var the_end = false;
 var ct = 0;
 var watchdog = 0;
 
+function hbit(symb)
+{
+    if ($("heartbit").innerHTML.length >= 120) {
+        $("heartbit").innerHTML = $("heartbit").innerHTML.substring(10);
+        $("heartbit").innerHTML += symb;
+    }
+    else {
+        $("heartbit").innerHTML += symb;
+    }
+    // $("heartbit").innerHTML = $("heartbit").innerHTML.substring(20,20); // DA METTERE APPOSTO!!!!
+        
+}
+
 function xhr_rd_cb(xhr_rd) 
 {
     var ret;
 
+    // console.log(xhr_rd.readyState);
+
     if (xhr_rd.readyState == 4) {
+        if (xhr_rd_watchdog != null) {
+            hbit('C');
+            clearTimeout(xhr_rd_watchdog);
+            xhr_rd_watchdog = null;
+        }
+
+        // console.log("SS: "+safestatus(xhr_rd));
+
        try {
            if ((ret = safestatus(xhr_rd)) == 200) {
+                xhr_rd_delay = 0;
+                // console.log("del a null "+xhr_rd_delayed);
            } else if (ret != -1) {
-               alert('There was a problem with the request.' + ret);
+                xhr_rd_delay = 5000;
+                hbit('X');
+               // alert('There was a problem with the request.' + ret);
            }
        } catch(b) {};
 
+        xhr_rd_delayed = null;
        xhr_rd_stopped = true;
     }
 };
 
+function xhr_rd_abort(xhr)
+{
+    hbit('A');
+    if (xhr != null)
+        xhr.abort();
+    // alert("de che");
+}
+
 function xhr_rd_start(sess,stat,subst,step) 
 {
-    if (the_end)
+    if (the_end) {
+        if (xhr_rd_watchdog != null) {
+            hbit('C');
+            clearTimeout(xhr_rd_watchdog);
+            xhr_rd_watchdog = null;
+        }
        return;
-    createCookie("sess",sess,1,xhr_rd_cookiepath);
+    }
+    createCookie("sess", sess, 24*365, xhr_rd_cookiepath);
+
+    // NOTE: *ctx = "" to prevent konqueror stream commands duplication.
+    xhr_rd_oldctx = "";
+    xhr_rd_newctx = "";
 
     /* NOTE document.uniqueID exists only under IE  */
-    // alert("di qui3");
+    // if (g_is_spawn == 1)
+    // alert("di qui3: "+(g_is_spawn == 1 ? "&table_idx="+g_table_idx : ""));
     xhr_rd.open('GET', 'index_rd.php?sess='+sess+"&stat="+stat+"&subst="+subst+"&step="+step+"&onlyone="+(document.uniqueID ? "TRUE" : "FALSE")+"&myfrom="+myfrom, true);
     //    try { 
     xhr_rd.onreadystatechange = function() { xhr_rd_cb(xhr_rd); }
     xhr_rd.send(null);
+    // 
+    // TODO: qui avvio del timer per riavviare xhr
+    // 
+    xhr_rd_watchdog = setTimeout(xhr_rd_abort, 60000, xhr_rd);
     xhr_rd_cur_n++;
     xhr_rd_stopped = false;
     // } catch (e) {}
@@ -81,17 +135,13 @@ function xhr_rd_poll(sess)
        xhr_rd.abort(); 
     }
     */
-
     var zug = "XHR_RD_POLL sess = "+sess+" stat = "+stat+" subst = "+subst+" step = "+gst.st+" step_loc = "+gst.st_loc+" step_loc_new = "+gst.st_loc_new+" STOP: "+xhr_rd_stopped;
 
     if (zug != $("sandbox").innerHTML)
        $("sandbox").innerHTML = zug;
-    
 
-    /* heartbeat log */
-    $("heartbit").innerHTML += "_";
-    if ($("heartbit").innerHTML.length == 20)
-       $("heartbit").innerHTML = "_";
+    /* heartbit log */
+    hbit("_");
     
     do {
        again = 0;
@@ -106,6 +156,8 @@ function xhr_rd_poll(sess)
            singlecomm = gst.comms.shift();
            // alert("EXE"+gugu);
            // $("xhrdeltalog").innerHTML = "EVALL: "+singlecomm.replace("<", "&lt;", "g"); +"<br>";
+           hbit("+");
+
            eval(singlecomm);
            again = 1;
        }
@@ -113,37 +165,53 @@ function xhr_rd_poll(sess)
            xhrrestart = 1;
            try { 
                if (xhr_rd == null)
-                       throw "restart";
+                    throw "restart";
                if (xhr_rd.responseText != null)
-                       xhr_rd_newctx = xhr_rd.responseText;
+                    xhr_rd_newctx = xhr_rd.responseText;
            }
            catch (e) {
                if (xhr_rd_stopped == true) {
                    xhr_rd_stopped = false;
                    // XX $("xhrstart").innerHTML += "XHRSTART: da catch<br>";
-                   xhr_rd_start(sess, stat, subst, gst.st);
+                    if (xhr_rd_delay > 0) {
+                        if (xhr_rd_delayed == null) {
+                            // console.log("XXX DI QUI "+xhr_rd_delay);
+                            xhr_rd_delayed = setTimeout(xhr_rd_start, xhr_rd_delay, sess, stat, subst, gst.st);
+                            // console.log("XXX DI QUI post"+xhr_rd_delayed);
+                        }
+                    }
+                    else {
+                        // console.log("yyy DI QUI "+xhr_rd_delay);
+                        xhr_rd_start(sess, stat, subst, gst.st);
+                    }
                }
-               
+                
                
                // $("sandbox").innerHTML += "return 1<br>";
                if (the_end != true) {
                    watchdog = 0;
                    setTimeout(xhr_rd_poll, tout, sess);
-                   $("heartbit").innerHTML += "-";
-                   if ($("heartbit").innerHTML.length == 20)
-                       $("heartbit").innerHTML = "-";
+                   
+                   // hbit(".");
+                   
                }
-               return;
-           }
-           
-
-           // no new char from the last loop, break
-           if (xhr_rd_old_n == xhr_rd_cur_n && 
-               xhr_rd_newctx.length == xhr_rd_checkedlen) {
-               watchdog++;
-               break;
-           }
-           else {
+                else {
+                    if (xhr_rd_watchdog != null) {
+                        clearTimeout(xhr_rd_watchdog);
+                        xhr_rd_watchdog = null;
+                    }
+                }    
+                return;
+            }
+                
+            
+            // no new char from the last loop, break
+            if (xhr_rd_old_n == xhr_rd_cur_n && 
+                xhr_rd_newctx.length == xhr_rd_checkedlen) {
+                watchdog++;
+                break;
+            }
+            else {
                watchdog = 0;
                // $("sandbox").innerHTML += "BIG IF<br>";
                var comm_match;
@@ -155,6 +223,8 @@ function xhr_rd_poll(sess)
                var delta = 0;
                var match_lines = /^_*$/;
 
+               hbit("/\\");
+
                // check for the same command group
                if (xhr_rd_old_n != xhr_rd_cur_n) {
                    xhr_rd_old_n = xhr_rd_cur_n;
@@ -211,16 +281,29 @@ function xhr_rd_poll(sess)
        // $("sandbox").innerHTML += "LITTLE IF<br>";
        // alert("di qui");
        // XX $("xhrstart").innerHTML += "XHRSTART: da end poll<br>";
-       xhr_rd_start(sess, stat, subst, gst.st);
-       // $("sandbox").innerHTML += "return 2<br>";
+
+        if (xhr_rd_delay > 0) {
+            if (xhr_rd_delayed == null) {
+                // console.log("XXX DI QUO "+xhr_rd_delay);
+                xhr_rd_delayed = setTimeout(xhr_rd_start, xhr_rd_delay, sess, stat, subst, gst.st);
+                // console.log("XXX DI QUO post"+xhr_rd_delayed);
+            }
+        }
+        else {
+            // console.log("yyy DI QUO "+xhr_rd_delay);
+            xhr_rd_start(sess, stat, subst, gst.st);
+        }
+        
     }
-       
-    // $("sandbox").innerHTML += "return 3<br>";
+    
     if (the_end != true) {
        setTimeout(xhr_rd_poll, tout, sess);
-       $("heartbit").innerHTML += "-";
-       if ($("heartbit").innerHTML.length == 20)
-           $("heartbit").innerHTML = "-";
+    }
+    else {
+        if (xhr_rd_watchdog != null) {
+            clearTimeout(xhr_rd_watchdog);
+            xhr_rd_watchdog = null;
+        }
     }
     return;
 };