o g@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)FactorycCs4t|d||_||jvr||_dS|||_dS)Nzget_%s)getattr_method namespaces_ns get_ns_prefix)selftypeskind namespacerD/home/ubuntu/webapp/venv/lib/python3.10/site-packages/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 rrkeyrrr __getattr__szFactory.__getattr__cCs|d|j|fS)rz{%s}%s)r r rrrr __getitem__szFactory.__getitem__N)__name__ __module__ __qualname__rrrrrrrr s rc@seZdZUdZeZejeefe d<      d&ddZ e ddZ e dd Z  d'd ejed ejefd d ZddZddZddZddZddZddZddZddZdejedefd d!Zd"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|std|p t|_|dur|n||_t|tr ||_n t||j|jd|_||_|dur3|ng|_ d|_ ||_ ||_ d|_ dS)NzNo URL given for the wsdl)settings) ValueErrorrrr transport isinstancerwsdlwsseplugins_default_service_default_service_name_default_port_name_default_soapheaders)rr#r$r! service_name port_namer%rrrrr8s    zClient.__init__cCs |jjjSN)r#r prefix_maprrrrr Us zClient.namespacescCs4|jr|jS|j|j|jd|_|jstd|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(r r.rrrserviceYszClient.servicer*r+cC8|jjsdS||}|||}t||jfi|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_optionsrr*r+r0portrrrr/m    z Client.bindc CsHz|jj|}Wntytdd|jjwt|||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#bindingsKeyErrorr joinkeysr)r binding_namer;r6rrrcreate_services zClient.create_servicecOs|jj||||d\}}|S)zZCreate the payload for the given operation. :rtype: lxml.etree._Element )client)_binding_create)rr0operation_nameargskwargsenvelope 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)rrrrr type_factorys zClient.type_factorycC|jj|S)zwReturn the type for the given qualified name. :rtype: zeep.xsd.ComplexType or zeep.xsd.AnySimpleType )r#rget_typernamerrrrNzClient.get_typecCrM)z\Return the element for the given qualified name. :rtype: zeep.xsd.Element )r#r get_elementrOrrrrRrQzClient.get_elementcCs|jj||dS)z'Set a shortcut for the given namespace.N)r#r set_ns_prefix)rprefixrrrrrSszClient.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))rheadersrrrset_default_soapheaderss zClient.set_default_soapheaderscCs6|r|j|}|std|St|jd}|S)NzPort not foundr)portsgetr listvalues)rr0rPr9rrrr5s zClient._get_portrPreturncCs<|r|jj|}|std|Stt|jjd}|S)NzService not found)r#r3rXr nextiterrZ)rrPr0rrrr4szClient._get_servicecCs|Sr,rr.rrr __enter__szClient.__enter__cCst|jdr |jdSdS)Nclose)hasattrr!r_rexc_type exc_value tracebackrrr__exit__s zClient.__exit__)NNNNNNNNNNN)rrr__doc__rrtypingUnionr__annotations__rpropertyr r0Optionalstrr/rArJrLrNrRrSrVr5r4r^rerrrrr&s@          rc@sHeZdZeZ  d dejedejefddZddZ d d d d Z dS) AsyncClientNr*r+cCr1r2)r#r3r4r5rr6r7r8rrrr/r:zAsyncClient.bindcs|Sr,rr.rrr __aenter__szAsyncClient.__aenter__r[cs|jIdHdSr,)r!acloserarrr __aexit__szAsyncClient.__aexit__rfrg)r[N) rrrrrrirmrnr/rprrrrrrros rocs 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. cs<ddlm}|dpt|d|d<tj|i|dS)Nr) SqliteCacher!)cache) zeep.cachertrXrsuperr)rrFrGrt __class__rrrs zCachingClient.__init__)rrrrhr __classcell__rrrxrrssrs)loggingri zeep.proxyrr zeep.settingsrzeep.transportsrr zeep.wsdlr getLoggerrloggerrrrorsrrrrs   <