Python Web 服务开发者 第 4 部分: Web 服务软件资源库，第 3 部分

	<DocDef xmlns='http://namespaces.4suite.org/4ss' name='WSDL'>
  <RdfMapping>
    <Subject>$uri</Subject>
    <Predicate>'http://schema.4suite.org#wsdl'</Predicate>
    <Object>/wsdl:definitions/@name</Object>
  </RdfMapping>
  <NsMapping>
    <Prefix>wsdl</Prefix>
    <Uri>http://schemas.xmlsoap.org/wsdl/</Uri>
  </NsMapping>
</DocDef>
           

	<rdf:Description ID='SoftRepoSoapHandler'>
  <rdf:type resource='http://xmlns.4Suite.org/4ss/properties#HttpHandler'/>    
  <Priority>30</Priority>
  <Module>WebServices4.SoftRepoSoapHandler</Module>
</rdf:Description>  
<rdf:Description ID='SoftRepoWsdlHandler'>
  <rdf:type resource='http://xmlns.4Suite.org/4ss/properties#HttpHandler'/>    
  <Module>WebServices4.WsdlHandler</Module>
</rdf:Description>  
<rdf:Description ID='SoftRepoGetHandler'>
  <rdf:type resource='http://xmlns.4Suite.org/4ss/properties#HttpHandler'/>
  <Module>FtServer.Protocols.Http.GetHandler</Module>
  <DocumentRoot>/WebServices-4</DocumentRoot>
</rdf:Description>
<rdf:Description ID='SoftRepoPostHandler'>
  <rdf:type resource='http://xmlns.4Suite.org/4ss/properties#HttpHandler'/>
  <Module>FtServer.Protocols.Http.PostHandler</Module>
  <DocumentRoot>/WebServices-4</DocumentRoot>
</rdf:Description>
<rdf:Description ID='SoftRepoDeleteHandler'>
  <rdf:type resource='http://xmlns.4Suite.org/4ss/properties#HttpHandler'/>
  <Module>FtServer.Protocols.Http.DeleteHandler</Module>
  <DocumentRoot>/WebServices-4</DocumentRoot>
</rdf:Description>
<rdf:Description ID='PythonSoftRepoServer'>
  <rdf:type resource='http://xmlns.4Suite.org/4ss/properties#PythonServer'/>
  <StartMode>MANUAL</StartMode>
  <Port>8080</Port>
  <PidFile>/tmp/PyHttp.pid</PidFile>
  <ErrorLog>/tmp/PyHttp.all</ErrorLog>
  <TransferLog>/tmp/PyHttp.all</TransferLog>
  <Handler resource='#SoftRepoGetHandler'/>
  <Handler resource='#SoftRepoWsdlHandler'/>
  <Handler resource='#SoftRepoPostHandler'/>
  <Handler resource='#SoftRepoDeleteHandler'/>
  <Handler resource='#SoftRepoSoapHandler'/>
</rdf:Description>
           

[molson@penny molson]$ 4ss_manager start PythonSoftRepoServer
PythonSoftRepoServer started (pid 6045)

		<?xml version="1.0"?>
<definitions name="Software Repository"
             xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
             xmlns:tns="http://4Suite.org/webservices-4.wsdl"
             xmlns="http://schemas.xmlsoap.org/wsdl/">
  
  <message name="AddSoftwareInput">
    <part name="title"/>
    <part name="creator"/>
    <part name="home"/>
    <part name="version"/>
    <part name="description"/>
  </message>
  <portType name="AddSoftwarePortType">
    <operation name="AddSoftware">
      <input message="tns:AddSoftwareInput"/>
    </operation>
  </portType>
                          
  <binding name="SoftwareRepoBinding"
           type="tns:AddSoftwarePortType">
    <soap:binding style="document"
                  transport="http://schemas.xmlsoap.org/soap/http"/>
    <operation name="Add">
      <soap:operation soapAction="http://localhost/Add"/> 
      <input>
        <soap:body use="literal" 
                   namespace="http://spam.com/softrepo"/>
      </input>             
    </operation>
  </binding>
  <service name="SoftwareRepoService">
    <documentation>Example Software Repository Service</documentation>
    <port name="SoftwareRepoPort" binding="tns:SoftwareRepoBinding"> 
      <soap:address location="http://localhost/Add"/>
    </port>
  </service>
                         
</definitions>
           

	<xsl:stylesheet
  xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
  version="1.0"
>
  <xsl:output method='text'/>
  <xsl:param name='wsdl'/>
  <xsl:template match='/'>
    <xsl:value-of select='$wsdl'/>
  </xsl:template>
</xsl:stylesheet>
           
    

from FtServer.Protocols.Http import CommonHandler
from FtServer import Core
class WsdlHandler(CommonHandler.CommonHandler):
    def handle(self, request):
        return self._safeHandleRequest(self._handle, request)
    def _handle(self,request):
        #See if the required name header is present
        if not request.headers.has_key('name'): return None
        name = request.headers['name']
        repo = Core.GetRepository()
        try:
            model = repo.getModel()
            #Get all of the statements from the model that define WSDL
            #documents with the requested name
            stmts = model.complete(None,"http://schema.4suite.org#wsdl",name)
            if not stmts:
                return self._createErrorResponse(request, 404, uri=name)
            #Fetch the document
            uri = stmts[0].subject
            body = repo.fetchDocument(uri).getContent()
        finally:
            repo.txRollback()
        headers = {'Content-type' : 'text/xml; charset=iso-8859-1',
                   'Content-length' : len(body),
                   }
        return CommonHandler.Response(200, headers, body)
        
def Register(properties):
    #Register are new handler to accept "WSDL" requests
    handler = WsdlHandler()
    return [(handler.handle, 'WSDL')]
           
   

		   #Request the WSDL
    requestor = httplib.HTTP(SERVER_ADDR, SERVER_PORT)
    requestor.putrequest('WSDL', '/')
    requestor.putheader('Host', SERVER_ADDR)
    requestor.putheader('Content-Type', 'text/plain; charset="iso-8859-1"')
    requestor.putheader('name', WEB_SERVICE_NAME)
    requestor.endheaders()
    requestor.send("")
    (status_code, message, reply_headers) = requestor.getreply()
    reply_body = requestor.getfile().read()
    if status_code != 200:
        raise Exception("Expected status code 200, actual %d: %s" % (status_code,message)) 
           
   

	   #now that we have gotten the WSDL, parse it in
    wsdl = wsdllib.ReadFromString(reply_body)
           
   

		import sys, string, httplib, base64, mimetools
import wsdllib
from Ft.Lib import pDomlette
from xml import xpath
SERVER_ADDR = '127.0.0.1'
SERVER_PORT = 8080
WEB_SERVICE_NAME = "Software Repository"
BODY_TEMPLATE = """<SOAP-ENV:Envelope
     xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"
     xmlns:s="http://spam.com/softrepo"
     SOAP-ENV:encodingStyle="http://spam.com/softrepo/encoding"
   >
     <SOAP-ENV:Body>
       <s:Add>
         <s:Title><![CDATA[%(title)s]]></s:Title>
         <s:Creator><![CDATA[%(creator)s]]></s:Creator>
         <s:Home><![CDATA[%(home)s]]></s:Home>
         <s:Version><![CDATA[%(version)s]]></s:Version>
         <s:Description><![CDATA[%(description)s]]></s:Description>
       </s:Add>
     </SOAP-ENV:Body>
   </SOAP-ENV:Envelope>"""
def _GetInputChoice(title,choices):
    print "Please enter a selection for '%s'" % title
    while 1:
        ctr = 0
        names = choices.keys()
        names.sort()
        for name in names:
            print "  %d.  %s" % (ctr,name)
            ctr = ctr + 1
        print
        resp = raw_input("Selection: ")
        error = 0
        try:
            resp = int(resp)
        except:
            error = 1
        else:
            if resp < 0 or resp >= ctr:
                error = 1
        if error:
            print "Invalid Entry, please try again"
        else:
            break
    print
    return names[resp]
def CreateSOAPMessage(wsdl):
    #Get the service name
    serviceName = _GetInputChoice("Service",wsdl.services)
    service = wsdl.services[serviceName]
    #Get the port name
    portName = _GetInputChoice("Service Port",service.ports)
    port = service.ports[portName]
    #Get the corresponding binding
    bindingName = port.binding
    if bindingName[:4] == 'tns:':
        bindingName = bindingName[4:]
    binding = wsdl.bindings[bindingName]
    portTypeName = binding.type
    if portTypeName[:4] == 'tns:':
        portTypeName = portTypeName[4:]
    portType = wsdl.portTypes[portTypeName]
    #Get the operation name
    operationName = _GetInputChoice("Operation",portType.operations)
    operation = portType.operations[operationName]
    messageName = operation.input.message
    if messageName[:4] == 'tns:':
        messageName = messageName[4:]
    message = wsdl.messages[messageName]
    #Finally, ask the user for the data about the parts
    actualParts = {}
    for name,part in message.parts.items():
        actualParts[name] = raw_input("Please enter value for '%s': "%name)
    body = BODY_TEMPLATE % actualParts
    return body
def main():
    #Request the WSDL
    requestor = httplib.HTTP(SERVER_ADDR, SERVER_PORT)
    requestor.putrequest('WSDL', '/')
    requestor.putheader('Host', SERVER_ADDR)
    requestor.putheader('Content-Type', 'text/plain; charset="iso-8859-1"')
    requestor.putheader('name', WEB_SERVICE_NAME)
    requestor.endheaders()
    requestor.send("")
    (status_code, message, reply_headers) = requestor.getreply()
    reply_body = requestor.getfile().read()
    if status_code != 200:
        raise Exception("Expected status code 200, actual %d: %s" % (status_code,message)) 
    #now that we have gotten the WSDL, parse it in
    wsdl = wsdllib.ReadFromString(reply_body)
    request_body = CreateSOAPMessage(wsdl)
    #Now make the SOAP request
    blen = len(request_body)
    requestor = httplib.HTTP(SERVER_ADDR, SERVER_PORT)
    requestor.putrequest('POST', '/softrepo/soap-handler')
    requestor.putheader('Host', SERVER_ADDR)
    requestor.putheader('Content-Type', 'text/plain; charset="iso-8859-1"')
    requestor.putheader('Content-Length', str(blen))
    requestor.putheader('SOAPAction', "")
    requestor.endheaders()
    requestor.send(request_body)
    (status_code, message, reply_headers) = requestor.getreply()
    reply_body = requestor.getfile().read()
    if status_code != 200:
        raise Exception("Expected status code 200, actual %d: %s" % (status_code,message)) 
    reader = pDomlette.PyExpatReader()
    dom = reader.fromString(reply_body)
    con = xpath.Context.Context(dom,processorNss = {'ftsoap':'http://spam.com/softrepo'})
    doc = xpath.Evaluate("//ftsoap:Document",context=con)[0]
    uri = doc.getAttributeNS('','uri')
    print "New Document (uri = %s)" % uri
    print base64.decodestring(doc.firstChild.data)
                        
if __name__ == '__main__':
    main()
          

	[molson@penny code]$ python src/example1.py 
Please enter a selection for 'Service'
  0.  SoftwareRepoService
Selection: 0
Please enter a selection for 'Service Port'
  0.  SoftwareRepoPort
Selection: 0
Please enter a selection for 'Operation'
  0.  AddSoftware
Selection: 0
Please enter value for 'title': New Software
Please enter value for 'description': This is a new software
Please enter value for 'version': 0.001
Please enter value for 'home': http://new-software.com
Please enter value for 'creator': Mike.Olson@fourthought.com
New Document (uri = /softrepo/incoming/New Software-0.001.xml)
<rdf:RDF
xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"
   xmlns:dc="http://purl.org/dc/elements/1.1"
   xmlns="http://namespaces.4suite.org/www/software-map"
 >
   <Software rdf:ID="New Software">
     <dc:Title>New Software</dc:Title>
     <dc:Creator>Mike.Olson@fourthought.com</dc:Creator>
     <Home rdf:resource="http://new-software.com"/>
     <CurrentVersion>0.001</CurrentVersion>
     <dc:Description>This is a new software</dc:Description>
   </Software>
 </rdf:RDF>
[molson@penny code]$