X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=manifold%2Fmanifoldapi.py;h=3fa5f9781e545f01735a270a697ff1697dc3567b;hb=10af098ebfcc500aef11ce9154028b8e20a0b046;hp=2524727015b4146284d5503cfd2681e2966d8543;hpb=a8a54f34297f76d9379070f0fd2c1bec9f761c47;p=myslice.git diff --git a/manifold/manifoldapi.py b/manifold/manifoldapi.py index 25247270..3fa5f978 100644 --- a/manifold/manifoldapi.py +++ b/manifold/manifoldapi.py @@ -10,6 +10,12 @@ from manifold.core.result_value import ResultValue debug=False debug=True +def mytruncate (obj, l): + # we will add '..' + l1=l-2 + repr="%s"%obj + return (repr[:l1]+'..') if len(repr)>l1 else repr + class ManifoldAPI: def __init__(self, auth=None, cainfo=None): @@ -21,7 +27,7 @@ class ManifoldAPI: self.trace = [] self.calls = {} self.multicall = False - self.url = config.manifold_url + self.url = config.manifold_url() self.server = xmlrpclib.Server(self.url, verbose=False, allow_none=True) def __repr__ (self): return "ManifoldAPI[%s]"%self.url @@ -33,8 +39,9 @@ class ManifoldAPI: elif isinstance (result,list): print "result is a %d-elts list"%len(result) elif isinstance (result,dict): print "result is a dict with %d keys : %s"%(len(result),result.keys()) - for (k,v) in result.iteritems(): print '...',k,':',v - print "result is a dict with %d keys : %s"%(len(result),result.keys()), + for (k,v) in result.iteritems(): + if v is None: continue + print '+++',k,':',mytruncate (v,60) else: print "[dont know how to display result] %s"%result # xxx temporary code for scaffolding a ManifolResult on top of an API that does not expose error info @@ -46,18 +53,24 @@ class ManifoldAPI: def __getattr__(self, methodName): def func(*args, **kwds): try: - if debug: print "====> ManifoldAPI.%s"%methodName,"auth",self.auth,"args",args,"kwds",kwds + if debug: + print "====> ManifoldAPI.%s"%methodName,"auth",self.auth,"args",args,"kwds",kwds result=getattr(self.server, methodName)(self.auth, *args, **kwds) if debug: print '<==== backend call %s(*%s,**%s) returned'%(methodName,args,kwds), print '.ctd. Authmethod=',self.auth['AuthMethod'], self.url,'->', self._print_result(result) + print '===== ManifoldAPI call done' return ResultValue(**result) except Exception,error: - # XXX Connection refused for example - print "** API ERROR **" + if "Connection refused" in error: + raise ManifoldException ( ManifoldResult (code=ManifoldCode.SERVER_UNREACHABLE, + output="%s answered %s"%(self.url,error))) + # otherwise + print "** MANIFOLD API ERROR **" + 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 @@ -67,7 +80,7 @@ class ManifoldAPI: 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" + print "W: Using 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']