X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=manifold%2Fmanifoldapi.py;h=e7c6ce901dbead4e65ab1298044ed294545f00ea;hb=4920497313e03cc832c29aaae13e45ca060ccc94;hp=8d4d1ac0f9805600aa5a49a0209aa869090f2fa1;hpb=fd94e2aa074f084afdecf26f023c8e369fec6605;p=myslice.git diff --git a/manifold/manifoldapi.py b/manifold/manifoldapi.py index 8d4d1ac0..e7c6ce90 100644 --- a/manifold/manifoldapi.py +++ b/manifold/manifoldapi.py @@ -20,14 +20,14 @@ class ManifoldAPI: def __init__(self, auth=None, cainfo=None): - config = Config() self.auth = auth self.cainfo = cainfo self.errors = [] self.trace = [] self.calls = {} self.multicall = False - self.url = config.manifold_url + config = Config() + self.url = config.manifold_url() self.server = xmlrpclib.Server(self.url, verbose=False, allow_none=True) def __repr__ (self): return "ManifoldAPI[%s]"%self.url @@ -65,8 +65,12 @@ class ManifoldAPI: return ResultValue(**result) except Exception,error: - # XXX Connection refused for example - print "** API ERROR **" + print "** MANIFOLD API ERROR **" + if "Connection refused" in error: + raise ManifoldException ( ManifoldResult (code=ManifoldCode.SERVER_UNREACHABLE, + output="%s answered %s"%(self.url,error))) + # otherwise + print "====> ERROR On ManifoldAPI.%s"%methodName,"auth",self.auth,"args",args,"kwds",kwds import traceback traceback.print_exc() if debug: print "KO (unexpected exception)",error @@ -74,12 +78,7 @@ class ManifoldAPI: return func -def execute_query(request, query): - if not 'manifold' in request.session or not 'auth' in request.session['manifold']: - print "W: Used hardcoded demo account for execute_query" - manifold_api_session_auth = {'AuthMethod': 'password', 'Username': 'demo', 'AuthString': 'demo'} - else: - manifold_api_session_auth = request.session['manifold']['auth'] +def _execute_query(request, query, manifold_api_session_auth): manifold_api = ManifoldAPI(auth=manifold_api_session_auth) print "-"*80 print query @@ -92,5 +91,16 @@ def execute_query(request, query): # XXX Handle errors #Error running query: {'origin': [0, 'XMLRPCAPI'], 'code': 2, 'description': 'No such session: No row was found for one()', 'traceback': 'Traceback (most recent call last):\n File "/usr/local/lib/python2.7/dist-packages/manifold/core/xmlrpc_api.py", line 68, in xmlrpc_forward\n user = Auth(auth).check()\n File "/usr/local/lib/python2.7/dist-packages/manifold/auth/__init__.py", line 245, in check\n return self.auth_method.check()\n File "/usr/local/lib/python2.7/dist-packages/manifold/auth/__init__.py", line 95, in check\n raise AuthenticationFailure, "No such session: %s" % e\nAuthenticationFailure: No such session: No row was found for one()\n', 'type': 2, 'ts': None, 'value': None} - return result['value'] + +def execute_query(request, query): + if not 'manifold' in request.session or not 'auth' in request.session['manifold']: + raise Exception, "User not authenticated" + manifold_api_session_auth = request.session['manifold']['auth'] + return _execute_query(request, query, manifold_api_session_auth) + +def execute_admin_query(request, query): + config = Config() + admin_user, admin_password = config.manifold_admin_user_password() + admin_auth = {'AuthMethod': 'password', 'Username': admin_user, 'AuthString': admin_password} + return _execute_query(request, query, admin_auth)