##// END OF EJS Templates
Removed sync_method parameter from backbone msg spec
Jonathan Frederic -
Show More
@@ -1,331 +1,331 b''
1 1 //----------------------------------------------------------------------------
2 2 // Copyright (C) 2013 The IPython Development Team
3 3 //
4 4 // Distributed under the terms of the BSD License. The full license is in
5 5 // the file COPYING, distributed as part of this software.
6 6 //----------------------------------------------------------------------------
7 7
8 8 //============================================================================
9 9 // Base Widget Model and View classes
10 10 //============================================================================
11 11
12 12 /**
13 13 * @module IPython
14 14 * @namespace IPython
15 15 **/
16 16
17 17 define(["notebook/js/widgetmanager",
18 18 "underscore",
19 19 "backbone"],
20 20 function(widget_manager, underscore, backbone){
21 21
22 22 //--------------------------------------------------------------------
23 23 // WidgetModel class
24 24 //--------------------------------------------------------------------
25 25 var WidgetModel = Backbone.Model.extend({
26 26 constructor: function (widget_manager, model_id, comm) {
27 27 this.widget_manager = widget_manager;
28 28 this.pending_msgs = 0;
29 29 this.msg_throttle = 3;
30 30 this.msg_buffer = null;
31 31 this.id = model_id;
32 32 this.views = [];
33 33
34 34 if (comm !== undefined) {
35 35 // Remember comm associated with the model.
36 36 this.comm = comm;
37 37 comm.model = this;
38 38
39 39 // Hook comm messages up to model.
40 40 comm.on_close($.proxy(this._handle_comm_closed, this));
41 41 comm.on_msg($.proxy(this._handle_comm_msg, this));
42 42 }
43 43 return Backbone.Model.apply(this);
44 44 },
45 45
46 46 send: function (content, callbacks) {
47 47 if (this.comm !== undefined) {
48 48 var data = {method: 'custom', custom_content: content};
49 49 this.comm.send(data, callbacks);
50 50 }
51 51 },
52 52
53 53 // Handle when a widget is closed.
54 54 _handle_comm_closed: function (msg) {
55 55 this.trigger('comm:close');
56 56 delete this.comm.model; // Delete ref so GC will collect widget model.
57 57 delete this.comm;
58 58 delete this.model_id; // Delete id from model so widget manager cleans up.
59 59 // TODO: Handle deletion, like this.destroy(), and delete views, etc.
60 60 },
61 61
62 62
63 63 // Handle incoming comm msg.
64 64 _handle_comm_msg: function (msg) {
65 65 var method = msg.content.data.method;
66 66 switch (method) {
67 67 case 'update':
68 68 this.apply_update(msg.content.data.state);
69 69 break;
70 70 case 'custom':
71 71 this.trigger('msg:custom', msg.content.data.custom_content);
72 72 break;
73 73 default:
74 74 // pass on to widget manager
75 75 this.widget_manager.handle_msg(msg, this);
76 76 }
77 77 },
78 78
79 79
80 80 // Handle when a widget is updated via the python side.
81 81 apply_update: function (state) {
82 82 this.updating = true;
83 83 try {
84 84 for (var key in state) {
85 85 if (state.hasOwnProperty(key)) {
86 86 this.set(key, state[key]);
87 87 }
88 88 }
89 89 //TODO: are there callbacks that make sense in this case? If so, attach them here as an option
90 90 this.save();
91 91 } finally {
92 92 this.updating = false;
93 93 }
94 94 },
95 95
96 96
97 97 _handle_status: function (msg, callbacks) {
98 98 //execution_state : ('busy', 'idle', 'starting')
99 99 if (this.comm !== undefined && msg.content.execution_state ==='idle') {
100 100 // Send buffer if this message caused another message to be
101 101 // throttled.
102 102 if (this.msg_buffer !== null &&
103 103 this.msg_throttle === this.pending_msgs) {
104 104 var data = {method: 'backbone', sync_method: 'update', sync_data: this.msg_buffer};
105 105 this.comm.send(data, callbacks);
106 106 this.msg_buffer = null;
107 107 } else {
108 108 // Only decrease the pending message count if the buffer
109 109 // doesn't get flushed (sent).
110 110 --this.pending_msgs;
111 111 }
112 112 }
113 113 },
114 114
115 115
116 116 // Custom syncronization logic.
117 117 _handle_sync: function (method, options) {
118 118 var model_json = this.toJSON();
119 119 var attr;
120 120
121 121 // Only send updated state if the state hasn't been changed
122 122 // during an update.
123 123 if (this.comm !== undefined) {
124 124 if (!this.updating) {
125 125 if (this.pending_msgs >= this.msg_throttle) {
126 126 // The throttle has been exceeded, buffer the current msg so
127 127 // it can be sent once the kernel has finished processing
128 128 // some of the existing messages.
129 129 if (method=='patch') {
130 130 if (this.msg_buffer === null) {
131 131 this.msg_buffer = $.extend({}, model_json); // Copy
132 132 }
133 133 for (attr in options.attrs) {
134 134 this.msg_buffer[attr] = options.attrs[attr];
135 135 }
136 136 } else {
137 137 this.msg_buffer = $.extend({}, model_json); // Copy
138 138 }
139 139
140 140 } else {
141 141 // We haven't exceeded the throttle, send the message like
142 142 // normal. If this is a patch operation, just send the
143 143 // changes.
144 144 var send_json = model_json;
145 145 if (method =='patch') {
146 146 send_json = {};
147 147 for (attr in options.attrs) {
148 148 send_json[attr] = options.attrs[attr];
149 149 }
150 150 }
151 151
152 var data = {method: 'backbone', sync_method: method, sync_data: send_json};
152 var data = {method: 'backbone', sync_data: send_json};
153 153 this.comm.send(data, options.callbacks);
154 154 this.pending_msgs++;
155 155 }
156 156 }
157 157 }
158 158
159 159 // Since the comm is a one-way communication, assume the message
160 160 // arrived.
161 161 return model_json;
162 162 },
163 163
164 164 });
165 165
166 166
167 167 //--------------------------------------------------------------------
168 168 // WidgetView class
169 169 //--------------------------------------------------------------------
170 170 var BaseWidgetView = Backbone.View.extend({
171 171 initialize: function(options) {
172 172 this.model.on('change',this.update,this);
173 173 this.widget_manager = options.widget_manager;
174 174 this.comm_manager = options.widget_manager.comm_manager;
175 175 this.options = options.options;
176 176 this.child_views = [];
177 177 this.model.views.push(this);
178 178 },
179 179
180 180 update: function(){
181 181 // update view to be consistent with this.model
182 182 // triggered on model change
183 183 },
184 184
185 185 <<<<<<< HEAD
186 186 <<<<<<< HEAD
187 187 child_view: function(model_id, view_name) {
188 188 =======
189 189 child_view: function(model_id, view_name, options) {
190 190 <<<<<<< HEAD
191 191 >>>>>>> s/comm_id/model_id (left over from before)
192 192 // create and return a child view, given a comm id for a model and (optionally) a view name
193 193 =======
194 194 // create and return a child view, given a model id for a model and (optionally) a view name
195 195 >>>>>>> Updated comm id comments in view to model id
196 196 // if the view name is not given, it defaults to the model's default view attribute
197 197 var child_model = this.widget_manager.get_model(model_id);
198 198 <<<<<<< HEAD
199 199 var child_view = this.widget_manager.create_view(child_model, view_name, this.cell);
200 200 =======
201 201 var child_view = this.widget_manager.create_view(child_model, view_name, options);
202 202 >>>>>>> Completely remove cell from model and view.
203 203 this.child_views[model_id] = child_view;
204 204 =======
205 205 child_view: function(comm_id, view_name, options) {
206 206 // create and return a child view, given a comm id for a model and (optionally) a view name
207 207 // if the view name is not given, it defaults to the model's default view attribute
208 208 var child_model = this.comm_manager.comms[comm_id].model;
209 209 var child_view = this.widget_manager.create_view(child_model, view_name, this.cell, options);
210 210 this.child_views[comm_id] = child_view;
211 211 >>>>>>> Add widget view options in creating child views
212 212 return child_view;
213 213 },
214 214
215 215 update_child_views: function(old_list, new_list) {
216 216 // this function takes an old list and new list of model ids
217 217 // views in child_views that correspond to deleted ids are deleted
218 218 // views corresponding to added ids are added child_views
219 219
220 220 // delete old views
221 221 _.each(_.difference(old_list, new_list), function(element, index, list) {
222 222 var view = this.child_views[element];
223 223 delete this.child_views[element];
224 224 view.remove();
225 225 }, this);
226 226
227 227 // add new views
228 228 _.each(_.difference(new_list, old_list), function(element, index, list) {
229 229 // this function adds the view to the child_views dictionary
230 230 this.child_view(element);
231 231 }, this);
232 232 },
233 233
234 234
235 235
236 236 render: function(){
237 237 // render the view. By default, this is only called the first time the view is created
238 238 },
239 239 send: function (content) {
240 240 this.model.send(content, this.widget_manager.callbacks(this));
241 241 },
242 242
243 243 touch: function () {
244 244 this.model.save(this.model.changedAttributes(), {patch: true, callbacks: this.widget_manager.callbacks(this)});
245 245 },
246 246
247 247 });
248 248
249 249 var WidgetView = BaseWidgetView.extend({
250 250 initialize: function (options) {
251 251 // TODO: make changes more granular (e.g., trigger on visible:change)
252 252 this.model.on('change', this.update, this);
253 253 this.model.on('msg:custom', this.on_msg, this);
254 254 BaseWidgetView.prototype.initialize.apply(this, arguments);
255 255 },
256 256
257 257 on_msg: function(msg) {
258 258 switch(msg.msg_type) {
259 259 case 'add_class':
260 260 this.add_class(msg.selector, msg.class_list);
261 261 break;
262 262 case 'remove_class':
263 263 this.remove_class(msg.selector, msg.class_list);
264 264 break;
265 265 }
266 266 },
267 267
268 268 add_class: function (selector, class_list) {
269 269 var elements = this._get_selector_element(selector);
270 270 if (elements.length > 0) {
271 271 elements.addClass(class_list);
272 272 }
273 273 },
274 274
275 275 remove_class: function (selector, class_list) {
276 276 var elements = this._get_selector_element(selector);
277 277 if (elements.length > 0) {
278 278 elements.removeClass(class_list);
279 279 }
280 280 },
281 281
282 282 update: function () {
283 283 // the very first update seems to happen before the element is finished rendering
284 284 // so we use setTimeout to give the element time to render
285 285 var e = this.$el;
286 286 var visible = this.model.get('visible');
287 287 setTimeout(function() {e.toggle(visible)},0);
288 288
289 289 var css = this.model.get('_css');
290 290 if (css === undefined) {return;}
291 291 for (var selector in css) {
292 292 if (css.hasOwnProperty(selector)) {
293 293 // Apply the css traits to all elements that match the selector.
294 294 var elements = this._get_selector_element(selector);
295 295 if (elements.length > 0) {
296 296 var css_traits = css[selector];
297 297 for (var css_key in css_traits) {
298 298 if (css_traits.hasOwnProperty(css_key)) {
299 299 elements.css(css_key, css_traits[css_key]);
300 300 }
301 301 }
302 302 }
303 303 }
304 304 }
305 305 },
306 306
307 307 _get_selector_element: function (selector) {
308 308 // Get the elements via the css selector. If the selector is
309 309 // blank, apply the style to the $el_to_style element. If
310 310 // the $el_to_style element is not defined, use apply the
311 311 // style to the view's element.
312 312 var elements;
313 313 if (selector === undefined || selector === null || selector === '') {
314 314 if (this.$el_to_style === undefined) {
315 315 elements = this.$el;
316 316 } else {
317 317 elements = this.$el_to_style;
318 318 }
319 319 } else {
320 320 elements = this.$el.find(selector);
321 321 }
322 322 return elements;
323 323 },
324 324 });
325 325
326 326 IPython.WidgetModel = WidgetModel;
327 327 IPython.WidgetView = WidgetView;
328 328 IPython.BaseWidgetView = BaseWidgetView;
329 329
330 330 return widget_manager;
331 331 });
General Comments 0
You need to be logged in to leave comments. Login now