Edit File: xmlrpc.cpython-36.pyc
3 �k�` T � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m Z d dl m Z d dl m Z d dl m Z d dl mZ d dl mZ d d l mZ d d l mZ d d l mZ d d lmZ d d lmZ d dlmZ d dlmZ G dd� d�Zdd� Z G dd� de �Z G dd� d�Z dd� Z G dd� d�Z!G d d � d e"�Z#G d d � d �Z$d d!� Z%d"d#� Z&G d$d%� d%e�Z'd&d'� Z(G d(d)� d)e j)�Z*G d*d+� d+ej+�Z,d,d-� Z-dS ).� N)� iterparse)� xmlrpclib)�StringIO)�urllib)�as_bytes)� as_string)� encodestring)� decodestring)�httplib)�PY2)� get_header)�xmlrpc_handler)� producers)� NOT_DONE_YETc @ sT e Zd ZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdS )�Faults� � � � � � � � � � �( �2 �< �F �P �Z �[ �\ N)�__name__� __module__� __qualname__�UNKNOWN_METHOD�INCORRECT_PARAMETERSZ BAD_ARGUMENTS�SIGNATURE_UNSUPPORTEDZSHUTDOWN_STATEZBAD_NAMEZ BAD_SIGNALZNO_FILEZNOT_EXECUTABLE�FAILEDZABNORMAL_TERMINATIONZ SPAWN_ERRORZALREADY_STARTEDZ NOT_RUNNING�SUCCESSZ ALREADY_ADDEDZ STILL_RUNNINGZ CANT_REREAD� r+ r+ � /usr/lib/python3.6/xmlrpc.pyr s$ r c C s& x t jD ]}tt |�| kr|S qW dS )NZUNKNOWN)r �__dict__�getattr)�codeZ faultnamer+ r+ r, �getFaultDescription. s r0 c @ s e Zd Zddd�Zdd� ZdS )�RPCErrorNc C s, || _ t|�| _|d k r(d| j|f | _d S )Nz%s: %s)r/ r0 �text)�selfr/ Zextrar+ r+ r, �__init__5 s zRPCError.__init__c C s d| j | jf S )Nzcode=%r, text=%r)r/ r2 )r3 r+ r+ r, �__str__; s zRPCError.__str__)N)r# r$ r% r4 r5 r+ r+ r+ r, r1 4 s r1 c @ s6 e Zd ZdZejdej�Zdd� Zdd� Z dd� Z d S ) �DeferredXMLRPCResponsez� A medusa producer that implements a deferred callback; requires a subclass of asynchat.async_chat that handles NOT_DONE_YET sentinel zConnection: (.*)c C s" || _ || _d| _t|j�| _d S )NF)�callback�request�finished�float�delay)r3 r8 r7 r+ r+ r, r4 C s z DeferredXMLRPCResponse.__init__c C s� | j r dS ydy| j� }|tkr"tS W n2 tk rV } ztj|j|j�}W Y d d }~X nX t|�}d| _ | j |�S t j � }| j j jjjd|� d| _ | j jd� Y nX d S )N� Tz XML-RPC response callback errori� )r9 r7 r r1 r �Faultr/ r2 �xmlrpc_marshal� getresponse� traceback� format_excr8 �channelZserver�logger�log�error)r3 �value�err�body�tbr+ r+ r, �moreI s$ " zDeferredXMLRPCResponse.morec C s d| j d< t|�| j d< | j j|� t| j| j j�}d}| j jdkr^|dkrXd| j d< q�d }n*| j jd krx|d kr�d }n| j jd kr�d }tj| j j � �}|r�d | j d< | j j j d|� tj | j j �}| j j jtjtj|| j j��� d | j j _|r�| j j j� d S ) Nztext/xmlz Content-TypezContent-Lengthr z1.0z keep-alivez Keep-AliveZ Connectionr z1.1�close)r8 �len�pushr � CONNECTION�header�versionr Zsimple_producerZbuild_reply_headerZoutgoing�insertZcomposite_producerrB �push_with_producerZglobbing_producerZhooked_producerrD Zcurrent_requestZclose_when_done)r3 rH � connectionZclose_itZoutgoing_headerZoutgoing_producerr+ r+ r, r? b s8 z"DeferredXMLRPCResponse.getresponseN) r# r$ r% �__doc__�re�compile� IGNORECASErN r4 rJ r? r+ r+ r+ r, r6 > s r6 c C s@ t | tj� }|r2t | t�s"| f} tj| |d�}n tj| �}|S )N)Zmethodresponse)� isinstancer r= �tuple�dumps)rF ZismethodresponserH r+ r+ r, r> � s r> c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�SystemNamespaceRPCInterfacec C s0 i | _ x|D ]\}}|| j |< q W | | j d< d S )N�system)� namespaces)r3 r] �nameZinstr+ r+ r, r4 � s z$SystemNamespaceRPCInterface.__init__c C sj i }x`| j D ]V}| j | }xF|jjD ]:}t||�}t|�r$|jd�s$d||f }t|j�||< q$W q W |S )N�_z%s.%s)r] � __class__r- r. �callable� startswith�strrT )r3 �methodsZns_name� namespaceZ method_name�funcZsigr+ r+ r, � _listMethods� s z(SystemNamespaceRPCInterface._listMethodsc C s | j � }t|j� �}|j� |S )z� Return an array listing the available method names @return array result An array of method names available (strings). )rg �list�keys�sort)r3 rd ri r+ r+ r, � listMethods� s z'SystemNamespaceRPCInterface.listMethodsc C s8 | j � }x |j� D ]}||kr|| S qW ttj��dS )z� Return a string showing the method's documentation @param string name The name of the method. @return string result The documentation for the method name. N)rg ri r1 r r( )r3 r^ rd Z methodnamer+ r+ r, � methodHelp� s z&SystemNamespaceRPCInterface.methodHelpc C s� | j � }x�|D ]z}||krd}g }t|| �}x<|D ]4}|d dkrN|d }q4|d dkr4|j|d � q4W |dkr~ttj��|g| S qW ttj��dS )ab Return an array describing the method signature in the form [rtype, ptype, ptype...] where rtype is the return data type of the method, and ptypes are the parameter data types that the method accepts in method argument order. @param string name The name of the method. @return array result The result. Nr �returnr �param)rg �gettags�appendr1 r r( )r3 r^ rd �methodZrtypeZptypesZparsed�thingr+ r+ r, �methodSignature� s z+SystemNamespaceRPCInterface.methodSignaturec sH |dd� }g }g }|||f� fdd� }d|_ |� }|tkr@|S |S dS )a Process an array of calls, and return an array of results. Calls should be structs of the form {'methodName': string, 'params': array}. Each result will either be a single-item array containing the result value, or a struct of the form {'faultCode': int, 'faultString': string}. This is useful when you need to make lots of small calls without lots of round trips. @param array calls An array of call requests @return array result An array of results Nc s� |r�y|d � }W nf t k rB } z|j|jd�}W Y d d }~X n8 tj� }d|d |d f }tjd| d�}Y nX |tk r�|jd� |j |� �x| o�| �r�| jd�}|j dd �}|j dg �} yB|d kr�t tj d��|d kr�t tj d ��t � j �} t| || �}W nh t k �r< } z|j|jd�}W Y d d }~X n8 tj� }d|d |d f }tjd| d�}Y nX t|tj��r�|j |� q�|j |� q�W |�s�| �r�tS |S d S ) Nr )Z faultCodeZ faultStringz%s:%sr zFAILED: � methodName�paramsz No methodNamezsystem.multicallz$Recursive system.multicall forbidden)r1 r/ r2 �sys�exc_infor r) r �poprp �getr' �AttrDictr] �traverserX �types� FunctionType) �remaining_calls� callbacks�resultsrF �exc�info�errmsg�callr^ ru �root)r3 r+ r, �multi� sR z4SystemNamespaceRPCInterface.multicall.<locals>.multig�������?)r; r )r3 Zcallsr~ r r� r� rF r+ )r3 r, � multicall� s 6z%SystemNamespaceRPCInterface.multicallN) r# r$ r% r4 rg rk rl rs r� r+ r+ r+ r, r[ � s r[ c @ s e Zd Zdd� ZdS )rz c C s | j |�S )N)ry )r3 r^ r+ r+ r, � __getattr__3 s zAttrDict.__getattr__N)r# r$ r% r� r+ r+ r+ r, rz 1 s rz c @ s e Zd Zdd� ZdS )�RootRPCInterfacec C s" x |D ]\}}t | ||� qW d S )N)�setattr)r3 � subinterfacesr^ � rpcinterfacer+ r+ r, r4 7 s zRootRPCInterface.__init__N)r# r$ r% r4 r+ r+ r+ r, r� 6 s r� c C s. t | �}|tjk rtj}n|tjkr*tj}|S )N)�intr ZMININTZMAXINT)rF �ir+ r+ r, � capped_int; s r� c C s t j tj| d�d d� � S )Nz%Y%m%dT%H:%M:%Sr )�datetime�timeZstrptime)r2 r+ r+ r, � make_datetimeC s r� c @ s� e Zd ZdZdZdd� dd� dd� dd� dd� d d� d d� d d� d d� d d� dd� d� Zdd� Zdd� Zdd� Zdd� Z dd� Z dS )�supervisor_xmlrpc_handlerz/RPC2zSupervisor XML-RPC Handlerc C s t | j�S )N)r� r2 )�xr+ r+ r, �<lambda>M s z"supervisor_xmlrpc_handler.<lambda>c C s t | j�S )N)r� r2 )r� r+ r+ r, r� N s c C s | j dkS )N�1)r2 )r� r+ r+ r, r� O s c C s | j pdS )Nr< )r2 )r� r+ r+ r, r� P s c C s t | j�S )N)r: r2 )r� r+ r+ r, r� Q s c C s t | j�S )N)r� r2 )r� r+ r+ r, r� R s c C s | d j S )Nr )r2 )r� r+ r+ r, r� S s c C s dd� | D �S )Nc S s g | ] }|j �qS r+ )r2 )�.0�vr+ r+ r, � <listcomp>T s z6supervisor_xmlrpc_handler.<lambda>.<locals>.<listcomp>r+ )r� r+ r+ r, r� T s c C s t dd� | D ��S )Nc S s g | ]\}}|j pd |j f�qS )r< )r2 )r� �kr� r+ r+ r, r� U s z6supervisor_xmlrpc_handler.<lambda>.<locals>.<listcomp>)�dict)r� r+ r+ r, r� U s c C s t tt| jpd���S )Nr< )r r r r2 )r� r+ r+ r, r� V s c C s | d j S )Nr )r2 )r� r+ r+ r, r� W s ) r� Zi4Zboolean�stringZdoublezdateTime.iso8601Zarray�data�struct�base64rn c C s t |�| _|| _d S )N)r� r� � supervisord)r3 r� r� r+ r+ r, r4 Z s z"supervisor_xmlrpc_handler.__init__c C s� d }}x�t t|��D ]�\}}| jj|j�}|rH||�}|j� ||_q|jdkr�y|d j}W n tk r~ |jpxd}Y nX |j� ||_q|jdkr�|j}q|jdkrtdd� |D ��}qW ||fS )NrF r r< rt ru c S s g | ] }|j �qS r+ )r2 )r� r� r+ r+ r, r� p s z3supervisor_xmlrpc_handler.loads.<locals>.<listcomp>) r r � unmarshallersry �tag�clearr2 � IndexErrorrY )r3 r� ru rq �action�elemZ unmarshallr+ r+ r, �loads^ s& z supervisor_xmlrpc_handler.loadsc C s |j j| j�S )N)�urirb �path)r3 r8 r+ r+ r, �matchs s z supervisor_xmlrpc_handler.matchc C s� | j jj}�yLy"tr |jdd�}| j|�\}}W n$ |jd|f � |jd� d S |sx|jd|f � |jd� d S |d kr�f }y,|jd| � | j||�}|jd| � W nL t k � r� } z.t j |j |j �}|jd||j |j f � W Y d d }~X nX t|tj��r$|jj}|t||�� n2tt|��} d |d < t| �|d < |j| � |j� W n0 tj� } |jd || f � |jd � Y nX d S )N�ascii�xmlcharrefreplacez2XML-RPC request data %r is invalid: unmarshallablei� z2XML-RPC request data %r is invalid: no method namezXML-RPC method called: %s()z)XML-RPC method %s() returned successfullyz+XML-RPC method %s() returned fault: [%d] %sztext/xmlz Content-TypezContent-LengthzHHandling XML-RPC request with data %r raised an unexpected exception: %si� ) r� ZoptionsrC r �encoder� rE Ztracer� r1 r r= r/ r2 rX r| r} rB rR r6 r r> rL rM �doner@ rA Zcritical) r3 r� r8 rC ru rq rF rG Z pushproducerrH rI r+ r+ r, �continue_requestv sX " z*supervisor_xmlrpc_handler.continue_requestc C s t | j||�S )N)r{ r� )r3 rq ru r+ r+ r, r� � s z supervisor_xmlrpc_handler.callN) r# r$ r% r� ZIDENTr� r4 r� r� r� r� r+ r+ r+ r, r� H s$ Gr� c C s� |j d�}t|�dkr ttj��|\}}|jd�r<ttj��t| |d �}|d krZttj��t||d �}t|tj �s|ttj��y||� S t k r� ttj ��Y nX d S )N�.r r_ ) �splitrL r1 r r& rb r. rX r| � MethodType� TypeErrorr' )�obrq ru Z dotted_partsre r� rf r+ r+ r, r{ � s r{ c @ s0 e Zd ZdZdZd dd�Zdd� Zd dd �ZdS ) �SupervisorTransportz� Provides a Transport for xmlrpclib that uses httplib.HTTPConnection in order to support persistent connections. Also support basic auth and UNIX domain socket servers. Nc C s� t jj| � || _|| _d| _|| _|jd�r�tj |�\}}tj |�\}}tj |�\}}|d krfd}nt |�}||fdd�} | | _ n*|jd�r�|fdd�} | | _ n td| ��d S ) NFzhttp://r c S s t j| |�S )N)r �HTTPConnection)�host�portr+ r+ r, �get_connection� s z4SupervisorTransport.__init__.<locals>.get_connectionzunix://c S s t d�}| dd � |_|S )NZ localhost� )�UnixStreamHTTPConnection� socketfile)� serverurlZconnr+ r+ r, r� � s z!Unknown protocol for serverurl %s)r � Transportr4 �username�password�verboser� rb r Z splittypeZ splithostZ splitportr� �_get_connection� ValueError) r3 r� r� r� �typer� r� r� r� r� r+ r+ r, r4 � s$ z SupervisorTransport.__init__c C s | j r| j j� d | _ d S )N)rS rK )r3 r+ r+ r, rK � s zSupervisorTransport.closer c C s& t |�}| js�| j� | _| jddd�| _| jd k r�| jd k r�d| j| jf }ttt |���}|j dd�}|j dd�}d| | jd< t t |��| jd< | jj d ||| j� | jj � }|jd kr�| jj� d | _tj|| |j|jd��|j� }t|�}|jd d �}| j� \} } | j|� | j� | j� S ) Nztext/xml)z User-Agentz Content-TypeZAcceptz%s:%s� r< zBasic %sZ AuthorizationzContent-LengthZPOST�� r� r� )r rS r� Z user_agentZheadersr� r� r r �replacerc rL r8 r? ZstatusrK r Z ProtocolError�reason�readr� Z getparserZfeed) r3 r� ZhandlerZ request_bodyr� Z unencodedZencoded�rr� �p�ur+ r+ r, r8 s: zSupervisorTransport.request)NNN)r )r# r$ r% rT rS r4 rK r8 r+ r+ r+ r, r� � s r� c @ s e Zd Zdd� ZdS )r� c C s$ t j t jt j�| _| jj| j� d S )N)�socketZAF_UNIXZ SOCK_STREAMZsock�connectr� )r3 r+ r+ r, r� - s z UnixStreamHTTPConnection.connectN)r# r$ r% r� r+ r+ r+ r, r� , s r� c C s8 g }d}d}d}d }}g }x�| j d�D ]�}|j� }|jd�r�|j||||dj|�f� |j dd�} t| �dkr~d}d}g }njt| �dkr�| d }d}g }nLt| �dkr�| d }| d }g }n*t| �d kr�| d }| d }| d j� g}| d dd� }|}n|�r|j|� |d7 }q(W |j||||dj|�f� |S ) z6 Parse documentation strings into JavaDoc-like tokens Nr r� �@r r r< r r )r� �striprb rp �joinrL �lstrip) ZcommentZtagsr� Zdatatyper^ Z tag_lineno�linenoZtag_text�line�partsr+ r+ r, ro 2 sD ro ).r� rU r� rv r� r@ r| Zxml.etree.ElementTreer Zsupervisor.compatr r r r r r r r r Z supervisor.medusa.http_serverr Z supervisor.medusa.xmlrpc_handlerr Zsupervisor.medusar Zsupervisor.httpr r r0 � Exceptionr1 r6 r> r[ r� rz r� r� r� r� r{ r� r� r� r� ro r+ r+ r+ r, �<module> sH R xS
Back to File Manager