U
e5d
@ sb d dl Z d dlZd dlZd dlmZ d dlmZ d dlZd dlZ d dl
m Z d dl Z d dl
mZ z d dlZW n ek
r dZY nX dd Zdejdd Zd
Zd Zd Zd
ZdZdZdZd ZdZ dZ d
Z dZ dZ dZ!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*+d d krFd!d" Z,n"e*+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/Z1d0d1 Z2e.e1fZ3G d2d3 d3Z4G d4d5 d5Z5G d6d7 d7Z6G d8d9 d9Z7G d:d; d;Z8G ddZdCdDZ?dEdF Z@d[dHdIZAG dJdK dKerTejBneCZDG dLdM dMZEG dNdO dOZFG dPdQ dQeFZGG dRdS dSZHeHZIeJdTkr^eHdUZKzeLeKjMN W n. e#k
r ZO zeLdVeO W 5 dZO[OX Y nX e9eKZPePQ ePRd dW ePSd d zeP D ]ZTeLeT q W n. e#k
r\ ZO zeLdVeO W 5 dZO[OX Y nX dS )\ N)datetime)Decimal)expat)BytesIOc C s$ | dd} | dd} | ddS )N&z&z>)replace)s r %/usr/lib64/python3.8/xmlrpc/client.pyescape s r
z%d.%d ii iDii ipiԁiCiBiiic @ s e Zd ZejZdS )ErrorN)__name__
__module__ __qualname__object__str__r r r r r s r c @ s e Zd Zdd Zdd ZdS )
ProtocolErrorc C s& t | || _|| _|| _|| _d S N)r __init__urlerrcodeerrmsgheaders)selfr 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__Nr 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 | || _|| _d S r )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__Nr r r r r r" s r" z%YZ0001c C s
| dS N%Y%m%dT%H:%M:%Sstrftimevaluer r r _iso8601_format s r, z%4Yc C s
| dS )Nz%4Y%m%dT%H:%M:%Sr( r* r r r r, s c C s | ddS )Nr' )r) zfillr* r r r r, s c C sL t | trt| S t | ttjfs<| dkr2t } t| } d| d d S )Nr z%04d%02d%02dT%02d:%02d:%02d )
isinstancer r, tupletime struct_time localtimer* r r r _strftime s
r5 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 r )r0 strr+ r5 )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| }| }n.t|drv|jj p|t
|}t d| jj |f ||fS )N timetupler zCan't compare %s and %s) r0 r6 r+ r r, r7 hasattrr8 r r type TypeError)r otherr
oZotyper r r make_comparable. s*
zDateTime.make_comparablec C s | |\}}||k S r r> r r< r
r= r r r __lt__C s zDateTime.__lt__c C s | |\}}||kS r r? r@ r r r __le__G s zDateTime.__le__c C s | |\}}||kS r r? r@ r r r __gt__K s zDateTime.__gt__c C s | |\}}||kS r r? r@ r r r __ge__O s zDateTime.__ge__c C s | |\}}||kS r r? r@ r r r __eq__S s zDateTime.__eq__c C s t | jdS r& )r2 strptimer+ r r r r r8 W s zDateTime.timetuplec C s | j S r 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+ idr r r r r b s zDateTime.__repr__c C s t | | _d S r )r7 stripr+ r datar r r decodee s zDateTime.decodec C s$ | d | | j | d d S Nzz
)writer+ )r outr r r encodeh s
zDateTime.encodeN)r )r r r r r> rA rB rC rD rE r8 r r rK rO r r r r r6 " s
r6 c C s t }|| |S r )r6 rK rJ r+ r r r _datetimem s
rQ c C s t | dS r& )r rF )rJ r r r _datetime_types s rR 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)r0 bytes bytearrayr; r r rJ rI r r r r s zBinary.__init__c C s t | jdS )Nzlatin-1)r7 rJ r r r r r s zBinary.__str__c C s t |tr|j}| j|kS r )r0 rS rJ )r r< r r r rE s
z
Binary.__eq__c C s t || _d S r )base64 decodebytesrJ rI r r r rK s z
Binary.decodec C s4 | d t| j}| |d | d d S Nz
asciiz
)rM rW encodebytesrJ rK )r rN encodedr r r rO s
z
Binary.encode)N)r r r r r rE rK rO r r r r rS | s
rS c C s t }|| |S r )rS rK rP r r r _binary s
r] c @ s$ e Zd Zdd Zdd Zdd ZdS ) ExpatParserc C sD t d d | _}|| _|j|_|j|_|j|_ d }|
|d d S r ) r Z ParserCreate_parser_targetstartZStartElementHandlerendZEndElementHandlerrJ ZCharacterDataHandlerxml)r targetparserencodingr r r r s zExpatParser.__init__c C s | j |d d S Nr )r_ ParserI r r r feed s zExpatParser.feedc C s8 z
| j }W n tk
r Y nX | `| ` |dd d S )NrT T)r_ AttributeErrorr` rh )r re r r r close s
zExpatParser.closeN)r r r r ri rk r r r r r^ s r^ 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 r )memorJ rf
allow_none)r rf rn r r r r s zMarshaller.__init__c C s g }|j }| j}t|tr@|d ||j|jd| |d n4|d |D ] }|d ||| |d qL|d d|}|S ) Nz
)r# r$ z
z
z
z
z
)append_Marshaller__dumpr0 r" r# r$ join)r valuesrN rM dumpvresultr r r dumps s&
zMarshaller.dumpsc C s z| j t| }W nf tk
rx t|ds)rn r; r r+ rM r r r dump_nil
s zMarshaller.dump_nilc C s$ |d ||rdpd |d d S )Nz10z
r r 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
OverflowErrorr7 intr r r r dump_long s
zMarshaller.dump_longc C s |d |t | |d d S )Nzz
)reprr r r r dump_double$ s zMarshaller.dump_doublec C s |d ||| |d d S )Nzz
r )r r+ rM r
r r r dump_unicode* s zMarshaller.dump_unicodec C s, |d t |}||d |d d S rY )rW r[ rK )r r+ rM r\ r r r
dump_bytes0 s
zMarshaller.dump_bytesc C sZ t |}|| jkrtdd | j|< | j}|d |D ]}||| q6|d | j|= d S )Nz"cannot marshal recursive sequencesz
z
)rG rm r; rq )r r+ rM irt ru r r r
dump_array8 s
zMarshaller.dump_arrayc C s t |}|| jkrtdd | j|< | j}|d | D ]D\}}|d t|ts\td|d|| ||| |d q:|d | j|= d S )Nz%cannot marshal recursive dictionariesz
z
z dictionary key must be stringz%s
z
z
)rG rm r; rq itemsr0 r7 )r r+ rM r
r rt kru r r r dump_structF s
zMarshaller.dump_structc C s |d |t | |d d S rL )r5 r r r r
dump_datetimeX s zMarshaller.dump_datetimec C s2 |j tkr || _|| | `n| |j| d S r )r WRAPPERSrM rO r rx r r r r
dump_instance^ s
zMarshaller.dump_instancery )NF) r r r r rz rw rq r r: r boolr r Zdump_intr floatr
r r7 r rU rV r r1 listr dictr r r r6 rS r r r r rl s:
rl 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 )NFutf-8)
_type_stack_marks_data_value _methodname _encodingrp
_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 r1 r r r r rk s
zUnmarshaller.closec C s | j S r )r r r r r
getmethodname s zUnmarshaller.getmethodnamec C s
|| _ d S r )r )r rf Z
standaloner r r rc s zUnmarshaller.xmlc C sh d|kr| dd }|dks&|dkr8| jt| j g | _| jrZ|| jkrZtd| |dk| _d S )N:arraystructzunknown tag %rr+ ) splitr rp lenr r r rz r! )r tagZattrsr r r ra s zUnmarshaller.startc C s | j | d S r )r rp )r textr r r rJ s zUnmarshaller.datac C sv z| j | }W nT tk
rb d|kr,Y d S z| j |dd }W n tk
r\ Y Y d S X Y nX || d| jS )Nr r ro )rz r{ r rr r )r r r~ r r r rb s zUnmarshaller.endc C sn z| j | }W nT tk
rb d|kr,Y d S z| j |dd }W n tk
r\ Y Y d S X Y nX || |S )Nr r )rz r{ r )r r rJ r~ r r r end_dispatch s zUnmarshaller.end_dispatchc C s | d d| _d S rg )rp r rI r r r end_nil s
zUnmarshaller.end_nilZnilc C s: |dkr| d n |dkr(| d ntdd| _d S )Nr Fr Tzbad boolean valuer )rp r; r rI r r r end_boolean s zUnmarshaller.end_booleanbooleanc C s | t| d| _d S rg )rp r r rI r r r end_int s zUnmarshaller.end_intZi1Zi2Zi4Zi8r Z
bigintegerc C s | t| d| _d S rg )rp r r rI r r r
end_double s zUnmarshaller.end_doubleZdoubler c C s | t| d| _d S rg )rp r r rI r r r end_bigdecimal s zUnmarshaller.end_bigdecimalZ
bigdecimalc C s& | j r|| j }| | d| _d S rg )r rK rp r rI r r r
end_string s
zUnmarshaller.end_stringstringnamec C s. | j }| j|d g| j|d < d| _d S rg )r popr r )r rJ markr r r end_array s
zUnmarshaller.end_arrayr c C s` | j }i }| j|d }tdt|dD ]}||d ||| < q,|g| j|d < d| _d S )Nr r r% )r r r ranger r )r rJ r r r r r r r
end_struct s
zUnmarshaller.end_structr c C s6 t }||d | jr"|j}| | d| _d S )NrZ r )rS rK rO r rJ rp r r rJ r+ r r r
end_base64
s
zUnmarshaller.end_base64rW c C s, t }|| | jr t|}| | d S r )r6 rK r rR rp r r r r end_dateTime s
zUnmarshaller.end_dateTimezdateTime.iso8601c C s | j r| | d S r )r r rI r r r end_value s zUnmarshaller.end_valuer+ c C s
d| _ d S )Nparamsr rI r r r
end_params" s zUnmarshaller.end_paramsr c C s
d| _ d S )Nr r rI r r r end_fault& s zUnmarshaller.end_faultr c C s" | j r|| j }|| _d| _d S )N
methodName)r rK r r rI r r r end_methodName* s zUnmarshaller.end_methodNamer N)FF)r r r r rk r rc ra rJ rb r rz r r r r r r r r r r r r r r r r r r r r sX
r c @ s$ e Zd Zdd Zdd Zdd ZdS )_MultiCallMethodc C s || _ || _d S r )_MultiCallMethod__call_list_MultiCallMethod__name)r Z call_listr r r r r 7 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|f d S r )r rp r r argsr r r __call__< s z_MultiCallMethod.__call__Nr r r r r r r r r r r 4 s r c @ s e Zd Zdd Zdd ZdS )MultiCallIteratorc C s
|| _ d S r )results)r r r r r r C 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 r: r"
ValueError)r r itemr r r __getitem__F s
z MultiCallIterator.__getitem__N)r r r r r r r r r r ? s r c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
MultiCallc C s || _ g | _d S r )_MultiCall__server_MultiCall__call_list)r serverr r r r ` s zMultiCall.__init__c C s d| j jt| f S )Nz <%s at %#x>)r r rG r r r r r d s zMultiCall.__repr__c C s t | j|S r )r r r r r r r g s zMultiCall.__getattr__c C s6 g }| j D ]\}}|||d q
t| jj|S )N)r r )r rp r r systemZ multicall)r Zmarshalled_listr r r r r r j s zMultiCall.__call__N)r r r r r r r r r r r r O 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 )NTFr r )
FastParserFastUnmarshallerrR rW rX r] rQ r" r r^ )r r Z
mkdatetimeZmkbytesrd re r r r getparser| s
r c C s t | trd}n|r t | tr |s&d}tr4t|}n
t||}|| }|dkr^dt| }nd}|rx|d|d|df}n|r|d|d f}n|S d
|S ) Nr% r z$
z
z
z
z
z
z
ro )r0 r" r1 FastMarshallerrl rw r7 rr )r
methodnameZmethodresponserf rn mrJ Z xmlheaderr r r rw s8
rw c C s2 t ||d\}}|| | | | fS Nr )r ri rk r )rJ r r pur r r loads s
r c C s< t stt }t jd|dd}|| W 5 Q R X | S )Nwbr% )modefileobjZ
compresslevel)gzipNotImplementedErrorr GzipFilerM getvalue)rJ r~ gzfr r r gzip_encode s r @c C s t stt jdt| dH}z$|dk r0| }n||d }W n tk
r\ tdY nX W 5 Q R X |dkrt||krtd|S )Nrbr r r r% z invalid dataz#max gzipped payload length exceeded)r r r r readOSErrorr r )rJ Z
max_decoder Zdecodedr r r gzip_decode s
r c @ s e Zd Zdd Zdd ZdS )GzipDecodedResponsec C s. t stt| | _t jj| d| jd d S )Nr r )r r r r ior r )r responser r r r : s z GzipDecodedResponse.__init__c C s" ztj| W 5 | j X d S r )r rk r r r r r r rk B s zGzipDecodedResponse.closeN)r r r r rk r r r r r 6 s r c @ s$ e Zd Zdd Zdd Zdd ZdS )_Methodc C s || _ || _d S r
_Method__send
_Method__name)r sendr r r r r O s z_Method.__init__c C s t | jd| j|f S r )r r r r r r r r R s z_Method.__getattr__c G s | | j|S r r r r r r r T s z_Method.__call__Nr r r r r r L s r c @ s e Zd Zde ZdZdZd ddddZd d d
Zd d d Z d
d Z
dd Z dd Z dd Z
dd Zdd Zdd Zdd ZdS ) TransportzPython-xmlrpc/%sTNFr )r c C s& || _ || _d| _t|| _g | _d S N)NN)r _use_builtin_types _connectionr _headers_extra_headers)r r r r r r r r k s
zTransport.__init__c C s dD ]v}z| ||||W S tjjk
r< |r8 Y q tk
rx } z |sf|jtjtjtjfkrh W 5 d }~X Y qX qd S )N)r r% ) single_requesthttpclientZRemoteDisconnectedr errnoZ
ECONNRESETZ ECONNABORTEDZEPIPE)r hosthandler request_bodyverboser er r r request} s zTransport.requestc C s z8| ||||}| }|jdkr6|| _| |W S W n2 tk
rN Y n tk
rj | Y nX |ddr| t
|| |j|j t |
d S )N zcontent-lengthro ) send_requestZ getresponseZstatusr parse_responser" Exceptionrk 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 r )r r r r r r r r s zTransport.getparserc C sr i }t |tr|\}}tj|\}}|rdtj|}t|d}d |
}dd| fg}ng }|||fS )Nr ro Z
AuthorizationzBasic ) r0 r1 urllibparseZ
_splituserZunquote_to_bytesrW r[ rK rr 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 | |\}| _}|tj|f| _ | j d S )Nr r% )r r r r r ZHTTPConnectionr r Zchostr r r r make_connection s
zTransport.make_connectionc C s | j \}}|r d| _ | d S r )r rk )r r
connectionr r r rk s
zTransport.closec C s | |}| j| j }|r$|d | jrJtrJ|jd|dd |d n |d| |d |d| jf | || |
|| |S )Nr% ZPOSTT)Zskip_accept_encoding)zAccept-Encodingr )z Content-Typeztext/xmlz
User-Agent) r r r Zset_debuglevelaccept_gzip_encodingr Z
putrequestrp
user_agent send_headers send_content)r r r
r debugr r r r r r s
zTransport.send_requestc C s |D ]\}}| || qd S r ) putheader)r r r keyvalr r r r s zTransport.send_headersc C sR | j d k r0| j t|k r0tr0|dd t|}|dtt| || d S )NContent-Encodingr zContent-Length)encode_thresholdr r r! r r7 Z
endheaders)r r r r r r r s
zTransport.send_contentc C s t |dr*|dddkr$t|}q.|}n|}| \}}|d}|sJqj| jr^tdt| || q:||k rz| | | S )Nr r$ ro r i zbody:)
r9 r r r r r printr ri rk )r r streamr r rJ r r r r $ s
zTransport.parse_response)FF)F)F)r r r __version__r r r% r r r r r r rk r r r r r r r r r ] s
! r c s. e Zd Zd ddd fdd Zdd Z ZS )
SafeTransportFr Nr contextc s t j|||d || _d S )Nr r r )superr r+ )r r r r r+ r r r r E s
zSafeTransport.__init__c C st | j r || j d kr | j d S ttjds2td| |\}| _}|tjj|d fd| ji|p`i f| _ | j d S )Nr r% HTTPSConnectionz1your version of http.client doesn't support HTTPSr+ ) r r9 r r r r r r/ r+ r r r r r N s
z SafeTransport.make_connection)FF)r r r r r
__classcell__r r r. r r) B s
r) c @ sV e Zd ZddddddZdd Zd d
Zd d Zd
d Zdd Zdd Z dd Z
dS ) ServerProxyNFr r* c
C s t j|\}
}|
dkr tdt j|\| _| _| js@d| _|d kr||
dkr^t} d| i} nt} i } | f |||d| }|| _ |pd| _
|| _ || _ d S )N)r httpsz unsupported XML-RPC protocolz/RPC2r2 r+ r, r )
r r Z
_splittyper Z
_splithost_ServerProxy__host_ServerProxy__handlerr) r _ServerProxy__transport_ServerProxy__encoding_ServerProxy__verbose_ServerProxy__allow_none)
r Zuri transportrf r rn r r r r+ r: r
Z extra_kwargsr r r r s,
zServerProxy.__init__c C s | j d S r )r5 rk r r r r Z__close s zServerProxy.__closec C sP t ||| j| jd| jd}| jj| j| j|| jd}t |dkrL|d }|S )N)rf rn xmlcharrefreplace)r r% r )
rw r6 r8 rO r5 r r3 r4 r7 r )r r r r r r r r Z __request s
zServerProxy.__requestc C s d| j j| j| jf S )Nz
<%s for %s%s>)r r r3 r4 r r r r r s zServerProxy.__repr__c C s t | j|S r )r _ServerProxy__requestr r r r r s zServerProxy.__getattr__c C s. |dkr| j S |dkr | jS td|f d S )Nrk r9 zAttribute %r not found)_ServerProxy__closer5 rj )r attrr r r r s
zServerProxy.__call__c C s | S r r r r r r __enter__ s zServerProxy.__enter__c G s | d S 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 r1 m s
r1 __main__zhttp://localhost:8000ZERROR )FF)NNNF)FF)r )UrW sysr2 r decimalr Z http.clientr Z urllib.parser Z xml.parsersr r r r r ImportErrorr
version_infor( r r 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, r5 r6 rQ rR rS r] r r^ rl r r r r r r r r rw r r r r r r r r r) r1 ZServerr r r& Z currentTimeZgetCurrentTimeru ZmultiZgetDatapowaddr r r r r s
K #! ( C %
'
K
f+h