o tBhv@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 namespacerb/var/www/html/riverr-enterprise-integrations-main/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@seZdZdZeZ      d!ddZeddZeddZ  d"d e j e d e j e fd d Z d dZddZddZddZddZddZddZddZde j e de fdd ZdS)#Clienta The zeep Client. :param wsdl: :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 NcCsv|std|p t|_|dur|n||_t||j|jd|_||_|dur*|ng|_d|_ ||_ ||_ d|_ dS)NzNo URL given for the wsdl)settings) ValueErrorrr_default_transport transportrwsdlwsseplugins_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 Rs 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'rr-rrrserviceVszClient.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*r/portrrrr.j    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"bindingsKeyErrorrjoinkeysr)r binding_namer:r5rrrcreate_service}s zClient.create_servicecOs|jj||||d\}}|S)zZCreate the payload for the given operation. :rtype: lxml.etree._Element )client)_binding_create)rr/operation_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_typernamerrrrMzClient.get_typecCrL)z\Return the element for the given qualified name. :rtype: zeep.xsd.Element )r"r get_elementrNrrrrQrPzClient.get_elementcCs|jj||dS)z'Set a shortcut for the given namespace.N)r"r set_ns_prefix)rprefixrrrrrRszClient.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)portsgetrlistvalues)rr/rOr8rrrr4s zClient._get_portrOreturncCs<|r|jj|}|std|Stt|jjd}|S)NzService not found)r"r2rWrnextiterrY)rrOr/rrrr3szClient._get_service)NNNNNNNN)rrr__doc__rr rpropertyr r/typingOptionalstrr.r@rIrKrMrQrRrUr4r3rrrrr&s<        rc@sHeZdZeZ  d dejedejefddZddZ d d d d Z dS) AsyncClientNr)r*cCr0r1)r"r2r3r4rr5r6r7rrrr.r9zAsyncClient.bindcs|Sr+rr-rrr __aenter__szAsyncClient.__aenter__rZcs|jIdHdSr+)r!aclose)rexc_type exc_value tracebackrrr __aexit__szAsyncClient.__aexit__r])NNN)rZN) rrrrr r`rarbr.rdrirrrrrcs 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. cs<ddlm}|dpt|d|d<tj|i|dS)Nr) SqliteCacher!)cache) zeep.cacherkrWrsuperr)rrErFrk __class__rrrs zCachingClient.__init__)rrrr^r __classcell__rrrorrjsrj)loggingr` zeep.proxyrr zeep.settingsrzeep.transportsrr zeep.wsdlr getLoggerrloggerrrrcrjrrrrs   2