X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=rest%2F__init__.py;h=fccfede72299bf4fb050e56a5354f6885016a07b;hb=refs%2Fheads%2Fonelab;hp=a8565963546a762a88ad2672103e85d694b25f0a;hpb=ba476841726dc818c0efd3ed25e42955a39fc504;p=myslice.git diff --git a/rest/__init__.py b/rest/__init__.py index a8565963..fccfede7 100644 --- a/rest/__init__.py +++ b/rest/__init__.py @@ -1,12 +1,13 @@ -from manifold.core.query import Query -from manifoldapi.manifoldapi import execute_query +import decimal +import datetime +import json from django.http import HttpResponse +from manifold.core.query import Query +from manifoldapi.manifoldapi import execute_query -import decimal -import datetime -import json +from myslice.settings import logger # handles serialization of datetime in json DateEncoder = lambda obj: obj.strftime("%B %d, %Y %H:%M:%S") if isinstance(obj, datetime.datetime) else None @@ -45,8 +46,7 @@ class ObjectRequest(object): table = self.type.split(':') prefix = table[0] table = table[1] - - if prefix is 'local': + if prefix == 'local': # XXX TODO: find a generic Query to get the fields like # select column.name from local:object where table == local:user table = self.type.split(':') @@ -75,7 +75,7 @@ class ObjectRequest(object): # What about key formed of multiple fields??? query = Query.get('local:object').filter_by('table', '==', self.type).select('key') results = execute_query(self.request, query) - print "key of object = %s" % results + logger.debug("key of object = {}".format(results)) if results : for r in results[0]['key'] : self.id = r @@ -114,6 +114,8 @@ class ObjectRequest(object): 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 @@ -134,9 +136,9 @@ class ObjectRequest(object): if self.params : for p in self.params : for k,v in p.iteritems() : - print "param: %s : %s" % (k,v) + logger.debug("param: {} : {}".format(k, v)) query.set({k : v}) - print "query = ",query + logger.debug("query = {}".format(query)) else: raise Exception, "Params are required for create" return execute_query(self.request, query) @@ -148,9 +150,9 @@ class ObjectRequest(object): if self.params : for p in self.params : for k,v in p.iteritems() : - print "param: %s : %s" % (k,v) + logger.debug("param: {} : {}".format(k, v)) query.set({k : v}) - print "query = ",query + logger.debug("query = {}".format(query)) else: raise Exception, "Params are required for update"