/*
 *  brisk - xhr.js
 *
 *  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
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABLILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * General Public License for more details. You should have received a
 * copy of the GNU General Public License along with this program; if
 * not, write to the Free Software Foundation, Inc, 59 Temple Place -
 * Suite 330, Boston, MA 02111-1307, USA.
 *
 */

var xhr_rd_cookiepath = "/brisk/";
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 (typeof xhr_rd_watchdog != 'undefined' && 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) {
                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) {
        //x alert("the_end1");
        if (typeof xhr_rd_watchdog != 'undefined' && xhr_rd_watchdog != null) {
            hbit('C');
            clearTimeout(xhr_rd_watchdog);
            xhr_rd_watchdog = null;
        }
	return;
    }
    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  */
    // 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) {}
};

function xhr_rd_poll(sess)
{
    var tout = 100;
    var again;
    var xhrrestart;
    ct++;

    /*
    if (watchdog >= 50) {
	watchdog = 0;
	// alert("ABORT XHR_RD");
	xhr_rd_stopped = true;
	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;

    /* heartbit log */
    hbit("_");
    
    do {
	again = 0;
	xhrrestart = 0;
	if (gst.st_loc < gst.st_loc_new) {
	    // there is some slow actions running
	    break;
	}
	else if (gst.comms.length > 0) {
	    var singlecomm;

	    singlecomm = gst.comms.shift();
	    // alert("EXE"+gugu);
	    // $("xhrdeltalog").innerHTML = "EVALL: "+singlecomm.replace("<", "&lt;", "g"); +"<br>";
	    hbit("+");

	    eval(singlecomm);
	    again = 1;
	}
	else {
	    xhrrestart = 1;
	    try { 
	        if (xhr_rd == null)
                    throw "restart";
		if (xhr_rd.responseText != null)
                    xhr_rd_newctx = xhr_rd.responseText;
	    }
	    catch (e) {
		if (xhr_rd_stopped == true) {
		    xhr_rd_stopped = false;
		    // XX $("xhrstart").innerHTML += "XHRSTART: da catch<br>";
                    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);
		    
		    // hbit(".");
		    
		}
                else {
                    //x alert("the_end2");
                    if (typeof xhr_rd_watchdog != 'undefined' && 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;
		var comm_clean;
		var comm_len;
		var comm_newpart;
		var comm_arr;
		var i;
		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;
		    xhr_rd_checkedlen = 0;
		    xhr_rd_oldctx = "";
		}
		else
		    delta = xhr_rd_oldctx.length;

		// $("xhrlog").innerHTML += "EVERY SEC<br>";		
		for (i = delta ; i < xhr_rd_newctx.length ; i++) {
		    if (xhr_rd_newctx[i] != '_') 
			break;
		}
		if (i == xhr_rd_newctx.length) {
		    xhr_rd_checkedlen = i;
		    break;
		}

		// $("xhrlog").innerHTML += "CHECK COM<br>";		
		// extracts the new part of the command string
		comm_newpart = xhr_rd_newctx.substr(delta);
		
		// XX $("xhrlog").innerHTML = xhr_rd_newctx.replace("<", "&lt;", "g");

		// $("response").innerHTML = comm_newpart;
		comm_match = /_*@BEGIN@(.*?)@END@/g;
		comm_clean = /_*@BEGIN@(.*?)@END@/;
		comm_len = 0;
		comm_arr = comm_newpart.match(comm_match);
		
		// $("sandbox").innerHTML += "PRE COMMARR<br>";
		if (comm_arr) {
		    // XX $("xhrdeltalog").innerHTML += "DELTA: "+delta +"<br>";
		    // XX alert("xhr_rd_newctx: "+xhr_rd_newctx);
		    // $("sandbox").innerHTML += "POST COMMARR<br>";
		    for (i = 0 ; i < comm_arr.length ; i++) {
			var temp = comm_arr[i].replace(comm_clean,"$1").split("|");
			gst.comms = gst.comms.concat(temp);
			// XX alert("COMM_ARR["+i+"]: "+comm_arr[i]+"  LEN:"+comm_arr[i].length);
			comm_len += comm_arr[i].length;
		    }
		    tout = 0;
		    xhr_rd_oldctx += comm_newpart.substr(0,comm_len);
		    // XX alert("XHR_RD_OLDCTX: "+xhr_rd_oldctx);
		    again = 1;
		}
		xhr_rd_checkedlen = xhr_rd_oldctx.length;
	    }
	}
    } while (again);

    if (xhrrestart == 1 && xhr_rd_stopped == true) {
	// $("sandbox").innerHTML += "LITTLE IF<br>";
	// alert("di qui");
	// XX $("xhrstart").innerHTML += "XHRSTART: da end poll<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);
        }
        
    }
    
    if (the_end != true) {
	setTimeout(xhr_rd_poll, tout, sess);
    }
    else {
        //x alert("the_end3");
        if (typeof(xhr_rd_watchdog) != 'undefined') {
            if (xhr_rd_watchdog != null) {
                clearTimeout(xhr_rd_watchdog);
                xhr_rd_watchdog = null;
            }
        }
    }
    return;
};

/*
  window.onload = function () {
  xhr_rd = createXMLHttpRequest();

  sess = $("user").value;
  window.setTimeout(xhr_rd_poll, 0, sess);
  };
*/