mirror of
https://github.com/ruby/ruby.git
synced 2025-08-26 14:34:39 +02:00
* added files
* lib/soap/attachment.rb
* lib/soap/header
* lib/soap/mimemessage.rb
* lib/soap/rpc/httpserver.rb
* lib/wsdl/soap/cgiStubCreator.rb
* lib/wsdl/soap/classDefCreator.rb
* lib/wsdl/soap/classDefCreatorSupport.rb
* lib/wsdl/soap/clientSkeltonCreator.rb
* lib/wsdl/soap/driverCreator.rb
* lib/wsdl/soap/mappingRegistryCreator.rb
* lib/wsdl/soap/methodDefCreator.rb
* lib/wsdl/soap/servantSkeltonCreator.rb
* lib/wsdl/soap/standaloneServerStubCreator.rb
* lib/wsdl/xmlSchema/enumeration.rb
* lib/wsdl/xmlSchema/simpleRestriction.rb
* lib/wsdl/xmlSchema/simpleType.rb
* lib/xsd/codegen
* lib/xsd/codegen.rb
* sample/soap/authheader
* sample/soap/raa2.4
* sample/soap/ssl
* sample/soap/swa
* sample/soap/whois.rb
* sample/soap/calc/samplehttpd.conf
* sample/soap/exchange/samplehttpd.conf
* sample/soap/sampleStruct/samplehttpd.conf
* sample/wsdl/raa2.4
* sample/wsdl/googleSearch/samplehttpd.conf
* test/openssl/_test_ssl.rb
* test/soap/header
* test/soap/ssl
* test/soap/struct
* test/soap/swa
* test/soap/wsdlDriver
* test/wsdl/multiplefault.wsdl
* test/wsdl/simpletype
* test/wsdl/test_multiplefault.rb
* modified files
* lib/soap/baseData.rb
* lib/soap/element.rb
* lib/soap/generator.rb
* lib/soap/marshal.rb
* lib/soap/netHttpClient.rb
* lib/soap/parser.rb
* lib/soap/processor.rb
* lib/soap/property.rb
* lib/soap/soap.rb
* lib/soap/streamHandler.rb
* lib/soap/wsdlDriver.rb
* lib/soap/encodingstyle/handler.rb
* lib/soap/encodingstyle/literalHandler.rb
* lib/soap/encodingstyle/soapHandler.rb
* lib/soap/mapping/factory.rb
* lib/soap/mapping/mapping.rb
* lib/soap/mapping/registry.rb
* lib/soap/mapping/rubytypeFactory.rb
* lib/soap/mapping/wsdlRegistry.rb
* lib/soap/rpc/cgistub.rb
* lib/soap/rpc/driver.rb
* lib/soap/rpc/element.rb
* lib/soap/rpc/proxy.rb
* lib/soap/rpc/router.rb
* lib/soap/rpc/soaplet.rb
* lib/soap/rpc/standaloneServer.rb
* lib/wsdl/data.rb
* lib/wsdl/definitions.rb
* lib/wsdl/operation.rb
* lib/wsdl/parser.rb
* lib/wsdl/soap/definitions.rb
* lib/wsdl/xmlSchema/complexContent.rb
* lib/wsdl/xmlSchema/complexType.rb
* lib/wsdl/xmlSchema/data.rb
* lib/wsdl/xmlSchema/parser.rb
* lib/wsdl/xmlSchema/schema.rb
* lib/xsd/datatypes.rb
* lib/xsd/qname.rb
* sample/soap/calc/httpd.rb
* sample/soap/exchange/httpd.rb
* sample/soap/sampleStruct/httpd.rb
* sample/soap/sampleStruct/server.rb
* sample/wsdl/amazon/AmazonSearch.rb
* sample/wsdl/amazon/AmazonSearchDriver.rb
* sample/wsdl/googleSearch/httpd.rb
* test/soap/test_basetype.rb
* test/soap/test_property.rb
* test/soap/test_streamhandler.rb
* test/soap/calc/test_calc.rb
* test/soap/calc/test_calc2.rb
* test/soap/calc/test_calc_cgi.rb
* test/soap/helloworld/test_helloworld.rb
* test/wsdl/test_emptycomplextype.rb
* test/wsdl/axisArray/test_axisarray.rb
* test/wsdl/datetime/test_datetime.rb
* test/wsdl/raa/test_raa.rb
* test/xsd/test_xmlschemaparser.rb
* test/xsd/test_xsd.rb
* summary
* add SOAP Header mustUnderstand support.
* add HTTP client SSL configuration and Cookies support (works
completely with http-access2).
* add header handler for handling sending/receiving SOAP Header.
* map Ruby's anonymous Struct to common SOAP Struct in SOAP Object
Model. it caused error.
* add WSDL simpleType support to restrict lexical value space.
* add SOAP with Attachment support.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@6567 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
nahi
parent
df2066555d
commit
ab31bf0d4d
60 changed files with 2262 additions and 3170 deletions
|
|
@ -11,6 +11,9 @@ require 'soap/processor'
|
|||
require 'soap/mapping'
|
||||
require 'soap/rpc/rpc'
|
||||
require 'soap/rpc/element'
|
||||
require 'soap/streamHandler'
|
||||
require 'soap/mimemessage'
|
||||
require 'soap/header/handlerset'
|
||||
|
||||
|
||||
module SOAP
|
||||
|
|
@ -24,6 +27,7 @@ class Router
|
|||
attr_accessor :allow_unqualified_element
|
||||
attr_accessor :default_encodingstyle
|
||||
attr_accessor :mapping_registry
|
||||
attr_reader :headerhandler
|
||||
|
||||
def initialize(actor)
|
||||
@actor = actor
|
||||
|
|
@ -33,6 +37,7 @@ class Router
|
|||
@allow_unqualified_element = false
|
||||
@default_encodingstyle = nil
|
||||
@mapping_registry = nil
|
||||
@headerhandler = Header::HandlerSet.new
|
||||
end
|
||||
|
||||
def add_method(receiver, qname, soapaction, name, param_def)
|
||||
|
|
@ -42,47 +47,112 @@ class Router
|
|||
@method[fqname] = RPC::SOAPMethodRequest.new(qname, param_def, soapaction)
|
||||
end
|
||||
|
||||
def add_header_handler
|
||||
raise NotImplementedError.new
|
||||
end
|
||||
|
||||
# Routing...
|
||||
def route(soap_string, charset = nil)
|
||||
opt = options
|
||||
opt[:charset] = charset
|
||||
is_fault = false
|
||||
def route(conn_data)
|
||||
soap_response = nil
|
||||
begin
|
||||
header, body = Processor.unmarshal(soap_string, opt)
|
||||
# So far, header is omitted...
|
||||
soap_request = body.request
|
||||
env = unmarshal(conn_data)
|
||||
if env.nil?
|
||||
raise ArgumentError.new("Illegal SOAP marshal format.")
|
||||
end
|
||||
receive_headers(env.header)
|
||||
soap_request = env.body.request
|
||||
unless soap_request.is_a?(SOAPStruct)
|
||||
raise RPCRoutingError.new("Not an RPC style.")
|
||||
end
|
||||
soap_response = dispatch(soap_request)
|
||||
rescue Exception
|
||||
soap_response = fault($!)
|
||||
is_fault = true
|
||||
conn_data.is_fault = true
|
||||
end
|
||||
|
||||
header = SOAPHeader.new
|
||||
opt = options
|
||||
opt[:external_content] = nil
|
||||
header = call_headers
|
||||
body = SOAPBody.new(soap_response)
|
||||
response_string = Processor.marshal(header, body, opt)
|
||||
|
||||
return response_string, is_fault
|
||||
env = SOAPEnvelope.new(header, body)
|
||||
response_string = Processor.marshal(env, opt)
|
||||
conn_data.send_string = response_string
|
||||
if ext = opt[:external_content]
|
||||
mime = MIMEMessage.new
|
||||
ext.each do |k, v|
|
||||
mime.add_attachment(v.data)
|
||||
end
|
||||
mime.add_part(conn_data.send_string + "\r\n")
|
||||
mime.close
|
||||
conn_data.send_string = mime.content_str
|
||||
conn_data.send_contenttype = mime.headers['content-type'].str
|
||||
end
|
||||
conn_data
|
||||
end
|
||||
|
||||
# Create fault response string.
|
||||
def create_fault_response(e, charset = nil)
|
||||
header = SOAPHeader.new
|
||||
soap_response = fault(e)
|
||||
body = SOAPBody.new(soap_response)
|
||||
body = SOAPBody.new(fault(e))
|
||||
env = SOAPEnvelope.new(header, body)
|
||||
opt = options
|
||||
opt[:external_content] = nil
|
||||
opt[:charset] = charset
|
||||
Processor.marshal(header, body, opt)
|
||||
response_string = Processor.marshal(env, opt)
|
||||
conn_data = StreamHandler::ConnectionData.new(response_string)
|
||||
conn_data.is_fault = true
|
||||
if ext = opt[:external_content]
|
||||
mime = MIMEMessage.new
|
||||
ext.each do |k, v|
|
||||
mime.add_attachment(v.data)
|
||||
end
|
||||
mime.add_part(conn_data.send_string + "\r\n")
|
||||
mime.close
|
||||
conn_data.send_string = mime.content_str
|
||||
conn_data.send_contenttype = mime.headers['content-type'].str
|
||||
end
|
||||
conn_data
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def call_headers
|
||||
headers = @headerhandler.on_outbound
|
||||
if headers.empty?
|
||||
nil
|
||||
else
|
||||
h = ::SOAP::SOAPHeader.new
|
||||
headers.each do |header|
|
||||
h.add(header.elename.name, header)
|
||||
end
|
||||
h
|
||||
end
|
||||
end
|
||||
|
||||
def receive_headers(headers)
|
||||
@headerhandler.on_inbound(headers) if headers
|
||||
end
|
||||
|
||||
def unmarshal(conn_data)
|
||||
opt = options
|
||||
contenttype = conn_data.receive_contenttype
|
||||
if /#{MIMEMessage::MultipartContentType}/i =~ contenttype
|
||||
opt[:external_content] = {}
|
||||
mime = MIMEMessage.parse("Content-Type: " + contenttype,
|
||||
conn_data.receive_string)
|
||||
mime.parts.each do |part|
|
||||
value = Attachment.new(part.content)
|
||||
value.contentid = part.contentid
|
||||
obj = SOAPAttachment.new(value)
|
||||
opt[:external_content][value.contentid] = obj if value.contentid
|
||||
end
|
||||
opt[:charset] =
|
||||
StreamHandler.parse_media_type(mime.root.headers['content-type'].str)
|
||||
env = Processor.unmarshal(mime.root.content, opt)
|
||||
else
|
||||
opt[:charset] = ::SOAP::StreamHandler.parse_media_type(contenttype)
|
||||
env = Processor.unmarshal(conn_data.receive_string, opt)
|
||||
end
|
||||
charset = opt[:charset]
|
||||
conn_data.send_contenttype = "text/xml; charset=\"#{charset}\""
|
||||
env
|
||||
end
|
||||
|
||||
# Create new response.
|
||||
def create_response(qname, result)
|
||||
name = fqname(qname)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue