U H4f@sddlZddlZddlmZmZddlmZddlmZm Z ddl m Z e e ZGdddZGdd d ZGd d d eZGd d d eZdS)N)AsyncServiceProxy ServiceProxy)Settings)AsyncTransport Transport)Documentc@s$eZdZddZddZddZdS)FactorycCs2t|d||_||jkr"||_n |||_dS)Nzget_%s)getattr_method namespaces_nsZ get_ns_prefix)selftypeskind namespacer//tmp/pip-unpacked-wheel-04z2hmy8/zeep/client.py__init__ s zFactory.__init__cCs||S)Return the complexType or simpleType for the given localname. :rtype: zeep.xsd.ComplexType or zeep.xsd.AnySimpleType rr keyrrr __getattr__szFactory.__getattr__cCs|d|j|fS)rz{%s}%s)r r rrrr __getitem__szFactory.__getitem__N)__name__ __module__ __qualname__rrrrrrrr src@seZdZUdZeZejeefe d<d$ddZ e ddZ e dd Z d%ejeejed d d Zd dZddZddZddZddZddZddZddZejeedddZd d!Zd&d"d#ZdS)'Clienta@The zeep Client. :param wsdl: Url/local WSDL location or preparsed WSDL Document :param wsse: :param transport: Custom transport class. :param service_name: The service name for the service binding. Defaults to the first service in the WSDL document. :param port_name: The port name for the default binding. Defaults to the first port defined in the service element in the WSDL document. :param plugins: a list of Plugin instances :param settings: a zeep.Settings() object _default_transportNcCs|s td|pt|_|dk r$|n||_t|tr@||_nt||j|jd|_||_|dk rf|ng|_ d|_ ||_ ||_ d|_ dS)NzNo URL given for the wsdl)settings) ValueErrorrrr transport isinstancerwsdlwsseplugins_default_service_default_service_name_default_port_name_default_soapheaders)r r"r#r service_name port_namer$rrrrr8s   zClient.__init__cCs |jjjSN)r"rZ prefix_mapr rrrr UszClient.namespacescCs4|jr |jS|j|j|jd|_|js.td|jS)zIThe default ServiceProxy instance :rtype: ServiceProxy r)r*zhThere is no default service defined. This is usually due to missing wsdl:service definitions in the WSDL)r%bindr&r'rr,rrrserviceYszClient.servicer-cCs4|jjs dS||}|||}t||jf|jSaCreate a new ServiceProxy for the given service_name and port_name. The default ServiceProxy instance (`self.service`) always referes to the first service/port in the wsdl Document. Use this when a specific port is required. N)r"services _get_service _get_portrbindingbinding_optionsr r)r*r/portrrrr.ms   z Client.bindc CsNz|jj|}Wn.tk r>tdd|jjYnXt|||dS)zCreate a new ServiceProxy for the given binding name and address. :param binding_name: The QName of the binding :param address: The address of the endpoint zANo binding found with the given QName. Available bindings are: %sz, )address)r"bindingsKeyErrorrjoinkeysr)r Z binding_namer8r4rrrcreate_services zClient.create_servicecOs|jj||||d\}}|S)zZCreate the payload for the given operation. :rtype: lxml.etree._Element )client)_binding_create)r r/Zoperation_nameargskwargsZenvelopeZ http_headersrrrcreate_messages zClient.create_messagecCst|jjd|S)zReturn a type factory for the given namespace. Example:: factory = client.type_factory('ns0') user = factory.User(name='John') :rtype: Factory type)rr"r)r rrrr type_factorys zClient.type_factorycCs|jj|S)zwReturn the type for the given qualified name. :rtype: zeep.xsd.ComplexType or zeep.xsd.AnySimpleType )r"rget_typer namerrrrFszClient.get_typecCs|jj|S)z\Return the element for the given qualified name. :rtype: zeep.xsd.Element )r"r get_elementrGrrrrIszClient.get_elementcCs|jj||dS)z'Set a shortcut for the given namespace.N)r"r set_ns_prefix)r prefixrrrrrJszClient.set_ns_prefixcCs ||_dS)aSet the default soap headers which will be automatically used on all calls. Note that if you pass custom soapheaders using a list then you will also need to use that during the operations. Since mixing these use cases isn't supported (yet). N)r()r headersrrrset_default_soapheaderss zClient.set_default_soapheaderscCs4|r|j|}|s0tdnt|jd}|S)NzPort not foundr)Zportsgetrlistvalues)r r/rHr7rrrr3s   zClient._get_port)rHreturncCs:|r |jj|}|s6tdntt|jjd}|S)NzService not found)r"r1rNrnextiterrP)r rHr/rrrr2s  zClient._get_servicecCs|Sr+rr,rrr __enter__szClient.__enter__cCst|jdr|jdS)Nclose)hasattrr rUr exc_type exc_value tracebackrrr__exit__s zClient.__exit__)NNNNNN)NN)NNN)rrr__doc__rrtypingUnionr__annotations__rpropertyr r/Optionalstrr.r=rCrErFrIrJrMr3r2rTr[rrrrr&s<          rc@sFeZdZeZd ejeejedddZddZ d dddd Z dS) AsyncClientNr-cCs4|jjs dS||}|||}t||jf|jSr0)r"r1r2r3rr4r5r6rrrr.s   zAsyncClient.bindcs|Sr+rr,rrr __aenter__szAsyncClient.__aenter__)rQcs|jIdHdSr+)r acloserWrrr __aexit__szAsyncClient.__aexit__)NN)NNN) rrrrrr]rarbr.rdrfrrrrrcs rccs eZdZdZfddZZS) CachingClientzShortcut to create a caching client, for the lazy people. This enables the SqliteCache by default in the transport as was the default in earlier versions of zeep. cs8ddlm}|dp t|d|d<tj||dS)Nr) SqliteCacher )cache)Z zeep.cacherhrNrsuperr)r rArBrh __class__rrrs zCachingClient.__init__)rrrr\r __classcell__rrrkrrgsrg)loggingr]Z zeep.proxyrrZ zeep.settingsrZzeep.transportsrrZ zeep.wsdlr getLoggerrloggerrrrcrgrrrrs   <