U
H4fE @ 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!rd 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__ ;/tmp/pip-unpacked-wheel-04z2hmy8/zeep/wsdl/bindings/soap.pyr s zSoapBinding.__init__c C s |j d| jd}|dk S )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 | |}|std| |j||}| || |j}|j} |r|sN|jj}|jj rnt
|| ||\}} t
||| ||\}} |jrt|jtr|jD ]}
|
|| \}} qn|j|| \}} |jjr| |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_headerscontentheadersZserviceZ_binding_optionsabstractZ
wsa_actionr ZWsAddressingPluginZegressr Z apply_egresswsse
isinstancelistapplysettingsZextra_http_headersupdate) r r/ r0 r1 clientoptions
operation_obj
serializedr2 r3 r< r" r" r# r. > s@
zSoapBinding._createc
C sP | j |||||d\}}|j|d ||}| |} |jjrB|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
rB rC address)r. r post_xmlr5 r@ raw_response
process_reply
r rB rC r/ r0 r1 r2 r3 responserD r" r" r# sendl s
zSoapBinding.sendc
sV | 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
rF rG N)r. r rH r@ rI r5 rJ rK r" r" r#
send_async s
zSoapBinding.send_asyncc
C s |j dkr|jsdS |j dkr8|js8td|j |j d|jdd}t|}d}|dkrt|j||jpjd }|jd
j}t |jd krt
|jd d d }n|j}zt || j |j
d
} W nB tk
r }
z$td|j |
|jf |j |jdW 5 d}
~
X Y nX |rt| |rd}|jr(|j| t|| |j|\} } | jd| jd} |j dksd| dk rp| | |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)r@ z?Server returned response (%s) with invalid XML: %s.
Content: %r)rR r9 soap-env:Body/soap-env:Faultr% )rR r9 r r: r5 r r encodingrU lenr r
r r@ r r r< verifyr Z
apply_ingressr' r(
process_errorrJ Z _set_root)r rB r/ rL content_type
media_typeZ message_packdecoderr9 docexcr3
fault_noderesultr" r" r# rJ sf
zSoapBinding.process_replyc C s t d S r- )NotImplementedError)r r^ r/ r" r" r# rZ s zSoapBinding.process_errorFc C s` |j d| jd}|d kr&td d S |d}|rX|rXt|}||dkrXtd d|iS )Nz soap:addressr% z'No valid soap:address found for servicelocationz&Forcing soap:address location to HTTPSrG )r' r( loggerdebugr5 r warning)r
xmlelementZ force_httpsZ address_noderc r" r" r# process_service_port s
z SoapBinding.process_service_portc C s t |d|j}t |d|j}|jd| jd}|d}ddg}||krRtd| |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
Ztarget_namespacer' r( r5 rb r findall
SoapOperationparseZ_operation_add) r) definitionsrg r r r+ r Zsupported_transportsr objr* r/ r" r" r# rn s&
zSoapBinding.parse)NN)F)__name__
__module__ __qualname____doc__r classmethodr, r4 r. rM rN rJ rZ rh rn
__classcell__r" r" r r# r s
. H
r c @ s2 e Zd ZejejejejdZdd Z dd Z
dS )
Soap11BindingZsoapsoap-envr Zxsdc sd |j d| jd d kr,tdd d t|d fdd}t|d|d|d j d
jddd S ) NrV r% Unknown fault occuredmessagecodeactordetailc s" j | jd}|d k r |jS d S )Nr% )r' r( textr childr` r" r# get_textD s z-Soap11Binding.process_error..get_textZ faultstringZ faultcodeZ
faultactorr )r' r( r r )r r^ r/ r r" r r# rZ 9 s zSoap11Binding.process_errorc C s d|j d< d S )Nztext/xml; charset=utf-8rS )r: r rE r/ r" r" r# r8 P s z Soap11Binding._set_http_headersN) rq rr rs r ZSOAP_11Z SOAP_ENV_11WSDLXSDr( rZ r8 r" r" r" r# rw 1 s rw c @ s2 e Zd ZejejejejdZdd Z dd Z
dS )
Soap12Bindingrx c s |j d| jd d kr,tdd d t|d fdd} jd| jd} jd| jd}g } j d | jd}|d k r|j d
| jd}t|j|jd } || |j d | jd}ql j d | jd}
t||d |
|d
d S )NrV r% rz r{ c s | }|d k r|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 r^ r/ r r| r} r Zsubcode_elementZsubcode_value_elementZ
subcode_qnameZ detail_noder" r r# rZ \ sZ
zSoap12Binding.process_errorc C s d ddd|j g|jd< d S )Nz; zapplication/soap+xmlz
charset=utf-8z action="%s"rS )join
soapactionr: r r" r" r# r8 s z Soap12Binding._set_http_headersN) rq rr rs r ZSOAP_12Z SOAP_ENV_12r r r( rZ r8 r" r" r" r# r T s 3r c sF e Zd ZdZ fddZdd Zedd Zdd fd
d Z Z S ) rm z3Represent's an operation within a specific binding.c s$ t || || _|| _|| _d S r- )r r r( r rj )r r bindingr( r rj r r" r# r s zSoapOperation.__init__c C sF t | jd d}|j|kr0td|j|jf | jrB| j|S d S )Nry ZEnvelopezpThe XML returned by the server does not contain a valid {%s}Envelope root element. The root element found is %s )r QNamer( tagr namespaceoutputZ deserialize)r r2 Zenvelope_qnamer" r" r# rJ s
zSoapOperation.process_replyc C s | d}|jd|jd}d}|dk r@| d}| d|j}n|j}| |||||} |dkrdt}
nt}
|D ]R} t| jj } | dkrql|
j
|| | || d }
| d
kr|
| j |
j < qlt
| | |
ql| S ) a
Definition::
*
?
?
?
<-- extensibility element (4) --> *
*
<-- extensibility element (5) --> *
Example::
r zsoap:operationr% NZ
soapActionrj Zrpc)inputr fault)ro rg r/ r( ri r )r5 r' r( r r r r r r localnamern faultsr setattr)r) ro rg r r( r r+ actionrj rp Z
message_classr* Ztag_namemsgr" r" r# rn s4 "
zSoapOperation.parser )ro c st t | | j D ](\}}|| jjkr||| jj| q| jrX| j|| jj | jrp| j|| jj d S r- )
r resolver itemsr; Zfault_messagesr Zoutput_messager Z
input_message)r ro r r r r" r# r s zSoapOperation.resolve)
rq rr rs rt r rJ ru rn r rv r" r" r r# rm s
Frm )+loggingtypinglxmlr Z#requests_toolbelt.multipart.decoderr Zzeepr r r Zzeep.exceptionsr r r Z zeep.loaderr
Z
zeep.utilsr r r
Zzeep.wsdl.attachmentsr Zzeep.wsdl.definitionsr r Zzeep.wsdl.messagesr r Zzeep.wsdl.messages.xopr Zzeep.wsdl.utilsr r
TYPE_CHECKINGZzeep.wsdl.wsdlr getLoggerrq rd r rw r rm r" r" r" r# s*
#E