Changeset bb3769a for fedd/fedd_proj.py


Ignore:
Timestamp:
Jul 16, 2008 11:28:14 AM (16 years ago)
Author:
Ted Faber <faber@…>
Branches:
axis_example, compt_changes, info-ops, master, version-1.30, version-2.00, version-3.01, version-3.02
Children:
0c0b13c
Parents:
0a47d52
Message:

parsing SOAP faults (finally)

File:
1 edited

Legend:

Unmodified
Added
Removed

  • fedd/fedd_proj.py

    r0a47d52 rbb3769a  
    2020from fedd_services import *
    2121from fedd_util import *
     22
     23if False:
     24    _RequestAccessFault_typecode = Struct(pname=("http://www.isi.edu/faber/fedd.wsdl", 'RequestAccessFault'), ofwhat=[ns0.faultType_Def( pname=("http://www.isi.edu/faber/fedd.wsdl", "RequestAccessFaultBody"), aname="_RequestAccessFaultBody", minoccurs=0, maxoccurs=1, nillable=True, encoded=None, typed=True)], pyclass=None)
     25    class RequestAccessFault:
     26        typecode = _RequestAccessFault_typecode
     27        __metaclass__ = pyclass_type
     28        def __init__(self, code=0, str="str"):
     29            self._RequestAccessFaultBody = None
     30    RequestAccessFault.typecode.pyclass=RequestAccessFault
    2231
    2332class fedd_proj:
    … …  
    5766                return "access_proj('%s', [])" % self.name
    5867
    59 
    60     class parse_error(RuntimeError):
    61         """Raised if the configuration file is unparsable"""
    62         pass
     68    # These are used to make the error reporting independent of the transport.
     69    # The XMLRPC and SOAP dispatchers will convert them to transport-specific
     70    # errors
     71    class server_error(RuntimeError): pass
     72    class client_error(RuntimeError): pass
     73    # Error parsing config
     74    class parse_error(RuntimeError): pass
     75
    6376
    6477    def __init__(self, config=None):
    … …  
    216229                    rc = subprocess.call(cmd)
    217230                except OSerror, e:
    218                     raise Fault(Fault.Server,
     231                    raise fedd_proj.server_error(
    219232                            "Dynamic project subprocess creation error "+ \
    220233                                    "[%s] (%s)" %  (cmd[1], e.strerror))
    … …  
    223236
    224237            if rc != 0:
    225                 raise Fault(Fault.Server,
     238                raise fedd_proj.server_error(
    226239                        "Dynamic project subprocess error " +\
    227240                                "[%s] (%d)" % (cmd[1], rc))
    … …  
    253266            ctx = fedd_ssl_context(self.cert_file, tc, password=self.cert_pwd)
    254267        except SSL.SSLError:
    255             raise Fault(Fault.Server, "Server certificates misconfigured")
     268            raise fedd_proj.server_error("Server certificates misconfigured")
    256269
    257270        # Of all the dumbass things.  The XMLRPC library in use here won't
    … …  
    274287            resp, method = xmlrpclib.loads(resp)
    275288        except xmlrpclib.Error, e:
    276             raise Fault(Fault.Server, "Remote XMLRPC Fault: %s" % e)
     289            raise fedd_proj.server_error("Remote XMLRPC Fault: %s" % e)
    277290       
    278291        if resp[0].has_key('RequestAccessResponseBody'):
    279292            return resp[0]['RequestAccessResponseBody']
    280293        else:
    281             raise Fault(Fault.Server, "Bad proxy response")
     294            raise fedd_proj.server_error("Bad proxy response")
    282295
    283296    def proxy_request(self, dt, req):
    … …  
    295308            ctx = fedd_ssl_context(self.cert_file, tc, password=self.cert_pwd)
    296309        except SSL.SSLError:
    297             raise Fault(Fault.Server, "Server certificates misconfigured")
     310            raise fedd_proj.server_error("Server certificates misconfigured")
    298311
    299312        loc = feddServiceLocator();
    … …  
    309322            resp = port.RequestAccess(msg)
    310323        except ZSI.ParseException, e:
    311             raise Fault(Fault.Server, "Bad format message (XMLRPC??): %s" %
     324            raise fedd_proj.server_error("Bad format message (XMLRPC??): %s" %
    312325                    str(e))
    313326        except ZSI.FaultException, e:
    … …  
    319332            return r['RequestAccessResponseBody']
    320333        else:
    321             raise Fault(Fault.Server, "Bad proxy response")
     334            raise fedd_proj.server_error("Bad proxy response")
    322335
    323336    def permute_wildcards(self, a, p):
    … …  
    388401                fedids = [ u for u in user if isinstance(u, type(fid))]
    389402                if len(fedids) > 1:
    390                     raise Fault(Fault.Client,
     403                    raise fedd_proj.client_error(
    391404                            "User asserting multiple fedids")
    392405                elif len(fedids) == 1 and fedids[0] != fid:
    393                     raise Fault(Fault.Client,
     406                    raise fedd_proj.client_error(
    394407                            "User asserting different fedid")
    395408            project = None
    … …  
    397410        elif principal_type == "project":
    398411            if isinstance(project, type(fid)) and fid != project:
    399                 raise Fault(Fault.Client,
     412                raise fedd_proj.client_error(
    400413                        "Project asserting different fedid")
    401414            tb = None
    … …  
    406419        print "Found: ", found
    407420       
    408         if found == None: raise Fault(Fault.Server, "Access denied")
     421        if found == None: raise fedd_proj.server_error("Access denied")
    409422
    410423        # resolve <dynamic> and <same> in found
    … …  
    416429                found[0].name = project
    417430            else :
    418                 raise Fault(Fault.Server,
     431                raise fedd_proj.server_error(
    419432                        "Project matched <same> when no project given")
    420433        elif found[0].name == "<dynamic>":
    … …  
    425438            if user_match == "<any>":
    426439                if user != None: found = (found[0], user[0])
    427                 else: raise Fault(Fault.Server,
     440                else: raise fedd_proj.server_error(
    428441                        "Matched <same> on anonymous request")
    429442            else:
    … …  
    474487            req = req['RequestAccessRequestBody']
    475488        else:
    476             raise Fault(Fault.Client, "No request!?")
     489            raise fedd_proj.client_error("No request!?")
    477490
    478491        if req.has_key('destinationTestbed'):
    … …  
    492505                                                t not in found[0].node_types]
    493506                if len(inaccessible) > 0:
    494                     raise Fault(Fault.Server,
     507                    raise fedd_proj.server_error(
    495508                            "Access denied (nodetypes %s)" % \
    496509                            str(', ').join(inaccessible))
    … …  
    503516                else: pass    # SSH key additions
    504517            else:
    505                 raise Fault(Fault.Client, "SSH access parameters required")
     518                raise fedd_proj.client_error("SSH access parameters required")
    506519
    507520            resp = self.build_response(req['allocID'], found, ssh)
    … …  
    512525                # Proxy the request using SOAP
    513526                return self.proxy_request(dt, req)
    514             except Fault, f:
     527            except RuntimeError, f:
    515528                p_fault = f
    516529         
    … …  
    519532            try:
    520533                return self.proxy_xmlrpc_request(dt, req)
    521             except Fault:
     534                print "here"
     535            except RuntimeError:
    522536                # Both failed, return the SOAP error.  If somehow that
    523537                # exception is gone, return the XMLRPC one
    … …  
    529543
    530544        msg = self.RequestAccess(unpack_soap(req), fedid)
     545       
    531546        resp = RequestAccessResponseMessage()
    532 
    533547        resp.set_element_RequestAccessResponseBody(
    534548                pack_soap(resp, "RequestAccessResponseBody", msg))
     549
    535550        return resp
    536551
    537552    def xmlrpc_RequestAccess(self, params, fid):
    538553        msg = self.RequestAccess(params[0], fedid)
     554
    539555        if msg != None:
    540556            return xmlrpclib.dumps(({ "RequestAccessResponseBody": msg },))
     557        else:
     558            raise server_error("No response generated?!");
    541559
    542560    def read_trust(self, trust):
    … …  
    709727    def soap_dispatch(self, method, req, fid):
    710728        if fedd_proj.soap_methods.has_key(method):
    711             return getattr(self, fedd_proj.soap_methods[method])(req, fid)
     729            try:
     730                return getattr(self, fedd_proj.soap_methods[method])(req, fid)
     731            except fedd_proj.server_error, e:
     732                de = ns0.faultType_Def((ns0.faultType_Def.schema,"RequestAccessFaultBody")).pyclass()
     733                de._code=100
     734                de._desc="temp"
     735                f = Fault(Fault.Server, "Server Test", detail=de)
     736                raise f
     737            except fedd_proj.client_error, e:
     738                raise Fault(Fault.Client, str(e))
    712739        else:
    713740            raise Fault(Fault.Client, "Unknown method: %s" % method)
    … …  
    715742    def xmlrpc_dispatch(self, method, req, fid):
    716743        if fedd_proj.xmlrpc_methods.has_key(method):
    717             return getattr(self, fedd_proj.xmlrpc_methods[method])(req, fid)
     744            try:
     745                return getattr(self, fedd_proj.xmlrpc_methods[method])(req, fid)
     746            except fedd_proj.server_error, e:
     747                raise xmlrpclib.Fault("server", str(e))
     748            except fedd_proj.client_error, e:
     749                raise xmlrpclib.Fault("client", str(e))
    718750        else:
    719751            raise xmlrpclib.Fault(100, "Unknown method: %s" % method)
Note: See TracChangeset for help on using the changeset viewer.