File: //opt/osm/venv/lib64/python3.10/site-packages/urllib3/http2/__pycache__/connection.cpython-310.pyc
o
<i�1 � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Zd dl
Zddl m Z ddl
mZ ddlmZmZ ddlmZ ddlmZ eZe�d �Ze�e�Ze� d
�Z e� d �Z ddd�Z d dd�Z G dd� dej!e �Z"G dd� de�Z#G dd� de�Z$dS ) � )� annotationsN� )�
_TYPE_BODY)�HTTPHeaderDict)�HTTPSConnection�_get_default_user_agent)�ConnectionError)�BaseHTTPResponse�Ts ^[!#$%&'*+\-.^_`|~0-9a-z]+$s* [\0\x00\x0a\x0d\r\n]|^[ \r\n\t]|[ \r\n\t]$�name�bytes�return�boolc C � t t�| ��S )a5
"An implementation that validates fields according to the definitions in Sections
5.1 and 5.5 of [HTTP] only needs an additional check that field names do not
include uppercase characters." (https://httpwg.org/specs/rfc9113.html#n-field-validity)
`http.client._is_legal_header_name` does not validate the field name according to the
HTTP 1.1 spec, so we do that here, in addition to checking for uppercase characters.
This does not allow for the `:` character in the header name, so should not
be used to validate pseudo-headers.
)r �RE_IS_LEGAL_HEADER_NAME�match)r � r �F/opt/osm/venv/lib/python3.10/site-packages/urllib3/http2/connection.py�_is_legal_header_name s r �valuec C r )aK
"A field value MUST NOT contain the zero value (ASCII NUL, 0x00), line feed
(ASCII LF, 0x0a), or carriage return (ASCII CR, 0x0d) at any position. A field
value MUST NOT start or end with an ASCII whitespace character (ASCII SP or HTAB,
0x20 or 0x09)." (https://httpwg.org/specs/rfc9113.html#n-field-validity)
)r �RE_IS_ILLEGAL_HEADER_VALUE�search)r r r r �_is_illegal_header_value, s r c @ s2 e Zd ZdZdZddd�Zddd �Zddd�ZdS )�
_LockedObjectaX
A wrapper class that hides a specific object behind a lock.
The goal here is to provide a simple way to protect access to an object
that cannot safely be simultaneously accessed from multiple threads. The
intended use of this class is simple: take hold of it with a context
manager, which returns the protected object.
)�lock�_obj�objr
c C s t �� | _|| _d S �N)� threading�RLockr r )�selfr r r r �__init__D s
z_LockedObject.__init__r
c C s | j �� | jS r )r �acquirer �r r r r � __enter__H s
z_LockedObject.__enter__�exc_type�type[BaseException] | None�exc_val�BaseException | None�exc_tb�types.TracebackType | None�Nonec C s | j �� d S r )r �release)r r% r' r) r r r �__exit__L s z_LockedObject.__exit__N)r r
)r
r
)r% r& r' r( r) r* r
r+ )�__name__�
__module__� __qualname__�__doc__� __slots__r! r$ r- r r r r r 6 s
r c s� e Zd Z d5d6� fd
d �
Zd7d
d�Zd8� fdd� Zd9dd�Zd:dd�Zd5d;dd �Zd<d d �Z d=d>d$d%�Z
d?d'd(�Z d@d)d)d)d*�dAd1d2�Z d8� fd3d4� Z
� ZS )B�HTTP2ConnectionN�host�str�port�
int | None�kwargs�
typing.Anyr
r+ c sZ | � � | _d | _g | _d|v sd|v rtd��t� j||fi |�� | jd ur+td��d S )N�proxy� proxy_configz$Proxies aren't supported with HTTP/2z%Tunneling isn't supported with HTTP/2)� _new_h2_conn�_h2_conn�
_h2_stream�_headers�NotImplementedError�superr! � _tunnel_host)r r4 r6 r8 �� __class__r r r! V s
�zHTTP2Connection.__init__�)_LockedObject[h2.connection.H2Connection]c C s t jjdd�}tt jj|d��S )NT)Z client_side)�config)�h2rF ZH2Configurationr �
connectionZ H2Connection)r rF r r r r< e s z HTTP2Connection._new_h2_connc sf t � �� | j�!}|�� |�� }r!| j�|� W d � d S W d � d S 1 s,w Y d S r )rA �connectr= Zinitiate_connection� data_to_send�sock�sendall)r �connrJ rC r r rI i s
�"�zHTTP2Connection.connect�method�urlc K s� d|v rt d��d|v rt d��|pd| _| �|� d| jv r,d| j� d| jp(d � �}n | j� d| jp4d � �}| j�d
� | j�d |�� f� | j�d |�� f� | j�d
|�� f� | j�}|� � | _
W d � dS 1 sow Y dS )z�putrequest
This deviates from the HTTPConnection method signature since we never need to override
sending accept-encoding headers or the host header.
� skip_hostz`skip_host` isn't supported�skip_accept_encodingz&`skip_accept_encoding` isn't supported�/�:�[z]:i� )s :schemes httpss :methods
:authoritys :pathN) r@ � _request_url�_validate_pathr4 r6 r? �append�encoder= Z get_next_available_stream_idr> )r rN rO r8 � authorityrM r r r �
putrequestp s
"�zHTTP2Connection.putrequest�header� str | bytes�valuesc G s� t |t�r |�� n|}|�� }t|�s tdt|�� ���|D ]"}t |t�r)|�� n|}t|�r8tdt|�� ���| j�||f� q d S )NzIllegal header name zIllegal header value ) �
isinstancer5 rX �lowerr �
ValueErrorr r? rW )r r[ r] r r r r � putheader� s �zHTTP2Connection.putheader� message_bodyc C sr | j d u r td��| j� }|j| j | j|d u d� |�� }r%| j�|� W d � n1 s/w Y g | _d S )N� Must call `putrequest` first.)� stream_id�headers�
end_stream)r> r r= � send_headersr? rJ rK rL )r rb rM rJ r r r �
endheaders� s
� � �
zHTTP2Connection.endheaders�datac C s| | j du r td��| j��}|�� }r| j�|� t|d�rV |�| j�}|s(n t |t
�r1|� � }|j | j |dd� |�� }rF| j�|� q |�
| j � W d � dS t |t
�r_|� � }z=t |t�r{|j | j |dd� |�� }rz| j�|� n |D ]}|j | j |dd� |�� }r�| j�|� q}|�
| j � W n ty� tdt|� ��w W d � dS 1 s�w Y dS )z�Send data to the server.
`data` can be: `str`, `bytes`, an iterable, or file-like objects
that support a .read() method.
Nrc �readTF)rf z6`data` should be str, bytes, iterable, or file. got %r)r> r r= rJ rK rL �hasattrrj � blocksizer^ r5 rX Z send_datarf r � TypeError�type)r ri rM rJ �chunkr r r �send� sV
� �
� � � ����"�zHTTP2Connection.send�httpre � typing.Mapping[str, str] | None�schemec C s t d��)Nz;HTTP/2 does not support setting up a tunnel through a proxy)r@ )r r4 r6 re rs r r r �
set_tunnel� s �zHTTP2Connection.set_tunnel�
HTTP2Responsec C s* d }t � }| j�t}d}|su| j�d� }rg|�|�}|D ]J}t|tjj�rHt � }|j
D ]\} }
| dkr:t |
� � �}q+|�
| � d�|
� d�� q+q t|tjj�r]||j7 }|�|j|j� q t|tjj�rfd}q |�� } rs| j�| � |r
W d � n1 sw Y |d us�J �t||| jt|�d�S )NFi�� s :status�asciiT)�statusre � request_urlri )� bytearrayr= rK �recvZ receive_datar^ rG �eventsZResponseReceivedr re �int�decode�addZ DataReceivedri Zacknowledge_received_dataZflow_controlled_lengthrd Z StreamEndedrJ rL ru rU r ) r rw ri rM rf Z
received_datar{ �eventre r[ r rJ r r r � getresponse� sJ
��
�� �� � �zHTTP2Connection.getresponseT)�preload_content�decode_content�enforce_content_length�body�_TYPE_BODY | Noner� r r� r� c K s� d|v r | j dur| j �| j� | �||� |pi }|�� D ]\} }
| �� dkr.|
dkr.q | �| |
� q dt| j�vrC| �dt � � |rR| j
|d� | � |� dS | �
� dS )zSend an HTTP/2 request�chunkedNztransfer-encodings
user-agent)rb ) rK �
settimeout�timeoutrZ �itemsr_ ra �dictr? r rh rp ) r rN rO r� re r� r� r� r8 �k�vr r r �request s
zHTTP2Connection.requestc s� | j �$}z|�� |�� }r| j�|� W n ty Y nw W d � n1 s*w Y | �� | _ d | _g | _t � �
� d S r ) r= Zclose_connectionrJ rK rL � Exceptionr< r> r? rA �close)r rM ri rC r r r� 3 s � �� �
zHTTP2Connection.closer )r4 r5 r6 r7 r8 r9 r
r+ )r
rE �r
r+ )rN r5 rO r5 r8 r9 r
r+ )r[ r\ r] r\ r
r+ )rb r9 r
r+ )ri r9 r
r+ )NNrq )
r4 r5 r6 r7 re rr rs r5 r
r+ )r
ru )NN)rN r5 rO r5 r� r� re rr r� r r� r r� r r8 r9 r
r+ )r. r/ r0 r! r< rI rZ ra rh rp rt r� r� r� �
__classcell__r r rC r r3 U s, �
0 �
.��'r3 c sD e Zd Z dd� fdd�
Zeddd��Zddd�Zddd�Z� ZS )ru Frw r| re r rx r5 ri r r� r r
r+ c s* t � j||ddd ||d� || _d| _d S )N� zHTTP/2)rw re �version�version_string�reasonr� rx r )rA r! �_data�length_remaining)r rw re rx ri r� rC r r r! F s �
zHTTP2Response.__init__c C s | j S r )r� r# r r r ri \ s zHTTP2Response.datac C � d S r r r# r r r �get_redirect_location` � z#HTTP2Response.get_redirect_locationc C r� r r r# r r r r� c r� zHTTP2Response.close)F) rw r| re r rx r5 ri r r� r r
r+ )r
r r� ) r. r/ r0 r! �propertyri r� r� r� r r rC r ru D s �
ru )r r r
r )r r r
r )%�
__future__r �logging�rer �types�typingZ h2.configrG Z
h2.connectionZ h2.eventsZ_base_connectionr � _collectionsr rH r r �
exceptionsr �responser Zorig_HTTPSConnection�TypeVarr
� getLoggerr. �log�compiler r r r �Genericr r3 ru r r r r �<module> s2
p