U
e5d9 @ s d dl mZmZmZmZmZ d dlmZ d dlm Z d dl
m Z d dl Z d dlZ
d dlZd dlZd dlZd dlZd dlZd dlZz d dlZW n ek
r dZY nX d*ddZd d
ZG d d d ZG d
d deZG dd dejeZG dd deZ G dd deZ G dd dej Z G dd dZ G dd deZ!G dd d ee Z"G d d d e e Z#e$d kr
d dl%Z%G d d! d!Z&ed"~Z'e'(e) e'(d#d$ d% e'j*e& dd& e'+ e,d' e,d( z e'- W n( e.k
r e,d) e/d Y nX W 5 Q R X dS )+ )Faultdumpsloads gzip_encode gzip_decode)BaseHTTPRequestHandler)partial) signatureNTc C sF |r| d}n|g}|D ]&}|dr6td| qt| |} q| S )N._z(attempt to access private attribute "%s")split
startswithAttributeErrorgetattr)objattrallow_dotted_namesZattrsi r %/usr/lib64/python3.8/xmlrpc/server.pyresolve_dotted_attribute| s
r c s fddt D S )Nc s( g | ] }| d stt |r|qS )r )r
callabler ).0memberr r r
s
z'list_public_methods..)dirr r r r list_public_methods s r c @ sl e Zd ZdddZdddZdddZd d
Zd d Zd d
dZdd Z dd Z
dd Z dd Z dd Z
dS ) SimpleXMLRPCDispatcherFNc C s& i | _ d | _|| _|pd| _|| _d S Nutf-8)funcsinstance
allow_noneencodinguse_builtin_typesselfr# r$ r% r r r __init__ s
z SimpleXMLRPCDispatcher.__init__c C s || _ || _d S N)r" r )r' r" r r r r register_instance s !z(SimpleXMLRPCDispatcher.register_instancec C s2 |d krt | j|dS |d kr$|j}|| j|< |S )N)name)r register_function__name__r! )r' Zfunctionr+ r r r r, s
z(SimpleXMLRPCDispatcher.register_functionc C s | j | j| j| jd d S )N)zsystem.listMethodszsystem.methodSignaturezsystem.methodHelp)r! updatesystem_listMethodssystem_methodSignaturesystem_methodHelpr' r r r register_introspection_functions s
z7SimpleXMLRPCDispatcher.register_introspection_functionsc C s | j d| ji d S )Nzsystem.multicall)r! r. system_multicallr2 r r r register_multicall_functions s z3SimpleXMLRPCDispatcher.register_multicall_functionsc C s zPt || jd\}}|d k r(|||}n | ||}|f}t|d| j| jd}W n tk
r } zt|| j| jd}W 5 d }~X Y nN t \}} }
z$ttdd|| f | j| jd}W 5 d } } }
X Y nX | | jdS )N)r% )Zmethodresponser# r$ )r# r$ %s:%sr$ r# xmlcharrefreplace)
r r% _dispatchr r# r$ r sysexc_infoencode) r' datadispatch_methodpathparamsmethodresponsefaultexc_type exc_valueexc_tbr r r _marshaled_dispatch s0
z*SimpleXMLRPCDispatcher._marshaled_dispatchc C s^ t | j }| jd k rVt| jdr8|t | j O }n t| jdsV|t t| jO }t|S )N _listMethodsr: )setr! keysr" hasattrrI r sorted)r' methodsr r r r/ s
z)SimpleXMLRPCDispatcher.system_listMethodsc C s dS )Nzsignatures not supportedr )r' method_namer r r r0 / s z-SimpleXMLRPCDispatcher.system_methodSignaturec C s d }|| j kr| j | }nX| jd k rrt| jdr<| j|S t| jdsrzt| j|| j}W n tk
rp Y nX |d kr~dS t|S d S )N _methodHelpr: ) r! r" rL rP r r r pydocgetdoc)r' rO rB r r r r1 < s$
z(SimpleXMLRPCDispatcher.system_methodHelpc
C s g }|D ]}|d }|d }z| | ||g W q tk
rj } z| |j|jd W 5 d }~X Y q t \}}} z | dd||f d W 5 d } }} X Y qX q|S )NZ
methodNamerA ) faultCode faultStringr6 r7 )appendr: r rT rU r; r< )
r' Z call_listresultsZcallrO rA rD rE rF rG r r r r4 [ s,
z'SimpleXMLRPCDispatcher.system_multicallc C s z| j | }W n tk
r" Y n X |d k r4|| S td| | jd k rt| jdrd| j||S zt| j|| j}W n tk
r Y nX |d k r|| S td| d S )Nz method "%s" is not supportedr: ) r! KeyError Exceptionr" rL r: r r r )r' rB rA funcr r r r: s*
z SimpleXMLRPCDispatcher._dispatch)FNF)F)NN)NN)r-
__module__ __qualname__r( r* r, r3 r5 rH r/ r0 r1 r4 r: r r r r r s
$
)
$r c @ sb e Zd ZdZdZdZdZedej ej
B Z dd Z dd Z
d
d Zd d
Zdd ZdddZdS )SimpleXMLRPCRequestHandler)/z/RPC2ix Tz
\s* ([^\s;]+) \s* #content-coding
(;\s* q \s*=\s* ([0-9\.]+))? #q
c C s^ i }| j dd}|dD ]<}| j|}|r |d}|rFt|nd}|||d< q |S )NzAccept-EncodingrQ , g ?r6 )headersgetr aepatternmatchgroupfloat)r' rZaeere vr r r accept_encodings s
z+SimpleXMLRPCRequestHandler.accept_encodingsc C s | j r| j| j kS dS d S )NT) rpc_pathsr@ r2 r r r is_rpc_path_valid s z,SimpleXMLRPCRequestHandler.is_rpc_path_validc
C s | s| d S zd}t| jd }g }|rht||}| j|}|sLqh|| |t|d 8 }q,d |}|
|}|d krW d S | j |t
| dd | j}W n tk
r6 } zp| d t| j dr| j jr| dt| t } t| d d
d } | d | | d d
| W 5 d }~X Y nX | d | dd | jd k rt|| jkr| dd}
|
rzt |}| dd W n t k
r Y nX | d tt| | | j | d S )Ni zcontent-lengthr_ r: i _send_traceback_headerz X-exceptionASCIIbackslashreplacez X-tracebackContent-length0 Content-typeztext/xmlgzipr zContent-Encoding) rm
report_404intrb minZrfilereadrV lenjoindecode_request_contentserverrH r r@ rY
send_responserL ro send_headerstr traceback
format_excr= end_headersencode_thresholdrk rc r NotImplementedErrorwfilewrite) r' Zmax_chunk_sizeZsize_remainingLZ
chunk_sizechunkr> rC ri Ztraceqr r r do_POST s`
z"SimpleXMLRPCRequestHandler.do_POSTc C s | j dd }|dkr |S |dkrvz
t|W S tk
rT | dd| Y q tk
rr | dd Y qX n| dd| | dd | d S )
Nzcontent-encodingZidentityrv i zencoding %r not supported zerror decoding gzip contentrr rs ) rb rc lowerr r r
ValueErrorr r )r' r> r$ r r r r} $ s
z1SimpleXMLRPCRequestHandler.decode_request_contentc C sF | d d}| dd | dtt| | | j| d S )Ni s No such pageru z
text/plainrr )r r r r{ r r r r' rC r r r rw 5 s
z%SimpleXMLRPCRequestHandler.report_404-c C s | j jrt| || d S r) )r~ logRequestsr log_request)r' codesizer r r r > s z&SimpleXMLRPCRequestHandler.log_requestN)r r )r- r[ r\ rl r ZwbufsizeZdisable_nagle_algorithmrecompileVERBOSE
IGNORECASErd rk rm r r} rw r r r r r r] s
G r] c @ s* e Zd ZdZdZedddddfddZdS )SimpleXMLRPCServerTFNc C s, || _ t| ||| tj| ||| d S r) )r r r( socketserver TCPServerr' ZaddrZrequestHandlerr r# r$ Zbind_and_activater% r r r r( W s zSimpleXMLRPCServer.__init__)r- r[ r\ Zallow_reuse_addressro r] r( r r r r r D s r c @ s< e Zd ZedddddfddZdd Zdd Zd d
d ZdS )
MultiPathXMLRPCServerTFNc
C s2 t | ||||||| i | _|| _|p*d| _d S r )r r( dispatchersr# r$ r r r r r( h s z MultiPathXMLRPCServer.__init__c C s || j |< |S r) r )r' r@
dispatcherr r r add_dispatcherr s
z$MultiPathXMLRPCServer.add_dispatcherc C s
| j | S r) r )r' r@ r r r get_dispatcherv s z$MultiPathXMLRPCServer.get_dispatcherc C s| z| j | |||}W n^ t d d \}}z2ttdd||f | j| jd}|| jd}W 5 d }}X Y nX |S )N r6 r7 r8 r9 ) r rH r; r< r r r$ r# r= )r' r> r? r@ rC rE rF r r r rH y s"
z)MultiPathXMLRPCServer._marshaled_dispatch)NN)r- r[ r\ r] r( r r rH r r r r r ` s
r c @ s0 e Zd Zd ddZdd Zdd Zd d d
ZdS )
CGIXMLRPCRequestHandlerFNc C s t | ||| d S r) )r r( r& r r r r( s z CGIXMLRPCRequestHandler.__init__c C sP | |}td tdt| t tj tjj| tjj d S )NzContent-Type: text/xmlContent-Length: %d)rH printr{ r; stdoutflushbufferr )r' request_textrC r r r
handle_xmlrpc s
z%CGIXMLRPCRequestHandler.handle_xmlrpcc C s d}t j| \}}tjj|||d }|d}td||f tdtjj tdt| t t j
t j
j
| t j
j d S )Nr )r messageexplainr z
Status: %d %szContent-Type: %sr )r Z responseshttpr~ ZDEFAULT_ERROR_MESSAGEr= r ZDEFAULT_ERROR_CONTENT_TYPEr{ r; r r r r )r' r r r rC r r r
handle_get s
z"CGIXMLRPCRequestHandler.handle_getc C sz |d kr$t jdd dkr$| nRztt jdd }W n ttfk
rV d}Y nX |d krltj |}|
| d S )NZREQUEST_METHODZGETZCONTENT_LENGTHr_ ) osenvironrc r rx r TypeErrorr; stdinrz r )r' r Zlengthr r r handle_request s
z&CGIXMLRPCRequestHandler.handle_request)FNF)N)r- r[ r\ r( r r r r r r r r s
r c @ s: e Zd Zdi i i fddZdi i i dfddZdd ZdS )
ServerHTMLDocNc C sZ |p| j }g }d}td}|||} | s0q:| \}
} |||||
| \} }
}}}}|
r|| dd}|d||f n|rdt| }|d||| f n~|rdt| }|d||| f nV|| | d d kr || |||| n(|r"|d
| n|| || | }q ||||d d
|S ) Nr zM\b((http|ftp)://\S+[\w/]|RFC[- ]?(\d+)|PEP[- ]?(\d+)|(self\.)?((?:\w|\.)+))\b"z"z%sz'http://www.rfc-editor.org/rfc/rfc%d.txtz(http://www.python.org/dev/peps/pep-%04d/r6 (zself.%srQ ) escaper r searchspanrV groupsreplacerx Znamelinkr| )r' textr r! classesrN rW herepatternre startendallZschemeZrfcZpepZselfdotr+ Zurlr r r markup s6
zServerHTMLDoc.markupc C s |r
|j p dd | }d} d| || |f }
t|rHtt|} nd} t|trp|d p`| } |d pld} n
t|} |
| | o| d| }
|
| | j |||}|od| }d |
|f S )
NrQ r z$%sz(...)r r6 z'%sz%sz- %s
%s
) r- r r r r
isinstancetuplerR rS Zgreyr preformat)r' objectr+ modr! r rN ZclZanchorZnotetitleZargspecZ docstringZdecldocr r r
docroutine s2
zServerHTMLDoc.docroutinec C s i }| D ] \}}d| ||< || ||< q | |}d| }| |dd}| || j|} | ohd| } |d| }g }
t| } | D ] \}}|
| j|||d q|| ddd d
|
}|S ) Nz#-z)%sz#ffffffz#7799eez %sz
%s
)r! ZMethodsz#eeaa77rQ )
itemsr Zheadingr r rM rV r Z
bigsectionr| ) r' server_nameZpackage_documentationrN Zfdictkeyvalueheadresultr contentsZ method_itemsr r r docserver s*
zServerHTMLDoc.docserver)r- r[ r\ r r r r r r r r s )
r c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) XMLRPCDocGeneratorc C s d| _ d| _d| _d S )Nz XML-RPC Server DocumentationzGThis server exports the following methods through the XML-RPC protocol.)r server_documentation server_titler2 r r r r( : s zXMLRPCDocGenerator.__init__c C s
|| _ d S r) )r )r' r r r r set_server_titleB s z#XMLRPCDocGenerator.set_server_titlec C s
|| _ d S r) )r )r' r r r r set_server_nameG s z"XMLRPCDocGenerator.set_server_namec C s
|| _ d S r) )r )r' r r r r set_server_documentationL s z+XMLRPCDocGenerator.set_server_documentationc C s i }| D ]}|| jkr&| j| }n| jd k rd d g}t| jdrT| j||d< t| jdrp| j||d< t|}|dkr|}qt| jdszt| j|}W q tk
r |}Y qX q|}n |||< q t }|
| j | j |}|
t| j|S )N_get_method_argstringr rP r6 )NNr: )r/ r! r" rL r rP r r r r r r r Zpagehtmlr r )r' rN rO rB Z method_infoZ
documenterZ
documentationr r r generate_html_documentationQ s<
z.XMLRPCDocGenerator.generate_html_documentationN)r- r[ r\ r( r r r r r r r r r 3 s
r c @ s e Zd Zdd ZdS )DocXMLRPCRequestHandlerc C sf | s| d S | j d}| d | dd | dtt| | | j
| d S )Nr rt ru z text/htmlrr ) rm rw r~ r r= r r r r{ r r r r r r r do_GET s
z DocXMLRPCRequestHandler.do_GETN)r- r[ r\ r r r r r r s
r c @ s" e Zd ZedddddfddZdS )DocXMLRPCServerTFNc
C s& t | ||||||| t| d S r) )r r( r r r r r r( s zDocXMLRPCServer.__init__)r- r[ r\ r r( r r r r r s r c @ s e Zd Zdd Zdd ZdS )DocCGIXMLRPCRequestHandlerc C sT | d}td tdt| t tj tjj| tjj d S )Nr zContent-Type: text/htmlr ) r r= r r{ r; r r r r r r r r r s
z%DocCGIXMLRPCRequestHandler.handle_getc C s t | t| d S r) )r r( r r2 r r r r( s
z#DocCGIXMLRPCRequestHandler.__init__N)r- r[ r\ r r( r r r r r s r __main__c @ s" e Zd Zdd ZG dd dZdS )ExampleServicec C s dS )NZ42r r2 r r r getData s zExampleService.getDatac @ s e Zd Zedd ZdS )zExampleService.currentTimec C s
t j S r) )datetimeZnowr r r r getCurrentTime s z)ExampleService.currentTime.getCurrentTimeN)r- r[ r\ staticmethodr r r r r currentTime s r N)r- r[ r\ r r r r r r r s r )Z localhosti@ c C s | | S r) r )xyr r r rn r add)r z&Serving XML-RPC on localhost port 8000zKIt is advisable to run this example server within a secure, closed network.z&
Keyboard interrupt received, exiting.)T)0Z
xmlrpc.clientr r r r r Z http.serverr functoolsr inspectr r r r r; r r rR r Zfcntl ImportErrorr r r r] r r r r ZHTMLDocr r r r r r- r r r~ r, powr* r5 r Z
serve_foreverKeyboardInterruptexitr r r r k sf
,EbQ