Revision 95ff92b4 snf-cyclades-app/synnefo/ui/static/snf/js/models.js

b/snf-cyclades-app/synnefo/ui/static/snf/js/models.js
72 72
        api: snf.api,
73 73
        api_type: 'compute',
74 74
        has_status: false,
75
        auto_bind: [],
76

  
75 77

  
76 78
        initialize: function() {
79
            var self = this;
80
            
81
            this._proxy_model_cache = {};
82
            _.each(this.auto_bind, function(fname) {
83
              self[fname] = _.bind(self[fname], self);
84
            });
85

  
77 86
            if (this.has_status) {
78 87
                this.bind("change:status", this.handle_remove);
79 88
                this.handle_remove();
80 89
            }
81 90
            
82 91
            this.api_call = _.bind(this.api.call, this);
92
              
93
            if (this.proxy_attrs) {
94
              this.init_proxy_attrs();             
95
            }
96

  
97
            if (this.storage_attrs) {
98
              this.init_storage_attrs();
99
            }
100

  
101
            if (this.model_actions) {
102
              this.init_model_actions();             
103
            }
104

  
83 105
            models.Model.__super__.initialize.apply(this, arguments);
106

  
107
        },
108
        
109
        // Initialize model actions object
110
        // For each entry in model's model_action object register the relevant 
111
        // model proxy `can_<actionname>` attributes.
112
        init_model_actions: function() {
113
          var actions = _.keys(this.model_actions);
114
          this.set({
115
            "actions": new models._ActionsModel({}, {
116
              actions: actions,
117
              model: this
118
            })
119
          });
120
          this.actions = this.get("actions");
121

  
122
          _.each(this.model_actions, function(params, key){
123
            var attr = 'can_' + key;
124
            if (params.length == 0) { return }
125
            var deps = params[0];
126
            var cb = _.bind(params[1], this);
127
            _.each(deps, function(dep) {
128
              this._set_proxy_attr(attr, dep, cb);
129
            }, this);
130
          }, this);
84 131
        },
132
        
133
        // Initialize proxy storage model attributes. These attribues allows 
134
        // us to automatically access cross collection associated objects.
135
        init_storage_attrs: function() {
136
          _.each(this.storage_attrs, function(params, attr) {
137
            var store, key, attr_name;
138
            store = synnefo.storage[params[0]];
139
            key = params[1];
140
            attr_name = attr;
141
          
142
            var resolve_related_instance = function(storage, attr_name, val) {
143
              var data = {};
144

  
145
              if (!val) { 
146
                // update with undefined and return
147
                data[key] = undefined;
148
                this.set(data);
149
                return;
150
              };
151
            
152
              // retrieve related object (check if its a Model??)
153
              var obj = store.get(val);
154
              
155
              if (obj) {
156
                // set related object
157
                data[attr_name] = obj;
158
                this.set(data, {silent:true})
159
                this.trigger("change:" + attr_name, obj);
160
              } else {
161
                var self = this;
162
                var retry = window.setInterval(function(){
163
                  var obj = store.get(val);
164
                  if (obj) {
165
                    data[key] = obj;
166
                    self.set(data, {silent:true})
167
                    self.trigger("change:" + attr_name, obj);
168
                    clearInterval(retry);
169
                  }
170
                }, 10);
171
              }
172
            }
173

  
174
            this.bind('change:' + attr, function() {
175
              resolve_related_instance.call(this, store, key, this.get(attr))
176
            });
85 177

  
178
            this.bind('add', function() {
179
              resolve_related_instance.call(this, store, key, this.get(attr))
180
            });
181
          }, this);
182
        },
183
        
184
        _proxy_model_cache: {},
185
        
186
        _set_proxy_attr: function(attr, check_attr, cb) {
187
          // initial set
188
          var data = {};
189
          data[attr] = cb.call(this, this.get(check_attr));
190
          if (data[attr] !== undefined) {
191
            this.set(data, {silent:true});
192
          }
193
          
194
          this.bind('change:' + check_attr, function() {
195
            if (this.get(check_attr) instanceof models.Model) {
196
              var model = this.get(check_attr);
197
              var proxy_cache_key = attr + '_' + check_attr;
198
              if (this._proxy_model_cache[proxy_cache_key]) {
199
                var proxy = this._proxy_model_cache[proxy_cache_key];
200
                proxy[0].unbind('change', proxy[1]);
201
              }
202
              var changebind = _.bind(function() {
203
                var data = {};
204
                data[attr] = cb.call(this, this.get(check_attr));
205
                this.set(data);
206
              }, this);
207
              model.bind('change', changebind);
208
              this._proxy_model_cache[proxy_cache_key] = [model, changebind];
209
            }
210
            var val = cb.call(this, this.get(check_attr));
211
            var data = {};
212
            if (this.get(attr) !== val) {
213
              data[attr] = val;
214
              this.set(data);
215
            }
216
          }, this);
217
        },
218

  
219
        init_proxy_attrs: function() {
220
          _.each(this.proxy_attrs, function(opts, attr){
221
            var cb = opts[1];
222
            _.each(opts[0], function(check_attr){
223
              this._set_proxy_attr(attr, check_attr, cb)
224
            }, this);
225
          }, this);
226
        },
227
        
86 228
        handle_remove: function() {
87 229
            if (this.get("status") == 'DELETED') {
88 230
                if (this.collection) {
......
2492 2634

  
2493 2635
    })
2494 2636
    
2637
    models._ActionsModel = models.Model.extend({
2638
      defaults: { pending: null },
2639
      actions: [],
2640
      status: {
2641
        INACTIVE: 0,
2642
        PENDING: 1,
2643
        CALLED: 2
2644
      },
2645

  
2646
      initialize: function(attrs, opts) {
2647
        models._ActionsModel.__super__.initialize.call(this, attrs);
2648
        this.actions = opts.actions;
2649
        this.model = opts.model;
2650
        this.bind("change", function() {
2651
          this.set({'pending': this.get_pending()});
2652
        }, this);
2653
        this.clear();
2654
      },
2655
      
2656
      _in_status: function(st) {
2657
        var actions = null;
2658
        _.each(this.attributes, function(status, action){
2659
          if (status == st) {
2660
            if (!actions) {
2661
              actions = []
2662
            }
2663
            actions.push(action);
2664
          }
2665
        });
2666
        return actions;
2667
      },
2668

  
2669
      get_pending: function() {
2670
        return this._in_status(this.status.PENDING);
2671
      },
2672

  
2673
      unset_pending_action: function(action) {
2674
        var data = {};
2675
        data[action] = this.status.INACTIVE;
2676
        this.set(data);
2677
      },
2678

  
2679
      set_pending_action: function(action, reset_pending) {
2680
        reset_pending = reset_pending === undefined ? true : reset_pending;
2681
        var data = {};
2682
        data[action] = this.status.PENDING;
2683
        if (reset_pending) {
2684
          this.reset_pending();
2685
        }
2686
        this.set(data);
2687
      },
2688
      
2689
      reset_pending: function() {
2690
        var data = {};
2691
        _.each(this.actions, function(action) {
2692
          data[action] = this.status.INACTIVE;
2693
        }, this);
2694
        this.set(data);
2695
      }
2696
    });
2697

  
2495 2698
    models.PublicPool = models.Model.extend({});
2496 2699
    models.PublicPools = models.Collection.extend({
2497 2700
      model: models.PublicPool,

Also available in: Unified diff