source: main/trunk/model-sites-dev/multimodal-mdl/collect/selfsim-my-ipod/script2/meandre-workflow/js-dynamic-mix.js@ 28433

var JSDynamicMixMeandreWorkflow = function() {

    var domain_prefix = window.location.protocol + "//" + window.location.hostname;

    this.meandreController = new MeandreController(domain_prefix,"1714","1712");

    this.baseURI     = "http://greenstone.org/meandre/flows/dynamic-javascript-mixer/"
    this.serviceHead = this.baseURI + "instance/greenstone-audio-web-service-head/0";
    this.serviceTail = this.baseURI + "instance/float32-frame-web-service-buffer/3";

    this.serviceJSDynamic = this.baseURI + "instance/dynamic-javascript-computation-component/2";

    this.flowPort = null;

    this.meandreFrameSize = null;
    this.meandreDataOutput = new Array();

    this.meandreCount = 0;
}


JSDynamicMixMeandreWorkflow.prototype.thisMeandreFlowIsRunning = function() {
    return this.flowPort != null;
}

function bin2String(array,range) {
    var result = "";

    var excerpt = range || 5000;

    var lowcut = Math.min(array.length,excerpt);
        
    result += "low cut: " + lowcut + "\n";
    for (var i = 0; i < lowcut; i++) {
    result += String.fromCharCode(65+array[i]);
    if (((i+1)%200)==0) {
        result += "\n";
    }
    }
    
    result += "\n";


    var highcut = Math.max(array.length-excerpt,0);
    result += "high cut: " + highcut + "\n";

    for (var i = highcut; i < array.length; i++) {
    result += String.fromCharCode(65+array[i]);
    if (((i+1)%200)==0) {
        result += "\n";
    }
    }
    result += "\n";

    return result;
}

JSDynamicMixMeandreWorkflow.prototype.processThisMeandreFlowOutputDataCallback = function(oEvent,oReq) {


    var arrayBuffer = oReq.response; // Note: not oReq.responseText

    if (arrayBuffer.byteLength) {
    //console.log("*** get-data callback: Recieved binary data: raw byte array buffer len = " + arrayBuffer.byteLength);

    //console.log("*** type of arrayBuffer: " + toType(arrayBuffer));

    //var float32Array = new Float32Array(arrayBuffer); 
    var byteArray = new Uint8Array(arrayBuffer); 
    var byteArrayLen = byteArray.length;

    var fixPos = new Array();
    for (var i=0; i<byteArrayLen; i++) {
        if ((byteArray[i]==10)) {
            // && ((i<byteArrayLen-1) && (byteArray[i+1]==13))) {
        // Despite the 'response' from the servlet being set to content type 'application/octet'
        // the output streamed through the server is still treated as text, and a '10' in the binary
        // stream is changed to '13', '10'

        fixPos.push(i-1); 
        }
    }

    var fixPosLen = fixPos.length;
    //console.log("*** fix pos len = " + fixPosLen);

    var fixedByteArrayLen = byteArrayLen - fixPosLen;
    var fixedByteArray = new Uint8Array(fixedByteArrayLen);

    var prevPos = 0;
    var newPos = 0;

    for (var i=0; i<fixPosLen; i++) {
        var currFixPos = fixPos[i];

        var sliceArray = byteArray.subarray(prevPos,currFixPos);
        fixedByteArray.set(sliceArray,newPos);

        prevPos = currFixPos+1; // shift over erroneous <CR> (char 13)
        newPos += sliceArray.length;

    }

    var remainingSliceArray = byteArray.subarray(prevPos);
    fixedByteArray.set(remainingSliceArray,newPos);
    
    if ((fixedByteArray.length % 4) != 0) {
        console.error("Fixed Returned binary data is not a multiple of 4");

        this.meandreDataOutput.push(byteArray);
    }
    else {
        //console.log("fixed byte array len = " + fixedByteArray.length);

        var float32Array = new Float32Array(fixedByteArray.buffer); 

        //console.log("float array len = " + float32Array.length);

        var meandreFrameSize = this.meandreFrameSize;
        var numFramesReceived = float32Array.length/meandreFrameSize;
        
        //console.log("** meandre output frameSize = " + meandreFrameSize);
        console.info("*** get-data callback: number of frames received = " + numFramesReceived);

        for (var i=0; i<numFramesReceived; i++) {
        var startPos = i*meandreFrameSize;
        var endPos   = startPos + meandreFrameSize -1;
        var frame = float32Array.subarray(startPos,endPos);
        
        //console.log("*** frameSize=" + meandreFrameSize + ", start pos=" + startPos + ", endPos=" + endPos + ", pushing on frame of size: " + frame.length);

        this.meandreDataOutput.push(frame);
        }       
    }   
    }
}



JSDynamicMixMeandreWorkflow.prototype.processThisMeandreFlowOutputData = function(flowPort) {

    // does flowPort need to be passed in as a parameter, now this is method not a function?

    var getinfo_options = {cmd: "get-info" };

    var info_props = this.meandreController.webComponentProperties(flowPort,this.serviceTail,getinfo_options)

    // values stored in 'info_props' are strings => need to make sure we treat get numeric fields such
    // as 'numFrames' as an integer

    var numFramesAvailable = parseInt(info_props.numFrames);
    if (isDefined(numFramesAvailable)) {
    this.meandreFrameSize = parseInt(info_props.frameSize); 
    }
    else {
    numFramesAvailable = 0;
    }

//    console.log("*** Meandre count = " + meandreCount);    

    if (numFramesAvailable>0) {

    var getNumFrames = Math.min(600,numFramesAvailable);

    console.info("get-data request: Number of frames available = " + numFramesAvailable, ", number of frames requested = " + getNumFrames);

//  console.log("***** doing a get-data");
    var getdata_options = {cmd: "get-data", numFrames: getNumFrames };
    var payload = this.meandreController.binaryWebComponent(flowPort,this.serviceTail,getdata_options,
                                this.processThisMeandreFlowOutputDataCallback,this);

    // delay the next call to 'get-info' to give the 'get-data' a chance to reach the server
    var that = this;
    setTimeout(function() {
        that.processThisMeandreFlowOutputData(flowPort);
    }, 800);

    }
    else {
    console.log("*** Sending 'done' command");
    var done_options = {cmd: "done" };
    this.meandreController.webComponent(flowPort,this.serviceHead,done_options);

    // disable 'stop' and make 'run' active again
    $('#meandre-stop-button').attr("disabled", "disabled");
    $('#meandre-run-button').removeAttr("disabled");
    }

    this.meandreCount++;
}


JSDynamicMixMeandreWorkflow.prototype.runThisMeandreFlow = function(elem,playCallback) {

    if (this.thisMeandreFlowIsRunning()) {
    console.error("runThisMeandreFlow(): The flow is already running on port " + this.flowPort);
    return;
    }

    var $progressElem = $('#processing');
    var $progressTitleElem = $('#processingTitle');
    var $progressTextElem = $('#processingText');

    var displayProgress = ($progressElem.length>0) ? true : false;
    if (displayProgress) {
    $progressTitleElem.html("Starting Meandre Workflow ...");
    $progressTextElem.css('display','none');
    $progressElem.css('display','block');
    }


    var flow_token = this.meandreController.runFlow(this.baseURI);
    //console.log("**** got flow token : " + flow_token);     
    
    // Give the flow time to start up ...
    var that = this;
    setTimeout(function() {
    // Now find out which port it is running on ...
    var flow_props = that.meandreController.runningFlowProperties(flow_token);
    var flow_port =  flow_props.port;

    var attempts = 0;
    while ((flow_port==null) || (flow_port <= 0)) {
        console.info("port returned as " + flow_port + ", trying again");
        flow_props = that.meandreController.runningFlowProperties(flow_token);
        flow_port =  flow_props.port;       
        attempts++;

        if (attempts==10) {
        break;
        }
    }

    console.info("Running Meandre flow on port : " + flow_port);
    that.flowPort = flow_port;
    
    $('#meandre-run-button').attr("disabled", "disabled");
    $('#meandre-stop-button').removeAttr("disabled");
    
    //$('#meandre-run-button').button({ disabled: true });
    //$('#meandre-stop-button').button({disabled: false});
    

    // send over the user's custom javascript
    var script_str = $("#js-dynamic-code").val();

    var script_options = { 
        code: encodeURIComponent(script_str) // effectively double encode to get it through the proxy-server
    };

    that.meandreController.webComponent(that.flowPort,that.serviceJSDynamic,script_options);


    var start_options = { 
        cmd: "generate-audio-signal", 
        docOID: "wibble",
        site: gs.xsltParams["site_name"],
        collect: collect,
        assocPath: gs.documentMetadata["assocfilepath"],
        assocFile: "doc.wav"
    };

    that.meandreController.webComponent(that.flowPort,that.serviceHead,start_options);
    
    setTimeout(function() { 
        that.processThisMeandreFlowOutputData(that.flowPort);

        if (displayProgress) {
        $progressElem.css('display','none');
        $progressTextElem.css('display','block');
        }

        if (elem!=null) {
        // runFlow has been triggered by clicking on the 'run' button
        togglePlay(null,document.getElementById('mainPlayButton'));
        }
        else if (playCallback!=null) {
        playCallback();
        }

    }, 800);

    }, 800);
}

JSDynamicMixMeandreWorkflow.prototype.stopThisMeandreFlow = function(elem) {
    
    this.meandreController.abortFlow(this.flowPort);
    
    $('#meandre-stop-button').attr("disabled", "disabled");
    $('#meandre-run-button').removeAttr("disabled");
    
    //$('#meandre-run-button').button({ disabled: false });
    //$('#meandre-stop-button').button({disabled: true});    
}