File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/urllib3/contrib/emscripten/__pycache__/response.cpython-310.pyc
Back
o ;j�% � @ s� d dl mZ d dlZd dlZd dlZd dlmZ d dlm Z d dl m Z d dl m Z mZ ddlmZmZ dd lmZ dd lmZ d d lmZ ejrQdd lmZmZ e� e �Z e G dd� d��Z G dd� de�Z dS )� )� annotationsN)�contextmanager)� dataclass)� HTTPException)�BytesIO�IOBase� )� InvalidHeader� TimeoutError)�BaseHTTPResponse)�Retry� )�EmscriptenRequest)�BaseHTTPConnection�BaseHTTPSConnectionc @ s. e Zd ZU ded< ded< ded< ded< d S ) �EmscriptenResponse�int� status_codezdict[str, str]�headerszIOBase | bytes�bodyr �requestN)�__name__� __module__� __qualname__�__annotations__� r r �W/opt/saltstack/salt/lib/python3.10/site-packages/urllib3/contrib/emscripten/response.pyr s r c s� e Zd Z d7d8� fdd � Zed9d d ��Zejd:dd ��Zed;dd��Zed<dd��Zejd=dd��Z d>d?d d �Z d@d d �Z !dAdBd%d&�Z d7d?d'd(�Z dCd)d*�Z dCd+d,�ZedDd-d.��ZdEd0d1�ZdCd2d3�ZedFd5d6��Z� ZS )G� EmscriptenHttpResponseWrapperN�internal_responser �url� str | None� connection�/BaseHTTPConnection | BaseHTTPSConnection | Nonec sd d | _ d | _d| _|| _|| _|| _d| _t� j|j |j |ddddd� | � | jj j �| _d| _d S )NFr zHTTP/?� T)r �statusZ request_url�versionZversion_string�reason�decode_content)�_pool�_body�_uncached_read_occurred� _response�_url� _connection�_closed�super�__init__r r � _init_lengthr �method�length_remaining�length_is_certain)�selfr r r! �� __class__r r r0 s$ � z&EmscriptenHttpResponseWrapper.__init__�returnc C � | j S �N�r, �r5 r r r r 8 � z!EmscriptenHttpResponseWrapper.url�Nonec C � || _ d S r: r; )r5 r r r r r < s c C r9 r: )r- r< r r r r! @ r= z(EmscriptenHttpResponseWrapper.connection� Retry | Nonec C r9 r: �Z_retriesr< r r r �retriesD r= z%EmscriptenHttpResponseWrapper.retriesrB c C r? r: rA )r5 rB r r r rB H s � �amt� int | Noner' � bool | None�typing.Generator[bytes]c c s$ � | j ||d�}|r|V ndS q)a_ A generator wrapper for the read() method. A call will block until ``amt`` bytes have been read from the connection or until the connection is closed. :param amt: How much of the content to read. The generator will return up to much data per iteration, but may return less. This is particularly likely when using compressed data. However, the empty string will never be returned. :param decode_content: If True, will attempt to decode the body based on the 'content-encoding' header. T)rD r' N��read)r5 rD r' �datar r r �streamM s ��z$EmscriptenHttpResponseWrapper.stream�request_methodc C s� | j �d�}|d ur9z dd� |�d�D �}t|�dkr!td| ��|�� }W n ty1 d }Y n w |dk r8d }nd }| jdv sPd | j krKd k sPn |d krRd}|S ) Nzcontent-lengthc S s h | ]}t |��qS r )r )�.0�valr r r � <setcomp>r s z=EmscriptenHttpResponseWrapper._init_length.<locals>.<setcomp>�,r z8Content-Length contained multiple unmatching values (%s)r )�� i0 �d �� �HEAD)r �get�split�lenr �pop� ValueErrorr$ )r5 rL �content_lengthZlengths�lengthr r r r1 g s. �� �� z*EmscriptenHttpResponseWrapper._init_lengthF� cache_content�bool�bytesc C s, | j s| jd u st| jjt�r| jjjrdS | �� �r t| jjt�s4t| jj�| _d| _ t | jj�| j_|d urI|dkrId}| jj� |�}d| _ n| jj� � }|rX| j sX|| _ nd| _ | jd urkt| jt|� d�| _t|�dksy| j r| jdkr| jj�� t�t|�W d � S 1 s�w Y d S )N� Tr F)r. r+ � isinstancer r �closed�_error_catcherrW r3 r4 r rI r* r) �max�close�typing�castr^ )r5 rD r' r\ rJ r r r rI � s< � �� � $�z"EmscriptenHttpResponseWrapper.readc c s � | � ||�}|s d S |V qr: rH )r5 rD r' r^ r r r � read_chunked� s � �z*EmscriptenHttpResponseWrapper.read_chunkedc C s( | j r| jsd S | j �| j� d | _d S r: )r( r- Z _put_connr< r r r � release_conn� s z*EmscriptenHttpResponseWrapper.release_connc C s | � � d S r: )rd r< r r r � drain_conn� s z(EmscriptenHttpResponseWrapper.drain_connc C s | j r| j S | jdd�S )NT)r\ )r) rI r< r r r rJ � s z"EmscriptenHttpResponseWrapper.data� typing.Anyc C s | j �d�}t�|�S )a� Deserializes the body of the HTTP response as a Python object. The body of the HTTP response must be encoded using UTF-8, as per `RFC 8529 Section 8.1 <https://www.rfc-editor.org/rfc/rfc8259#section-8.1>`_. To use a custom JSON decoder pass the result of :attr:`HTTPResponse.data` to your custom decoder instead. If the body of the HTTP response is not decodable to UTF-8, a `UnicodeDecodeError` will be raised. If the body of the HTTP response is not a valid JSON document, a `json.JSONDecodeError` will be raised. Read more :ref:`here <json_content>`. :returns: The body of the HTTP response as a Python object. zutf-8)rJ �decode�_json�loads)r5 rJ r r r �json� s z"EmscriptenHttpResponseWrapper.jsonc C sD | j s t| jjt�r| jj�� | jr| j�� d | _d| _ d S d S )NT)r. r` r+ r r rd r- r< r r r rd � s �z#EmscriptenHttpResponseWrapper.close�typing.Generator[None]c c s( � ddl m}m} d}z\zdV d}W n# |y% } ztt|���d}~w |y6 } ztt|���d}~ww W |sRt| jjt �rL| jjj sL| jj� � | � � dS t| jjt �rd| jjj rf| � � dS dS dS |s�t| jjt �r|| jjj s|| jj� � | � � w t| jjt �r�| jjj r�| � � w w w )z� Catch Emscripten specific exceptions thrown by fetch.py, instead re-raising urllib3 variants, so that low-level exceptions are not leaked in the high-level api. On exit, release the connection back to the pool. r )� _RequestError� _TimeoutErrorFNT) Zfetchrp rq r �strr r` r+ r r ra rd rh )r5 rp rq Z clean_exit�er r r rb � sP � � ��� �� �� �� �� �� �z,EmscriptenHttpResponseWrapper._error_catcher)NN)r r r r r! r" )r8 r )r r r8 r> )r8 r" )r8 r@ )rB r@ r8 r> )rC N)rD rE r' rF r8 rG )rL r r8 rE )NNF)rD rE r' rF r\ r] r8 r^ )r8 r> )r8 r^ )r8 rj )r8 ro )r r r r0 �propertyr �setterr! rB rK r1 rI rg rh ri rJ rn rd r rb � __classcell__r r r6 r r s@ � � ' �* � r )!� __future__r rn rl �loggingre � contextlibr Z dataclassesr � http.clientr �ior r � exceptionsr r �responser Z util.retryr r r � TYPE_CHECKINGZ_base_connectionr r � getLoggerr �logr r r r r r �<module> s$
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings