class SOAP::Client
Constants
- NO_PROXY_HOSTS
- SSLEnabled
Attributes
connect_timeout[RW]
debug_dev[RW]
no_proxy[RW]
protocol_version[RW]
proxy[R]
receive_timeout[RW]
request_filter[R]
send_timeout[RW]
ssl_config[RW]
test_loopback_response[R]
Public Class Methods
new(proxy = nil, agent = nil)
click to toggle source
# File lib/soap/netHttpClient.rb, line 37 def initialize(proxy = nil, agent = nil) @proxy = proxy ? URI.parse(proxy) : nil @agent = agent @debug_dev = nil @test_loopback_response = [] @request_filter = Filter::FilterChain.new @session_manager = SessionManager.new @no_proxy = @ssl_config = @protocol_version = nil @connect_timeout = @send_timeout = @receive_timeout = nil end
Public Instance Methods
get_content(url, header = {})
click to toggle source
# File lib/soap/netHttpClient.rb, line 96 def get_content(url, header = {}) if str = @test_loopback_response.shift return str end unless url.is_a?(URI) url = URI.parse(url) end extra = header.dup extra['User-Agent'] = @agent if @agent res = start(url) { |http| http.get(url.request_uri, extra) } res.body end
post(url, req_body, header = {})
click to toggle source
# File lib/soap/netHttpClient.rb, line 92 def post(url, req_body, header = {}) post_redirect(url, req_body, header, 10) end
proxy=(proxy)
click to toggle source
# File lib/soap/netHttpClient.rb, line 48 def proxy=(proxy) if proxy.nil? @proxy = nil else if proxy.is_a?(URI) @proxy = proxy else @proxy = URI.parse(proxy) end if @proxy.scheme == nil or @proxy.scheme.downcase != 'http' or @proxy.host == nil or @proxy.port == nil raise ArgumentError.new("unsupported proxy `#{proxy}'") end end reset_all @proxy end
reset(url)
click to toggle source
# File lib/soap/netHttpClient.rb, line 84 def reset(url) # no persistent connection. ignored. end
reset_all()
click to toggle source
# File lib/soap/netHttpClient.rb, line 88 def reset_all # no persistent connection. ignored. end
set_auth(uri, user_id, passwd)
click to toggle source
# File lib/soap/netHttpClient.rb, line 66 def set_auth(uri, user_id, passwd) raise NotImplementedError.new("auth is not supported under soap4r + net/http.") end
set_basic_auth(uri, user_id, passwd)
click to toggle source
# File lib/soap/netHttpClient.rb, line 70 def set_basic_auth(uri, user_id, passwd) # net/http does not handle url. @basic_auth = [user_id, passwd] raise NotImplementedError.new("basic_auth is not supported under soap4r + net/http.") end
Private Instance Methods
create_connection(url)
click to toggle source
# File lib/soap/netHttpClient.rb, line 167 def create_connection(url) proxy_host = proxy_port = nil unless no_proxy?(url) proxy_host = @proxy.host proxy_port = @proxy.port end http = Net::HTTP::Proxy(proxy_host, proxy_port).new(url.host, url.port) if http.respond_to?(:set_debug_output) http.set_debug_output(@debug_dev) end http.open_timeout = @connect_timeout if @connect_timeout http.read_timeout = @receive_timeout if @receive_timeout case url when URI::HTTPS if SSLEnabled http.use_ssl = true else raise RuntimeError.new("Cannot connect to #{url} (OpenSSL is not installed.)") end when URI::HTTP # OK else raise RuntimeError.new("Cannot connect to #{url} (Not HTTP.)") end http end
no_proxy?(uri)
click to toggle source
# File lib/soap/netHttpClient.rb, line 196 def no_proxy?(uri) if !@proxy or NO_PROXY_HOSTS.include?(uri.host) return true end unless @no_proxy return false end @no_proxy.scan(/([^:,]+)(?::(\d+))?/) do |host, port| if /(\A|\.)#{Regexp.quote(host)}\z/i =~ uri.host && (!port || uri.port == port.to_i) return true end end false end
post_redirect(url, req_body, header, redirect_count)
click to toggle source
# File lib/soap/netHttpClient.rb, line 113 def post_redirect(url, req_body, header, redirect_count) if str = @test_loopback_response.shift if @debug_dev @debug_dev << "= Request\n\n" @debug_dev << req_body @debug_dev << "\n\n= Response\n\n" @debug_dev << str end status = 200 reason = nil contenttype = 'text/xml' content = str return Response.new(status, reason, contenttype, content) return str end unless url.is_a?(URI) url = URI.parse(url) end extra = header.dup extra['User-Agent'] = @agent if @agent res = start(url) { |http| if @debug_dev @debug_dev << "= Request\n\n" @debug_dev << req_body << "\n" end http.post(url.request_uri, req_body, extra) } case res when Net::HTTPRedirection if redirect_count > 0 post_redirect(res['location'], req_body, header, redirect_count - 1) else raise ArgumentError.new("Too many redirects") end else Response.from_httpresponse(res) end end
start(url) { |worker| ... }
click to toggle source
# File lib/soap/netHttpClient.rb, line 153 def start(url) http = create_connection(url) response = nil http.start { |worker| response = yield(worker) worker.finish } if @debug_dev @debug_dev << "\n\n= Response\n\n" @debug_dev << response.body << "\n" end response end