# File lib/soap/wsdlDriver.rb, line 268
268:     def initialize(host, wsdl, port, logdev)
269:       @host = host
270:       @wsdl = wsdl
271:       @port = port
272:       @logdev = logdev
273:       @soapaction = nil
274:       @options = setup_options
275:       @default_encodingstyle = nil
276:       @allow_unqualified_element = nil
277:       @generate_explicit_type = false
278:       @mapping_registry = nil           # for rpc unmarshal
279:       @wsdl_mapping_registry = nil      # for rpc marshal
280:       @wiredump_file_base = nil
281:       @mandatorycharset = nil
282:       @wsdl_elements = @wsdl.collect_elements
283:       @wsdl_types = @wsdl.collect_complextypes + @wsdl.collect_simpletypes
284:       @rpc_decode_typemap = @wsdl_types +
285:         @wsdl.soap_rpc_complextypes(port.find_binding)
286:       @wsdl_mapping_registry = Mapping::WSDLEncodedRegistry.new(
287:         @rpc_decode_typemap)
288:       @doc_mapper = Mapping::WSDLLiteralRegistry.new(
289:         @wsdl_types, @wsdl_elements)
290:       endpoint_url = @port.soap_address.location
291:       # Convert a map which key is QName, to a Hash which key is String.
292:       @operation = {}
293:       @port.inputoperation_map.each do |op_name, op_info|
294:         orgname = op_name.name
295:         name = XSD::CodeGen::GenSupport.safemethodname(orgname)
296:         @operation[name] = @operation[orgname] = op_info
297:         add_method_interface(op_info)
298:       end
299:       @proxy = ::SOAP::RPC::Proxy.new(endpoint_url, @soapaction, @options)
300:     end

     # File lib/soap/wsdlDriver.rb, line 363
363:     def document_send(name, header_obj, body_obj)
364:       set_wiredump_file_base(name)
365:       unless op_info = @operation[name]
366:         raise RuntimeError, "method: #{name} not defined"
367:       end
368:       req_header = header_obj ? header_from_obj(header_obj, op_info) : nil
369:       req_body = body_from_obj(body_obj, op_info)
370:       opt = create_options({
371:         :soapaction => op_info.soapaction || @soapaction,
372:         :decode_typemap => @wsdl_types})
373:       env = @proxy.invoke(req_header, req_body, opt)
374:       raise EmptyResponseError unless env
375:       if env.body.fault
376:         raise ::SOAP::FaultError.new(env.body.fault)
377:       end
378:       res_body_obj = env.body.response ?
379:         Mapping.soap2obj(env.body.response, @mapping_registry) : nil
380:       return env.header, res_body_obj
381:     end

     # File lib/soap/wsdlDriver.rb, line 306
306:     def endpoint_url
307:       @proxy.endpoint_url
308:     end

     # File lib/soap/wsdlDriver.rb, line 310
310:     def endpoint_url=(endpoint_url)
311:       @proxy.endpoint_url = endpoint_url
312:     end

     # File lib/soap/wsdlDriver.rb, line 314
314:     def headerhandler
315:       @proxy.headerhandler
316:     end

     # File lib/soap/wsdlDriver.rb, line 302
302:     def inspect
303:       "#<#{self.class}:#{@proxy.inspect}>"
304:     end

     # File lib/soap/wsdlDriver.rb, line 326
326:     def reset_stream
327:       @proxy.reset_stream
328:     end

     # File lib/soap/wsdlDriver.rb, line 330
330:     def rpc_call(name, *values)
331:       set_wiredump_file_base(name)
332:       unless op_info = @operation[name]
333:         raise RuntimeError, "method: #{name} not defined"
334:       end
335:       req_header = create_request_header
336:       req_body = create_request_body(op_info, *values)
337:       reqopt = create_options({
338:         :soapaction => op_info.soapaction || @soapaction})
339:       resopt = create_options({
340:         :decode_typemap => @rpc_decode_typemap})
341:       env = @proxy.route(req_header, req_body, reqopt, resopt)
342:       raise EmptyResponseError unless env
343:       receive_headers(env.header)
344:       begin
345:         @proxy.check_fault(env.body)
346:       rescue ::SOAP::FaultError => e
347:         Mapping.fault2exception(e)
348:       end
349:       ret = env.body.response ?
350:         Mapping.soap2obj(env.body.response, @mapping_registry) : nil
351:       if env.body.outparams
352:         outparams = env.body.outparams.collect { |outparam|
353:           Mapping.soap2obj(outparam)
354:         }
355:         return [ret].concat(outparams)
356:       else
357:         return ret
358:       end
359:     end

     # File lib/soap/wsdlDriver.rb, line 318
318:     def streamhandler
319:       @proxy.streamhandler
320:     end

     # File lib/soap/wsdlDriver.rb, line 322
322:     def test_loopback_response
323:       @proxy.test_loopback_response
324:     end

     # File lib/soap/wsdlDriver.rb, line 550
550:     def add_document_method_interface(name, parts_names)
551:       ::SOAP::Mapping.define_singleton_method(@host, name) do |h, b|
552:         @servant.document_send(name, h, b)
553:       end
554:       @host.method(name)
555:     end

     # File lib/soap/wsdlDriver.rb, line 519
519:     def add_method_interface(op_info)
520:       name = XSD::CodeGen::GenSupport.safemethodname(op_info.op_name.name)
521:       orgname = op_info.op_name.name
522:       parts_names = op_info.bodyparts.collect { |part| part.name }
523:       case op_info.style
524:       when :document
525:         if orgname != name and orgname.capitalize == name.capitalize
526:           add_document_method_interface(orgname, parts_names)
527:         end
528:         add_document_method_interface(name, parts_names)
529:       when :rpc
530:         if orgname != name and orgname.capitalize == name.capitalize
531:           add_rpc_method_interface(orgname, parts_names)
532:         end
533:         add_rpc_method_interface(name, parts_names)
534:       else
535:         raise RuntimeError.new("unknown style: #{op_info.style}")
536:       end
537:     end

     # File lib/soap/wsdlDriver.rb, line 539
539:     def add_rpc_method_interface(name, parts_names)
540:       ::SOAP::Mapping.define_singleton_method(@host, name) do |*arg|
541:         unless arg.size == parts_names.size
542:           raise ArgumentError.new(
543:             "wrong number of arguments (#{arg.size} for #{parts_names.size})")
544:         end
545:         @servant.rpc_call(name, *arg)
546:       end
547:       @host.method(name)
548:     end

     # File lib/soap/wsdlDriver.rb, line 485
485:     def body_from_obj(obj, op_info)
486:       if obj.is_a?(SOAPBody)
487:         obj
488:       elsif op_info.bodyparts.empty?
489:         if obj.nil?
490:           nil
491:         else
492:           raise RuntimeError.new("no body found in schema")
493:         end
494:       elsif op_info.bodyparts.size == 1
495:         part = op_info.bodyparts[0]
496:         ele = bodyitem_from_obj(obj, part.element || part.type)
497:         SOAPBody.new(ele)
498:       else
499:         body = SOAPBody.new
500:         op_info.bodyparts.each do |part|
501:           child = Mapping.get_attribute(obj, part.name)
502:           ele = bodyitem_from_obj(child, part.element || part.type)
503:           body.add(ele.elename.name, ele)
504:         end
505:         body
506:       end
507:     end

     # File lib/soap/wsdlDriver.rb, line 509
509:     def bodyitem_from_obj(obj, name)
510:       if obj.nil?
511:         SOAPElement.new(name)
512:       elsif obj.is_a?(SOAPElement)
513:         obj
514:       else
515:         Mapping.obj2soap(obj, @doc_mapper, name)
516:       end
517:     end

     # File lib/soap/wsdlDriver.rb, line 440
440:     def create_method_obj(names, params)
441:       o = Object.new
442:       idx = 0
443:       while idx < params.length
444:         o.instance_variable_set('@' + names[idx], params[idx])
445:         idx += 1
446:       end
447:       o
448:     end

     # File lib/soap/wsdlDriver.rb, line 422
422:     def create_method_struct(op_info, *params)
423:       parts_names = op_info.bodyparts.collect { |part| part.name }
424:       obj = create_method_obj(parts_names, params)
425:       method = Mapping.obj2soap(obj, @wsdl_mapping_registry, op_info.op_name)
426:       if method.members.size != parts_names.size
427:         new_method = SOAPStruct.new
428:         method.each do |key, value|
429:           if parts_names.include?(key)
430:             new_method.add(key, value)
431:           end
432:         end
433:         method = new_method
434:       end
435:       method.elename = op_info.op_name
436:       method.type = XSD::QName.new      # Request should not be typed.
437:       method
438:     end

     # File lib/soap/wsdlDriver.rb, line 385
385:     def create_options(hash = nil)
386:       opt = {}
387:       opt[:default_encodingstyle] = @default_encodingstyle
388:       opt[:allow_unqualified_element] = @allow_unqualified_element
389:       opt[:generate_explicit_type] = @generate_explicit_type
390:       opt.update(hash) if hash
391:       opt
392:     end

     # File lib/soap/wsdlDriver.rb, line 417
417:     def create_request_body(op_info, *values)
418:       method = create_method_struct(op_info, *values)
419:       SOAPBody.new(method)
420:     end

     # File lib/soap/wsdlDriver.rb, line 400
400:     def create_request_header
401:       headers = @proxy.headerhandler.on_outbound
402:       if headers.empty?
403:         nil
404:       else
405:         h = SOAPHeader.new
406:         headers.each do |header|
407:           h.add(header.elename.name, header)
408:         end
409:         h
410:       end
411:     end

     # File lib/soap/wsdlDriver.rb, line 450
450:     def header_from_obj(obj, op_info)
451:       if obj.is_a?(SOAPHeader)
452:         obj
453:       elsif op_info.headerparts.empty?
454:         if obj.nil?
455:           nil
456:         else
457:           raise RuntimeError.new("no header definition in schema: #{obj}")
458:         end
459:       elsif op_info.headerparts.size == 1
460:         part = op_info.headerparts[0]
461:         header = SOAPHeader.new()
462:         header.add(headeritem_from_obj(obj, part.element || part.eletype))
463:         header
464:       else
465:         header = SOAPHeader.new()
466:         op_info.headerparts.each do |part|
467:           child = Mapping.get_attribute(obj, part.name)
468:           ele = headeritem_from_obj(child, part.element || part.eletype)
469:           header.add(part.name, ele)
470:         end
471:         header
472:       end
473:     end

     # File lib/soap/wsdlDriver.rb, line 475
475:     def headeritem_from_obj(obj, name)
476:       if obj.nil?
477:         SOAPElement.new(name)
478:       elsif obj.is_a?(SOAPHeaderItem)
479:         obj
480:       else
481:         Mapping.obj2soap(obj, @doc_mapper, name)
482:       end
483:     end

     # File lib/soap/wsdlDriver.rb, line 413
413:     def receive_headers(headers)
414:       @proxy.headerhandler.on_inbound(headers) if headers
415:     end

     # File lib/soap/wsdlDriver.rb, line 394
394:     def set_wiredump_file_base(name)
395:       if @wiredump_file_base
396:         @proxy.set_wiredump_file_base(@wiredump_file_base + "_#{name}")
397:       end
398:     end

     # File lib/soap/wsdlDriver.rb, line 557
557:     def setup_options
558:       if opt = Property.loadproperty(::SOAP::PropertyName)
559:         opt = opt["client"]
560:       end
561:       opt ||= Property.new
562:       opt.add_hook("protocol.mandatorycharset") do |key, value|
563:         @mandatorycharset = value
564:       end
565:       opt.add_hook("protocol.wiredump_file_base") do |key, value|
566:         @wiredump_file_base = value
567:       end
568:       opt["protocol.http.charset"] ||= XSD::Charset.xml_encoding_label
569:       opt["protocol.http.proxy"] ||= Env::HTTP_PROXY
570:       opt["protocol.http.no_proxy"] ||= Env::NO_PROXY
571:       opt
572:     end