- # platform is local
- if ((object_type == 'platform') or (object_type == 'testbed')) :
- object_type = 'local:platform'
- if object_properties == None :
- object_properties = ['platform', 'platform_longname', 'platform_url', 'platform_description','gateway_type'];
- return switch.get('platform', error)(request, object_name, object_properties, object_filters)
- else :
- if object_properties == None :
- query = Query.get('local:object').filter_by('table', '==', object_type).select('column.name')
- results = execute_query(request, query)
- if results :
- object_properties = []
- for r in results[0]['column'] :
- object_properties.append(r['name'])
- else :
- return error(request, object_name, {})
- return switch.get(object_type, error)(request, object_name, object_properties, object_filters)
-
-# if request.method == 'GET':
-# return switch.get(request, object_type, object_name, object_properties)
-# elif request.method == 'POST':
-# return post(request, object_type, object_name)
-
-def platform(request, object_name, object_properties, object_filters = None):
- query = Query().get('local:platform').filter_by('disabled', '==', '0').filter_by('gateway_type', '==', 'sfa').filter_by('platform', '!=', 'myslice').select(object_properties)
- return send(request, execute_query(request, query), object_properties)
-
-# Add different filters possibilities [['user.user_hrn','==','$user_hrn'],['parent_authority','==','ple.upmc']]
-def slice(request, object_name, object_properties, object_filters = None):
- #query = Query().get('slice').filter_by('user.user_hrn', '==', '$user_hrn').select(object_properties)
- query = Query().get('slice').filter_by('parent_authority', '==', 'ple.upmc').select(object_properties)
- return send(request, execute_query(request, query), object_properties)
+ def applyFilters(self, query, force_filters = False):
+ if (force_filters and not self.filters) :
+ raise Exception, "Filters required"
+ if self.filters :
+ for k, f in self.filters.iteritems() :
+ if (f[:1] == "!") :
+ query.filter_by(k, '!=', f[1:])
+ elif (f[:2] == ">=") :
+ query.filter_by(k, '>=', f[2:])
+ elif (f[:1] == ">") :
+ query.filter_by(k, '>', f[1:])
+ elif (f[:2] == "<=") :
+ query.filter_by(k, '<=', f[2:])
+ elif (f[:1] == "<") :
+ query.filter_by(k, '<', f[1:])
+ elif (f[:8] == "CONTAINS") :
+ query.filter_by(k, 'CONTAINS', f[8:])
+ else :
+ query.filter_by(k, '==', f)
+ return query
+
+ def get(self):
+ query = Query.get(self.type)
+ if (self.id is not None) and (self.id not in self.fields) :
+ query.select(self.fields + [self.id])
+ else :
+ query.select(self.fields)
+
+ query = self.applyFilters(query)
+ return execute_query(self.request, query)