rest/initscript.py

   1 from django.http                    import HttpResponse
   2 import json
   3 from manifold.core.query            import Query
   4 from manifoldapi.manifoldapi        import execute_admin_query
   5
   6 def dispatch(request, action):
   7
   8     results = []
   9     error = None
  10     try:
  11         if request.method == 'POST':
  12             req_items = request.POST
  13         elif request.method == 'GET':
  14             req_items = request.GET
  15
  16         for el in req_items.items():
  17             if el[0].startswith('slice_hrn'):
  18                 slice_hrn = el[1]
  19             elif el[0].startswith('initscript_code'):
  20                 initscript_code = el[1]
  21
  22         if (action == 'get') :
  23             # select initscript_code from initscript where slice_hrn=='onelab.upmc.express'
  24             query = Query.get('initscript').filter_by('slice_hrn', '==', slice_hrn).select('initscript_code')
  25             results = execute_admin_query(request, query)
  26
  27         if (action == 'update') :
  28             # UPDATE initscript SET initscript_code='test3' where slice_hrn=='onelab.upmc.express'
  29             params = {'initscript_code' : initscript_code}
  30             query = Query.update('initscript').filter_by('slice_hrn', '==', slice_hrn).set(params)
  31             results = execute_admin_query(request, query)
  32
  33             if results[0]['initscript_code']==1:
  34                 results[0]['initscript_code']=initscript_code
  35             else:
  36                 error = "Error in update return value"
  37
  38         if (action == 'delete') :
  39             # delete from initscript where slice_hrn=='onelab.upmc.express'
  40             query = Query.delete('initscript').filter_by('slice_hrn', '==', slice_hrn)
  41             results = execute_admin_query(request, query)
  42
  43             if results[0]['initscript_code']==1:
  44                 results[0]['initscript_code']=""
  45             else:
  46                 error = "Error in delete return value"
  47     except Exception, e:
  48         error = str(e)
  49     if error is not None:
  50         ret = { "ret" : 1, "error" : error }
  51     elif not results :
  52         ret = { "ret" : 1, "slice_hrn" : slice_hrn }
  53     else :
  54         ret = { "ret" : 0, "slice_hrn" : slice_hrn }
  55         ret.update(results[0])
  56
  57     return HttpResponse(json.dumps(ret), content_type="application/json")