X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=manifold%2Fmanifoldproxy.py;h=29239b5d5cc1e66ac990ce541966ae44139e1f4a;hb=74b3a7675c43e2884b396cd9d5febfebc6e9ff97;hp=3b3ba0fb9ddfa29684383d7b1213a8df07f84fb1;hpb=b709866ba93d98c32127ff4deae5b783e271e5b3;p=myslice.git diff --git a/manifold/manifoldproxy.py b/manifold/manifoldproxy.py index 3b3ba0fb..29239b5d 100644 --- a/manifold/manifoldproxy.py +++ b/manifold/manifoldproxy.py @@ -6,17 +6,30 @@ from django.http import HttpResponse, HttpResponseForbidden from manifold.manifoldquery import ManifoldQuery from manifold.manifoldapi import ManifoldAPI +debug=False +debug=True + # add artificial delay in s debug_spin=0 #debug_spin=1 +# pretend the server only returns - empty lists to 'get' requests - this is to mimick +# misconfigurations or expired credentials or similar corner case situations +debug_empty=False +#debug_empty=True + +# turn this on if you want the fastest possible (locally cached) feedback +# beware that this is very rough though... +work_offline=False +#work_offline=True + # this view is what the javascript talks to when it sends a query # see also # myslice/urls.py # as well as -# static/js/manifold-async.js -def api (request,format): - """the view associated with /manifold/api/ +# static/js/manifold.js +def proxy (request,format): + """the view associated with /manifold/proxy/ with the query passed using POST""" # expecting a POST @@ -28,22 +41,61 @@ with the query passed using POST""" # format_in : how is the query encoded in POST # format_out: how to serve the results if format != 'json': - print "manifoldproxy.api: unexpected format %s -- exiting"%format + print "manifoldproxy.proxy: unexpected format %s -- exiting"%format return try: # translate incoming POST request into a query object + if debug: print 'manifoldproxy.proxy: request.POST',request.POST manifold_query = ManifoldQuery() - manifold_query.fill_from_dict(request.POST) + manifold_query.fill_from_POST(request.POST) + offline_filename="offline-%s-%s.json"%(manifold_query.action,manifold_query.subject) # retrieve session for request manifold_api_session_auth = request.session['manifold']['auth'] + if debug_empty and manifold_query.action.lower()=='get': + json_answer=json.dumps({'code':0,'value':[]}) + print "By-passing : debug_empty & 'get' request : returning a fake empty list" + return HttpResponse (json_answer, mimetype="application/json") + ### patch : return the latest one.. + if work_offline: + # if that won't work then we'll try to update anyways + try: + with (file(offline_filename,"r")) as f: + json_answer=f.read() + print "By-passing : using contents from %s"%offline_filename + return HttpResponse (json_answer, mimetype="application/json") + except: + import traceback + traceback.print_exc() + print "Could not run in offline mode, PROCEEDING" + pass + # actually forward manifold_api= ManifoldAPI(auth=manifold_api_session_auth) + if debug: print 'manifoldproxy.proxy: sending to backend', manifold_query answer=manifold_api.send_manifold_query (manifold_query) - if debug_spin: + print "="*80 + print "ANSWER IN PROXY", answer + print "="*80 + if debug: + print '<=== manifoldproxy.proxy: received from backend with code', answer['code'] + if answer['code']==0: + print ".... ctd ", + value=answer['result'] # was: value + if isinstance (value, list): print "result is a list with %d entries"%len(value) + elif isinstance (value, dict): print "result is a dict with keys %s"%value.keys() + else: print "result is other (type=%s) : %s"%(type(value),value) + json_answer=json.dumps(answer) + # if in debug mode we save this so we can use offline mode later + if (debug): + with (file(offline_filename,"w")) as f: + f.write(json_answer) + # this is an artificial delay added for debugging purposes only + if debug_spin>0: + print "Adding additional artificial delay",debug_spin import time time.sleep(debug_spin) - # return json-encoded answer - return HttpResponse (json.dumps(answer), mimetype="application/json") + return HttpResponse (json_answer, mimetype="application/json") + except: import traceback traceback.print_exc()