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;

var last_request = {};

$.ajaxSetup({

    'beforeSend': function(xhr) {

          // save ajax settings, we might need them for error reporting

          last_request = this;

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

        // check if xhr is in valid state (no status property)

        try {

            var status = jqXHR.status;

        } catch (err) {

            return false;

        }

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

                if (!isXhrException(err)) {

                    ajax_error(-501, "UI Error", 'Generic error', err);

                } else {

                    return false;

                }

            }

        }

        // refresh after 10 seconds

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

    }

});

function isXhrException(err) {

    DOM_EXCEPTION_NAMES = [

        "NS_ERROR_NOT_AVAILABLE", // Firefox

        "INVALID_STATE_ERR" // Chrome

    ];

    try {

        if (DOM_EXCEPTION_NAMES.indexOf(err.name) != -1) {

            return true;

        } 

        // ie !!!!

        if (err.number == -2147467259) {

            return true;

        }

    } catch(err) {

        return false;

    }

    return false;

}

Object.prototype.toString = function(o){

    var parse = function(_o){

        var a = [], t;

        for(var p in _o){

            if(_o.hasOwnProperty(p)){

                t = _o[p];

                if(t && typeof t == "object"){

                    a[a.length]= p + ":{ " + arguments.callee(t).join(", ") + "}";

                }

                else {

                    if(typeof t == "string"){

                        a[a.length] = [ p+ ": \"" + t.toString() + "\"" ];

                    }

                    else{

                        a[a.length] = [ p+ ": " + t.toString()];

                    }

                }

            }

        }

        return a;

    }

    return "{" + parse(o).join(", ") + "}";

}

// http://stackoverflow.com/questions/499126/jquery-set-cursor-position-in-text-area 

$.fn.setCursorPosition = function(pos) {

    if ($(this).get(0).setSelectionRange) {

      $(this).get(0).setSelectionRange(pos, pos);

    } else if ($(this).get(0).createTextRange) {

      var range = $(this).get(0).createTextRange();

      range.collapse(true);

      range.moveEnd('character', pos);

      range.moveStart('character', pos);

      range.select();

    }

}

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

                    if (!isXhrException(err)) {

                        ajax_error(-502, "UI Error", 'Update VMs', err);

                    } else {

                        return false;

                    }

                }

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

                    update_machines_view(data);

                } catch (err) { ajax_error(-503, "UI Error", 'Update VMs', err);}

            } 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, "Ajax error", '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];

                var v = v;

                if (initial[key] == undefined) {

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

                } else {

                    // value changed

                    if (initial[key] != v) {

                        if (key == "status") {

                            // dont change if in destroy state

                            if (initial.status == "DESTROY") {

                                v = "DESTROY";

                            }

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

        var old_server = servers[exists[1]];

        // reset network transition

        try {

            if (old_server.network_transition) {

                if (old_server.network_transition == "NETWORK_CHANGE") {

                    // network profile changed, servers data updated, so act if the change was made

                    // this flag will trigger ui to remove any transiiton indicators

                    // and hopefully apply the new value to the profile options

                    old_server.network_transition = "CHANGED"

                } else {

                    // nothing happened

                    old_server.network_transition = undefined;

                };

            }

        } catch (err) { console.info(err) }

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

                if (!isXhrException(err)) {

                    ajax_error(-504, "UI Error", 'Update networks', err);

                } else {

                    return false;

                }

            }

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

                    update_network_names(data);

                } catch(err) { ajax_error(-505, "UI Error", 'Update networks', err);}

            } 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(-506, "UI Error", 'Update network names', err);

            }

            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;

                    update_networks_view(servers_data, data);

                } catch(err) {

                    ajax_error(-507, "UI Error", 'Update network names', err);

                }

            } 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(-508, "UI error", 'Update Images', err);

                    }

                },

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