rest/delete.py

   1 from manifold.core.query            import Query
   2
   3 from django.views.generic.base      import TemplateView
   4 from django.shortcuts               import render_to_response
   5
   6 from unfold.loginrequired           import LoginRequiredView
   7 from django.http                    import HttpResponse
   8
   9 from manifold.core.query            import Query, AnalyzedQuery
  10 from manifoldapi.manifoldapi        import execute_query
  11
  12 from string import join
  13 import decimal
  14 import datetime
  15 import json
  16
  17 # handles serialization of datetime in json
  18 DateEncoder = lambda obj: obj.strftime("%B %d, %Y %H:%M:%S") if isinstance(obj, datetime.datetime) else None
  19
  20 # support converting decimal in json
  21 json.encoder.FLOAT_REPR = lambda o: format(o, '.2f')
  22
  23 # handles decimal numbers serialization in json
  24 class DecimalEncoder(json.JSONEncoder):
  25     def _iterencode(self, o, markers=None):
  26         if isinstance(o, decimal.Decimal):
  27             return (str(o) for o in [o])
  28         return super(DecimalEncoder, self)._iterencode(o, markers)
  29
  30 class objectRequest(object):
  31
  32     def __init__(self, request, object_type, object_name):
  33         self.type = object_type
  34         self.name = object_name
  35         # No params in delete
  36         self.properties = []
  37         self.filters = {}
  38         self.options = None
  39
  40         self.request = request
  41
  42         # What about key formed of multiple fields???
  43         query = Query.get('local:object').filter_by('table', '==', self.type).select('key')
  44         results = execute_query(self.request, query)
  45         print "key of object = %s" % results
  46         if results :
  47             for r in results[0]['key'] :
  48                 self.id = r
  49         else :
  50             return error('Manifold db error')
  51
  52         query = Query.get('local:object').filter_by('table', '==', self.type).select('column.name')
  53         results = execute_query(self.request, query)
  54         if results :
  55             for r in results[0]['column'] :
  56                 self.properties.append(r['name'])
  57         else :
  58             return error('Manifold db error')
  59
  60     def setId(self):
  61         if self.id in self.properties :
  62             self.properties.remove(self.id)
  63             [self.id].extend(self.properties)
  64
  65     def execute(self):
  66         query = Query.delete(self.type)
  67         if self.filters :
  68             for k, f in self.filters.iteritems() :
  69                 if (f[:1] == "!") :
  70                     query.filter_by(k, '!=', f[1:])
  71                 elif (f[:2] == ">=") :
  72                     query.filter_by(k, '>=', f[2:])
  73                 elif (f[:1] == ">") :
  74                     query.filter_by(k, '>', f[1:])
  75                 elif (f[:2] == "<=") :
  76                     query.filter_by(k, '<=', f[2:])
  77                 elif (f[:1] == "<") :
  78                     query.filter_by(k, '<', f[1:])
  79                 else :
  80                     query.filter_by(k, '==', f)
  81         else:
  82             raise Exception, "Filters are required for delete"
  83         return execute_query(self.request, query)
  84
  85 def dispatch(request, object_type, object_name):
  86
  87     o = objectRequest(request, object_type, object_name)
  88
  89     object_filters = {}
  90     object_params = {}
  91     result = {}
  92
  93     if request.method == 'POST':
  94         req_items = request.POST
  95     elif request.method == 'GET':
  96         #return HttpResponse(json.dumps({'error' : 'only post request is supported'}), content_type="application/json")
  97         req_items = request.GET
  98
  99     for el in req_items.items():
 100         if el[0].startswith('filters'):
 101             o.filters[el[0][8:-1]] = el[1]
 102         elif el[0].startswith('options'):
 103             o.options = req_items.getlist('options[]')
 104
 105     try:
 106         response = o.execute()
 107
 108         if response :
 109             return HttpResponse(json.dumps({'success' : 'record deleted'}), content_type="application/json")
 110         else :
 111             return HttpResponse(json.dumps({'error' : 'an error has occurred'}), content_type="application/json")
 112
 113     except Exception, e:
 114         return HttpResponse(json.dumps({'error' : str(e)}), content_type="application/json")
 115