- return error(request, object_name, {})
- return switch.get(object_type, error)(request, object_name, object_properties, object_filters)
-
-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')
- if object_filters :
- for k, f in object_filters.iteritems() :
- query.filter_by(k, '==', f)
- query.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')
- if object_filters :
- for k, f in object_filters.iteritems() :
- query.filter_by(k, '==', f)
- query.select(object_properties)
- return send(request, execute_query(request, query), object_properties)
-
-def resource(request, object_name, object_properties, object_filters = None):
- query = Query().get('resource')
- if object_filters :
- for k, f in object_filters.iteritems() :
- query.filter_by(k, '==', f)
- query.select(object_properties)
- return send(request, execute_query(request, query), object_properties)
-
-def user(request, object_name, object_properties, object_filters = None):
- query = Query().get('user')#.filter_by('user_hrn', '==', '$user_hrn')
- if object_filters :
- for k, f in object_filters.iteritems() :
- query.filter_by(k, '==', f)
- query.select(object_properties)
- return send(request, execute_query(request, query), object_properties)
+ return error('db error')
+ return None
+
+ def addFilters(self, properties):
+ selected_properties = []
+ for p in properties :
+ if p in self.properties :
+ selected_properties.append(p)
+ self.properties = selected_properties
+ self.setId()
+
+ def setId(self):
+ if self.id in self.properties :
+ self.properties.remove(self.id)
+ [self.id].extend(self.properties)
+
+ def execute(self):
+ query = Query.get(self.type).select(self.properties)
+ 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:])
+ else :
+ query.filter_by(k, '==', f)
+ return execute_query(self.request, query)