plugins.scheduler: scheduler almost working
[myslice.git] / portal / sliceview.py
1 from django.template                 import RequestContext
2 from django.shortcuts                import render_to_response
3
4 from unfold.loginrequired            import LoginRequiredAutoLogoutView
5
6 from unfold.page                     import Page
7 from manifold.core.query             import Query, AnalyzedQuery
8
9 from ui.topmenu                      import topmenu_items, the_user
10
11 from plugins.raw                     import Raw
12 from plugins.stack                   import Stack
13 from plugins.tabs                    import Tabs
14 from plugins.querytable              import QueryTable 
15 from plugins.queryupdater            import QueryUpdater
16 from plugins.googlemap               import GoogleMap
17 from plugins.senslabmap              import SensLabMap
18 from plugins.scheduler               import Scheduler
19 from plugins.querycode               import QueryCode
20 from plugins.query_editor            import QueryEditor
21 from plugins.active_filters          import ActiveFilters
22 from plugins.quickfilter             import QuickFilter
23 from plugins.messages                import Messages
24 from plugins.slicestat               import SliceStat
25
26 from myslice.config                  import Config
27
28 tmp_default_slice='ple.upmc.myslicedemo'
29
30 # temporary : turn off the users part to speed things up
31 #do_query_users=True
32 do_query_users=False
33
34 insert_messages=False
35 #insert_messages=True
36
37 class SliceView (LoginRequiredAutoLogoutView):
38
39     def get (self,request, slicename=tmp_default_slice):
40     
41         page = Page(request)
42         page.add_css_files ('css/slice-view.css')
43         page.add_js_files  ( [ "js/common.functions.js" ] )
44         page.add_js_chunks ('$(function() { messages.debug("sliceview: jQuery version " + $.fn.jquery); });')
45         page.add_js_chunks ('$(function() { messages.debug("sliceview: users turned %s"); });'%("on" if do_query_users else "off"))
46         config=Config()
47         page.add_js_chunks ('$(function() { messages.debug("manifold URL %s"); });'%(config.manifold_url()))
48         page.expose_js_metadata()
49     
50         metadata = page.get_metadata()
51         resource_md = metadata.details_by_object('resource')
52         resource_fields = [column['name'] for column in resource_md['column']]
53     
54         user_md = metadata.details_by_object('user')
55         user_fields = ['user_hrn'] # [column['name'] for column in user_md['column']]
56     
57         # TODO The query to run is embedded in the URL
58         main_query = Query.get('slice').filter_by('slice_hrn', '=', slicename)
59         main_query.select(
60                 'slice_hrn',
61                 'resource.hrn', 'resource.hostname', 'resource.type', 
62                 'resource.network_hrn',
63                 'lease.urn',
64                 'user.user_hrn',
65                 #'application.measurement_point.counter'
66         )
67     
68         query_resource_all = Query.get('resource').select(resource_fields)
69         if do_query_users:
70             query_user_all = Query.get('user').select(user_fields)
71     
72         aq = AnalyzedQuery(main_query, metadata=metadata)
73         page.enqueue_query(main_query, analyzed_query=aq)
74         page.enqueue_query(query_resource_all)
75         if do_query_users:
76             page.enqueue_query(query_user_all)
77     
78         # ... and for the relations
79         # XXX Let's hardcode resources for now
80         sq_resource    = aq.subquery('resource')
81         sq_user        = aq.subquery('user')
82         sq_lease       = aq.subquery('lease')
83         sq_measurement = aq.subquery('measurement')
84         
85     
86         # Prepare the display according to all metadata
87         # (some parts will be pending, others can be triggered by users).
88         # 
89         # For example slice measurements will not be requested by default...
90     
91         # Create the base layout (Stack)...
92         main_stack = Stack (
93             page=page,
94             title="Slice %s"%slicename,
95             sons=[],
96         )
97     
98         # ... responsible for the slice properties...
99     
100         # a nice header
101         main_stack.insert (
102             Raw (page=page,
103                  togglable=False, 
104                  toggled=True,
105                  html="<h2 class='well well-lg'> Slice %s</h2>"%slicename)
106         )
107     
108         # --------------------------------------------------------------------------
109         # QueryUpdater (Pending Operations)
110
111         main_stack.insert(QueryUpdater(
112             page                = page,
113             title               = 'Pending operations',
114             query               = main_query,
115             togglable           = True,
116             # start turned off, it will open up itself when stuff comes in
117             toggled             = False, 
118             domid               = 'pending',
119             outline_complete    = True,
120         ))
121
122         # --------------------------------------------------------------------------
123         # Filter Resources
124        
125         filter_query_editor = QueryEditor(
126             page  = page,
127             query = sq_resource, 
128             query_all = query_resource_all,
129             title = "Select Columns",
130             domid = 'select-columns',
131             )
132         filter_active_filters = ActiveFilters(
133             page  = page,
134             query = sq_resource,
135             title = "Active Filters",
136             )
137         filters_area = Stack(
138             page                = page,
139             title               = 'Filter Resources',
140             domid               = 'filters',
141             sons                = [filter_query_editor, filter_active_filters],
142             togglable           = True,
143             toggled             = 'persistent',
144             outline_complete    = True, 
145         )
146         main_stack.insert (filters_area)
147
148         # --------------------------------------------------------------------------
149         # RESOURCES
150         # the resources part is made of a Tabs (Geographic, List), 
151
152         resources_as_gmap = GoogleMap(
153             page       = page,
154             title      = 'Geographic view',
155             domid      = 'resources-map',
156             # tab's sons preferably turn this off
157             togglable  = False,
158             query      = sq_resource,
159             query_all  = query_resource_all,
160             googlemap_api_key = Config().googlemap_api_key(),
161             checkboxes = True,
162             # center on Paris
163             latitude   = 49.,
164             longitude  = 9,
165             zoom       = 4,
166         )
167
168         resources_as_3dmap = SensLabMap(
169             page       = page,
170             title      = '3D Map',
171             domid      = 'senslabmap',
172             query      = sq_resource,
173             query_all  = query_resource_all,
174         )
175
176         resources_as_list = QueryTable( 
177             page       = page,
178             domid      = 'resources-list',
179             title      = 'List view',
180             # this is the query at the core of the slice list
181             query      = sq_resource,
182             query_all  = query_resource_all,
183             checkboxes = True,
184             datatables_options = { 
185                 'iDisplayLength': 25,
186                 'bLengthChange' : True,
187                 'bAutoWidth'    : True,
188                 },
189             )
190
191         resources_as_scheduler = Scheduler(
192             page        = page,
193             title       = 'Scheduler',
194             domid       = 'scheduler',
195             query       = sq_resource,
196             query_all_resources = query_resource_all,
197             query_lease = sq_lease,
198         )
199
200        # with the new 'Filter' stuff on top, no need for anything but the querytable
201         resources_as_list_area = resources_as_list 
202
203         resources_area = Tabs ( page=page, 
204                                 domid="resources",
205                                 togglable=True,
206                                 title="Resources",
207                                 outline_complete=True,
208                                 sons=[ 
209                                        resources_as_scheduler,
210                                        #resources_as_gmap, 
211                                        #resources_as_3dmap,
212                                        resources_as_list_area, ],
213                                 active_domid = 'resources-map',
214                                 )
215         main_stack.insert (resources_area)
216
217         # --------------------------------------------------------------------------
218         # USERS
219     
220         if do_query_users:
221             tab_users = Tabs(
222                 page                = page,
223                 domid               = 'users',
224                 outline_complete    = True,
225                 togglable           = True,
226                 title               = 'Users',
227                 active_domid        = 'users-list',
228                 )
229             main_stack.insert(tab_users)
230     
231             tab_users.insert(QueryTable( 
232                 page        = page,
233                 title       = 'Users List',
234                 domid       = 'users-list',
235                 # tab's sons preferably turn this off
236                 togglable   = False,
237                 # this is the query at the core of the slice list
238                 query       = sq_user,
239                 query_all  = query_user_all,
240                 checkboxes  = True,
241                 datatables_options = { 
242                     'iDisplayLength' : 25,
243                     'bLengthChange'  : True,
244                     'bAutoWidth'     : True,
245                 },
246             ))
247
248 # DEMO    
249         # --------------------------------------------------------------------------
250         # MEASUREMENTS
251         measurements_stats_cpu = SliceStat(
252             title = "CPU Usage",
253             domid = 'resources-stats-cpu',
254             page  = page,
255             stats = 'slice',
256             key   = 'hrn',
257             query = 'none',
258             slicename = slicename,
259             o = 'cpu'
260         )
261         
262         measurements_stats_mem = SliceStat(
263             title = "Memory Usage",
264             domid = 'resources-stats-mem',
265             page  = page,
266             stats = 'slice',
267             key   = 'hrn',
268             query = 'none',
269             slicename = slicename,
270             o = 'mem'
271         )
272         
273         measurements_stats_asb = SliceStat(
274             title = "Traffic Sent",
275             domid = 'resources-stats-asb',
276             page  = page,
277             stats = 'slice',
278             key   = 'hrn',
279             query = 'none',
280             slicename = slicename,
281             o = 'asb'
282         )
283         
284         measurements_stats_arb = SliceStat(
285             title = "Traffic Received",
286             domid = 'resources-stats-arb',
287             page  = page,
288             stats = 'slice',
289             key   = 'hrn',
290             query = 'none',
291             slicename = slicename,
292             o = 'arb'
293         )
294
295         tab_measurements = Tabs ( page=page,
296                                 domid="measurements",
297                                 togglable=True,
298                                 toggled  = False,
299                                 title="Measurements",
300                                 outline_complete=True,
301                                 sons=[ measurements_stats_cpu, measurements_stats_mem, measurements_stats_asb, measurements_stats_arb ],
302                                 active_domid = 'measurements_stats_cpu',
303                                 )
304         main_stack.insert (tab_measurements)
305         
306 #        tab_measurements = Tabs (
307 #            page                = page,
308 #            active_domid        = 'measurements-list',
309 #            outline_complete    = True,
310 #            togglable           = True,
311 #            title               = 'Measurements',
312 #            domid               = 'measurements',
313 #        )
314 #        main_stack.insert(tab_measurements)
315 #    
316 #        tab_measurements.insert(QueryTable( 
317 #            page        = page,
318 #            title       = 'Measurements',
319 #            domid       = 'measurements-list',
320 #            # tab's sons preferably turn this off
321 #            togglable   = False,
322 #            # this is the query at the core of the slice list
323 #            query       = sq_measurement,
324 #            # do NOT set checkboxes to False
325 #            # this table being otherwise empty, it just does not fly with dataTables
326 #            checkboxes  = True,
327 #            datatables_options = { 
328 #                'iDisplayLength' : 25,
329 #                'bLengthChange'  : True,
330 #                'bAutoWidth'     : True,
331 #            },
332 #        ))
333 #    
334 #        # --------------------------------------------------------------------------
335 #        # MESSAGES (we use transient=False for now)
336         if insert_messages:
337             main_stack.insert(Messages(
338                     page   = page,
339                     title  = "Runtime messages for slice %s"%slicename,
340                     domid  = "msgs-pre",
341                     levels = "ALL",
342                     # plain messages are probably less nice for production but more reliable for development for now
343                     transient = False,
344                     # these make sense only in non-transient mode..
345                     togglable = True,
346                     toggled = 'persistent',
347                     outline_complete = True,
348                     ))
349     
350     
351         # variables that will get passed to the view-unfold1.html template
352         template_env = {}
353         
354         # define 'unfold_main' to the template engine - the main contents
355         template_env [ 'unfold_main' ] = main_stack.render(request)
356     
357         # more general variables expected in the template
358         template_env [ 'title' ] = '%(slicename)s'%locals()
359         # the menu items on the top
360         template_env [ 'topmenu_items' ] = topmenu_items('Slice', request) 
361         # so we can sho who is logged
362         template_env [ 'username' ] = the_user (request) 
363     
364         # don't forget to run the requests
365         page.expose_queries ()
366     
367         # xxx create another plugin with the same query and a different layout (with_datatables)
368         # show that it worls as expected, one single api call to backend and 2 refreshed views
369     
370         # the prelude object in page contains a summary of the requirements() for all plugins
371         # define {js,css}_{files,chunks}
372         prelude_env = page.prelude_env()
373         template_env.update(prelude_env)
374         result=render_to_response ('view-unfold1.html',template_env,
375                                    context_instance=RequestContext(request))
376         return result