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 def dispatch(request, object_type, object_name):
  31
  32     object_filters = {}
  33     object_params = {}
  34     result = {}
  35
  36     if request.method == 'POST':
  37         req_items = request.POST.items()
  38     elif request.method == 'GET':
  39         return HttpResponse(json.dumps({'error' : 'only post request is supported'}), content_type="application/json")
  40
  41     query = Query.delete(object_type)
  42
  43     if object_filters :
  44         for k, f in object_filters.iteritems() :
  45             query.filter_by(k, '==', f)
  46     else:
  47         return HttpResponse(json.dumps({'error' : 'Filters are required for delete'}), content_type="application/json")
  48     # DEBUG
  49     print object_filters
  50
  51 # No params in delete
  52 #    if object_params :
  53 #        query.set(object_params.iteritems())
  54 #    else :
  55 #        return HttpResponse(json.dumps({'error' : 'an error has occurred'}), content_type="application/json")
  56 #
  57 #    # DEBUG
  58 #    print object_params
  59
  60     result = execute_query(request, query)
  61
  62     # DEBUG
  63     print result
  64
  65     if result :
  66         return HttpResponse(json.dumps({'error' : 'an error has occurred'}), content_type="application/json")
  67     else :
  68         return HttpResponse(json.dumps({'success' : 'record updated'}), content_type="application/json")
  69