File: //proc/self/root/lib/python3.6/site-packages/rhn/__pycache__/rpclib.cpython-36.pyc
3
�y=jB � @ sh d Z ddljZddlmZmZmZmZ ddl m
Z
G dd� de �Z G dd� dej
�Zd d
� Zd d � ZdS )
z13.0.5-1.module_el8.10.0+7087+bd4dfabe.cloudlinux-� N)�urlparse�
urlunparse� splittype� splithost)�
transportsc @ s e Zd ZdS )�MalformedURIErrorN)�__name__�
__module__� __qualname__� r r � /usr/lib/python3.6/rpclib.pyr s r c sR e Zd ZdZd� fdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
� Z S )�Servera uri [,options] -> a logical connection to an XML-RPC server
uri is the connection point on the server, given as
scheme://host/target.
If the target part and the slash preceding it are both omitted,
"/RPC2" is assumed.
The following options can be given as keyword arguments:
transport: a transport factory
verbose: verbosity level
proxy: use an HTTP proxy
username: username for authenticated HTTP proxy
password: password for authenticated HTTP proxy
Nr c sL |j d�}|d kr,tj||| j|||�d�}| j|� t� j|||d� d S )N�https)� use_https�timeout�proxy)�verbose)�
startswithr ZRequestsTransport�
get_proxy_uri� _reset_host_handler_and_type�super�__init__) �self�uriZ transportr r ZusernameZpasswordr r )� __class__r r r 7 s
zServer.__init__c C s� |d kr d S d}d|kr8|j d�\}}}|j� dkr8d}td||f �}d }|d k rX|}|rp|d k rp|d | }|r�|j|d |j d�}t|�S )N�httpz://r z%s://%s�:�@)�netloc)� partition�lowerr �_replacer r ) r Z
proxy_hostZ
proxy_userZ
proxy_pass�scheme�prefix�_�partsZ auth_stringr r r r G s zServer.get_proxy_uric C sx t |�\}}|dkr td��t|�dk s8|dd� dkr<t�|j� | _| jd krXtd ��t|�\| _| _| jstd
| _dS ) z�
Reset the attributes:
self._host, self._handler, self._type
according the value of self._uri.
Kept for backwards compatibility.
Nzmissing protocol in uri� r � z//r r z unsupported XML-RPC protocolz/RPC2)r r ) r r �lenr Z_type�IOErrorr Z_hostZ_handler)r r �typer r r r i s
z#Server._reset_host_handler_and_typec C s | j j||�S )N)�_ServerProxy__transport�
set_header)r �name�argr r r r, � s zServer.set_headerc C s | j j||�S )N)r+ �
add_header)r r- r. r r r r/ � s zServer.add_headerc C s
| j j� S )N)r+ �
clear_headers)r r r r r0 � s zServer.clear_headersc C s | j j|� d S )N)r+ �set_trusted_cert)r Zcertfiler r r r1 � s zServer.set_trusted_cert)Nr NNNN) r r r
�__doc__r r r r, r/ r0 r1 �
__classcell__r r )r r r
$ s "r
c C s> dd l }t| |j�s*|| kr&| | gS g S dd� | j|�D �S )Nr c S s g | ]}|j d d�d j� �qS )r � )�split�strip)�.0�xr r r �
<listcomp>� s z#getHeaderValues.<locals>.<listcomp>)� mimetools�
isinstanceZMessageZgetallmatchingheaders)�headersr- r: r r r �getHeaderValues� s
r= c C sb d}d}d}|| kr t | | �}d}|| krZt| |�}|rZdj|�}ddl}d|j|� }||fS )z% Reports the error from the headers. r � zX-RHN-Fault-CodezX-RHN-Fault-StringNz%s)�intr= �join�base64Z decodestring)r< Zerrcode�errmsg�sZ_sListZ_srA r r r � reportError� s
rD )� __version__Z
xmlrpc.clientZclientZ xmlrpclibZ urllib.parser r r r Zrhnr r) r Z ServerProxyr
r= rD r r r r �<module> s
i