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;

var error_timeout = 20000;

$.ajaxSetup({

    'beforeSend': function(xhr) {

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

    },

    // catch uncaught error requests

    // stop interaction and show only for the 5xx errors

    // refresh the page after 20secs

    error: function(jqXHR, textStatus, errorThrown) {

        // stop interaction for important (aka 500) error codes only

        if (jqXHR.status >= 500 && jqXHR.status < 600)

        {

            try {

                ajax_error(jqXHR.status, undefined, 'Unknown', jqXHR.responseText);

            } catch(err) {

                ajax_error(0, undefined, 'Unknown', jqXHR.responseText);

            }

        }

        // refresh after 10 seconds

        window.setTimeout("window.location.reload()", window.error_timeout);

    }

});

// jquery show/hide events

var _oldshow = $.fn.show;

$.fn.show = function(speed, callback) {

    $(this).trigger('show');

    return _oldshow.apply(this,arguments);

}

var _oldhide = $.fn.hide;

$.fn.hide = function(speed, callback) {

    $(this).trigger('hide');

    return _oldhide.apply(this,arguments);

}

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 'okeanos';

    }

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

        return 'okeanos';

    } else {

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

            return 'okeanos';

        } else {

            return metadata.values.OS;

        }

    }

}

function os_icon_from_value(metadata) {

    if (!metadata) {

        return 'okeanos';

    }

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

        return 'okeanos';

    } else {

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

            return 'okeanos';

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

                    update_servers_data(data.servers.values, data);

                    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;

}

function update_servers_data(servers_update, data) {

    $(window).trigger("vm:update", servers_update, data);

    // first call

    if (!window.servers || window.servers.length == 0) {

        window.servers = servers_update;

        return;

    }

    // server exists helper

    server_exists = function(server) {

        var id = server.id;

        var found = false;

        var index = 0;

        $.each(servers, function(i, s) {

            if (s.id == id) { found = true, index = i };

        });

        if (found)

            return [found, index];

        return false;

    }

    // merge object properties

    merge = function() {

        var initial = arguments[0];

        var status_changed = undefined;

        $.each(arguments, function(index, el) {

            $.each(el, function(key,v) {

                // new attribute added

                var previous_value = initial[key];

                if (initial[key] == undefined) {

                    $(window).trigger("vm:attr:add", initial, key, v);

                } else {

                    // value changed

                    if (initial[key] != v) {

                        if (key == "status") {

                            status_changed = {'old': previous_value, 'new': v}; 

                        }

                        $(window).trigger("vm:attr:change", {'initial': initial, 'attr': key, 'newvalue': v});

                    }

                }

                initial[key] = v;

            });

        });

        if (status_changed !== undefined) {

            $(window).trigger('vm:status:change', {'vm': initial, 'old': status_changed['old'], 'new': status_changed['new']});

        }

        return initial;

    }

    // server removed

    var remove = [];

    $.each(servers_update, function(index, server) {

        if (server.status == "DELETED") {

            remove.push(server.id);

        }

    });

    // check server, if exists merge it with new values else add it

    $.each(servers_update, function(index, server) {

        var exists = server_exists(server);

        if (exists !== false) {

            try {

                servers[exists[1]] = merge(servers[exists[1]], server);

            } catch (err) {

            }

        } else {

            servers.push(server);

            $(window).trigger("vm:add", server);

        }

        if (remove.indexOf(server.id) > -1) {

            var remove_exists = server_exists(server);

            servers.splice(remove_exists[1], 1);

            $(window).trigger("vm:remove", server);

        }

    });

}

// 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;

                    update_servers_data(data.servers.values, data);

                    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++){