jobs.js

/** This class handles job submissions to the charts tool. */
define( [ 'utils/utils' ], function( Utils ) {

    /** Time to wait before refreshing to check if job has completed */
    var WAITTIME = 1000;

    /** Submit job request to charts tool */
    var request = function( app, parameters, success, error ) {
        var chart = app.chart;
        chart.state( 'wait', 'Requesting job results...' );
         if ( chart.get( 'modified' ) ) {
            cleanup( chart );
            chart.set( 'modified', false );
        }
        var dataset_id_job = chart.get( 'dataset_id_job' );
        if ( dataset_id_job != '' ) {
            wait( chart, success, error );
        } else {
            var chart_id            = chart.id;
            var chart_type          = chart.get( 'type' );
            var chart_definition    = chart.definition;
            chart.state( 'wait', 'Sending job request...' );
            Utils.request({
                type    : 'POST',
                url     : Galaxy.root + 'api/tools',
                data    : parameters,
                success : function( response ) {
                    if ( !response.outputs || response.outputs.length == 0 ) {
                        chart.state( 'failed', 'Job submission failed. No response.' );
                        error && error();
                    } else {
                        refreshHdas();
                        var job = response.outputs[0];
                        chart.state( 'wait', 'Your job has been queued. You may close the browser window. The job will run in the background.' );
                        chart.set( 'dataset_id_job', job.id );
                        self.app.storage.save();
                        wait( chart, success, error );
                    }
                },
                error   : function( response ) {
                    var message = '';
                    if ( response && response.message && response.message.data && response.message.data.input ) {
                        message = response.message.data.input + '.';
                    }
                    chart.state( 'failed', 'This visualization requires the \'charts\' tool. Please make sure it is installed. ' + message );
                    error && error();
                          
                }
            });
        }
    };

    /* Remove previous data when re-running jobs */
    var cleanup = function( chart ) {
        var self = this;
        var previous =  chart.get( 'dataset_id_job' );
        if (previous != '') {
            Utils.request({
                type    : 'PUT',
                url     : Galaxy.root + 'api/histories/none/contents/' + previous,
                data    : { deleted: true },
                success : function() { refreshHdas() }
            });
            chart.set( 'dataset_id_job', '' );
        }
    };

    /** Request job details */
    var wait = function( chart, success, error ) {
        var self = this;
        Utils.request({
            type    : 'GET',
            url     : Galaxy.root + 'api/datasets/' + chart.get( 'dataset_id_job' ),
            data    : {},
            success : function( dataset ) {
                var ready = false;
                switch ( dataset.state ) {
                    case 'ok':
                        chart.state( 'wait', 'Job completed successfully...' );
                        success && success( dataset );
                        ready = true;
                        break;
                    case 'error':
                        chart.state( 'failed', 'Job has failed. Please check the history for details.' );
                        error && error( dataset );
                        ready = true;
                        break;
                    case 'running':
                        chart.state( 'wait', 'Your job is running. You may close the browser window. The job will continue in the background.' );
                }
                !ready && setTimeout( function() { wait( chart, success, error ) }, WAITTIME );
            }
        });
    };

    /** Refresh history panel */
    var refreshHdas = function() {
        Galaxy && Galaxy.currHistoryPanel && Galaxy.currHistoryPanel.refreshContents();
    };

    return { request: request }
});