1 from django.template import RequestContext
2 from django.shortcuts import render_to_response
4 from manifold.core.query import Query, AnalyzedQuery
5 from manifoldapi.manifoldapi import execute_query
8 from django.views.generic.base import TemplateView
10 from unfold.loginrequired import LoginRequiredView
11 from django.http import HttpResponse
12 from django.shortcuts import render
14 from unfold.page import Page
16 from myslice.configengine import ConfigEngine
18 from plugins.apply import ApplyPlugin
19 from plugins.querytable import QueryTable
20 from plugins.googlemap import GoogleMap
21 # from plugins.queryupdater import QueryUpdaterPlugin
22 from plugins.filter_status import FilterStatusPlugin
23 from plugins.testbeds import TestbedsPlugin
24 from plugins.scheduler2 import Scheduler2
25 from plugins.columns_editor import ColumnsEditor
26 from plugins.sladialog import SlaDialog
27 from plugins.lists.simplelist import SimpleList
29 from myslice.theme import ThemeView
31 class SliceResourceView (LoginRequiredView, ThemeView):
32 template_name = "slice-resource-view.html"
34 def get(self, request, slicename):
36 if request.GET.get('message') :
37 msg = "Slice successfully updated"
42 metadata = page.get_metadata()
43 page.expose_js_metadata()
45 resource_md = metadata.details_by_object('resource')
46 resource_fields = [column['name'] for column in resource_md['column']]
48 user_md = metadata.details_by_object('user')
49 user_fields = ['user_hrn'] # [column['name'] for column in user_md['column']]
51 # TODO The query to run is embedded in the URL
52 # Example: select slice_hrn, resource.urn, lease.resource, lease.start_time, lease.end_time from slice where slice_hrn == "ple.upmc.myslicedemo"
53 main_query = Query.get('slice').filter_by('slice_hrn', '=', slicename)
57 # - The record key is needed otherwise the storage of records
62 'resource.hostname', 'resource.type',
63 # - The facility_name and testbed_name are required for the
64 # testbeds plugin to properly work.
65 'resource.facility_name',
66 'resource.testbed_name',
71 # - The lease_id is important for NITOS identify already existing
76 #'application.measurement_point.counter'
78 # for internal use in the querytable plugin;
79 # needs to be a unique column present for each returned record
80 main_query_init_key = 'urn'
81 aq = AnalyzedQuery(main_query, metadata=metadata)
82 page.enqueue_query(main_query, analyzed_query=aq)
83 sq_resource = aq.subquery('resource')
84 sq_lease = aq.subquery('lease')
86 query_resource_all = Query.get('resource').select(resource_fields)
87 #page.enqueue_query(query_resource_all)
90 #lease_md = metadata.details_by_object('lease')
91 #lease_fields = [column['name'] for column in lease_md['column']]
93 #query_lease_all = Query.get('lease').select(lease_fields)
94 #page.enqueue_query(query_lease_all)
96 # --------------------------------------------------------------------------
98 # resources as a list using datatable plugin
100 list_resources = QueryTable(
102 domid = 'resources-list',
105 query_all = query_resource_all,
108 datatables_options = {
109 'iDisplayLength': 25,
110 'bLengthChange' : True,
116 # --------------------------------------------------------------------------
117 # RESERVED RESOURCES LIST
118 # resources as a list using datatable plugin
120 list_reserved_resources = SimpleList(
127 list_reserved_leases = SimpleList(
134 # list_reserved_resources = QueryTable(
136 # domid = 'resources-reserved-list',
137 # title = 'List view',
138 # query = sq_resource,
139 # query_all = sq_resource,
142 # datatables_options = {
143 # 'iDisplayLength': 25,
144 # 'bLengthChange' : True,
145 # 'bAutoWidth' : True,
149 # --------------------------------------------------------------------------
151 # list of fields to be applied on the query
152 # this will add/remove columns in QueryTable plugin
154 filter_column_editor = ColumnsEditor(
157 query_all = query_resource_all,
158 title = "Select Columns",
159 domid = 'select-columns',
162 # --------------------------------------------------------------------------
164 # the resources part is made of a Tabs (Geographic, List),
166 map_resources = GoogleMap(
168 title = 'Geographic view',
169 domid = 'resources-map',
170 # tab's sons preferably turn this off
173 # this key is the one issued by google
174 googlemap_api_key = ConfigEngine().googlemap_api_key(),
175 # the key to use at init-time
176 init_key = main_query_init_key,
179 # To center around Europe : 53,9 / 3
185 # --------------------------------------------------------------------------
186 # LEASES Nitos Scheduler
187 # Display the leases reservation timeslots of the resources
189 resources_as_scheduler2 = Scheduler2(
193 # this is the query at the core of the slice list
195 query_lease = sq_lease,
198 # --------------------------------------------------------------------------
199 # QueryUpdater (Pending Operations)
201 # pending_resources = QueryUpdaterPlugin(
203 # title = 'Pending operations',
204 # query = main_query,
206 # # start turned off, it will open up itself when stuff comes in
209 # outline_complete = True,
210 # username = request.user,
213 # --------------------------------------------------------------------------
215 # testbeds as a list of filters
217 network_md = metadata.details_by_object('network')
218 network_fields = [column['name'] for column in network_md['column']]
220 #query_networks = Query.get('network').select(network_fields)
221 #page.enqueue_query(query_networks)
223 filter_testbeds = TestbedsPlugin(
225 domid = 'testbeds-filter',
226 title = 'Filter by testbeds',
228 #query_networks = query_networks,
229 #init_key = "network_hrn",
231 #datatables_options = {
232 # 'iDisplayLength': 25,
233 # 'bLengthChange' : True,
234 # 'bAutoWidth' : True,
238 filter_status = FilterStatusPlugin(
240 domid = "filter-status",
247 username = request.user,
251 # --------------------------------------------------------------------------
252 # SLA View and accept dialog
254 sla_dialog = SlaDialog(
256 title = 'sla dialog',
259 # start turned off, it will open up itself when stuff comes in
261 domid = 'sla_dialog',
262 outline_complete = True,
263 username = request.user,
266 ## check user is pi or not
267 platform_query = Query().get('local:platform').select('platform_id','platform','gateway_type','disabled')
268 account_query = Query().get('local:account').select('user_id','platform_id','auth_type','config')
269 platform_details = execute_query(self.request, platform_query)
270 account_details = execute_query(self.request, account_query)
272 # XXX When session has expired, this is None and thus not iterable
273 for platform_detail in platform_details:
274 for account_detail in account_details:
275 if platform_detail['platform_id'] == account_detail['platform_id']:
276 if 'config' in account_detail and account_detail['config'] is not '':
277 account_config = json.loads(account_detail['config'])
278 if 'myslice' in platform_detail['platform']:
279 acc_auth_cred = account_config.get('delegated_authority_credentials','N/A')
281 if acc_auth_cred == {} or acc_auth_cred == 'N/A':
287 template_env['list_resources'] = list_resources.render(self.request)
288 template_env['list_reserved_resources'] = list_reserved_resources.render(self.request)
289 template_env['list_reserved_leases'] = list_reserved_leases.render(self.request)
291 template_env['columns_editor'] = filter_column_editor.render(self.request)
293 template_env['filter_testbeds'] = filter_testbeds.render(self.request)
294 template_env['filter_status'] = filter_status.render(self.request)
295 template_env['apply'] = apply.render(self.request)
297 template_env['map_resources'] = map_resources.render(self.request)
298 template_env['scheduler'] = resources_as_scheduler2.render(self.request)
299 # template_env['pending_resources'] = pending_resources.render(self.request)
300 template_env['sla_dialog'] = '' # sla_dialog.render(self.request)
301 template_env["theme"] = self.theme
302 template_env["username"] = request.user
303 template_env["pi"] = pi
304 template_env["slice"] = slicename
305 template_env["section"] = "resources"
306 template_env["msg"] = msg
307 template_env.update(page.prelude_env())
309 return render_to_response(self.template, template_env, context_instance=RequestContext(request))