ikan Uploader :
Directory : /usr/lib/python3.6/site-packages/rhn/__pycache__/
Upload File : |
| Current File : //usr/lib/python3.6/site-packages/rhn/__pycache__/transports.cpython-36.pyc |
3
�U�f�| � @ sZ d dl Z d dlZd dlZd dlmZ d dlmZmZ d dlm Z d dl
m Z y d dl Z d dl
mZmZmZ W n* ek
r� d dljZ eZeZeZY nX dZdZG d d
� d
e�ZG d d � d e j�ZG d
d� de�Z G dd� de�Z G dd� de �Z G dd� d�Z d%dd�Z d&dd�Z!G dd � d �Z"G d d � d �Z#d'd d �Z$d(d!d"�Z%e#Z&G d#d$� d$�Z'dS ))� N)� connections)�sstr�bstr)�SmartIO)� UserDictCase)�IntType�
StringType�ListTypezI2.8.62.8.6-8.module_el8.10.0+6858+3ddf28328.module_el8.10.0+6858+3ddf2832� c @ s e Zd ZdS )� NotProcessedN)�__name__�
__module__� __qualname__� r r � /usr/lib/python3.6/transports.pyr $ s r c @ s� e Zd Zde Zd'dd�Zd(dd�Zd d
� Zd d � Zd
d� Z d)dd�Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd*d d �Zd d � Zd!d"� Zd#d$� Zd%d&� ZdS )+� Transportzrhn.rpclib.py/%sr Nc C sz d| _ ddd�| _| j||d� t� | _d| _d | _d| _d | _|| _ || _
d| _ d | _ d | _
d | _d | _|| _|| _d S )NFr )�transfer�encoding�POSTi @ )Z_use_builtin_types�_transport_flags�set_transport_flagsr �_headers�verbose�
connection�method�_lang�refreshCallback�progressCallback�
bufferSize�
headers_in�response_status�response_reason� _redirectedZ
_use_datetime�timeout)�selfr r r r Z use_datetimer# r r r �__init__* s" zTransport.__init__� @ c C s || _ || _d S )N)r r )r$ r r r r r �set_progress_callback? s z Transport.set_progress_callbackc C s
|| _ d S )N)r )r$ r r r r �set_refresh_callbackD s z Transport.set_refresh_callbackc C s |d kr d}|| _ d S )Ni @ )r )r$ r r r r �set_buffer_sizeJ s zTransport.set_buffer_sizec C s |dkrt d| ��|| _d S )N�GETr zUnknown request method %s)r* r )�IOErrorr )r$ r r r r �
set_methodR s zTransport.set_methodc K s< | j j|� |d k r || j d< |d k r0|| j d< | j� d S )Nr r )r �update�validate_transport_flags)r$ r r �kwargsr r r r X s
z Transport.set_transport_flagsc C s
| j j� S )N)r �copy)r$ r r r �get_transport_flagsc s z Transport.get_transport_flagsc C sH | j jd�}t|dd�}|| j d< | j jd�}t|dd�}|| j d< d S )Nr � )�strictr )r �get�lookupTransfer�lookupEncoding)r$ r r r r r r. f s
z"Transport.validate_transport_flagsc C s@ t |�t g �t f �gkr.dd� |D �| j|< nt|�| j|< d S )Nc S s g | ] }t |��qS r )�str)�.0�ar r r �
<listcomp>t s z(Transport.set_header.<locals>.<listcomp>)�typer r7 )r$ �name�argr r r �
set_headerq s zTransport.set_headerc C sF || j kr&| j | }t|t�s4|g}ng }| j |< |jt|�� d S )N)r �
isinstancer �appendr7 )r$ r< r= Zvlistr r r �
add_headerx s
zTransport.add_headerc C s | j j� d S )N)r �clear)r$ r r r �
clear_headers� s zTransport.clear_headersc C s8 | j rtd|f � | jr*tj|| jd�S tj|�S d S )NzConnecting via http to %s)r# )r �printr# r �HTTPConnection)r$ �hostr r r �get_connection� s
zTransport.get_connectionc C sX || _ | j|�\}}}|s g }| j|�}|j| j� | j rJ|j| j d � t|| jd�}|jf | j � |j
d| j� x*t | j j
� �| D ]\} }
|j
| |
� q�W |j
dd� |j|� xd
D ]} |j| � q�W |j||�\} }
| j �rtd� x$| j
� D ]\} }
td | |
f � q�W |
jdk�r6| d | _|
j| _d S | | _|
j| _|
j| _| j|
|�S )Nr2 )r r z
User-Agentz Content-Typeztext/xml�Content-Length�HostzIncoming headers:z %s : %s�- �. ZLocation)rH rI )rJ rK )r �
get_host_inforG Zset_user_agent�
user_agentZset_debuglevel�Outputr r r r> �listr �items�process� clear_header� send_httprD �statusr" r r �reasonr! �_process_response)r$ rF �handlerZ request_bodyr �
extra_headers�x509r Zreq�header�value�h�headers�fdr r r �request� s<
zTransport.requestc C sb t | j| j| jd�}|j|�}t|t�rPt|j|j |j
| j| jd�}|j |_ |S |j � | j |�S )N)r r )r r )
�Inputr r r �decoder? � InputStream�Filer^ �lengthr< �close�parse_response)r$ r^ r Zresp�fr r r rV � s
zTransport._process_responsec C s | j S )N)r" )r$ r r r �
redirected� s zTransport.redirectedc C sf | j � \}}x@|jd�}|s P | jr,| j� | jr@tdt|�� |j|� qW |j� |j� |j� S )Ni zbody:)Z getparser�readr r rD �reprZfeedre )r$ rg �p�u�responser r r rf � s
zTransport.parse_responsec C s
|| _ d S )N)r )r$ �langr r r �setlang� s zTransport.setlang)r r NNNN)r& )NN)r )r r
r � __version__rM r% r' r( r) r, r r1 r. r> rA rC rG r_ rV rh rf ro r r r r r ' s&
8 r c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�
SafeTransportr Nc C s< t j| |||||d� g | _x|p$g D ]}| j|� q&W d S )N)r r r# )r r% �
trusted_certs�add_trusted_cert)r$ r r r r rr r# �certfiler r r r% � s
zSafeTransport.__init__c C s* t j|t j�std| ��| jj|� d S )Nz%Certificate file %s is not accessible)�os�access�R_OK�
ValueErrorrr r@ )r$ rt r r r rs s z SafeTransport.add_trusted_certc C sR | j |�\}}}| jr$td|f � | jr>tj|| j| jd�S tj|| jd�S d S )NzConnecting via https to %s)rr r# )rr )rL r rD r# r ZHTTPSConnectionrr )r$ rF rX rY r r r rG s z SafeTransport.get_connection)r r NNNN)r r
r r% rs rG r r r r rq � s
rq c @ s e Zd Zddd�Zdd� ZdS )�ProxyTransportNr c C s, t j| |||||d� || _|| _|| _d S )N)r r r# )r r% �_proxy�_proxy_username�_proxy_password) r$ �proxy�
proxyUsername�
proxyPasswordr r r r r# r r r r% s
zProxyTransport.__init__c C s^ | j r td|| j| j| jf � | jrBtj| j|| j| j| jd�S tj| j|| j| jd�S d S )Nz8Connecting via http to %s proxy %s, username %s, pass %s)�username�passwordr# )r� r� )r rD rz r{ r| r# r ZHTTPProxyConnection)r$ rF r r r rG # s
z ProxyTransport.get_connection)NNr r NNN)r r
r r% rG r r r r ry s
ry c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�SafeProxyTransportNr c
C sB t j| |||||||| d� g | _x|p*g D ]}
| j|
� q,W d S )N)r~ r r r r r r# )ry r% rr rs ) r$ r} r~ r r r r r rr r# rt r r r r% 0 s zSafeProxyTransport.__init__c C s* t j|t j�std| ��| jj|� d S )Nz%Certificate file %s is not accessible)ru rv rw rx rr r@ )r$ rt r r r rs = s z#SafeProxyTransport.add_trusted_certc C sf | j r td|| j| j| jf � | jrFtj| j|| j| j| j| jd�S tj| j|| j| j| jd�S d S )Nz9Connecting via https to %s proxy %s, username %s, pass %s)r� r� rr r# )r� r� rr ) r rD rz r{ r| r# r ZHTTPSProxyConnectionrr )r$ rF r r r rG B s
z!SafeProxyTransport.get_connection)NNr r NNNN)r r
r r% rs rG r r r r r� / s
r� c @ s: e Zd Zd dd�Zejfdd�Zejfdd �Zd
d � ZdS )
r` N� � @ c C s� d | _ d | _d | _d| _d| _d| _|| _|| _|| _|s�dt j
krTt j
d j � | _ dt j
krnt j
d j � | _dt j
kr�t j
d j � | _dt j
kr�t t j
d �| _dt j
kr�t j
d | _d t j
kr�t j
d | _n�x�|j
� D ]�}|| }|j � }|d
k�r&yt |�| _W n tk
�r" d| _Y nX q�|d k�r<|j � | _ q�|d k�rR|j � | _q�|d
k�rh|j � | _q�|dk�r~|j � | _q�|dkr�|| _q�W d | _d S )Nr �C� Z HTTP_CONTENT_TRANSFER_ENCODINGZHTTP_CONTENT_ENCODINGz CONTENT-TYPEZCONTENT_LENGTHZHTTP_ACCEPT_LANGUAGEZHTTP_X_PACKAGE_FILENAMEzcontent-lengthzcontent-transfer-encodingzcontent-encodingz content-typezaccept-languagezx-package-filename)r r r; rd rn r< r r � max_mem_sizeru �environ�lower�int�keysrx �io)r$ r] r r r� rZ r[ r\ r r r r% h sR
zInput.__init__c C s� | j dkrd S | jr2t|| j| j| j| jd�| _n
t|�| _| j sN| jdkrRd S | jdkr�dd l }| j}|j
dd� t | jd�| _|j || j� n
t
| j��d S )Nzapplication/octet-stream)r r r� �binary�base64r )r� )r; rd � _smart_readr r r� r� �_smart_total_readr r� �seekr ra �NotImplementedError)r$ r^ r� Zold_ior r r ri � s"
z
Input.readc C s^ | j dkr t|| j| j|jd�S | js0| j|� t|d�rB|j� | j sT| jdkrVn�| jdkr�dd l }|j
� }| jj dd� |j | jj� �|j
� }~t|�| _t| jd�| _| jj|� n�| jdk�r dd l}| jj dd� |jd t| jd �}|j� }t|�| _t| jd�| _| jj|� n*| jd
k�r<t| j| j��nt| j| j��| jj dd� | jS )Nzapplication/octet-stream)re re �__plain�x-zlib�deflater )r� �x-gzip�gzip�rb)�mode�
compresslevel�fileobjzx-gpg)r� r� )r� r� )r; rb rd r< re r� ri �hasattrr �zlibZ
decompressobjr� Z
decompress�flush�lenr r� �writer� �GzipFile�COMPRESS_LEVELr� r )r$ r^ r� �obj�datar� �gzr r r ra � s>
z Input.decodec C s | j S )N)rn )r$ r r r �getlang� s z
Input.getlang)NNr� r� ) r r
r r% �sys�stdinri ra r� r r r r r` g s
70r` � � @ c C s. t |d�}x | j|�}|s P |j|� q W |S )z�
Tries to read data from the supplied stream, and puts the results into a
StmartIO object. The data will be in memory or in a temporary file,
depending on how much it's been read
Returns a SmartIO object
)r� )r ri r� )r^ r r� r� �chunkr r r r� � s
r� c C s� t j � }|}t|d�}|}x�|dkr�t j � } t||�}
| j|
�} t| �}
|
sNP ||
}|j| � |d krjq | | dks~|dkr | }t|| �} | | | d }
|dkr�d}n||
}|| ||
|� q W |jdd� |S )N)r� r r2 g���ư>)�timer �minri r� r� �floatr� )r^ �amtr r r� Z startTimeZlastTime�bufZorigsizeZcurTime�lr� Z bytesReadZspeedZsecsr r r r� s2
r� c @ s e Zd Zddd�Zdd� ZdS )rb � <unknown>Nc C s || _ t|�| _|| _|| _d S )N)r^ r� rd r< re )r$ r^ rd r< re r r r r% = s
zInputStream.__init__c C s d| j | jf S )Nz0Input data is a stream of %d bytes for file %s.
)rd r< )r$ r r r �__repr__C s zInputStream.__repr__)r� N)r r
r r% r� r r r r rb < s
rb c @ s� e Zd ZdZdZdZdZdZdZdZ ddgddgd d
gd ggZ
dd d
gZ d dd�Z dd� Z
dd� Zdd� Zd!dd�Zd"dd�Zd d � Zd d � ZdS )#�
BaseOutputr r2 � � Nr� zx-gzipr� zx-zlibr� zx-gpgr� r� r c C s� |rt |tj�std��|| _|| _d | _t� | _d| _ d| _
i | _ d | _ d | _
d | _d | _d | _d | _| j||d� d| _d S )Nz&Expected an HTTPConnection type objectr )r r )r? r rE � Exceptionr � _connectionr� r r] r r �transport_flagsr� r� �_hostZ_handlerZ
_http_typeZ _protocolr �_BaseOutput__processed)r$ r r r r r r r r% c s$ zBaseOutput.__init__c C sB t |�t g �t f �gkr0djtt|��| j|< nt|�| j|< d S )N�,)r; �join�mapr7 r] )r$ r< r= r r r r> � s zBaseOutput.set_headerc C s || j kr| j |= d S )N)r] )r$ r< r r r rR � s
zBaseOutput.clear_headerc C s� || _ | j| jkr�dd l}| j| j d }| jd|� tdd�}|jdt|d�}t j
d dkrn|j t |�� n|j t
|�� |j� |j� | _ |j� n�| j| jkr�dd l}| j| j d }| jd|� |jt�}|j|�|j� | _ n8| j| jk�r t| j| j��| j| j d }| jd|� | j| jk�rT| j| j }| jd|� | jd d
� nH| j| jk�r�dd l} | j| j }| jd|� | jd d � | j | j �| _ | jd t | j �� t }
t t j � �dk�r�t j � d }
| jd
d|
� d| _ d S )Nr zContent-Encodingr2 )Z force_mem�wb)r� r� r� r� zContent-Transfer-Encodingz Content-Typezapplication/binaryz text/base64zContent-LengthzX-Transport-Infoz=Extended Capabilities Transport (C) Red Hat, Inc (version %s))!r� r � ENCODE_GZIPr� � encodingsr> r r� r� r� � version_infor� r r re �getvalue� ENCODE_ZLIBr� Z compressobj�compressr� �
ENCODE_GPGr� r �TRANSFER_BINARY� transfers�TRANSFER_BASE64r� Z encodestringr� rp �splitr� ) r$ r� r� Z
encoding_namerg r� r� r� Z
transfer_namer� Z rpc_versionr r r rQ � sT
zBaseOutput.processc K s || _ || _| jj|� d S )N)r r r� r- )r$ r r r/ r r r r � s z BaseOutput.set_transport_flags�/RPC2c C s� | j s
t�|| _| jd kr"td��| jj� | jj| j|t| j �| j
d� | jj � }| j |�s~t
jd| j|f |j|j|j��|j|fS )NzNo connection object found)Zbodyr] z%s %s)r� r r� r� r� Zconnectr_ r r r� r] Z getresponse�response_acceptable� xmlrpclibZ
ProtocolErrorrT rU �msg)r$ rF rW rm r r r rS � s
zBaseOutput.send_httpc C sP |j dkrdS |j d
kr dS |j dkr*dS | jjd�s:dS |jd d krLdS dS ) z*Returns true if the response is acceptable�� r2 �- �. �� r Zallow_partial_contentz Content-Typezapplication/octet-stream)r� r� )rT r� r4 r� )r$ rm r r r r� � s
z BaseOutput.response_acceptablec C s | j r| j j� d | _ d S )N)r� re )r$ r r r re � s
zBaseOutput.close)r r Nr )r r )r� )r r
r Z ENCODE_NONEr� r� r� Z
TRANSFER_NONEr� r� r� r� r% r> rR rQ r rS r� re r r r r r� I s,
8
r� c C s� | dkr dS t | t�r8d| ko.ttj�k n r8| S t | t�rpx,tttj��D ]}tj| | j� krR|S qRW |r�td| ��dS )zTGiven a string or numeric representation of a transfer, return the
transfer codeNr zUnsupported transfer %s) r? r r� rN r� r �ranger� rx )r r3 �ir r r r5 s (
r5 c C s� | dkr dS t | t�r8d| ko.ttj�k n r8| S t | t�rpx,tttj��D ]}| j� tj| krR|S qRW |r�td| ��dS )zUGiven a string or numeric representation of an encoding, return the
encoding codeNr zUnsupported encoding %s) r? r r� rN r� r r� r� rx )r r3 r� r r r r6 s (
r6 c @ s@ e Zd Zddd�Zdd� Zddd �Zd
d � Zd d
� Zdd� ZdS )rc r N� @ c C sF || _ || _|j| _|| _d| _|r<||jd�d d � | _|| _d S )Nr� �/r2 )rd �file_objre r r< �rfindr )r$ r� rd r< r r r r r r% & s z
File.__init__c C s | j S )N)rd )r$ r r r �__len__1 s z File.__len__c C s$ |d kr| j � }|j� S | jj|�S )N)� _get_fileri r� )r$ r� r^ r r r ri 4 s z File.readc C sP | j � }xB|j| j�}|s P tjd dkr:|jt|�� q
|jt|�� q
W |S )zHCopies the contents of this File object into another file
objectr r� )r� ri r r� r� r� r r )r$ �filer^ r� r r r � read_to_file< s zFile.read_to_filec C sL | j r,t| j| j | j| jd�}|jdd� nt| j| jd�}|jdd� |S )z�Read everything into a temporary file and call the progress
callbacks if the file length is defined, or just reads till EOF)r r r )r )rd r� r� r r r� r� )r$ r� r r r r� J s
zFile._get_filec C s | j r| j � d | _ d S )N)re )r$ r r r �__del__X s z File.__del__)r NNr� )N) r r
r r% r� ri r� r� r� r r r r rc % s
rc )r� r� )r� Nr� )r )r )(ru r� r� Zrhnr Zrhn.i18nr r Z rhn.SmartIOr Zrhn.UserDictCaser r� �typesr r r � ImportErrorZ
xmlrpc.clientZclientr� �bytesrO rp r� r� r r rq ry r� r` r� r� rb r� r5 r6 rN rc r r r r �<module>
sD
V 8
;
8
........