Changeset 0c0b13c for fedd/fedd_proj.py


Ignore:
Timestamp:
Jul 16, 2008 5:59:59 PM (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:
dc8c3e6
Parents:
bb3769a
Message:

cross transport proxy operations work!

File:
1 edited

Legend:

Unmodified
Added
Removed

  • fedd/fedd_proj.py

    rbb3769a r0c0b13c  
    2020from fedd_services import *
    2121from fedd_util import *
     22import parse_detail
    2223
    2324if False:
    … …  
    6667                return "access_proj('%s', [])" % self.name
    6768
    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
     69    # This is used to make the service error reporting independent of the
     70    # transport.  The XMLRPC and SOAP dispatchers will convert it into
     71    # transport-specific errors
     72    class service_error(RuntimeError):
     73        access = 1
     74        proxy= 2
     75        req = 3
     76        server_config = 4
     77        internal = 5
     78        code_str = {
     79            access : "Access Denied",
     80            proxy : "Proxy Error",
     81            req : "Badly Formed Request",
     82            server_config: "Server Configuration Error",
     83            internal : "Internal Error"
     84        }
     85        str_code = dict([ (v, k) for k, v in code_str.iteritems() ])
     86        client_errors = ( req )
     87        server_errors = ( access, proxy, server_config, internal)
     88
     89        def __init__(self, code=None, desc=None, from_string=None):
     90            self.code = code
     91            self.desc = desc
     92            if code == None:
     93                self.set_code_from_string(from_string)
     94            RuntimeError.__init__(self, desc)
     95
     96        def code_string(self, code=None):
     97            code = code or self.code
     98            return fedd_proj.service_error.code_str.get(code)
     99       
     100        def set_code_from_string(self, errstr):
     101            self.code = fedd_proj.service_error.str_code.get(errstr,
     102                   fedd_proj. service_error.internal)
     103            return self.code
     104       
     105        def is_client_error(self):
     106            return self.code in fedd_proj.service_error.client_errors
     107
     108        def is_server_error(self):
     109            return self.code in fedd_proj.service_error.server_errors
     110
     111    # Used to report errors parsing the configuration files, not in providing
     112    # service
    74113    class parse_error(RuntimeError): pass
    75114
    … …  
    229268                    rc = subprocess.call(cmd)
    230269                except OSerror, e:
    231                     raise fedd_proj.server_error(
     270                    raise fedd_proj.service_error(\
     271                            fedd_proj.service_error.internal,
    232272                            "Dynamic project subprocess creation error "+ \
    233273                                    "[%s] (%s)" %  (cmd[1], e.strerror))
    … …  
    236276
    237277            if rc != 0:
    238                 raise fedd_proj.server_error(
     278                raise fedd_proj.service_error(\
     279                        fedd_proj.service_error.internal,
    239280                        "Dynamic project subprocess error " +\
    240281                                "[%s] (%d)" % (cmd[1], rc))
    … …  
    266307            ctx = fedd_ssl_context(self.cert_file, tc, password=self.cert_pwd)
    267308        except SSL.SSLError:
    268             raise fedd_proj.server_error("Server certificates misconfigured")
     309            raise fedd_proj.service_error(fedd_proj.service_error.server_config,
     310                    "Server certificates misconfigured")
    269311
    270312        # Of all the dumbass things.  The XMLRPC library in use here won't
    … …  
    286328                    { "RequestAccessRequestBody": r})
    287329            resp, method = xmlrpclib.loads(resp)
     330        except xmlrpclib.Fault, f:
     331            se = fedd_proj.service_error(None, f.faultString, f.faultCode)
     332            raise se
    288333        except xmlrpclib.Error, e:
    289             raise fedd_proj.server_error("Remote XMLRPC Fault: %s" % e)
     334            raise fedd_proj.service_error(fedd_proj.service_error.proxy,
     335                    "Remote XMLRPC Fault: %s" % e)
    290336       
    291337        if resp[0].has_key('RequestAccessResponseBody'):
    292338            return resp[0]['RequestAccessResponseBody']
    293339        else:
    294             raise fedd_proj.server_error("Bad proxy response")
     340            raise fedd_proj.service_error(fedd_proj.service_error.proxy,
     341                    "Bad proxy response")
    295342
    296343    def proxy_request(self, dt, req):
    … …  
    308355            ctx = fedd_ssl_context(self.cert_file, tc, password=self.cert_pwd)
    309356        except SSL.SSLError:
    310             raise fedd_proj.server_error("Server certificates misconfigured")
     357            raise fedd_proj.service_error(fedd_proj.service_error.server_config,
     358                    "Server certificates misconfigured")
    311359
    312360        loc = feddServiceLocator();
    … …  
    322370            resp = port.RequestAccess(msg)
    323371        except ZSI.ParseException, e:
    324             raise fedd_proj.server_error("Bad format message (XMLRPC??): %s" %
     372            raise fedd_proj.service_error(fedd_proj.service_error.proxy,
     373                    "Bad format message (XMLRPC??): %s" %
    325374                    str(e))
    326         except ZSI.FaultException, e:
    327             raise e.fault
    328 
    329375        r = unpack_soap(resp)
    330376
    … …  
    332378            return r['RequestAccessResponseBody']
    333379        else:
    334             raise fedd_proj.server_error("Bad proxy response")
     380            raise fedd_proj.service_error(fedd_proj.service_error.proxy,
     381                    "Bad proxy response")
    335382
    336383    def permute_wildcards(self, a, p):
    … …  
    401448                fedids = [ u for u in user if isinstance(u, type(fid))]
    402449                if len(fedids) > 1:
    403                     raise fedd_proj.client_error(
     450                    raise fedd_proj.service_error(service_error.req,
    404451                            "User asserting multiple fedids")
    405452                elif len(fedids) == 1 and fedids[0] != fid:
    406                     raise fedd_proj.client_error(
     453                    raise fedd_proj.service_error(service_error.req,
    407454                            "User asserting different fedid")
    408455            project = None
    … …  
    410457        elif principal_type == "project":
    411458            if isinstance(project, type(fid)) and fid != project:
    412                 raise fedd_proj.client_error(
     459                raise fedd_proj.service_error(service_error.req,
    413460                        "Project asserting different fedid")
    414461            tb = None
    … …  
    419466        print "Found: ", found
    420467       
    421         if found == None: raise fedd_proj.server_error("Access denied")
     468        if found == None:
     469            raise fedd_proj.service_error(fedd_proj.service_error.access,
     470                    "Access denied")
    422471
    423472        # resolve <dynamic> and <same> in found
    … …  
    429478                found[0].name = project
    430479            else :
    431                 raise fedd_proj.server_error(
     480                raise fedd_proj.service_error(\
     481                        fedd_proj.service_error.server_config,
    432482                        "Project matched <same> when no project given")
    433483        elif found[0].name == "<dynamic>":
    … …  
    438488            if user_match == "<any>":
    439489                if user != None: found = (found[0], user[0])
    440                 else: raise fedd_proj.server_error(
     490                else: raise fedd_proj.service_error(\
     491                        fedd_proj.service_error.server_config,
    441492                        "Matched <same> on anonymous request")
    442493            else:
    … …  
    487538            req = req['RequestAccessRequestBody']
    488539        else:
    489             raise fedd_proj.client_error("No request!?")
     540            raise fedd_proj.service_error(service_error.req, "No request!?")
    490541
    491542        if req.has_key('destinationTestbed'):
    … …  
    505556                                                t not in found[0].node_types]
    506557                if len(inaccessible) > 0:
    507                     raise fedd_proj.server_error(
     558                    raise fedd_proj.service_error(fedd_proj.service_error.access,
    508559                            "Access denied (nodetypes %s)" % \
    509560                            str(', ').join(inaccessible))
    … …  
    516567                else: pass    # SSH key additions
    517568            else:
    518                 raise fedd_proj.client_error("SSH access parameters required")
     569                raise fedd_proj.service_error(service_error.req,
     570                        "SSH access parameters required")
    519571
    520572            resp = self.build_response(req['allocID'], found, ssh)
    … …  
    525577                # Proxy the request using SOAP
    526578                return self.proxy_request(dt, req)
    527             except RuntimeError, f:
    528                 p_fault = f
    529          
    530            
    531             # This runs if SOAP failed
    532             try:
     579            except fedd_proj.service_error, e:
     580                if e.code == fedd_proj.service_error.proxy: p_fault = None
     581                else: raise
     582            except ZSI.FaultException, f:
     583                p_fault = f.fault.detail[0]
     584                   
     585
     586            # If we could not get a valid SOAP response to the request above,
     587            # try the same address using XMLRPC and let any faults flow back
     588            # out.
     589            if p_fault == None:
    533590                return self.proxy_xmlrpc_request(dt, req)
    534                 print "here"
    535             except RuntimeError:
    536                 # Both failed, return the SOAP error.  If somehow that
    537                 # exception is gone, return the XMLRPC one
    538                 if p_fault != None: raise p_fault
    539                 else: raise
     591            else:
     592                # Build the fault
     593                body = p_fault.get_element_RequestAccessFaultBody()
     594                if body != None:
     595                    raise service_error(body.get_element_code(),
     596                                body.get_element_desc());
     597                else:
     598                    raise fedd_proj.service_error(\
     599                            fedd_proj.service_error.proxy,
     600                            "Undefined fault from proxy??");
    540601
    541602    def soap_RequestAccess(self, ps, fid):
    … …  
    556617            return xmlrpclib.dumps(({ "RequestAccessResponseBody": msg },))
    557618        else:
    558             raise server_error("No response generated?!");
     619            raise service_error(fedd_proj.service_error.internal,
     620                    "No response generated?!");
    559621
    560622    def read_trust(self, trust):
    … …  
    729791            try:
    730792                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))
     793            except fedd_proj.service_error, e:
     794                de = ns0.faultType_Def(
     795                        (ns0.faultType_Def.schema,
     796                            "RequestAccessFaultBody")).pyclass()
     797                de._code=e.code
     798                de._errstr=e.code_string()
     799                de._desc=e.desc
     800                if  e.is_server_error():
     801                    raise Fault(Fault.Server, e.code_string(), detail=de)
     802                else:
     803                    raise Fault(Fault.Client, e.code_string(), detail=de)
    739804        else:
    740805            raise Fault(Fault.Client, "Unknown method: %s" % method)
    … …  
    744809            try:
    745810                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))
     811            except fedd_proj.service_error, e:
     812                raise xmlrpclib.Fault(e.code_string(), e.desc)
    750813        else:
    751814            raise xmlrpclib.Fault(100, "Unknown method: %s" % method)
Note: See TracChangeset for help on using the changeset viewer.