Synnefo

;(function(root){

    // root

    var root = root;

    // setup namepsaces

    var snf = root.synnefo = root.synnefo || {};

    var models = snf.models = snf.models || {}

    var storage = snf.storage = snf.storage || {};

    var util = snf.util = snf.util || {};

    // shortcuts

    var bb = root.Backbone;

    var slice = Array.prototype.slice

    // logging

    var logger = new snf.logging.logger("SNF-MODELS");

    var debug = _.bind(logger.debug, logger);

    // get url helper

    var getUrl = function() {

        return snf.config.api_url + "/" + this.path;

    }

    // i18n

    BUILDING_MESSAGES = window.BUILDING_MESSAGES || {'INIT': 'init', 'COPY': '{0}, {1}, {2}', 'FINAL': 'final'};

    // Base object for all our models

    models.Model = bb.Model.extend({

        sync: snf.api.sync,

        api: snf.api,

        has_status: false,

        initialize: function() {

            if (this.has_status) {

                this.bind("change:status", this.handle_remove);

                this.handle_remove();

            }

            models.Model.__super__.initialize.apply(this, arguments)

        },

        handle_remove: function() {

            if (this.get("status") == "DELETED") {

                if (this.collection) {

                    this.collection.remove(this.id);

                }

            }

        },

        // custom set method to allow submodels to use

        // set_<attr> methods for handling the value of each

        // attribute and overriding the default set method

        // for specific parameters

        set: function(params, options) {

            _.each(params, _.bind(function(value, key){

                if (this["set_" + key]) {

                    params[key] = this["set_" + key](value);

                }

            }, this))

            var ret = bb.Model.prototype.set.call(this, params, options);

            return ret;

        },

        url: function(options) {

            return getUrl.call(this) + "/" + this.id;

        },

        api_path: function(options) {

            return this.path + "/" + this.id;

        },

        parse: function(resp, xhr) {

            return resp.server;

        },

        remove: function() {

            this.api.call(this.api_path(), "delete");

        }

    })

    // Base object for all our model collections

    models.Collection = bb.Collection.extend({

        sync: snf.api.sync,

        api: snf.api,

        url: function(options) {

            return getUrl.call(this) + (options.details || this.details ? '/detail' : '');

        },

        fetch: function(options) {

            // default to update

            if (!this.noUpdate) {

                if (!options) { options = {} };

                if (options.update === undefined) { options.update = true };

                if (!options.removeMissing && options.refresh) { options.removeMissing = true };

            }

            // custom event foreach fetch

            return bb.Collection.prototype.fetch.call(this, options)

        },

        get_fetcher: function(timeout, fast, limit, initial, params) {

            var fetch_params = params;

            var timeout = parseInt(timeout);

            var fast = fast || 1000;

            var limit = limit;

            var initial_call = initial || true;

            var last_ajax = undefined;

            var cb = _.bind(function(){

                updater._ajax = last_ajax;

                if (last_ajax) {

                    last_ajax.abort();

                }

                last_ajax = this.fetch(fetch_params);

            }, this);

            var updater = new snf.api.updateHandler({'callback': cb, timeout:timeout, 

                                                    fast:fast, limit:limit, 

                                                    call_on_start:initial_call});

            snf.api.bind("call", _.bind(function(){ updater.faster()}, this));

            return updater;

        }

    });

    // Image model

    models.Image = models.Model.extend({

        path: 'images',

        get_size: function() {

            return parseInt(this.get('metadata') ? this.get('metadata').values.size : -1)

        },

        get_os: function() {

            return this.get("OS");

        }

    });

    // Flavor model

    models.Flavor = models.Model.extend({

        path: 'flavors',

        details_string: function() {

            return "{0} CPU, {1}MB, {2}GB".format(this.get('cpu'), this.get('ram'), this.get('disk'));

        },

        get_disk_size: function() {

            return parseInt(this.get("disk") * 1000)

        },

    });

    //network vms list helper

    var NetworkVMSList = function() {

        this.initialize = function() {

            this.vms = [];

            this.pending = [];

            this.pending_for_removal = [];

        }

        this.add_pending_for_remove = function(vm_id) {

            if (this.pending_for_removal.indexOf(vm_id) == -1) {

                this.pending_for_removal.push(vm_id);

            }

            if (this.pending_for_removal.length) {

                this.trigger("pending:remove:add");

            }

        },

        this.add_pending = function(vm_id) {

            if (this.pending.indexOf(vm_id) == -1) {

                this.pending[this.pending.length] = vm_id;

            }

            if (this.pending.length) {

                this.trigger("pending:add");

            }

        }

        this.check_pending = function() {

            var len = this.pending.length;

            var args = [this.pending];

            this.pending = _.difference(this.pending, this.vms);

            if (len != this.pending.length) {

                if (this.pending.length == 0) {

                    this.trigger("pending:clear");

                }

            }

            var len = this.pending_for_removal.length;

            this.pending_for_removal = _.intersection(this.pending_for_removal, this.vms);

            if (this.pending_for_removal.length == 0) {

                this.trigger("pending:remove:clear");

            }

        }

        this.add = function(vm_id) {

            if (this.vms.indexOf(vm_id) == -1) {

                this.vms[this.vms.length] = vm_id;

                this.trigger("network:connect", vm_id);

                this.check_pending();

                return true;

            }

        }

        this.remove = function(vm_id) {

            if (this.vms.indexOf(vm_id) > -1) {

                this.vms = _.without(this.vms, vm_id);

                this.trigger("network:disconnect", vm_id);

                this.check_pending();

                return true;

            }

        }

        this.get = function() {

            return this.vms;

        }

        this.list = function() {

            return storage.vms.filter(_.bind(function(vm){

                return this.vms.indexOf(vm.id) > -1;

            }, this))

        }

        this.initialize();

    };

    _.extend(NetworkVMSList.prototype, bb.Events);

    // vm networks list helper

    var VMNetworksList = function() {

        this.initialize = function() {

            this.networks = {};

            this.network_ids = [];

        }

        this.add = function(net_id, data) {

            if (!this.networks[net_id]) {

                this.networks[net_id] = data || {};

                this.network_ids[this.network_ids.length] = net_id;

                this.trigger("network:connect", net_id);

                return true;

            }

        }

        this.remove = function(net_id) {

            if (this.networks[net_id]) {

                delete this.networks[net_id];

                this.network_ids = _.without(this.network_ids, net_id);

                this.trigger("network:disconnect", net_id);

                return true;

            }

            return false;

        }

        this.get = function() {

            return this.networks;

        }

        this.list = function() {

            return storage.networks.filter(_.bind(function(net){

                return this.network_ids.indexOf(net.id) > -1;

            }, this))

        }

        this.initialize();

    };

    _.extend(VMNetworksList.prototype, bb.Events);

    // Image model

    models.Network = models.Model.extend({

        path: 'networks',

        has_status: true,

        initialize: function() {

            this.vms = new NetworkVMSList();

            this.vms.bind("pending:add", _.bind(this.handle_pending_connections, this, "add"));

            this.vms.bind("pending:clear", _.bind(this.handle_pending_connections, this, "clear"));

            this.vms.bind("pending:remove:add", _.bind(this.handle_pending_connections, this, "add"));

            this.vms.bind("pending:remove:clear", _.bind(this.handle_pending_connections, this, "clear"));

            ret = models.Network.__super__.initialize.apply(this, arguments);

            storage.vms.bind("change:linked_to_nets", _.bind(this.update_connections, this, "vm:change"));

            storage.vms.bind("add", _.bind(this.update_connections, this, "add"));

            storage.vms.bind("remove", _.bind(this.update_connections, this, "remove"));

            storage.vms.bind("reset", _.bind(this.update_connections, this, "reset"));

            this.bind("change:linked_to", _.bind(this.update_connections, this, "net:change"));

            this.update_connections();

            this.update_state();

            return ret;

        },

        update_state: function() {

            if (this.vms.pending.length) {

                this.set({state: "CONNECTING"});

                return

            }

            if (this.vms.pending_for_removal.length) {

                this.set({state: "DISCONNECTING"});

                return

            }   

            var firewalling = false;

            _.each(this.vms.get(), _.bind(function(vm_id){

                var vm = storage.vms.get(vm_id);

                if (!vm) { return };

                if (!_.isEmpty(vm.pending_firewalls)) {

                    this.set({state:"FIREWALLING"});

                    firewalling = true;

                    return false;

                }

            },this));

            if (firewalling) { return };

            this.set({state:"NORMAL"});

        },

        handle_pending_connections: function(action) {

            this.update_state();

        },

        // handle vm/network connections

        update_connections: function(action, model) {

            // vm removed disconnect vm from network

            if (action == "remove") {

                var removed_from_net = this.vms.remove(model.id);

                var removed_from_vm = model.networks.remove(this.id);

                if (removed_from_net) {this.trigger("vm:disconnect", model, this); this.change()};

                if (removed_from_vm) {vm.trigger("network:disconnect", this, model); this.change()};

                return;

            }

            // update links for all vms

            var links = this.get("linked_to");

            storage.vms.each(_.bind(function(vm) {

                var vm_links = vm.get("linked_to") || [];

                if (vm_links.indexOf(this.id) > -1) {

                    // vm has connection to current network

                    if (links.indexOf(vm.id) > -1) {

                        // and network has connection to vm, so try

                        // to append it

                        var add_to_net = this.vms.add(vm.id);

                        var index = _.indexOf(vm_links, this.id);

                        var add_to_vm = vm.networks.add(this.id, vm.get("linked_to_nets")[index]);

                        // call only if connection did not existed

                        if (add_to_net) {this.trigger("vm:connect", vm, this); this.change()};

                        if (add_to_vm) {vm.trigger("network:connect", this, vm); vm.change()};

                    } else {

                        // no connection, try to remove it

                        var removed_from_net = this.vms.remove(vm.id);

                        var removed_from_vm = vm.networks.remove(this.id);

                        if (removed_from_net) {this.trigger("vm:disconnect", vm, this); this.change()};

                        if (removed_from_vm) {vm.trigger("network:disconnect", this, vm); vm.change()};

                    }

                } else {

                    // vm has no connection to current network, try to remove it

                    var removed_from_net = this.vms.remove(vm.id);

                    var removed_from_vm = vm.networks.remove(this.id);

                    if (removed_from_net) {this.trigger("vm:disconnect", vm, this); this.change()};

                    if (removed_from_vm) {vm.trigger("network:disconnect", this, vm); vm.change()};

                }

            },this));

        },

        is_public: function() {

            return this.id == "public";

        },

        contains_vm: function(vm) {

            var net_vm_exists = this.vms.get().indexOf(vm.id) > -1;

            var vm_net_exists = vm.is_connected_to(this);

            return net_vm_exists && vm_net_exists;

        },

        add_vm: function (vm, callback) {

            return this.api.call(this.api_path() + "/action", "create", 

                                 {add:{serverRef:"" + vm.id}},

                                 _.bind(function(){

                                     this.vms.add_pending(vm.id);

                                     if (callback) {callback()}

                                 },this));

        },

        remove_vm: function (vm, callback) {

            return this.api.call(this.api_path() + "/action", "create", 

                                 {remove:{serverRef:"" + vm.id}},

                                 _.bind(function(){

                                     this.vms.add_pending_for_remove(vm.id);

                                     if (callback) {callback()}

                                 },this));

        },

        rename: function(name, callback) {

            return this.api.call(this.api_path(), "update", {network:{name:name}}, callback);

        },

        get_connectable_vms: function() {

            var servers = this.vms.list();

            return storage.vms.filter(function(vm){return servers.indexOf(vm.id) == -1})

        },

        state_message: function() {

            if (this.get("state") == "NORMAL" && this.is_public()) {

                return "Public network";

            }

            return models.Network.STATES[this.get("state")];

        },

        in_progress: function() {

            return models.Network.STATES_TRANSITIONS[this.get("state")] != undefined;

        }

    });

    models.Network.STATES = {

        'NORMAL': 'Private network',

        'CONNECTING': 'Connecting...',

        'DISCONNECTING': 'Disconnecting...',

        'FIREWALLING': 'Firewall update...'

    }

    models.Network.STATES_TRANSITIONS = {

        'CONNECTING': ['NORMAL'],

        'DISCONNECTING': ['NORMAL'],

        'FIREWALLING': ['NORMAL']

    }

    // Virtualmachine model

    models.VM = models.Model.extend({

        path: 'servers',

        has_status: true,

        initialize: function(params) {

            this.networks = new VMNetworksList();

            this.pending_firewalls = {};

            models.VM.__super__.initialize.apply(this, arguments);

            this.set({state: params.status || "ERROR"});

            this.log = new snf.logging.logger("VM " + this.id);

            this.pending_action = undefined;

            // init stats parameter

            this.set({'stats': undefined}, {silent: true});

            // defaults to not update the stats

            // each view should handle this vm attribute 

            // depending on if it displays stat images or not

            this.do_update_stats = false;

            // interval time

            // this will dynamicaly change if the server responds that

            // images get refreshed on different intervals

            this.stats_update_interval = synnefo.config.STATS_INTERVAL || 5000;

            // initialize interval

            this.init_stats_intervals(this.stats_update_interval);

            // clear stats intervals on update

            this.bind("remove", _.bind(function(){

                try {

                    window.clearInterval(this.stats_interval);

                } catch (err) {};

            }, this));

            this.bind("change:progress", _.bind(this.update_building_progress, this));

            this.update_building_progress();

            this.bind("change:firewalls", _.bind(this.handle_firewall_change, this));

            // default values

            this.set({linked_to_nets:this.get("linked_to_nets") || []});

            this.set({firewalls:this.get("firewalls") || []});

        },

        handle_firewall_change: function() {

        },

        set_linked_to_nets: function(data) {

            this.set({"linked_to":_.map(data, function(n){ return n.id})});

            return data;

        },

        is_connected_to: function(net) {

            return _.filter(this.networks.list(), function(n){return n.id == net.id}).length > 0;

        },

        status: function(st) {

            if (!st) { return this.get("status")}

            return this.set({status:st});

        },

        set_status: function(st) {

            var new_state = this.state_for_api_status(st);

            var transition = false;

            if (this.state() != new_state) {

                if (models.VM.STATES_TRANSITIONS[this.state()]) {

                    transition = this.state();

                }

            }

            // call it silently to avoid double change trigger

            this.set({'state': this.state_for_api_status(st)}, {silent: true});

            // trigger transition

            if (transition) { this.trigger("transition", {from:transition, to:new_state}) };

            return st;

        },

        update_building_progress: function() {

            if (this.is_building()) {

                var progress = this.get("progress");

                if (progress == 0) {

                    this.state("BUILD_INIT");

                    this.set({progress_message: BUILDING_MESSAGES['INIT']});

                }

                if (progress > 0 && progress < 99) {

                    this.state("BUILD_COPY");

                    var params = this.get_copy_details(true);

                    this.set({progress_message: BUILDING_MESSAGES['COPY'].format(params.copy, 

                                                                                 params.size, 

                                                                                 params.progress)});

                }

                if (progress == 100) {

                    this.state("BUILD_FINAL");

                    this.set({progress_message: BUILDING_MESSAGES['FINAL']});

                }

            } else {

            }

        },

        get_copy_details: function(human, image) {

            var human = human || false;

            var image = image || this.get_image();

            var progress = this.get('progress');

            var size = image.get_size();

            var size_copied = (size * progress / 100).toFixed(2);

            if (human) {

                size = util.readablizeBytes(size*1024*1024);

                size_copied = util.readablizeBytes(size_copied*1024*1024);

            }

            return {'progress': progress, 'size': size, 'copy': size_copied};

        },

        // clear and reinitialize update interval

        init_stats_intervals: function (interval) {

            try {

                window.clearInterval(this.stats_interval);

            } catch (err){}

            //this.stats_interval = window.setInterval(_.bind(this.update_stats, this), interval);

            //this.update_stats(true);

        },

        // do the api call

        update_stats: function(force) {

            // do not update stats if flag not set

            if (!this.do_update_stats && !force) {

                return;

            }

            // make the api call, execute handle_stats_update on sucess

            // TODO: onError handler ???

            stats_url = this.url() + "/stats";

            this.sync("GET", this, {url: stats_url, refresh:true, success: _.bind(this.handle_stats_update, this)});

        },

        // this method gets executed after a successful vm stats api call

        handle_stats_update: function(data) {

            // avoid browser caching

            if (data.stats && _.size(data.stats) > 0) {

                var ts = $.now();

                var stats = data.stats;

                _.each(['cpuBar', 'cpuTimeSeries', 'netBar', 'netTimeSeries'], function(k) {

                    stats[k] = stats[k] + "?_=" + ts;

                })

                data.stats = stats;

            }

            this.set({'stats': data.stats}, {silent:true});

            // trigger the event

            this.trigger("stats:update");

            // do we need to change the interval ??

            if (data.stats.refresh * 1000 != this.stats_update_interval) {

                this.stats_update_interval = data.stats.refresh * 1000;

                this.init_stats_intervals(this.stats_update_interval);

            }

        },

        // helper method that sets the do_update_stats

        // in the future this method could also make an api call

        // immediaetly if needed

        enable_stats_update: function() {

            this.do_update_stats = true;

        },

        require_reboot: function() {

            if (this.is_active()) {

                this.set({'reboot_required': true});

            }

        },

        set_pending_action: function(data) {

            this.pending_action = data;

            return data;

        },

        // machine has pending action

        update_pending_action: function(action, force) {

            this.set({pending_action: action});

        },

        clear_pending_action: function() {

            this.set({pending_action: undefined});

        },

        has_pending_action: function() {

            return this.get("pending_action") ? this.get("pending_action") : false;

        },

        // machine is active

        is_active: function() {

            return models.VM.ACTIVE_STATES.indexOf(this.state()) > -1;

        },

        // machine is building 

        is_building: function() {

            return models.VM.BUILDING_STATES.indexOf(this.state()) > -1;

        },

        // user can connect to machine

        is_connectable: function() {

            // check if ips exist

            if (!this.get_addresses().ip4 && !this.get_addresses().ip6) {

                return false;

            }

            return models.VM.CONNECT_STATES.indexOf(this.state()) > -1;

        },

        set_firewalls: function(data) {

            _.each(data, _.bind(function(val, key){

                if (this.pending_firewalls && this.pending_firewalls[key] && this.pending_firewalls[key] == val) {

                        this.require_reboot();

                        this.remove_pending_firewall(key, val);

                }

            }, this));

            return data;

        },

        remove_pending_firewall: function(net_id, value) {

            if (this.pending_firewalls[net_id] == value) {

                delete this.pending_firewalls[net_id];

                storage.networks.get(net_id).update_state();

            }

        },

        remove_meta: function(key, complete, error) {

            var url = this.api_path() + "/meta/" + key;

            this.api.call(url, "delete", undefined, complete, error);

        },

        save_meta: function(meta, complete, error) {

            var url = this.api_path() + "/meta/" + meta.key;

            var payload = {meta:{}};

            payload.meta[meta.key] = meta.value;

            this.api.call(url, "update", payload, complete, error)

        },

        set_firewall: function(net_id, value, callback) {

            if (this.get("firewalls") && this.get("firewalls")[net_id] == value) { return }

            this.pending_firewalls[net_id] = value;

            this.trigger("change", this, this);

            this.api.call(this.api_path() + "/action", "create", {"firewallProfile":{"profile":value}}, callback);

            storage.networks.get(net_id).update_state();

        },

        firewall_pending: function(net_id) {

            return this.pending_firewalls[net_id] != undefined;

        },

        // update/get the state of the machine

        state: function() {

            var args = slice.call(arguments);

            // TODO: it might not be a good idea to let api set the state

            if (args.length > 0 && models.VM.STATES.indexOf(args[0]) > -1) {

                this.set({'state': args[0]});

            }

            return this.get('state');

        },

        // get the state that the api status corresponds to

        state_for_api_status: function(status) {

            return this.state_transition(this.state(), status);

        },

        // vm state equals vm api status

        state_is_status: function(state) {

            return models.VM.STATUSES.indexOf(state) != -1;

        },

        // get transition state for the corresponging api status

        state_transition: function(state, new_status) {

            var statuses = models.VM.STATES_TRANSITIONS[state];

            if (statuses) {

                if (statuses.indexOf(new_status) > -1) {

                    return new_status;

                } else {

                    return state;

                }

            } else {

                return new_status;

            }

        },

        // the current vm state is a transition state

        in_transition: function() {

            return models.VM.TRANSITION_STATES.indexOf(this.state()) > -1 || 

                models.VM.TRANSITION_STATES.indexOf(this.get('status')) > -1;

        },

        // get image object

        // TODO: update images synchronously if image not found

        get_image: function() {

            var image = storage.images.get(this.get('imageRef'));

            if (!image) {

                storage.images.update_unknown_id(this.get('imageRef'));

                image = storage.flavors.get(this.get('imageRef'));

            }

            return image;

        },

        // get flavor object

        // TODO: update flavors synchronously if image not found

        get_flavor: function() {

            var flv = storage.flavors.get(this.get('flavorRef'));

            if (!flv) {

                storage.flavors.update_unknown_id(this.get('flavorRef'));

                flv = storage.flavors.get(this.get('flavorRef'));

            }

            return flv;

        },

        // retrieve the metadata object

        get_meta: function() {

            //return {

                //'OS': 'debian',

                //'username': 'vinilios',

                //'group': 'webservers',

                //'meta2': 'meta value',

                //'looooooooooooooooong meta': 'short value',

                //'short meta': 'loooooooooooooooooooooooooooooooooong value',

                //'21421': 'fdsfds fds',

                //'21421': 'fdsfds fds',

                //'1fds 21421': 'fdsfds fds',

                //'fds 21421': 'fdsfds fds',

                //'fge 21421': 'fdsfds fds',

                //'21421 rew rew': 'fdsfds fds'

            //}