- for el in req_items:
- if el[0].startswith('filters'):
- object_filters[el[0][8:-1]] = el[1]
- elif el[0].startswith('columns'):
- object_properties = request.POST.getlist('columns[]')
-
- # 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)
-
-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)
-
-def authority(request, object_name, object_properties, object_filters = None):
- query = Query().get('authority')#.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)
-
-def send(request, response, object_properties):
- if request.path.split('/')[1] == 'rest' :
- response_data = response
- return HttpResponse(json.dumps(response_data, cls=DecimalEncoder, default=DateEncoder), content_type="application/json")
- elif request.path.split('/')[1] == 'table' :
- return render_to_response('table-default.html', {'data' : response, 'properties' : object_properties})
- elif request.path.split('/')[1] == 'datatable' :
+
+ 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)
+
+ def create(self):
+ query = Query.create(self.type)
+ # No filters for create
+ if self.params :
+ for p in self.params :
+ for k,v in p.iteritems() :
+ logger.debug("param: {} : {}".format(k, v))
+ query.set({k : v})
+ logger.debug("query = {}".format(query))
+ else:
+ raise Exception, "Params are required for create"
+ return execute_query(self.request, query)
+
+ def update(self):
+ query = Query.update(self.type)
+ query = self.applyFilters(query, True)
+
+ if self.params :
+ for p in self.params :
+ for k,v in p.iteritems() :
+ logger.debug("param: {} : {}".format(k, v))
+ query.set({k : v})
+ logger.debug("query = {}".format(query))
+ else:
+ raise Exception, "Params are required for update"
+
+ if self.id is not None:
+ query.select(self.id)
+
+ return execute_query(self.request, query)
+
+ def delete(self):
+ query = Query.delete(self.type)
+ query = self.applyFilters(query, True)
+ if self.filters :
+ query.set(self.filters)
+ else:
+ raise Exception, "Filters are required for delete"
+ return execute_query(self.request, query)
+
+ def json(self):
+ return HttpResponse(json.dumps(self.get(), cls=DecimalEncoder, default=DateEncoder), content_type="application/json")
+
+ def datatable(self):
+ response = self.get()