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