Synnefo

//

// Copyright 2011 GRNET S.A. All rights reserved.

//

// Redistribution and use in source and binary forms, with or

// without modification, are permitted provided that the following

// conditions are met:

//

//   1. Redistributions of source code must retain the above

//      copyright notice, this list of conditions and the following

//      disclaimer.

//

//   2. Redistributions in binary form must reproduce the above

//      copyright notice, this list of conditions and the following

//      disclaimer in the documentation and/or other materials

//      provided with the distribution.

//

// THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

// OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

// PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR

// CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

// USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED

// AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

// LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

// ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

// POSSIBILITY OF SUCH DAMAGE.

//

// The views and conclusions contained in the software and

// documentation are those of the authors and should not be

// interpreted as representing official policies, either expressed

// or implied, of GRNET S.A.

//

var API_URL = "/api/v1.1";

var changes_since = 0, deferred = 0, update_request = false, load_request = false, pending_actions = [];

var flavors = [], images = [], servers = [], disks = [], cpus = [], ram = [];

var networks = [], networks_changes_since = 0;

//FIXME: authentication

//if cookie with value X-Auth-Token exists, set the value on the headers.

    $.ajaxSetup({

        'beforeSend': function(xhr) {

            //if ($.cookie("X-Auth-Token") != null) {

              xhr.setRequestHeader("X-Auth-Token", $.cookie("X-Auth-Token"));

            //} else {

            //    $.cookie("X-Auth-Token", "46e427d657b20defe352804f0eb6f8a2"); // set X-Auth-Token cookie

            //}

        }

    });

function ISODateString(d){

    //return a date in an ISO 8601 format using UTC.

    //do not include time zone info (Z) at the end

    //taken from the Mozilla Developer Center

    function pad(n){ return n<10 ? '0'+n : n }

    return  d.getUTCFullYear()+ '-' +

            pad(d.getUTCMonth()+1) + '-' +

            pad(d.getUTCDate()) + 'T' +

            pad(d.getUTCHours()) + ':' +

            pad(d.getUTCMinutes()) + ':' +

            pad(d.getUTCSeconds()) +'Z'

}

function parse_error(responseText, errorCode){

    var errors = [];

    try {

        responseObj = JSON.parse(responseText);

    }

    catch(err) {

        errors[0] = {'code': errorCode};

        return errors;

    }

    for (var err in responseObj){

        errors[errors.length] = responseObj[err];

    }

    return errors;

}

// indexOf prototype for IE

if (!Array.prototype.indexOf) {

  Array.prototype.indexOf = function(elt /*, from*/) {

    var len = this.length;

    var from = Number(arguments[1]) || 0;

    from = (from < 0)

         ? Math.ceil(from)

         : Math.floor(from);

    if (from < 0)

      from += len;

    for (; from < len; from++) {

      if (from in this &&

          this[from] === elt)

        return from;

    }

    return -1;

  };

}

// trim prototype for IE

if(typeof String.prototype.trim !== 'function') {

    String.prototype.trim = function() {

        return this.replace(/^\s+|\s+$/g, '');

    }

}

function update_confirmations() {

    // hide all confirm boxes to begin with

    $('#machines-pane div.confirm_single').hide();

    $('#machines-pane div.confirm_multiple').hide();

    var action_type = [];

    // standard view or single view

    if ($.cookie("view") == '0' || $.cookie("view") == '2') {

        for (var i=0; i<pending_actions.length; i++) {

            // show single confirms

            if (pending_actions[i][0] == reboot) {

                action_type = "reboot";

            } else if (pending_actions[i][0] == shutdown) {

                action_type = "shutdown";

            } else if (pending_actions[i][0] == start) {

                action_type = "start";

            } else if (pending_actions[i][0] == open_console) {

                action_type = "console";

            } else {

                action_type = "destroy";

            }

            $("#machines-pane #" + pending_actions[i][1] +

            " div.action-container." + action_type + " div.confirm_single").show();

        }

    }

    // if more than one pending action show multiple confirm box

    if (pending_actions.length>1 || $.cookie("view") == '1' && pending_actions.length == 1){

        $('#machines-pane div.confirm_multiple span.actionLen').text(pending_actions.length);

        $('#machines-pane div.confirm_multiple').show();

    }

}

function update_network_confirmations(){

    // hide all confirm boxes to begin with

    $('#networks-pane div.confirm_multiple').hide();

    for (var i=0;i<pending_actions.length;i++){

        // show single confirms depending on the action

        if (pending_actions[i][0] == delete_network) {

            $("#networks-pane div.network#net-"+pending_actions[i][1]).children('.confirm_single').show();

        } else if (pending_actions[i][0] == remove_server_from_network) {

            $("#networks-pane div.network #net-"+pending_actions[i][1]+"-server-"+pending_actions[i][2]).children('.confirm_single').show();

        } // else {}

    }

    // if more than one pending action show multiple confirm box

    if (pending_actions.length > 1){

        $('#networks-pane div.confirm_multiple span.actionLen').text(pending_actions.length);

        $('#networks-pane div.confirm_multiple').show();

    }

}

function list_view() {

    changes_since = 0; // to reload full list

    pending_actions = []; // clear pending actions

    update_confirmations();

    clearTimeout(deferred);    // clear old deferred calls

    try {

        update_request.abort(); // cancel pending ajax updates

        load_request.abort();

    }catch(err){}

    $.cookie("view", '1'); // set list cookie

    uri = $("a#list").attr("href");

    load_request = $.ajax({

        url: uri,

        type: "GET",

        timeout: TIMEOUT,

        dataType: "html",

        error: function(jqXHR, textStatus, errorThrown) {

            return false;

        },

        success: function(data, textStatus, jqXHR) {

            $("a#list")[0].className += ' activelink';

            $("a#standard")[0].className = '';

            $("a#single")[0].className = '';

            $("div#machinesview").html(data);

        }

    });

    return false;

}

function single_view() {

    changes_since = 0; // to reload full list

    pending_actions = []; // clear pending actions

    update_confirmations();

    clearTimeout(deferred);    // clear old deferred calls

    try {

        update_request.abort(); // cancel pending ajax updates

        load_request.abort();

    }catch(err){}

    $.cookie("view", '2'); // set list cookie

    uri = $("a#single").attr("href");

    load_request = $.ajax({

        url: uri,

        type: "GET",

        timeout: TIMEOUT,

        dataType: "html",

        error: function(jqXHR, textStatus, errorThrown) {

            return false;

        },

        success: function(data, textStatus, jqXHR) {

            $("a#single")[0].className += ' activelink';

            $("a#standard")[0].className = '';

            $("a#list")[0].className = '';

            $("div#machinesview").html(data);

        }

    });

    return false;

}

function standard_view() {

    changes_since = 0; // to reload full list

    pending_actions = []; // clear pending actions

    update_confirmations();

    clearTimeout(deferred);    // clear old deferred calls

    try {

        update_request.abort() // cancel pending ajax updates

        load_request.abort();

    }catch(err){}

    $.cookie("view", '0');

    uri = $("a#standard").attr("href");

    load_request = $.ajax({

        url: uri,

        type: "GET",

        timeout: TIMEOUT,

        dataType: "html",

        error: function(jqXHR, textStatus, errorThrown) {

            return false;

        },

        success: function(data, textStatus, jqXHR) {

            $("a#standard")[0].className += ' activelink';

            $("a#list")[0].className = '';

            $("a#single")[0].className = '';

            $("div#machinesview").html(data);

        }

    });

    return false;

}

function choose_view() {

    if ($.cookie("view")=='1') {

        list_view();

    } else if ($.cookie("view")=='2'){

        single_view();

    } else {

        standard_view();

    }

}

// return value from metadata key "OS", if it exists

function os_icon(metadata) {

    if (!metadata) {

        return 'unknown';

    }

    if (metadata.values.OS == undefined || metadata.values.OS == '') {

        return 'unknown';

    } else {

        if (os_icons.indexOf(metadata.values.OS) == -1) {

            return 'unknown';

        } else {

            return metadata.values.OS;

        }

    }

}

function os_icon_from_value(metadata) {

    if (!metadata) {

        return 'unknown';

    }

if (metadata == undefined || metadata == '') {

        return 'unknown';

    } else {

        if (os_icons.indexOf(metadata) == -1) {

            return 'unknown';

        } else {

            return metadata;

        }

    }

}

// get and show a list of running and terminated machines

function update_vms(interval) {

    try{ console.info('updating machines'); } catch(err){}

    var uri= API_URL + '/servers/detail';

    if (changes_since != 0)

        uri+='?changes-since='+changes_since

    update_request = $.ajax({

        cache: false,

        url: uri,

        type: "GET",

        timeout: TIMEOUT,

        dataType: "json",

        error: function(jqXHR, textStatus, errorThrown) {

            // don't forget to try again later

            if (interval) {

                clearTimeout(deferred);    // clear old deferred calls

                deferred = setTimeout(function() {update_vms(interval);},interval,interval);

            }

            // as for now, just show an error message

            try { console.info('update_vms errback:' + jqXHR.status ) } catch(err) {}

            try {

                ajax_error(jqXHR.status, undefined, 'Update VMs', jqXHR.responseText);

            } catch(err) {

                ajax_error(0, undefined, 'Update VMs', jqXHR.responseText);

            }

            return false;

            },

        success: function(data, textStatus, jqXHR) {

            // create changes_since string if necessary

            if (jqXHR.getResponseHeader('Date') != null){

                changes_since_date = new Date(jqXHR.getResponseHeader('Date'));

                changes_since = ISODateString(changes_since_date);

            }

            if (interval) {

                clearTimeout(deferred);    // clear old deferred calls

                deferred = setTimeout(function() {update_vms(interval);},interval,interval);

            }

            if (jqXHR.status == 200 || jqXHR.status == 203) {

                try {

                    servers = data.servers.values;

                    jQuery.parseJSON(data);

                    update_machines_view(data);

                } catch(err) { ajax_error('400', undefined, 'Update VMs', jqXHR.responseText);}

            } else if (jqXHR.status != 304){

                try { console.info('update_vms callback:' + jqXHR.status ) } catch(err) {}

                /*

                FIXME:  Here it should return the error, however Opera does not support 304.

                        Instead 304 it returns 0. To dealt with this we treat 0 as an

                        304, which should be corrected (Bug #317).

                */

                //ajax_error(jqXHR.status, undefined, 'Update VMs', jqXHR.responseText);

            }

            return false;

        }

    });

    return false;

}

// get a list of running and terminated machines, used in network view

function update_networks(interval) {

    try{ console.info('updating networks'); } catch(err){}

    var uri= API_URL + '/servers/detail';

    if (changes_since != 0)

        uri+='?changes-since='+changes_since

    update_request = $.ajax({

        cache: false,

        url: uri,

        type: "GET",

        timeout: TIMEOUT,

        dataType: "json",

        error: function(jqXHR, textStatus, errorThrown) {

            // don't forget to try again later

            if (interval) {

                clearTimeout(deferred);    // clear old deferred calls

                deferred = setTimeout(function() {update_networks(interval);},interval,interval);

            }

            // as for now, just show an error message

            try { console.info('update_networks errback:' + jqXHR.status ) } catch(err) {}

            try {

                ajax_error(jqXHR.status, undefined, 'Update networks', jqXHR.responseText);

            } catch(err) {

                ajax_error(0, undefined, 'Update networks', jqXHR.responseText);

            }

            return false;

            },

        success: function(data, textStatus, jqXHR) {

            // create changes_since string if necessary

            if (jqXHR.getResponseHeader('Date') != null){

                changes_since_date = new Date(jqXHR.getResponseHeader('Date'));

                changes_since = ISODateString(changes_since_date);

            }

            if (interval) {

                clearTimeout(deferred);    // clear old deferred calls

                deferred = setTimeout(function() {update_networks(interval);},interval,interval);

            }

            if (jqXHR.status == 200 || jqXHR.status == 203) {

                try {

                    servers = data.servers.values;

                    jQuery.parseJSON(data);

                    update_network_names(data);

                } catch(err) { ajax_error('400', undefined, 'Update networks', jqXHR.responseText);}

            } else if (jqXHR.status == 304) {

                update_network_names();

            }

            else {

                try { console.info('update_networks callback:' + jqXHR.status ) } catch(err) {}

                /*

                FIXME:  Here it should return the error, however Opera does not support 304.

                        Instead 304 it returns 0. To dealt with this we treat 0 as an

                        304, which should be corrected (Bug #317).

                */

                //ajax_error(jqXHR.status, undefined, 'Update networks', jqXHR.responseText);

                update_network_names();

            }

            return false;

        }

    });

    return false;

}

// get and show a list of public and private networks

function update_network_names(servers_data) {

    try{ console.info('updating network names'); } catch(err){}

    var uri= API_URL + '/networks/detail';

    if (networks_changes_since != 0)

        //FIXME: Comment out the following, until metadata do not 304 when changed

        uri+='?changes-since=' + networks_changes_since

    update_request = $.ajax({

        cache: false,

        url: uri,

        type: "GET",

        timeout: TIMEOUT,

        dataType: "json",

        error: function(jqXHR, textStatus, errorThrown) {

            // as for now, just show an error message

            try {

                console.info('update_network names errback:' + jqXHR.status )

            } catch(err) {}

            try {

                ajax_error(jqXHR.status, undefined, 'Update network names', jqXHR.responseText);

            } catch(err) {

                ajax_error(0, undefined, 'Update network names', jqXHR.responseText);

            }

            return false;

            },

        success: function(data, textStatus, jqXHR) {

            // create changes_since string if necessary

            if (jqXHR.getResponseHeader('Date') != null){

                changes_since_date = new Date(jqXHR.getResponseHeader('Date'));

                networks_changes_since = ISODateString(changes_since_date);

            }

            if (jqXHR.status == 200 || jqXHR.status == 203) {

                try {

                    networks = data.networks.values;

                    jQuery.parseJSON(data);

                    update_networks_view(servers_data, data);

                } catch(err) {

                    ajax_error('400', undefined, 'Update network names', jqXHR.responseText);

                }

            } else if (jqXHR.status == 304) {

                update_networks_view(servers_data);

            } else if (jqXHR.status != 304){

                try { console.info('update_network_names callback:' + jqXHR.status ) } catch(err) {}

                /*

                FIXME:  Here it should return the error, however Opera does not support 304.

                        Instead 304 it returns 0. To dealt with this we treat 0 as an

                        304, which should be corrected (Bug #317).

                */

                //ajax_error(jqXHR.status, undefined, 'Update network names', jqXHR.responseText);

                update_networks_view(servers_data);

            }

            return false;

        }

    });

    return false;

}

// get and show a list of available standard and custom images

function update_images() {

    $.ajax({

        url: API_URL + '/images/detail',

        type: "GET",

        //async: false,

        dataType: "json",

        timeout: TIMEOUT,

        error: function(jqXHR, textStatus, errorThrown) {

                    try {

                        ajax_error(jqXHR.status, undefined, 'Update Images', jqXHR.responseText);

                    } catch(err) {

                        ajax_error(0, undefined, 'Update Images', jqXHR.responseText);

                    }

                },

        success: function(data, textStatus, jqXHR) {

            try {

                images = data.images.values;

                jQuery.parseJSON(data);

                update_wizard_images();

            } catch(err){

                ajax_error("NO_IMAGES");

            }

        }

    });

    return false;

}

function update_wizard_images() {

    if ($("ul#standard-images li").toArray().length + $("ul#custom-images li").toArray().length == 0) {

        $.each(images, function(i,image){

            var img = $('#image-template').clone().attr("id","img-"+image.id).fadeIn("slow");

            img.find("label").attr('for',"img-radio-" + image.id);

            img.find(".image-title").text(image.name);

            if (image.metadata) {

                if (image.metadata.values.description != undefined) {

                    img.find(".description").text(image.metadata.values.description);

                }

                if (image.metadata.values.size != undefined) {

                    img.find("#size").text(image.metadata.values.size);

                }

            }

            img.find("input.radio").attr('id',"img-radio-" + image.id);

            if (i==0) img.find("input.radio").attr("checked","checked");

            var image_logo = os_icon(image.metadata);

            img.find("img.image-logo").attr('src','static/icons/os/'+image_logo+'.png');

            if (image.metadata) {

                if (image.metadata.values.serverId != undefined) {

                    img.appendTo("ul#custom-images");

                } else {

                    img.appendTo("ul#standard-images");

                }

            } else {

                img.appendTo("ul#standard-images");

            }

        });

    }

}

function update_wizard_flavors(){

    // sliders for selecting VM flavor

    $("#cpu:range").rangeinput({min:0,

                               value:0,

                               step:1,

                               progress: true,

                               max:cpus.length-1});

    $("#storage:range").rangeinput({min:0,

                               value:0,

                               step:1,

                               progress: true,

                               max:disks.length-1});

    $("#ram:range").rangeinput({min:0,

                               value:0,

                               step:1,

                               progress: true,

                               max:ram.length-1});

    $("#small").click();

    // update the indicators when sliding

    $("#cpu:range").data().rangeinput.onSlide(function(event,value){

        $("#cpu-indicator")[0].value = cpus[Number(value)];

        $("#cpu-indicator").addClass('selectedrange');

    });

    $("#cpu:range").data().rangeinput.change(function(event,value){

        $("#cpu-indicator")[0].value = cpus[Number(value)];

        $("#custom").click();

        $("#cpu-indicator").removeClass('selectedrange');

    });

    $("#ram:range").data().rangeinput.onSlide(function(event,value){

        $("#ram-indicator")[0].value = ram[Number(value)];

        $("#ram-indicator").addClass('selectedrange');

    });

    $("#ram:range").data().rangeinput.change(function(event,value){

        $("#ram-indicator")[0].value = ram[Number(value)];

        $("#custom").click();

        $("#ram-indicator").removeClass('selectedrange');

    });

    $("#storage:range").data().rangeinput.onSlide(function(event,value){

        $("#storage-indicator")[0].value = disks[Number(value)];

        $("#storage-indicator").addClass('selectedrange');

    });

    $("#storage:range").data().rangeinput.change(function(event,value){

        $("#storage-indicator")[0].value = disks[Number(value)];

        $("#custom").click();

        $("#storage-indicator").removeClass('selectedrange');

    });

}

Array.prototype.unique = function () {

    var r = new Array();

    o:for(var i = 0, n = this.length; i < n; i++)

    {

        for(var x = 0, y = r.length; x < y; x++)

        {

            if(r[x]==this[i])

            {

                continue o;

            }

        }

        r[r.length] = this[i];

    }

    return r;

}

// get and configure flavor selection

function update_flavors() {

    $.ajax({

        url: API_URL + '/flavors/detail',

        type: "GET",

        //async: false,

        dataType: "json",

        timeout: TIMEOUT,

        error: function(jqXHR, textStatus, errorThrown) {

            try {

                ajax_error(jqXHR.status, undefined, 'Update Flavors', jqXHR.responseText);

            } catch (err) {

                ajax_error(err);

            }

            // start updating vm list

            update_vms(UPDATE_INTERVAL);

        },

        success: function(data, textStatus, jqXHR) {

            try {

                flavors = data.flavors.values;

                jQuery.parseJSON(data);

                $.each(flavors, function(i, flavor) {

                    cpus[i] = flavor['cpu'];

                    disks[i] = flavor['disk'];

                    ram[i] = flavor['ram'];

                });

                cpus = cpus.unique();

                disks = disks.unique();

                ram = ram.unique();

                update_wizard_flavors();

            } catch(err){

                ajax_error("NO_FLAVORS");

            }

            // start updating vm list

            update_vms(UPDATE_INTERVAL);

        }

    });

    return false;

}

// return flavorRef from cpu, disk, ram values

function identify_flavor(cpu, disk, ram){

    for (i=0;i<flavors.length;i++){

        if (flavors[i]['cpu'] == cpu && flavors[i]['disk']==disk && flavors[i]['ram']==ram) {

            return flavors[i]['id']

        }

    }

    return 0;

}

// return image entry from imageRef

function get_image(imageRef) {

    for (i=0;i<images.length;i++){

        if (images[i]['id'] == imageRef) {

            return images[i];

        }

    }

    return 0;

}

// return machine entry from serverID

function get_machine(serverID) {

    for (i=0;i<servers.length;i++){

        if (servers[i]['id'] == serverID) {

            return servers[i];

        }

    }

    return 0;

}

// update the actions in icon view, per server

function update_iconview_actions(serverID, server_status) {

    if ($.cookie("view")=='2') {

        // remove .disable from all actions to begin with

        $('#machinesview-single #' + serverID + ' div.single-action').show();

        // decide which actions should be disabled

        for (current_action in actions) {

            if (actions[current_action].indexOf(server_status) == -1 ) {

                $('#machinesview-single #' + serverID + ' div.action-' + current_action).hide();

            }

        }

    } else {

        // remove .disable from all actions to begin with

        $('#machinesview-icon.standard #' + serverID + ' div.actions').find('a').removeClass('disabled');

        // decide which actions should be disabled

        for (current_action in actions) {

            if (actions[current_action].indexOf(server_status) == -1 ) {

                $('#machinesview-icon.standard #' + serverID + ' a.action-' + current_action).addClass('disabled');

            }

        }

    }

}

// update the actions in list view

function update_listview_actions() {

    var states = [];

    var on = [];

    var checked = $("table.list-machines tbody input[type='checkbox']:checked");

    // disable all actions to begin with

    $('#machinesview .list div.actions').children().removeClass('enabled');

    // are there multiple machines selected?

    if (checked.length>1)

        states[0] = 'multiple';

    // check the states of selected machines

    checked.each(function(i,checkbox) {

        states[states.length] = checkbox.className;

        var ip = $("#" + checkbox.id.replace('input-','') + ".ip span.public").text();

        if (ip.replace('undefined','').length)

            states[states.length] = 'network';

    });

    // decide which actions should be enabled

    for (a in actions) {

        var enabled = false;

        for (var s =0; s<states.length; s++) {

            if (actions[a].indexOf(states[s]) != -1 ) {

                enabled = true;

            } else {

                enabled = false;

                break;

            }

        }

        if (enabled)

            on[on.length]=a;

    }

    // enable those actions

    for (action in on) {

        $("#action-" + on[action]).addClass('enabled');

    }

}

//create server action

function create_vm(machineName, imageRef, flavorRef){

    var image_logo = os_icon(get_image(imageRef).metadata);

    var uri = API_URL + '/servers';

    var payload = {

        "server": {

            "name": machineName,

            "imageRef": imageRef,

            "flavorRef" : flavorRef,

            "metadata" : {

                "OS" : image_logo

            }

        }