rest/update.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.update(object_type)
  42
  43     if object_filters :
  44         for k, f in object_filters.iteritems() :
  45             query.filter_by(k, '==', f)
  46
  47     # DEBUG
  48     print object_filters
  49
  50     if object_params :
  51         query.set(object_params.iteritems())
  52     else :
  53         return HttpResponse(json.dumps({'error' : 'an error has occurred'}), content_type="application/json")
  54
  55     # DEBUG
  56     print object_params
  57
  58     #result = execute_query(request, query)
  59
  60     # DEBUG
  61     print result
  62
  63     if result :
  64         return HttpResponse(json.dumps({'error' : 'an error has occurred'}), content_type="application/json")
  65     else :
  66         return HttpResponse(json.dumps({'success' : 'record updated'}), content_type="application/json")
  67