o
gE @ s d dl Z d dlZd dlmZ d dlmZ d dlmZmZm Z d dl
m Z m Z m
Z
d dlmZ d dlmZmZmZ d dlmZ d d lmZmZ d d
lmZmZ d d l m Z d d l m Z m Z ej!red d
l"m#Z# e $e%Z&G dd deZ'G dd de'Z(G dd de'Z)G dd deZ*dS ) N)etree)MultipartDecoder)nspluginswsa)FaultTransportErrorXMLSyntaxError) parse_xml)as_qnameget_media_type
qname_attr) MessagePack)Binding Operation)DocumentMessage
RpcMessage) process_xop)etree_to_stringurl_http_to_https)
Definitionc st e Zd ZdZ fddZedd Zdd Zdd d
Zd d Z d
d Z
dd Z dd Z dddZ
edd Z ZS ) SoapBindingzSoap 1.1/1.2 bindingc s t ||| || _|| _dS )a[ The SoapBinding is the base class for the Soap11Binding and
Soap12Binding.
:param wsdl:
:type wsdl:
:param name:
:type name: string
:param port_name:
:type port_name: string
:param transport:
:type transport: zeep.transports.Transport
:param default_style:
N)super__init__ transport
default_style)selfwsdlname port_namer r __class__ P/home/ubuntu/webapp/venv/lib/python3.10/site-packages/zeep/wsdl/bindings/soap.pyr s
zSoapBinding.__init__c C s |j d| jd}|duS )zCheck if this binding instance should be used to parse the given
node.
:param node: The node to match against
:type node: lxml.etree._Element
soap:binding
namespacesN)findnsmap)clsnode soap_noder" r" r# match. s zSoapBinding.matchc O s | |||\}}|S N)_create)r operationargskwargsenvelope http_headersr" r" r# create_message: s zSoapBinding.create_messageNc C s | |}|s
td| |j|i |}| || |j}|j} |re|s)|jj}|jj r9t
|| ||\}} t
||| ||\}} |jret|jtr\|jD ]
}
|
|| \}} qPn |j|| \}} |jjrp| |jj || fS )zCreate the XML document to send to the server.
Note that this generates the soap envelope without the wsse applied.
zOperation %r not found)get
ValueErrorcreate_set_http_headerscontentheadersservice_binding_optionsabstract
wsa_actionr WsAddressingPluginegressr apply_egresswsse
isinstancelistapplysettingsextra_http_headersupdate) r r/ r0 r1 clientoptions
operation_obj
serializedr2 r3 rB r" r" r# r. > s4
zSoapBinding._createc
C sP | j |||||d\}}|j|d ||}| |} |jjr!|S | || |S )a Called from the service
:param client: The client with which the operation was called
:type client: zeep.client.Client
:param options: The binding options
:type options: dict
:param operation: The operation object from which this is a reply
:type operation: zeep.wsdl.definitions.Operation
:param args: The args to pass to the operation
:type args: tuple
:param kwargs: The kwargs to pass to the operation
:type kwargs: dict
rI rJ address)r. r post_xmlr5 rF raw_response
process_reply
r rI rJ r/ r0 r1 r2 r3 responserK r" r" r# sendl s
zSoapBinding.sendc
sX | j |||||d\}}|j|d ||I dH }|jjr |S | |} | || |S )a Called from the async service
:param client: The client with which the operation was called
:type client: zeep.client.Client
:param options: The binding options
:type options: dict
:param operation: The operation object from which this is a reply
:type operation: zeep.wsdl.definitions.Operation
:param args: The args to pass to the operation
:type args: tuple
:param kwargs: The kwargs to pass to the operation
:type kwargs: dict
rM rN N)r. r rO rF rP r5 rQ rR r" r" r#
send_async s
zSoapBinding.send_asyncc
C s| |j dv r
|js
dS |j dkr |js td|j |j d|jdd}t|}d}|dkrOt|j||jp5d }|jd
j}t |jd krNt
|jd d d }n|j}z t || j |j
d
} W n tyy }
ztd|j |
|jf |j |jdd}
~
ww |rt| |rd}|jr|j| t|| |j|\} } | jd| jd} |j dks| dur| | |S || }
|r||
|S |
S )a Process the XML reply from the server.
:param client: The client with which the operation was called
:type client: zeep.client.Client
:param operation: The operation object from which this is a reply
:type operation: zeep.wsdl.definitions.Operation
:param response: The response object returned by the remote server
:type response: requests.Response
) N z5Server returned HTTP status %d (no content available)) status_code Content-Typeztext/xmlzmultipart/relatedzutf-8r )parts)rF z?Server returned response (%s) with invalid XML: %s.
Content: %r)rY r9 soap-env:Body/soap-env:Faultr% )rY r9 r r: r5 r r encodingr\ lenr r
r rF r r rB verifyr
apply_ingressr' r(
process_errorrQ _set_root)r rI r/ rS content_type
media_type message_packdecoderr9 docexcr3
fault_noderesultr" r" r# rQ sb
zSoapBinding.process_replyc C s t r- )NotImplementedError)r rh r/ r" r" r# rb s zSoapBinding.process_errorFc C s` |j d| jd}|d u rtd d S |d}|r,|r,t|}||dkr,td d|iS )Nz soap:addressr% z'No valid soap:address found for servicelocationz&Forcing soap:address location to HTTPSrN )r' r( loggerdebugr5 r warning)r
xmlelement force_https address_noderm r" r" r# process_service_port s
z SoapBinding.process_service_portc C s t |d|j}t |d|j}|jd| jd}|d}ddg}||vr)td| |d d
}| |j||||} |jd | jdD ]}
tj ||
| | jd } |
| q@| S )
a
Definition::
*
<-- extensibility element (1) --> *
*
<-- extensibility element (2) --> *
?
<-- extensibility element (3) -->
?
<-- extensibility element (4) --> *
*
<-- extensibility element (5) --> *
r typer$ r% r z$http://schemas.xmlsoap.org/soap/httpz-http://www.w3.org/2003/05/soap/bindings/HTTP/z:The binding transport %s is not supported (only soap/http)styledocumentzwsdl:operation)r( ) r
target_namespacer' r( r5 rl r findall
SoapOperationparse_operation_add) r) definitionsrq r r r+ r supported_transportsr objr* r/ r" r" r# r{ s&
zSoapBinding.parse)NN)F)__name__
__module__ __qualname____doc__r classmethodr, r4 r. rT rU rQ rb rt r{
__classcell__r" r" r r# r s
. H
r c @ 2 e Zd ZejejejejdZdd Z dd Z
dS )
Soap11Bindingsoapsoap-envr xsdc s` |j d| jd d u rtdd d t|d fdd}t|d|d|d j d
jdd) Nr] r% Unknown fault occuredmessagecodeactordetailc s" j | jd}|d ur|jS d S )Nr% )r' r( textr childrj r" r# get_textD s z-Soap11Binding.process_error..get_text faultstring faultcode
faultactorr )r' r( r r )r rh r/ r r" r r# rb 9 s zSoap11Binding.process_errorc C s d|j d< d S )Nztext/xml; charset=utf-8rZ )r: r rL r/ r" r" r# r8 P s z Soap11Binding._set_http_headersN) r r r r SOAP_11 SOAP_ENV_11WSDLXSDr( rb r8 r" r" r" r# r 1 s r c @ r )
Soap12Bindingr c s |j d| jd d u rtdd d t|d fdd} jd| jd} jd| jd}g } j d | jd}|d ur[|j d
| jd}t|j|jd } || |j d | jd}|d us: j d | jd}
t||d |
|d
)Nr] r% r r c s | }|d ur |jS d S r- )r' r r r r" r# r g s
z-Soap12Binding.process_error..get_textz soap-env:Reason/soap-env:Textz soap-env:Code/soap-env:Valuez soap-env:Code/soap-env:Subcodezsoap-env:Valuezsoap-env:Subcodezsoap-env:Detail)r r r r subcodes)r' r( r r findtextr r append) r rh r/ r r r r subcode_elementsubcode_value_element
subcode_qname detail_noder" r r# rb \ sN
zSoap12Binding.process_errorc C s d ddd|j g|jd< d S )Nz; zapplication/soap+xmlz
charset=utf-8z action="%s"rZ )join
soapactionr: r r" r" r# r8 s z Soap12Binding._set_http_headersN) r r r r SOAP_12 SOAP_ENV_12r r r( rb r8 r" r" r" r# r T s 3r c sB e Zd ZdZ fddZdd Zedd Zd fd
d Z Z S )
rz z3Represent's an operation within a specific binding.c s$ t || || _|| _|| _d S r- )r r r( r rv )r r bindingr( r rv r r" r# r s
zSoapOperation.__init__c C sF t | jd d}|j|krtd|j|jf | jr!| j|S d S )Nr EnvelopezpThe XML returned by the server does not contain a valid {%s}Envelope root element. The root element found is %s )r QNamer( tagr namespaceoutput deserialize)r r2 envelope_qnamer" r" r# rQ s
zSoapOperation.process_replyc C s | d}|jd|jd}d}|dur | d}| d|j}n|j}| |||||} |dkr2t}
nt}
|D ])} t| jj } | dvrDq6|
j
|| | || d }
| d
krY|
| j |
j < q6t
| | |
q6| S ) a
Definition::
*
?
?
?
<-- extensibility element (4) --> *
*
<-- extensibility element (5) --> *
Example::
r zsoap:operationr% N
soapActionrv rpc)inputr fault)r} rq r/ r( ru r )r5 r' r( r r r r r r localnamer{ faultsr setattr)r) r} rq r r( r r+ actionrv r
message_classr* tag_namemsgr" r" r# r{ s4
"
zSoapOperation.parser} r c sx t | | j D ]\}}|| jjv r ||| jj| q | jr,| j|| jj | jr:| j|| jj d S d S r- )
r resolver itemsr= fault_messagesr output_messager
input_message)r r} r r r r" r# r s zSoapOperation.resolve)r} r )
r r r r r rQ r r{ r r r" r" r r# rz s
Frz )+loggingtypinglxmlr #requests_toolbelt.multipart.decoderr zeepr r r zeep.exceptionsr r r zeep.loaderr
zeep.utilsr r r
zeep.wsdl.attachmentsr zeep.wsdl.definitionsr r zeep.wsdl.messagesr r zeep.wsdl.messages.xopr zeep.wsdl.utilsr r
TYPE_CHECKINGzeep.wsdl.wsdlr getLoggerr rn r r r rz r" r" r" r# s,
#E