class SOAP::NetHttpClient

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 36
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 95
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 91
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 47
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 83
def reset(url)
  # no persistent connection.  ignored.
end
reset_all() click to toggle source
# File lib/soap/netHttpClient.rb, line 87
def reset_all
  # no persistent connection.  ignored.
end
set_auth(uri, user_id, passwd) click to toggle source
# File lib/soap/netHttpClient.rb, line 65
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 69
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 166
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 195
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 112
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 152
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