3
2a\ & @ sf d dl Z d dlZd dlZd dlmZ d dlmZ d dlZd dlZ d dl
m Z d dl Z d dl
mZ y d dlZW n ek
r dZY nX dd Zdejdd ZdXZdZZd[Zd\Zd]Zd^Zd_Zd`ZdaZ dbZ dcZ ddZ deZ dfZ!G dd de"Z#G dd de#Z$G dd de#Z%G d d d e#Z&e' Z(Z)ed d d Z*e*j+d d krFd d! Z,n"e*j+d"d kr`d#d! Z,nd$d! Z,[*d%d& Z-G d'd( d(Z.d)d* Z/d+d, Z0G d-d. d.Z1d/d0 Z2e.e1fZ3G d1d2 d2Z4G d3d4 d4Z5G d5d6 d6Z6G d7d8 d8Z7G d9d: d:Z8G d;d< d<Z9d Z: Z;Zd?Z=dhd@dAZ>didBdCZ?dDdE Z@djdGdHZAG dIdJ dJerTejBneCZDG dKdL dLZEG dMdN dNZFG dOdP dPeFZGG dQdR dRZHeHZIeJdSkrbeHdTZKyeLeKjMjN W n. e#k
r ZO zeLdUeO W Y ddZO[OX nX e9eKZPePjQ ePjRd dV ePjSd d y xeP D ]ZTeLeT q W W n. e#k
r` ZO zeLdUeO W Y ddZO[OX nX dS )k N)datetime)Decimal)expat)BytesIOc C s$ | j dd} | j dd} | j ddS )N&z&z>)replace)s r +/opt/alt/python36/lib64/python3.6/client.pyescape s r
z%d.%d i iX i~ i~ i,~ i i iY iZ i[ c @ s e Zd Zdd ZdS )Errorc C s t | S )N)repr)selfr r r __str__ s z
Error.__str__N)__name__
__module__ __qualname__r r r r r r s r c @ s e Zd Zdd Zdd ZdS )
ProtocolErrorc C s& t j| || _|| _|| _|| _d S )N)r __init__urlerrcodeerrmsgheaders)r r r r r r r r r s
zProtocolError.__init__c C s d| j j| j| j| jf S )Nz<%s for %s: %s %s>) __class__r r r r )r r r r __repr__ s zProtocolError.__repr__N)r r r r r r r r r r s r c @ s e Zd ZdS )
ResponseErrorN)r r r r r r r r s r c @ s e Zd Zdd Zdd ZdS )Faultc K s t j| || _|| _d S )N)r r faultCode faultString)r r" r# Zextrar r r r s
zFault.__init__c C s d| j j| j| jf S )Nz <%s %s: %r>)r r r" r# )r r r r r s zFault.__repr__N)r r r r r r r r r r! s r! z%YZ0001c C s
| j dS )Nz%Y%m%dT%H:%M:%S)strftime)valuer r r _iso8601_format
s r& z%4Yc C s
| j dS )Nz%4Y%m%dT%H:%M:%S)r$ )r% r r r r& s c C s | j djdS )Nz%Y%m%dT%H:%M:%S )r$ zfill)r% r r r r& s c C sL t | trt| S t | ttjfs<| dkr2tj } tj| } d| d d S )Nr z%04d%02d%02dT%02d:%02d:%02d )
isinstancer r& tupletimeZ struct_timeZ localtime)r% r r r _strftime s
r- c @ sn e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z dd Z dd Z
dd ZdS ) DateTimer c C s t |tr|| _n
t|| _d S )N)r* strr% r- )r r% r r r r ) s
zDateTime.__init__c C s t |tr| j}|j}nzt |tr2| j}t|}n`t |trH| j}|}nJt|drd| j }|j }n.t|drv|jj p|t
|}t d| jj |f ||fS )N timetupler zCan't compare %s and %s) r* r. r% r r& r/ hasattrr0 r r type TypeError)r otherr
oZotyper r r make_comparable/ s$
zDateTime.make_comparablec C s | j |\}}||k S )N)r6 )r r4 r
r5 r r r __lt__D s zDateTime.__lt__c C s | j |\}}||kS )N)r6 )r r4 r
r5 r r r __le__H s zDateTime.__le__c C s | j |\}}||kS )N)r6 )r r4 r
r5 r r r __gt__L s zDateTime.__gt__c C s | j |\}}||kS )N)r6 )r r4 r
r5 r r r __ge__P s zDateTime.__ge__c C s | j |\}}||kS )N)r6 )r r4 r
r5 r r r __eq__T s zDateTime.__eq__c C s t j| jdS )Nz%Y%m%dT%H:%M:%S)r, strptimer% )r r r r r0 X s zDateTime.timetuplec C s | j S )N)r% )r r r r r ` s zDateTime.__str__c C s d| j j| jt| f S )Nz<%s %r at %#x>)r r r% id)r r r r r c s zDateTime.__repr__c C s t |j | _d S )N)r/ stripr% )r datar r r decodef s zDateTime.decodec C s$ |j d |j | j |j d d S )Nzz
)writer% )r outr r r encodei s
zDateTime.encodeN)r )r r r r r6 r7 r8 r9 r: r; r0 r r r@ rC r r r r r. # s
r. c C s t }|j| |S )N)r. r@ )r? r% r r r _datetimen s
rD c C s t j| dS )Nz%Y%m%dT%H:%M:%S)r r< )r? r r r _datetime_typet s rE c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
BinaryNc C s> |d krd}n&t |ttfs,td|jj t|}|| _d S )N z#expected bytes or bytearray, not %s)r* bytes bytearrayr3 r r r? )r r? r r r r s zBinary.__init__c C s t | jdS )Nzlatin-1)r/ r? )r r r r r s zBinary.__str__c C s t |tr|j}| j|kS )N)r* rF r? )r r4 r r r r; s
z
Binary.__eq__c C s t j|| _d S )N)base64 decodebytesr? )r r? r r r r@ s z
Binary.decodec C s4 |j d tj| j}|j |jd |j d d S )Nz
asciiz
)rA rJ encodebytesr? r@ )r rB encodedr r r rC s
z
Binary.encode)N)r r r r r r; r@ rC r r r r rF } s
rF c C s t }|j| |S )N)rF r@ )r? r% r r r _binary s
rO c @ s$ e Zd Zdd Zdd Zdd ZdS ) ExpatParserc C sD t jd d | _}|| _|j|_|j|_|j|_ d }|j
|d d S )N) r Z ParserCreate_parser_targetstartZStartElementHandlerendZEndElementHandlerr? ZCharacterDataHandlerxml)r targetparserencodingr r r r s zExpatParser.__init__c C s | j j|d d S )Nr )rQ Parse)r r? r r r feed s zExpatParser.feedc C s8 y
| j }W n tk
r Y nX | `| ` |jdd d S )NrG T)rQ AttributeErrorrR rY )r rW r r r close s
zExpatParser.closeN)r r r r rZ r\ r r r r rP s rP c @ s e Zd Zd ddZi Zdd Zdd Zd d
Zeeed< d d Z e ee
< d
d Z e ee < e Z
dd Zeee< efddZeee< dd Zeee< eee< dd Zeee< eee< efddZeee< dd Zeee < dd Z e ee < e ee < e ed < dS )
MarshallerNFc C s i | _ d | _|| _|| _d S )N)memor? rX
allow_none)r rX r_ r r r r s zMarshaller.__init__c C s g }|j }| j}t|tr@|d ||j|jd| |d n8|d x&|D ] }|d ||| |d qNW |d dj|}|S ) Nz
)r" r# z
z
z
z
z
)append_Marshaller__dumpr* r! r" r# join)r valuesrB rA dumpvresultr r r dumps s"
zMarshaller.dumpsc C s y| j t| }W nj tk
r| t|ds)r_ r3 )r r% rA r r r dump_nil s zMarshaller.dump_nilc C s$ |d ||rdpd |d d S )Nz10z
r )r r% rA r r r dump_bool s zMarshaller.dump_boolc C s< |t ks|tk rtd|d |tt| |d d S )Nzint exceeds XML-RPC limitsz z
)MAXINTMININT
OverflowErrorr/ int)r r% rA r r r dump_long s
zMarshaller.dump_longc C s |d |t | |d d S )Nzz
)r )r r% rA r r r dump_double% s zMarshaller.dump_doublec C s |d ||| |d d S )Nzz
r )r r% rA r
r r r dump_unicode+ s zMarshaller.dump_unicodec C s, |d t j|}||jd |d d S )Nz
rL z
)rJ rM r@ )r r% rA rN r r r
dump_bytes1 s
zMarshaller.dump_bytesc C s^ t |}|| jkrtdd | j|< | j}|d x|D ]}||| q8W |d | j|= d S )Nz"cannot marshal recursive sequencesz
z
)r= r^ r3 rb )r r% rA ire rf r r r
dump_array9 s
zMarshaller.dump_arrayc C s t |}|| jkrtdd | j|< | j}|d xP|j D ]D\}}|d t|ts^td|d|| ||| |d q
z
z dictionary key must be stringz%s
z
z
)r= r^ r3 rb itemsr* r/ )r r% rA r
r| re krf r r r dump_structG s
zMarshaller.dump_structc C s |d |t | |d d S )Nzz
)r- )r r% rA r r r
dump_datetimeY s zMarshaller.dump_datetimec C s2 |j tkr || _|j| | `n| j|j| d S )N)r WRAPPERSrA rC r ri )r r% rA r r r
dump_instance_ s
zMarshaller.dump_instancerj )NF) r r r r rk rh rb rp r2 rs boolrx rw Zdump_intry floatr
rz r/ r{ rH rI r} r+ listr dictr r r r. rF r r r r r] s:
r] c @ sj e Zd ZdDddZdd Zdd Zdd Zd
d Zd d
Zdd Z dd Z
i Z dd Z e e d< dd Z
e
e d< dd Zee d< ee d< ee d < ee d < ee d < ee d < d d! Zee d"< ee d#< d$d% Zee d&< d'd( Zee d)< ee d*< d+d, Zee d-< d.d/ Zee d0< d1d2 Zee d3< d4d5 Zee d6< d7d8 Zee d9< d:d; Zee d<< d=d> Zee d?< d@dA Zee dB< dCS )E UnmarshallerFc C sH d | _ g | _g | _g | _d| _d | _d| _| jj| _|p:|| _|| _ d S )NFzutf-8)
_type_stack_marks_data_value _methodname _encodingra
_use_datetime
_use_bytes)r use_datetimeuse_builtin_typesr r r r s
zUnmarshaller.__init__c C s: | j d ks| jrt | j dkr0tf | jd t| jS )Nfaultr )r r r r! r r+ )r r r r r\ s
zUnmarshaller.closec C s | j S )N)r )r r r r
getmethodname s zUnmarshaller.getmethodnamec C s
|| _ d S )N)r )r rX Z
standaloner r r rU s zUnmarshaller.xmlc C sh d|kr|j dd }|dks&|dkr8| jjt| j g | _| jrZ|| jkrZtd| |dk| _d S )N:r arraystructzunknown tag %rr% ) splitr ra lenr r r rk r )r tagZattrsr r r rS s zUnmarshaller.startc C s | j j| d S )N)r ra )r textr r r r? s zUnmarshaller.datac C sp y| j | }W nN tk
r\ d|kr*d S y| j |jdd }W n tk
rV d S X Y nX || dj| jS )Nr r r` r )rk rl r rc r )r r ro r r r rT s zUnmarshaller.endc C sh y| j | }W nN tk
r\ d|kr*d S y| j |jdd }W n tk
rV d S X Y nX || |S )Nr r r )rk rl r )r r r? ro r r r end_dispatch s zUnmarshaller.end_dispatchc C s | j d d| _d S )Nr )ra r )r r? r r r end_nil s
zUnmarshaller.end_nilZnilc C s: |dkr| j d n |dkr(| j d ntdd| _d S )Nrr Frq Tzbad boolean valuer )ra r3 r )r r? r r r end_boolean s zUnmarshaller.end_booleanbooleanc C s | j t| d| _d S )Nr )ra rw r )r r? r r r end_int s zUnmarshaller.end_intZi1Zi2Zi4Zi8rw Z
bigintegerc C s | j t| d| _d S )Nr )ra r r )r r? r r r
end_double s zUnmarshaller.end_doubleZdoubler c C s | j t| d| _d S )Nr )ra r r )r r? r r r end_bigdecimal s zUnmarshaller.end_bigdecimalZ
bigdecimalc C s& | j r|j| j }| j| d| _d S )Nr )r r@ ra r )r r? r r r
end_string s
zUnmarshaller.end_stringstringnamec C s. | j j }| j|d g| j|d < d| _d S )Nr )r popr r )r r? markr r r end_array s
zUnmarshaller.end_arrayr c C sd | j j }i }| j|d }x,tdt|dD ]}||d ||| < q.W |g| j|d < d| _d S )Nr r r )r r r ranger r )r r? r r r~ r| r r r
end_struct s
zUnmarshaller.end_structr c C s6 t }|j|jd | jr"|j}| j| d| _d S )NrL r )rF r@ rC r r? ra r )r r? r% r r r
end_base64 s
zUnmarshaller.end_base64rJ c C s, t }|j| | jr t|}| j| d S )N)r. r@ r rE ra )r r? r% r r r end_dateTime s
zUnmarshaller.end_dateTimezdateTime.iso8601c C s | j r| j| d S )N)r r )r r? r r r end_value s zUnmarshaller.end_valuer% c C s
d| _ d S )Nparams)r )r r? r r r
end_params# s zUnmarshaller.end_paramsr c C s
d| _ d S )Nr )r )r r? r r r end_fault' s zUnmarshaller.end_faultr c C s" | j r|j| j }|| _d| _d S )N
methodName)r r@ r r )r r? r r r end_methodName+ s zUnmarshaller.end_methodNamer N)FF)r r r r r\ r rU rS r? rT r rk r r r r r r r r r r r r r r r r r r r s sX
r c @ s$ e Zd Zdd Zdd Zdd ZdS )_MultiCallMethodc C s || _ || _d S )N)_MultiCallMethod__call_list_MultiCallMethod__name)r Z call_listr r r r r 8 s z_MultiCallMethod.__init__c C s t | jd| j|f S )Nz%s.%s)r r r )r r r r r __getattr__; s z _MultiCallMethod.__getattr__c G s | j j| j|f d S )N)r ra r )r argsr r r __call__= s z_MultiCallMethod.__call__N)r r r r r r r r r r r 5 s r c @ s e Zd Zdd Zdd ZdS )MultiCallIteratorc C s
|| _ d S )N)results)r r r r r r D s zMultiCallIterator.__init__c C sR | j | }t|ti kr.t|d |d n t|tg krF|d S tdd S )Nr" r# r z#unexpected type in multicall result)r r2 r!
ValueError)r r| itemr r r __getitem__G s
z MultiCallIterator.__getitem__N)r r r r r r r r r r @ s r c @ s0 e Zd Zdd Zdd ZeZdd Zdd Zd S )
MultiCallc C s || _ g | _d S )N)_MultiCall__server_MultiCall__call_list)r serverr r r r a s zMultiCall.__init__c C s d| j jt| f S )Nz <%s at %#x>)r r r= )r r r r r e s zMultiCall.__repr__c C s t | j|S )N)r r )r r r r r r j s zMultiCall.__getattr__c C s: g }x"| j D ]\}}|j||d q W t| jjj|S )N)r r )r ra r r systemZ multicall)r Zmarshalled_listr r r r r r m s zMultiCall.__call__N)r r r r r r r r r r r r r P s
r Fc C sr t rHtrH|rt}tj}n| r&t}t}nt}t}tdd||t}t |}n"t| |d}t rbt |}nt |}||fS )NTF)r r )
FastParserFastUnmarshallerrE rJ rK rO rD r! r rP )r r Z
mkdatetimeZmkbytesrV rW r r r getparser s
r c C s t | trd}n|r t | tr |s&d}tr4t|}n
t||}|j| }|dkr^dt| }nd}|rx|d|d|df}n|r|d|d f}n|S d
j|S ) Nr zutf-8z$
z
z
z
z
z
z
r` )r* r! r+ FastMarshallerr] rh r/ rc )r
methodnameZmethodresponserX r_ mr? Z xmlheaderr r r rh s2
rh c C s2 t ||d\}}|j| |j |j |j fS )N)r r )r rZ r\ r )r? r r pur r r loads s
r c C s< t stt }t jd|dd}|j| W d Q R X |j S )Nwbr )modefileobjZ
compresslevel)gzipNotImplementedErrorr GzipFilerA getvalue)r? ro gzfr r r gzip_encode s r @c C s t stt jdt| dH}y$|dk r0|j }n|j|d }W n tk
r\ tdY nX W d Q R X |dkrt||krtd|S )Nrb)r r r r z invalid dataz#max gzipped payload length exceeded)r r r r readOSErrorr r )r? Z
max_decoder Zdecodedr r r gzip_decode s
r c @ s e Zd Zdd Zdd ZdS )GzipDecodedResponsec C s. t stt|j | _t jj| d| jd d S )Nr )r r )r r r r ior r )r responser r r r = s z GzipDecodedResponse.__init__c
C s" zt jj| W d | jj X d S )N)r r r\ r )r r r r r\ E s zGzipDecodedResponse.closeN)r r r r r\ r r r r r 9 s r c @ s$ e Zd Zdd Zdd Zdd ZdS )_Methodc C s || _ || _d S )N)
_Method__send
_Method__name)r sendr r r r r R s z_Method.__init__c C s t | jd| j|f S )Nz%s.%s)r r r )r r r r r r U s z_Method.__getattr__c G s | j | j|S )N)r r )r r r r r r W s z_Method.__call__N)r r r r r r r r r r r O s r c @ sz e Zd Zde ZdZdZdddZd ddZd d d
Z d d Z
d
d Z dd Z dd Z
dd Zdd Zdd Zdd ZdS ) TransportzPython-xmlrpc/%sTNFc C s || _ || _d| _g | _d S )N)NN)r _use_builtin_types _connection_extra_headers)r r r r r r r n s zTransport.__init__c C s~ xxdD ]p}y| j ||||S tjjk
r8 |r4 Y q tk
rt } z"|sb|jtjtjtjfkrd W Y d d }~X qX qW d S )Nr r )r r ) single_requesthttpclientZRemoteDisconnectedr errnoZ
ECONNRESETZ ECONNABORTEDZEPIPE)r hosthandler request_bodyverboser| er r r request~ s
zTransport.requestc C s y6| j ||||}|j }|jdkr4|| _| j|S W n2 tk
rL Y n tk
rh | j Y nX |jddr~|j t
|| |j|j t |j
d S )N zcontent-lengthr` ) send_requestZ getresponsestatusr parse_responser! Exceptionr\ getheaderr r reasonr Z
getheaders)r r r r r Z http_connZrespr r r r s"
zTransport.single_requestc C s t | j| jdS )N)r r )r r r )r r r r r s zTransport.getparserc C sr i }t |tr|\}}tjj|\}}|rdtjj|}tj|jd}dj |j
}dd| fg}ng }|||fS )Nzutf-8r` Z
AuthorizationzBasic ) r* r+ urllibparseZ splituserZunquote_to_bytesrJ rM r@ rc r )r r x509ZauthZ
extra_headersr r r
get_host_info s
zTransport.get_host_infoc C sL | j r || j d kr | j d S | j|\}| _}|tjj|f| _ | j d S )Nr r )r r r r r ZHTTPConnection)r r chostr r r r make_connection s
zTransport.make_connectionc C s | j \}}|r d| _ |j d S )N)NN)r r\ )r r
connectionr r r r\ s
zTransport.closec C s | j |}| jd d }|r&|jd | jrLtrL|jd|dd |jd
n |jd| |jd |jd | jf | j|| | j || |S ) Nr ZPOSTT)Zskip_accept_encodingAccept-Encodingr Content-Typetext/xmlz
User-Agent)r r )r r )
r r Zset_debuglevelaccept_gzip_encodingr Z
putrequestra
user_agent send_headers send_content)r r r r debugr r r r r r s
zTransport.send_requestc C s" x |D ]\}}|j || qW d S )N) putheader)r r r keyvalr r r r s zTransport.send_headersc C sR | j d k r0| j t|k r0tr0|jdd t|}|jdtt| |j| d S )NzContent-Encodingr zContent-Length)encode_thresholdr r r r r/ Z
endheaders)r r r r r r r s
zTransport.send_contentc C s t |dr*|jdddkr$t|}q.|}n|}| j \}}x2|jd}|sLP | jr`tdt| |j| q)r r r r )r r r r r s zServerProxy.__repr__c C s t | j|S )N)r _ServerProxy__request)r r r r r r s zServerProxy.__getattr__c C s. |dkr| j S |dkr | jS td|f d S )Nr\ r zAttribute %r not found)_ServerProxy__closer r[ )r attrr r r r s
zServerProxy.__call__c C s | S )Nr )r r r r __enter__ s zServerProxy.__enter__c G s | j d S )N)r )r r r r r __exit__ s zServerProxy.__exit__)NNFFFF) r r r r r r r r r r r r! r r r r r l s
r __main__zhttp://localhost:8000ZERROR l il i iDii ipiԁiDiCiBiiii)FF)NNNF)FF)r )UrJ sysr, r decimalr Z http.clientr Z urllib.parser Z xml.parsersr r r r r ImportErrorr
version_infor
rt ru Z PARSE_ERRORZ SERVER_ERRORZAPPLICATION_ERRORZ SYSTEM_ERRORZTRANSPORT_ERRORZNOT_WELLFORMED_ERRORZUNSUPPORTED_ENCODINGZINVALID_ENCODING_CHARZINVALID_XMLRPCZMETHOD_NOT_FOUNDZINVALID_METHOD_PARAMSZINTERNAL_ERRORr r r r r! r r ZBooleanZ_day0r$ r& r- r. rD rE rF rO r rP r] r r r r r r r r rh r r r r objectr r r r r ZServerr r r Z currentTimeZgetCurrentTimerf ZmultiZgetDatapowaddr r r r r s
K #! ( C '
'
J
d)i