X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=manifold%2Fmanifoldapi.py;h=2548287fd69d326f8801b6a2067d8e63b8ce96f7;hb=9e6b289bad3042093d0414ed90a336aaa5bfa09a;hp=4d2503118f8b5f51094d5fb973da815fe8aea807;hpb=69867d5296684463d3aad4f6db867d24005102aa;p=myslice.git diff --git a/manifold/manifoldapi.py b/manifold/manifoldapi.py index 4d250311..2548287f 100644 --- a/manifold/manifoldapi.py +++ b/manifold/manifoldapi.py @@ -38,13 +38,24 @@ class ManifoldAPI: print "kwds",kwds try: result=getattr(self.server, methodName)(self.auth, *args, **kwds) - if debug: - print '===> backend call',methodName, self.auth, self.url,'->', - if not result: print "[no/empty result]" - elif isinstance (result,str): print "result is '%s'"%result - elif isinstance (result,list): print "result is a %d-elts list"%len(result) - else: print "[dont know how to display result]" - return ManifoldResult (code=ManifoldCode.SUCCESS, value=result) + ### attempt to cope with old APIs and new APIs + if isinstance (result, dict) and 'code' in result: + # this sounds like a result from a new API, leave it untouched + # XXX jordan : we need to wrap it into a ResultValue structure + # XXX this is not good until we merge both repos + if result['code'] != 2: + return ManifoldResult(code=result['code'], value=result['value']) + else: + return ManifoldResult(code=result['code'], output=result['description']) + else: + if debug: + print '<=== backend call', methodName, args, kwds + print '.... ctd', 'Authmethod=',self.auth['AuthMethod'], self.url,'->', + if not result: print "[no/empty result]" + elif isinstance (result,str): print "result is '%s'"%result + elif isinstance (result,list): print "result is a %d-elts list"%len(result) + else: print "[dont know how to display result]" + return ManifoldResult (code=ManifoldCode.SUCCESS, value=result) except xmlrpclib.Fault, error: ### xxx this is very rough for now # until we have some agreement about how the API calls should return error conditions @@ -63,18 +74,11 @@ class ManifoldAPI: return func def send_manifold_query (self, query): - (action,subject)= (query.action,query.subject) - # use e.g. self.Get rather than self.server.Get so we use the __getattr__ code - if action=='get': -# this makes the backend to squeak and one can't login anymore... -# return self.Get(subject, query.filters, query.timestamp, query.fields) - return self.Get(subject, query.filters, {}, query.fields) - elif action=='update': - answer=self.Update(subject, query.filters, query.params, query.fields) - if not isinstance (answer, ManifoldResult): print "UNEXECPECTED answer", answer - return answer - else: - warning="WARNING: ManifoldAPI.send_manifold_query: %s not implemented for now"%action - print warning - print 3 - return ManifoldResult(code=ManifoldCode.NOT_IMPLEMENTED, output=warning) + # We use a dictionary representation of the query for forwarding it to the API + ret = self.forward(query.to_dict()) + if debug: + print "="*80 + print "Result:" + print ret + print "="*80 + return ret