require "builder"
require "gyoku"
require "nori"
require "savon/soap"
Nori.configure do |config|
config.strip_namespaces = true
config.convert_tags_to { |tag| tag.snakecase.to_sym }
end
module Savon
module SOAP
# = Savon::SOAP::XML
#
# Represents the SOAP request XML. Contains various global and per request/instance settings
# like the SOAP version, header, body and namespaces.
class XML
# XML Schema Type namespaces.
SchemaTypes = {
"xmlns:xsd" => "http://www.w3.org/2001/XMLSchema",
"xmlns:xsi" => "http://www.w3.org/2001/XMLSchema-instance"
}
# Accepts an +endpoint+, an +input+ tag and a SOAP +body+.
def initialize(endpoint = nil, input = nil, body = nil)
self.endpoint = endpoint if endpoint
self.input = input if input
self.body = body if body
end
# Accessor for the SOAP +input+ tag.
attr_accessor :input
# Accessor for the SOAP +endpoint+.
attr_accessor :endpoint
# Sets the SOAP +version+.
def version=(version)
raise ArgumentError, "Invalid SOAP version: #{version}" unless SOAP::Versions.include? version
@version = version
end
# Returns the SOAP +version+. Defaults to Savon.soap_version.
def version
@version ||= Savon.soap_version
end
# Sets the SOAP +header+ Hash.
attr_writer :header
# Returns the SOAP +header+. Defaults to an empty Hash.
def header
@header ||= Savon.soap_header.nil? ? {} : Savon.soap_header
end
# Sets the SOAP envelope namespace.
attr_writer :env_namespace
# Returns the SOAP envelope namespace. Uses the global namespace if set Defaults to :env.
def env_namespace
@env_namespace ||= Savon.env_namespace.nil? ? :env : Savon.env_namespace
end
# Sets the +namespaces+ Hash.
attr_writer :namespaces
# Returns the +namespaces+. Defaults to a Hash containing the SOAP envelope namespace.
def namespaces
@namespaces ||= begin
key = env_namespace.blank? ? "xmlns" : "xmlns:#{env_namespace}"
{ key => SOAP::Namespace[version] }
end
end
def namespace_by_uri(uri)
namespaces.each do |candidate_identifier, candidate_uri|
return candidate_identifier.gsub(/^xmlns:/, '') if candidate_uri == uri
end
nil
end
def used_namespaces
@used_namespaces ||= {}
end
def use_namespace(path, uri)
@internal_namespace_count ||= 0
unless identifier = namespace_by_uri(uri)
identifier = "ins#{@internal_namespace_count}"
namespaces["xmlns:#{identifier}"] = uri
@internal_namespace_count += 1
end
used_namespaces[path] = identifier
end
def types
@types ||= {}
end
# Sets the default namespace identifier.
attr_writer :namespace_identifier
# Returns the default namespace identifier.
def namespace_identifier
@namespace_identifier ||= :wsdl
end
# Returns whether all local elements should be namespaced. Might be set to :qualified,
# but defaults to :unqualified.
def element_form_default
@element_form_default ||= :unqualified
end
# Sets whether all local elements should be namespaced.
attr_writer :element_form_default
# Accessor for the default namespace URI.
attr_accessor :namespace
# Accessor for the Savon::WSSE object.
attr_accessor :wsse
# Accepts a +block+ and yields a Builder::XmlMarkup object to let you create
# custom body XML.
def body
@body = yield builder(nil) if block_given?
@body
end
# Sets the SOAP +body+. Expected to be a Hash that can be translated to XML via `Gyoku.xml`
# or any other Object responding to to_s.
attr_writer :body
# Accepts a +block+ and yields a Builder::XmlMarkup object to let you create
# a completely custom XML.
def xml(directive_tag = :xml, attrs = {})
@xml = yield builder(directive_tag, attrs) if block_given?
end
# Accepts an XML String and lets you specify a completely custom request body.
attr_writer :xml
# Returns the XML for a SOAP request.
def to_xml
@xml ||= tag(builder, :Envelope, complete_namespaces) do |xml|
tag(xml, :Header) { xml << header_for_xml } unless header_for_xml.empty?
if input.nil?
tag(xml, :Body)
else
tag(xml, :Body) { xml.tag!(*add_namespace_to_input) { xml << body_to_xml } }
end
end
end
private
# Returns a new Builder::XmlMarkup object.
def builder(directive_tag = :xml, attrs = {})
builder = Builder::XmlMarkup.new
builder.instruct!(directive_tag, attrs) if directive_tag
builder
end
# Expects a builder +xml+ instance, a tag +name+ and accepts optional +namespaces+
# and a block to create an XML tag.
def tag(xml, name, namespaces = {}, &block)
return xml.tag! name, namespaces, &block if env_namespace.blank?
xml.tag! env_namespace, name, namespaces, &block
end
# Returns the complete Hash of namespaces.
def complete_namespaces
defaults = SchemaTypes.dup
defaults["xmlns:#{namespace_identifier}"] = namespace if namespace
defaults.merge namespaces
end
# Returns the SOAP header as an XML String.
def header_for_xml
@header_for_xml ||= Gyoku.xml(header) + wsse_header
end
# Returns the WSSE header or an empty String in case WSSE was not set.
def wsse_header
wsse.respond_to?(:to_xml) ? wsse.to_xml : ""
end
# Returns the SOAP body as an XML String.
def body_to_xml
return body.to_s unless body.kind_of? Hash
Gyoku.xml add_namespaces_to_body(body), :element_form_default => element_form_default, :namespace => namespace_identifier
end
def add_namespaces_to_body(hash, path = [input[1].to_s])
return unless hash
return hash if hash.kind_of?(Array)
return hash.to_s unless hash.kind_of? Hash
hash.inject({}) do |newhash, (key, value)|
camelcased_key = Gyoku::XMLKey.create(key)
newpath = path + [camelcased_key]
if used_namespaces[newpath]
newhash.merge(
"#{used_namespaces[newpath]}:#{camelcased_key}" =>
add_namespaces_to_body(value, types[newpath] ? [types[newpath]] : newpath)
)
else
newhash.merge(key => value)
end
end
end
def add_namespace_to_input
return input.compact unless used_namespaces[[input[1].to_s]]
[used_namespaces[[input[1].to_s]], input[1], input[2]]
end
end
end
end