Welcome to the "trac"-ing site of soap4r!
[soap4r] [httpclient] [openpgp4u] [pkcs1] [logger] [csv] [vtr]

Changeset 1089

Show
Ignore:
Timestamp:
12/01/03 21:25:08 (5 years ago)
Author:
nahi
Message:

* renamed property "client.streamhandler" to "client.protocol".

* delegate property key "client.protocol.http" to streamHandler.rb.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/lib/soap/rpc/driver.rb

    r1087 r1089  
    4848 
    4949  def httpproxy 
    50     @servant.options["client.streamhandler.http.proxy"] 
     50    @servant.options["client.protocol.http.proxy"] 
    5151  end 
    5252 
    5353  def httpproxy=(httpproxy) 
    54     @servant.options["client.streamhandler.http.proxy"] = httpproxy 
     54    @servant.options["client.protocol.http.proxy"] = httpproxy 
     55  end 
     56 
     57  def wiredump_dev 
     58    @servant.options["client.protocol.http.wiredump_dev"] 
     59  end 
     60 
     61  def wiredump_dev=(wiredump_dev) 
     62    @servant.options["client.protocol.http.wiredump_dev"] = wiredump_dev 
    5563  end 
    5664 
    5765  def mandatorycharset 
    58     @servant.options["client.streamhandler.mandatorycharset"] 
     66    @servant.options["client.protocol.mandatorycharset"] 
    5967  end 
    6068 
    6169  def mandatorycharset=(mandatorycharset) 
    62     @servant.options["client.streamhandler.mandatorycharset"] = mandatorycharset 
    63   end 
    64  
    65   def wiredump_dev 
    66     @servant.options["client.streamhandler.wiredump_dev"] 
    67   end 
    68  
    69   def wiredump_dev=(wiredump_dev) 
    70     @servant.options["client.streamhandler.wiredump_dev"] = wiredump_dev 
     70    @servant.options["client.protocol.mandatorycharset"] = mandatorycharset 
    7171  end 
    7272 
    7373  def wiredump_file_base 
    74     @servant.options["client.streamhandler.wiredump_file_base"] 
     74    @servant.options["client.protocol.wiredump_file_base"] 
    7575  end 
    7676 
    7777  def wiredump_file_base=(wiredump_file_base) 
    78     @servant.options["client.streamhandler.wiredump_file_base"] = 
    79       wiredump_file_base 
     78    @servant.options["client.protocol.wiredump_file_base"] = wiredump_file_base 
    8079  end 
    8180 
    …… 
    137136      @host = host 
    138137      @namespace = namespace 
    139       @mapping_registry = nil      # for unmarshal 
    140       @soapaction = soapaction 
     138      @mapping_registry = nil 
     139      @soapaction = nil 
    141140      @wiredump_file_base = nil 
    142141      @options = ::SOAP::Property.new 
    143       set_options_hook 
    144       name = 'http_proxy' 
    145       httpproxy = ENV[name] || ENV[name.upcase] 
    146       @streamhandler = HTTPPostStreamHandler.new(endpoint_url, httpproxy, 
    147         XSD::Charset.encoding_label) 
     142      set_options 
     143      @streamhandler = HTTPPostStreamHandler.new(endpoint_url, 
     144        @options["client.protocol.http"] ||= ::SOAP::Property.new) 
    148145      @proxy = Proxy.new(@streamhandler, @soapaction) 
    149146      @proxy.allow_unqualified_element = true 
    …… 
    242239    end 
    243240 
    244     def set_options_hook 
    245       @options.add_hook("client.streamhandler.http.proxy") do |key, value| 
    246         @streamhandler.proxy = value 
    247         @streamhandler.reset 
    248       end 
    249       @options.add_hook("client.streamhandler.mandatorycharset") do |key, value| 
     241    def set_options 
     242      @options.add_hook("client.protocol.mandatorycharset") do |key, value| 
    250243        @proxy.mandatorycharset = value 
    251244      end 
    252       @options.add_hook("client.streamhandler.wiredump_dev") do |key, value| 
    253         @streamhandler.wiredump_dev = value 
    254         @streamhandler.reset 
    255       end 
    256       @options.add_hook("client.streamhandler.wiredump_file_base") do |key, value| 
     245      @options.add_hook("client.protocol.wiredump_file_base") do |key, value| 
    257246        @wiredump_file_base = value 
    258247      end 
     248      @options["client.protocol.http.charset"] = XSD::Charset.encoding_label 
    259249    end 
    260250  end 

  • trunk/lib/soap/streamHandler.rb

    r1067 r1089  
    88 
    99require 'soap/soap' 
     10require 'soap/property' 
    1011 
    1112 
    …… 
    7778public 
    7879   
    79   attr_accessor :wiredump_dev 
    80   attr_accessor :wiredump_file_base 
    81   attr_accessor :charset 
    8280  attr_reader :client 
    8381   
    8482  NofRetry = 10         # [times] 
    8583 
    86   def initialize(endpoint_url, proxy = nil, charset = nil) 
     84  def initialize(endpoint_url, options) 
    8785    super(endpoint_url) 
    88     @proxy = proxy || ENV['http_proxy'] || ENV['HTTP_PROXY'] 
    89     @charset = charset || XSD::Charset.charset_label($KCODE) 
    90     @wiredump_dev = nil # Set an IO to get wiredump. 
    91     @wiredump_file_base = nil 
     86    @proxy = @charset = @wiredump_dev = @wiredump_file_base = nil 
    9287    @client = Client.new(@proxy, "SOAP4R/#{ Version }") 
     88    @options = options 
     89    set_options 
     90    @client.debug_dev = @wiredump_dev 
    9391  end 
    9492 
    9593  def inspect 
    9694    "#<#{self.class}:#{endpoint_url}>" 
    97   end 
    98  
    99   def proxy=(proxy) 
    100     @proxy = proxy 
    101     @client.proxy = @proxy 
    10295  end 
    10396 
    …… 
    112105private 
    113106 
     107  def set_options 
     108    @proxy = @options["proxy"] 
     109    @options.add_hook("proxy") do |key, value| 
     110      @proxy = value 
     111    end 
     112    @charset = @options["charset"] || XSD::Charset.charset_label($KCODE) 
     113    @options.add_hook("charset") do |key, value| 
     114      @charset = value 
     115    end 
     116    @wiredump_dev = @options["wiredump_dev"] 
     117    @options.add_hook("wiredump_dev") do |key, value| 
     118      @wiredump_dev = value 
     119      @client.debug_dev = @wiredump_dev 
     120    end 
     121    @wiredump_file_base = @options["wiredump_file_base"] 
     122    @options.add_hook("wiredump_file_base") do |key, value| 
     123      @wiredump_file_base = value 
     124    end 
     125    @options.lock 
     126  end 
     127 
    114128  def send_post(soap_string, soapaction, charset) 
    115129    data = ConnectionData.new 
    116130    data.send_string = soap_string 
    117131    data.send_contenttype = StreamHandler.create_media_type(charset) 
    118  
    119     wiredump_dev = if @wiredump_dev && @wiredump_dev.respond_to?("<<") 
    120         @wiredump_dev 
    121       else 
    122         nil 
    123       end 
    124     @client.debug_dev = wiredump_dev 
    125132 
    126133    if @wiredump_file_base 
    …… 
    135142    extra['SOAPAction'] = "\"#{ soapaction }\"" 
    136143 
    137     wiredump_dev << "Wire dump:\n\n" if wiredump_dev 
     144    @wiredump_dev << "Wire dump:\n\n" if @wiredump_dev 
    138145    begin 
    139146      res = @client.post(@endpoint_url, soap_string, extra) 
    …… 
    142149      raise 
    143150    end 
    144     wiredump_dev << "\n\n" if wiredump_dev 
     151    @wiredump_dev << "\n\n" if @wiredump_dev 
    145152 
    146153    receive_string = res.content 

  • trunk/lib/soap/wsdlDriver.rb

    r1087 r1089  
    100100 
    101101  def httpproxy 
    102     @servant.options["client.streamhandler.http.proxy"] 
     102    @servant.options["client.protocol.http.proxy"] 
    103103  end 
    104104 
    105105  def httpproxy=(httpproxy) 
    106     @servant.options["client.streamhandler.http.proxy"] = httpproxy 
     106    @servant.options["client.protocol.http.proxy"] = httpproxy 
     107  end 
     108 
     109  def wiredump_dev 
     110    @servant.options["client.protocol.http.wiredump_dev"] 
     111  end 
     112 
     113  def wiredump_dev=(wiredump_dev) 
     114    @servant.options["client.protocol.http.wiredump_dev"] = wiredump_dev 
    107115  end 
    108116 
    109117  def mandatorycharset 
    110     @servant.options["client.streamhandler.mandatorycharset"] 
     118    @servant.options["client.protocol.mandatorycharset"] 
    111119  end 
    112120 
    113121  def mandatorycharset=(mandatorycharset) 
    114     @servant.options["client.streamhandler.mandatorycharset"] = mandatorycharset 
    115   end 
    116  
    117   def wiredump_dev 
    118     @servant.options["client.streamhandler.wiredump_dev"] 
    119   end 
    120  
    121   def wiredump_dev=(wiredump_dev) 
    122     @servant.options["client.streamhandler.wiredump_dev"] = wiredump_dev 
     122    @servant.options["client.protocol.mandatorycharset"] = mandatorycharset 
    123123  end 
    124124 
    125125  def wiredump_file_base 
    126     @servant.options["client.streamhandler.wiredump_file_base"] 
     126    @servant.options["client.protocol.wiredump_file_base"] 
    127127  end 
    128128 
    129129  def wiredump_file_base=(wiredump_file_base) 
    130     @servant.options["client.streamhandler.wiredump_file_base"] = 
    131       wiredump_file_base 
     130    @servant.options["client.protocol.wiredump_file_base"] = wiredump_file_base 
    132131  end 
    133132 
    …… 
    168167 
    169168      @options = ::SOAP::Property.new 
    170       set_options_hook 
     169      set_options 
    171170      @mapping_registry = nil           # for rpc unmarshal 
    172171      @wsdl_mapping_registry = nil      # for rpc marshal 
    …… 
    179178      @wsdl_elements = @wsdl.collect_elements 
    180179      @wsdl_types = @wsdl.collect_complextypes 
    181       @rpc_decode_typemap = @wsdl_types + @wsdl.soap_rpc_complextypes(port.find_binding) 
     180      @rpc_decode_typemap = @wsdl_types + 
     181        @wsdl.soap_rpc_complextypes(port.find_binding) 
    182182      @wsdl_mapping_registry = Mapping::WSDLRegistry.new(@rpc_decode_typemap) 
    183183      @doc_mapper = Mapper.new(@wsdl_elements, @wsdl_types) 
    184  
    185       @streamhandler = HTTPPostStreamHandler.new(@port.soap_address.location, 
    186         ENV['http_proxy'] || ENV['HTTP_PROXY'], XSD::Charset.encoding_label) 
     184      endpoint_url = @port.soap_address.location 
     185      @streamhandler = HTTPPostStreamHandler.new(endpoint_url, 
     186        @options["client.protocol.http"] ||= ::SOAP::Property.new) 
     187      # Convert a map which key is QName, to a Hash which key is String. 
    187188      @operations = {} 
    188       # Convert a map which key is QName, to a Hash which key is String. 
    189189      @port.inputoperation_map.each do |op_name, op_info| 
    190190        @operations[op_name.name] = op_info 
    …… 
    397397    end 
    398398 
    399     def set_options_hook 
    400       @options.add_hook("client.streamhandler.http.proxy") do |key, value| 
    401         @streamhandler.proxy = value 
    402         @streamhandler.reset 
    403       end 
    404       @options.add_hook("client.streamhandler.mandatorycharset") do |key, value| 
     399    def set_options 
     400      @options.add_hook("client.protocol.mandatorycharset") do |key, value| 
    405401        @mandatorycharset = value 
    406402      end 
    407       @options.add_hook("client.streamhandler.wiredump_dev") do |key, value| 
    408         @streamhandler.wiredump_dev = value 
    409         @streamhandler.reset 
    410       end 
    411       @options.add_hook("client.streamhandler.wiredump_file_base") do |key, value| 
     403      @options.add_hook("client.protocol.wiredump_file_base") do |key, value| 
    412404        @wiredump_file_base = value 
    413405      end 
     406      @options["client.protocol.http.charset"] = XSD::Charset.encoding_label 
    414407    end 
    415408