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

var ChromagramMeandreWorkflow = 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/chromagram-v1/";
    this.serviceHead = "http://greenstone.org/meandre/flows/chromagram-v1/instance/greenstone-audio-web-service-head/0";
    this.serviceTail = "http://greenstone.org/meandre/flows/chromagram-v1/instance/float32-frame-web-service-buffer/5";

    this.flowPort = null;

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

    this.meandreCount = 0;
}


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

ChromagramMeandreWorkflow.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); 

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


    // Break it up into frames

    //payload.data = float32Array;
    this.meandreDataOutput.push(float32Array);
    }
}



ChromagramMeandreWorkflow.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(1000,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);
    }, 400);

    }
    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++;
}


ChromagramMeandreWorkflow.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});
    
    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();
        }

    }, 700);

    }, 800);
}

ChromagramMeandreWorkflow.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});    
}