File: //lib/python3.6/site-packages/S3/__pycache__/Custom_httplib3x.cpython-36.pyc
3
�9pe�, � @ s
d dl mZmZ d dlZd dlZd dljZd dlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZ d dlmZ ddlmZ ddd gZd d d �Zd
d� Zdd� Zd dd�Zd dd�Zdd� Z d!dd�Z G dd� de�Z d"d d �Z eej _!eej"_#e ej"_$e ej"_%eej"_&e ej"_'dS )#� )�absolute_import�print_functionN)
� _CS_REQ_SENT�_CS_REQ_STARTED�CONTINUE�UnknownProtocol�CannotSendHeader�
NO_CONTENT� NOT_MODIFIED�EXPECTATION_FAILED� HTTPMessage�
HTTPException)�StringIO� )� encode_to_s3ZPATCHZPOSTZPUT�datac C sn y
| j d�S tk
rh } zBt|j|j|j|jd|j� | |j|j� |f �}d|_|�W Y dd}~X nX dS )z<Call data.encode("latin-1") but show a better error message.zlatin-1z`%s (%.20r) is not valid Latin-1. Use %s.encode('utf-8') if you want to send it encoded in UTF-8.N)�encode�UnicodeEncodeError�encoding�object�start�end�title� __cause__)r �name�err�exc� r �&/usr/lib/python3.6/Custom_httplib3x.py�_encode s
r c C s� | j dk rdS | j� \}}}| | _| _|j� | _|dkrBd| _n|jd�rTd| _nt|��t j
| j � | _ | _ | j
dkr�x | j D ]}td|d d
� q�W | j jd �}|r�|j� d kr�d
| _d| _nd| _| j� | _d| _| j jd�}|o�| j �r2yt|�| _W n tk
�r d| _Y nX | jdk �r8d| _nd| _|tk�st|tk�std| k�o`dk n �st| jdk�rzd| _| j �r�| j �r�| jdk�r�d
| _dS )z� Re-implemented httplib begin function
to not loop over "100 CONTINUE" status replies
but to report it to higher level so it can be processed.
N�HTTP/1.0�HTTP/0.9�
zHTTP/1.� r zheader:� )r ztransfer-encoding�chunkedTFzcontent-length�d �� ZHEAD)r r! )�headersZ _read_status�code�status�strip�reason�version�
startswithr �httplibZ
parse_headers�fp�msg�
debuglevel�print�get�lowerr% Z
chunk_leftZ _check_closeZ
will_close�length�int�
ValueErrorr r
�_method)�selfr- r* r, �hdrZtr_encr6 r r r �httpresponse_patched_begin* sL
r< c C sd | dkr |j � tkrdS dS t| d�r*dS yt| �}|jS tk
rL Y nX t| t�r`t| �S dS )zG## REIMPLEMENTED because new in last httplib but needed by send_requestNr �read) �upper�_METHODS_EXPECTING_BODY�hasattr�
memoryview�nbytes� TypeError�
isinstance�str�len)�body�methodZmvr r r �)httpconnection_patched_get_content_lengthp s
rI Fc
C s� t jdd� |D ��}i }d|kr(d|d< d|kr8d|d< d}x0|j� D ]$\} }
d | j� krFd
|
j� krFd }qFW | j||f|� d |kr�d
|kr�d}t||�} | d kr�|d k r�| jdkr�td| � d }| jdd� q�| jdt | �� nd}x(|j� D ] \} }
| jt
| �t
|
�� q�W t |t ��r*t |d�}|�s@| j
||d� nX|�sNtd��| j
� | j� } | j� t| _| jtk�r�t� �n| jtk�r�| j||� d S )Nc S s g | ] }|j � �qS r )r5 )�.0�kr r r �
<listcomp>� s z7httpconnection_patched_send_request.<locals>.<listcomp>�hostr Z skip_hostzaccept-encodingZskip_accept_encodingF�expectz 100-continueTzcontent-lengthztransfer-encodingr z Unable to determine size of %rzTransfer-Encodingr% zContent-LengthrG )�encode_chunkedz.A body is required when expecting 100-continue)�dict�fromkeys�itemsr5 Z
putrequestrI r2 r3 Z putheaderrE r rD r �
endheadersr
Z getresponser= r �_HTTPConnection__stater* r �ExpectationFailedr �wrapper_send_body)
r: rH ZurlrG r( rO Z header_namesZskipsZexpect_continuer; �valueZcontent_lengthZrespr r r �#httpconnection_patched_send_request� sN
rX c C s* | j tkrt| _ nt� �| j||d� dS )zDREIMPLEMENTED because new argument encode_chunked added after py 3.4)rO N)rT r r r � _send_output)r: � message_bodyrO r r r �!httpconnection_patched_endheaders� s
r[ c c sd d}| j dkrtd� | j|�}|r6| j dkr6td� x(|j|�}|sHP |rV|jd�}|V q8W dS )zGREIMPLEMENTED because needed by send_output and added after py 3.4
i r zsendIng a read()ablez encoding file using iso-8859-1z
iso-8859-1N)r2 r3 Z
_is_textIOr= r )r: �readableZ blocksizer Z datablockr r r �$httpconnection_patched_read_readable� s
r] c C sF | j jd� dj| j �}| j dd�= | j|� |dk rB| j||� dS )zUREIMPLEMENTED because needed by endheaders and parameter
encode_chunked was added� s
N)r^ r^ )Z_buffer�extend�join�sendrV )r: rZ rO r1 r r r �"httpconnection_patched_send_output� s
rb c @ s e Zd ZdS )rU N)�__name__�
__module__� __qualname__r r r r rU s rU c C s� t |d�r| j|�}nZy t|� W nF tk
rh y t|�}W n$ tk
rb tdt|� ��Y nX Y nX |f}xX|D ]P}|s�| jdkrvtd� qv|r�| jdkr�dj t
|��j d�| d }| j |� qvW |r�| jdkr�| j d � d S )
Nr= zAmessage_body should be a bytes-like object or an iterable, got %rr zZero length chunk ignoredr# z{:X}
�asciis
s 0
)
r@ Z_read_readablerA rC �iter�typer2 r3 Z _http_vsn�formatrF r ra )r: rZ rO Zchunks�chunkr r r �(httpconnection_patched_wrapper_send_body s*
rk )r )F)NF)NF)F)(Z
__future__r r �os�sysZ http.clientZclientr/ r r r r r r r
r r r
�ior Z BaseUtilsr r? r r< rI rX r[ r] rb rU rk Z HTTPResponseZbeginZHTTPConnectionrS Z_send_readablerY Z
_send_requestrV r r r r �<module> s.
0
F!
D
,