| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/cygwin64/lib/python3.9/site-packages/urllib3/__pycache__/ |
Upload File : |
a
�?�a+n � @ sV d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ d dlm
Z z d dl Z W n e
yj dZ Y n0 ddlmZ ddlmZmZ dd lmZmZmZmZmZmZmZmZm Z m Z dd
l m Z dd l m!Z!m"Z" e�#e$�Z%G d d
� d
e&�Z'G dd� de&�Z(G dd� de&�Z)e du�r(G dd� de&�Z*G dd� de&�Z+dd� Z,G dd� dej-�Z.dS )� )�absolute_importN)�contextmanager)�error)�timeout� )�HTTPHeaderDict)� BaseSSLError�
HTTPException)
�BodyNotHttplibCompatible� DecodeError� HTTPError�IncompleteRead�InvalidChunkLength�
InvalidHeader�
ProtocolError�ReadTimeoutError�ResponseNotChunked�SSLError)�six)� is_fp_closed�is_response_to_headc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DeflateDecoderc C s d| _ d| _t�� | _d S )NT� )�
_first_try�_data�zlib�
decompressobj�_obj��self� r �4/usr/lib/python3.9/site-packages/urllib3/response.py�__init__$ s zDeflateDecoder.__init__c C s t | j|�S �N��getattrr �r �namer r r! � __getattr__) s zDeflateDecoder.__getattr__c C s� |s|S | j s| j�|�S | j|7 _z"| j�|�}|rFd| _ d | _|W S tjy� d| _ t�tj �| _z| �| j�W d | _ Y S d | _0 Y n0 d S )NF)r r �
decompressr r r r � MAX_WBITS)r �dataZ decompressedr r r! r) , s& �zDeflateDecoder.decompressN��__name__�
__module__� __qualname__r" r( r) r r r r! r # s r c @ s e Zd ZdZdZdZdS )�GzipDecoderStater r � N)r- r. r/ � FIRST_MEMBER�
OTHER_MEMBERS� SWALLOW_DATAr r r r! r0 C s r0 c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� GzipDecoderc C s t �dt j �| _tj| _d S �N� )r r r* r r0 r2 �_stater r r r! r" K s zGzipDecoder.__init__c C s t | j|�S r# r$ r& r r r! r( O s zGzipDecoder.__getattr__c C s� t � }| jtjks|s t|�S z|| j�|�7 }W n: tjyl | j}tj| _|tj krft|� Y S � Y n0 | jj
}|s�t|�S tj | _t� dtj �| _q d S r6 )
� bytearrayr8 r0 r4 �bytesr r) r r r3 � unused_datar r* )r r+ �retZprevious_stater r r! r) R s
zGzipDecoder.decompressNr, r r r r! r5 J s r5 c @ s e Zd Zdd� Zdd� ZdS )�
BrotliDecoderc C s0 t �� | _t| jd�r"| jj| _n
| jj| _d S )Nr) )�brotliZ Decompressorr �hasattrr) Zprocessr r r r! r" n s
zBrotliDecoder.__init__c C s t | jd�r| j�� S dS )N�flushr )r? r r@ r r r r! r@ u s
zBrotliDecoder.flushN)r- r. r/ r" r@ r r r r! r= j s r= c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� MultiDecoderc C s dd� |� d�D �| _d S )Nc S s g | ]}t |�� ��qS r )� _get_decoder�strip)�.0�mr r r! �
<listcomp>� r z)MultiDecoder.__init__.<locals>.<listcomp>�,)�split� _decoders)r Zmodesr r r! r" � s zMultiDecoder.__init__c C s | j d �� S �Nr )rI r@ r r r r! r@ � s zMultiDecoder.flushc C s t | j�D ]}|�|�}q
|S r# )�reversedrI r) )r r+ �dr r r! r) � s zMultiDecoder.decompressN)r- r. r/ r" r@ r) r r r r! rA { s rA c C s: d| v rt | �S | dkr t� S td ur4| dkr4t� S t� S )NrG �gzip�br)rA r5 r> r= r )�moder r r! rB � s rB c @ sb e Zd ZddgZedur"edg7 Zg d�ZdId
d �Zd d
� Zdd� Zdd� Z e
dd� �Z e
dd� �Z dd� Z
dd� Zdd� Zd d � ZeejfZedur�eejf7 Zd d � Zd d!� Zed"d#� �ZdJd$d%�ZdKd'd(�Zed)d*� �Z d+d,� Z dLd-d.�Z d/d0� Z d1d2� Z e
d3d4� �Z!d5d6� Z"d7d8� Z#d9d:� Z$d;d<� Z%d=d>� Z&d?d@� Z'dAdB� Z(dMdCdD�Z)dEdF� Z*dGdH� Z+dS )N� HTTPResponserM ZdeflateNrN )i- i. i/ i3 i4 � r TFc C s t |t�r|| _n
t|�| _|| _|| _|| _|| _|| _|
| _|| _ || _
d | _ d | _ d | _
| | _d| _| | _|| _|r�t |tjtf�r�|| _ |
| _| | _t|d�r�|| _
d| _d | _| j�dd��� }dd� |� d�D �}d |v r�d
| _| � |�| _ |�r| j �s| j |d �| _ d S ) Nr �readFztransfer-encodingrQ c s s | ]}|� � V qd S r# )rC )rD �encr r r! � <genexpr>� r z(HTTPResponse.__init__.<locals>.<genexpr>rG �chunkedT��decode_content) �
isinstancer �headers�status�version�reason�strictrW �retries�enforce_content_length�
auto_close�_decoder�_body�_fp�_original_response�_fp_bytes_read�msg� _request_urlr Z string_typesr: �_pool� _connectionr? rU �
chunk_left�get�lowerrH � _init_length�length_remainingrR )r �bodyrY rZ r[ r\ r] Zpreload_contentrW �original_responseZpool�
connectionrf r^ r_ �request_methodZ request_urlr` Ztr_enc� encodingsr r r! r" � sB
zHTTPResponse.__init__c C s | j | jv r| j�d�S dS )N�locationF)rZ �REDIRECT_STATUSESrY rk r r r r! �get_redirect_location s z"HTTPResponse.get_redirect_locationc C s( | j r | jsd S | j �| j� d | _d S r# )rh ri Z _put_connr r r r! � release_conn s zHTTPResponse.release_connc C s, z | � � W n ttttfy& Y n0 d S r# )rR r � SocketErrorr r r r r r! �
drain_conn s zHTTPResponse.drain_connc C s" | j r | j S | jr | jdd�S d S )NT)�
cache_content)rb rc rR r r r r! r+ % s zHTTPResponse.datac C s | j S r# )ri r r r r! rq . s zHTTPResponse.connectionc C s
t | j�S r# )r rc r r r r! �isclosed2 s zHTTPResponse.isclosedc C s | j S r# )re r r r r! �tell5 s zHTTPResponse.tellc C s� | j �d�}|d ur�| jr(t�d� d S z<tdd� |�d�D ��}t|�dkrZtd| ��|� � }W n t
yz d }Y n0 |dk r�d }zt | j �}W n t
y� d}Y n0 |d v s�d
| kr�d k s�n |d kr�d}|S )
Nzcontent-lengthz�Received response with both Content-Length and Transfer-Encoding set. This is expressly forbidden by RFC 7230 sec 3.3.2. Ignoring Content-Length and attempting to process response as Transfer-Encoding: chunked.c S s g | ] }t |��qS r )�int)rD �valr r r! rF W r z-HTTPResponse._init_length.<locals>.<listcomp>rG r z8Content-Length contained multiple unmatching values (%s)r )�� i0 �d �� ZHEAD)
rY rk rU �logZwarning�setrH �lenr �pop�
ValueErrorr} rZ )r rr �lengthZlengthsrZ r r r! rm = s6 � ��
&zHTTPResponse._init_lengthc sh � j �dd��� }� jd u rd|� jv r2t|�� _n2d|v rd� fdd�|�d�D �}t|�rdt|�� _d S )N�content-encodingrQ rG c s" g | ]}|� � � jv r|� � �qS r )rC �CONTENT_DECODERS)rD �er r r! rF | s �z.HTTPResponse._init_decoder.<locals>.<listcomp>)rY rk rl ra r� rB rH r� )r �content_encodingrs r r r! �
_init_decoderq s
�zHTTPResponse._init_decoderc
C sz |s|S z| j r | j �|�}W nF | jyd } z,| j�dd��� }td| |��W Y d }~n
d }~0 0 |rv|| �� 7 }|S )Nr� rQ zEReceived response with content-encoding: %s, but failed to decode it.)ra r) �DECODER_ERROR_CLASSESrY rk rl r �_flush_decoder)r r+ rW �
flush_decoderr� r� r r r! �_decode� s �� zHTTPResponse._decodec C s$ | j r | j �d�}|| j �� S dS )Nr )ra r) r@ )r �bufr r r! r� � s zHTTPResponse._flush_decoderc
c s: d}z�z
d V W n� t y0 t| jd d��Y nz tyt } z.dt|�vrRt|��t| jd d��W Y d }~n>d }~0 ttfy� } ztd| |��W Y d }~n
d }~0 0 d}W |s�| j r�| j �
� | j r�| j �
� | j r�| j � � r�| �
� nH|�s| j �r| j �
� | j �r| j �
� | j �r4| j � � �r4| �
� 0 d S )NFzRead timed out.zread operation timed outzConnection broken: %rT)�
SocketTimeoutr rh r �strr r rx r rd �closeri r{ rw )r Z
clean_exitr� r r r! �_error_catcher� s6
"$
�
zHTTPResponse._error_catcherc C s" | � � |d u r| j}| jd u r$d S d}t| jdd�}| �� �� |d u r`|sV| j�� nd}d}nPd}|st| j�|�nd}|dkr�|s�| j�� d}| jr�| jdvr�t | j
| j��W d � n1 s�0 Y |�r | j
t |�7 _
| jd u�r| jt |�8 _| � |||�}|�r || _
|S )NF�closedr Tr )r N)r� rW rc r% r� rR r� r_ rn r
re r� r� rb )r �amtrW rz r� Z fp_closedr+ r r r! rR � s:
��
, zHTTPResponse.read� c c sR | j r*| �� r*| j||d�D ]
}|V q n$t| j�sN| j||d�}|r*|V q*d S )NrV )r� rW )rU �supports_chunked_reads� read_chunkedr rc rR )r r� rW �liner+ r r r! �stream+ s
zHTTPResponse.streamc
K sb |j }t|t�s.tjr"t�|�}n t|�� �}t|dd�}| f |||j|j |j
||d�|��}|S )Nr] r )ro rY rZ r[ r\ r] rp ) rf rX r r ZPY2� from_httplib�itemsr% rZ r[ r\ )Z ResponseCls�rZ response_kwrY r] Zrespr r r! r� E s$
��
zHTTPResponse.from_httplibc C s | j S r# �rY r r r r! �
getheadersf s zHTTPResponse.getheadersc C s | j �||�S r# )rY rk )r r' �defaultr r r! � getheaderi s zHTTPResponse.getheaderc C s | j S r# r� r r r r! �infom s zHTTPResponse.infoc C s6 | j s| j�� | jr | j�� | js2tj�| � d S r# )r� rc r� ri r` �io�IOBaser r r r! r� q s
zHTTPResponse.closec C sT | j stjj�| �S | jd u r"dS t| jd�r8| j�� S t| jd�rL| jjS dS d S )NTr{ r� )r` r� r� r� �__get__rc r? r{ r r r r! r� { s
zHTTPResponse.closedc C s6 | j d u rtd��n t| j d�r*| j �� S td��d S )Nz-HTTPResponse has no file to get a fileno from�filenozOThe file-like object this HTTPResponse is wrapped around has no file descriptor)rc �IOErrorr? r� r r r r! r� � s
�zHTTPResponse.filenoc C s2 | j d ur.t| j d�r.t| j dd�s.| j �� S d S )Nr@ r� F)rc r? r% r@ r r r r! r@ � s �
� �zHTTPResponse.flushc C s dS )NTr r r r r! �readable� s zHTTPResponse.readablec C s: | � t|��}t|�dkr dS ||d t|��< t|�S d S rJ )rR r� )r �bZtempr r r! �readinto� s
zHTTPResponse.readintoc C s t | jd�S )N�fp)r? rc r r r r! r� � s z#HTTPResponse.supports_chunked_readsc C sd | j d urd S | jj�� }|�dd�d }zt|d�| _ W n$ ty^ | �� t| |��Y n0 d S )N� ;r r r7 ) rj rc r� �readlinerH r} r� r� r )r r� r r r! �_update_chunk_length� s
z!HTTPResponse._update_chunk_lengthc C s� d }|d u r2| j �| j�}|}| j �d� d | _nv|| jk rZ| j �|�}| j| | _|}nN|| jkr�| j �|�}| j �d� d | _|}n | j �| j�}| j �d� d | _|S )Nr1 )rc Z
_safe_readrj )r r� Zreturned_chunk�chunk�valuer r r! �
_handle_chunk� s&
zHTTPResponse._handle_chunkc c s | � � | jstd��| �� s&td��| �� �� | jrZt| j�rZ| j�� W d � d S | j j
d u rvW d � d S | � � | j dkr�q�| �
|�}| j||dd�}|rv|V qv|r�| �� }|r�|V | j j
�� }|s�q�|dkr�q�q�| jr�| j�� W d � n1 �s
0 Y d S )NzHResponse is not chunked. Header 'transfer-encoding: chunked' is missing.zkBody should be http.client.HTTPResponse like. It should have have an fp attribute which returns raw chunks.r F)rW r� s
)r� rU r r� r
r� rd r r� rc r� r� rj r� r� r� r� )r r� rW r� Zdecodedr� r r r! r� � sF ��
� zHTTPResponse.read_chunkedc C s. | j d ur$t| j j�r$| j jd jS | jS d S )N���)r^ r� �historyZredirect_locationrg r r r r! �geturl s zHTTPResponse.geturlc c s� g }| j dd�D ]n}d|v rt|�d�}d�|�|d d V |dd� D ]}|d V qJ|d rn|d g}q~g }q|�|� q|r�d�|�V d S )NTrV �
r r r r� )r� rH �join�append)r �bufferr� �xr r r! �__iter__& s
zHTTPResponse.__iter__)rQ Nr r Nr TTNNNNNFNNT)NNF)r� N)N)NN),r- r. r/ r� r> ru r" rv rw ry �propertyr+ rq r{ r| rm r� r� r r r� r� r� r r� rR r� � classmethodr� r� r� r� r� r� r� r@ r� r� r� r� r� r� r� r� r r r r! rP � sx !
�
C
4
7
J
F rP )/Z
__future__r r� Zloggingr �
contextlibr Zsocketr rx r r� r> � ImportError� _collectionsr rq r r �
exceptionsr
r r r
r r r r r r Zpackagesr Z
util.responser r Z getLoggerr- r� �objectr r0 r5 r= rA rB r� rP r r r r! �<module> s0
0