U
H4f[ @ s d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z m
Z
d dlmZ e eZejejejd ZG d
d d e ZG d d
d
eZG dd deZG dd de
ZdS ) N)etree)nsFault)
qname_attr)messages)Binding Operation)url_http_to_https)httpwsdlmimec @ s: e Zd Zdd Zd
ddZedd Zdd Zd
d Zd S ) HttpBindingc O s, t |tr | |}|s td|j||S )NzOperation not found)
isinstancestrget
ValueErrorcreate)self operationargskwargs r ;/tmp/pip-unpacked-wheel-04z2hmy8/zeep/wsdl/bindings/http.pycreate_message s
zHttpBinding.create_messageFc C sX |j dtd}|d kr td|d}|rP|rPt|}||dkrPtd d|iS )Nz http:address
namespacesz No `http:address` node foundlocationz&Forcing http:address location to HTTPSaddress)findNSMAPr r r
loggerwarning)r
xmlelementZ force_httpsZ address_noder r r r process_service_port s
z HttpBinding.process_service_portc C sZ t |d|j}t |d|j}| |j||}|jdtdD ] }t|||}|| q8|S )Nnametypezwsdl:operationr )r Ztarget_namespacer findallr
HttpOperationparseZ_operation_add)cls definitionsr# r% Z port_nameobjnoder r r r r) ' s zHttpBinding.parsec C s" |j dkr| |jS ||jS )N ) status_code
process_errorcontent
process_reply)r clientr responser r r r2 2 s
zHttpBinding.process_replyc C s t |dd S )N)messager )r docr r r r0 7 s zHttpBinding.process_errorN)F) __name__
__module__ __qualname__r r$ classmethodr) r2 r0 r r r r r s
r c @ s e Zd Zdd Zedd ZdS )HttpPostBindingc
C sX | |}|std| |j||}|d |j }|jj||j|jd} | ||| S zCalled from the servicezOperation %r not foundr )headers) r r r path transportpostr1 r= r2
r r3 optionsr r r Z
operation_obj
serializedurlr4 r r r send< s
zHttpPostBinding.sendc C s, | ttd d}|dk o*|ddkS )Check if this binding instance should be used to parse the given
node.
:param node: The node to match against
:type node: lxml.etree._Element
r bindingNverbPOST)r r QNamer r r* r- Z http_noder r r matchJ s zHttpPostBinding.matchNr7 r8 r9 rE r: rL r r r r r; ; s r; c @ s e Zd Zdd Zedd ZdS )HttpGetBindingc
C sX | |}|std| |j||}|d |j }|jj ||j|jd} | ||| S r< )r r r r> r? r1 r= r2 rA r r r rE X s
zHttpGetBinding.sendc C s* | ttjd}|dk o(|ddkS )rF rG NrH GET)r r rJ r HTTPr rK r r r rL f s zHttpGetBinding.matchNrM r r r r rN W s rN c s< e Zd Z fddZdd Zedd Z fddZ ZS ) r( c s t || || _d S N)super__init__r )r r% rG r __class__r r rS t s zHttpOperation.__init__c C s | j |S rQ )outputZ deserialize)r Zenveloper r r r2 x s zHttpOperation.process_replyc C s | d}|jdtd}| d}| |||}|D ]}t|jj} | dkrNq2d}
t|} t| dkrn| d }
d} |
dk r|
jtt j
dkrt j } nR|
jtt j
d krt j
} n6|
jtt jd
krt j} n|
jtt jd krt j} | r2| |||}
|
stt|| |
q2|S ) aQ
r% zhttp:operationr r )inputrV Nr Z
urlEncodedZurlReplacementr1 ZmimeXml)r r r r rJ tag localnamelistlenr rP r Z
UrlEncodedZUrlReplacementMIMEZ MimeContentZMimeXMLr) AssertionErrorsetattr)r* r+ r# rG r% Zhttp_operationr r, r- Ztag_nameZ message_nodenodesZ
message_classmsgr r r r) { s6
zHttpOperation.parsec s@ t | | jr$| j|| jj | jr<| j|| jj d S rQ )rR resolverV ZabstractZoutput_messagerW Z
input_message)r r+ rT r r ra s
zHttpOperation.resolve) r7 r8 r9 rS r2 r: r) ra
__classcell__r r rT r r( s s
/r( )logginglxmlr Zzeepr Zzeep.exceptionsr Z
zeep.utilsr Z zeep.wsdlr Zzeep.wsdl.definitionsr r Zzeep.wsdl.utilsr
getLoggerr7 r! rP ZWSDLr\ r r r; rN r( r r r r s
*