File: //usr/local/lib/python3.10/dist-packages/pip/_internal/network/__pycache__/session.cpython-310.pyc
o
��h�J � @ s� U d Z ddlmZ ddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlmZmZmZ ddlmZmZmZmZ ddl m Z m Z ddl m Z! ddl"m#Z#m$Z$ dd l"m%Z& dd
l'm(Z(m)Z) dd l*m+Z+ dd l,m-Z- dd
l.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z; ddl<m=Z= ddl>m?Z?m@Z@ ddlAmBZB er�ddlCmDZD ddlEmFZF ddlGmHZH e �IeJ�ZKeLeMeMeeeNeMf f ZOejPde/d� g d �ZQd eRd < d ZSd7d"d#�ZTejUd$d%�d8d'd(��ZVG d)d*� d*e$�ZWG d+d,� d,�ZXG d-d.� d.eXe&�Z%G d/d0� d0eXe!�Z G d1d2� d2e%�ZYG d3d4� d4e �ZZG d5d6� d6e j[�Z\dS )9zhPipSession and supporting code, containing all pip-specific
network request configuration and behavior.
� )� annotationsN)� Generator�Mapping�Sequence)�
TYPE_CHECKING�Any�Optional�Union)�requests�urllib3)�CacheControlAdapter)�DEFAULT_POOLBLOCK� BaseAdapter)� HTTPAdapter)�PreparedRequest�Response)�CaseInsensitiveDict)�ConnectionPool)�InsecureRequestWarning)� __version__)�get_default_environment)�Link)�MultiDomainBasicAuth)�
SafeFileCache)�has_tls)�libc_ver)�build_url_from_netloc� parse_netloc)� url_to_path)�
SSLContext)� PoolManager)� ProxyManager�ignore)�category))�https�*r% )r% � localhostr% )r% z 127.0.0.0/8r% )r% z::1/128r% )�filer% N)�sshr% r% zlist[SecureOrigin]�SECURE_ORIGINS)�
BUILD_BUILDID�BUILD_ID�CI� PIP_IS_CI�return�boolc C s t dd� tD ��S )z?
Return whether it looks like pip is running under CI.
c s s � | ]}|t jv V qd S �N)�os�environ)�.0�name� r5 �H/usr/local/lib/python3.10/dist-packages/pip/_internal/network/session.py� <genexpr>i s � z looks_like_ci.<locals>.<genexpr>)�any�CI_ENVIRONMENT_VARIABLESr5 r5 r5 r6 �
looks_like_cib s r: � )�maxsize�strc
C s� dt d�t�� dt�� id�} | d d dkr t�� | d d< nF| d d dkrEtj}|jd kr6|d
d � }d �d
d� |D ��| d d< n!| d d dkrVt�� | d d< n| d d dkrft�� | d d< tj�d�r�ddl m
} |� � |� � |�
� f}ttdd� tg d�|���}ttdd� tddgt� ���}|r�||d< |r�|| d< tj�d�r�t�� d r�d t�� d d�| d< t�� r�t�� | �d i �d< t�� r�t�� | �d i �d < t�� r�t�� | d < t� r�dd
l}|j| d < t� �d!�}|d
u�rt |j �| d"< t � d#�d
u�r2z
t j d#d$gt j!d%d&�}W n
t"�y Y nw |�d'��r2|�#d(�d) �$� | d*< t%� �r8d+nd
| d,< t&j'�(d-�} | d
u�rK| | d.< d/j)| t*j+| d0d+d1�d2�S )3z6
Return a string representing the user agent.
�pip)r4 �versionr4 )� installer�python�implementationrB �CPythonr? �PyPy�finalN� �.c S s g | ]}t |��qS r5 )r= )r3 �xr5 r5 r6 �
<listcomp>� s z user_agent.<locals>.<listcomp>�Jython�
IronPython�linuxr )�distroc S � | d S �Nr; r5 �rH r5 r5 r6 �<lambda>� � z user_agent.<locals>.<lambda>)r4 r? �idc S rN rO r5 rP r5 r5 r6 rQ � rR �lib�libcrM �darwin�macOS�system�release�cpu�openssl_version�
setuptools�setuptools_version�rustcz --versiong �?)�stderr�timeouts rustc � r; �
rustc_versionT�ci�PIP_USER_AGENT_USER_DATA� user_dataz9{data[installer][name]}/{data[installer][version]} {json})�,�:)�
separators� sort_keys)�data�json),r �platform�python_version�python_implementation�sys�pypy_version_info� releaselevel�join�
startswith� pip._vendorrM r4 r? �codename�dict�filter�zipr �mac_verrX �
setdefaultrY �machiner �_ssl�OPENSSL_VERSIONr �get_distributionr= �shutil�which�
subprocess� check_output�STDOUT� Exception�split�decoder: r1 r2 �get�formatrk �dumps)
rj rp rM �linux_distribution� distro_infosrU �ssl�setuptools_dist� rustc_outputre r5 r5 r6 �
user_agentl s� ��
� ����
��
�r� c @ s, e Zd Z dddd�Zddd�ZdS )�LocalFSAdapterFNT�requestr �streamr/ r` �"float | tuple[float, float] | None�verify�
bool | str�cert� str | tuple[str, str] | None�proxies�Mapping[str, str] | Noner. r c
C s� t |j�}t� }d|_|j|_zt�|�} W n* ty@ }
z d|_t|
�j|_ t
� |j � d|
� �� � �|_
W Y d }
~
|S d }
~
ww tjj| jdd�} t�|�d pRd} t| | j| d��|_t|d �|_
|j
j|_|S )
N�� i� z: T)�usegmtr z
text/plain)z Content-TypezContent-Lengthz
Last-Modified�rb)r �urlr � status_coder1 �stat�OSError�type�__name__�reason�io�BytesIO�encode�raw�email�utils�
formatdate�st_mtime� mimetypes�
guess_typer �st_size�headers�open�close)
�selfr� r� r` r� r� r� �pathname�resp�stats�exc�modified� content_typer5 r5 r6 �send� s0
&����
zLocalFSAdapter.send�Nonec C s d S r0 r5 )r� r5 r5 r6 r� � s zLocalFSAdapter.close)FNTNN)r� r r� r/ r` r� r� r� r� r� r� r� r. r )r. r� )r� �
__module__� __qualname__r� r� r5 r5 r5 r6 r� � s �'r� c sH e Zd ZdZdd�d� fd
d �Zefd � fdd�
Zd � fdd� Z� ZS ) �_SSLContextAdapterMixina# Mixin to add the ``ssl_context`` constructor argument to HTTP adapters.
The additional argument is forwarded directly to the pool manager. This allows us
to dynamically decide what SSL store to use at runtime, which is used to implement
the optional ``truststore`` backend.
N)� ssl_contextr� �SSLContext | None�kwargsr r. r� c s || _ t� jdi |�� d S )Nr5 )� _ssl_context�super�__init__)r� r� r� �� __class__r5 r6 r� s z _SSLContextAdapterMixin.__init__� connections�intr< �blockr/ � pool_kwargsr c s2 | j d ur |�d| j � t� jd|||d�|��S )Nr� )r� r< r� r5 )r� rz r� �init_poolmanager)r� r� r< r� r� r� r5 r6 r� s
��z(_SSLContextAdapterMixin.init_poolmanager�proxyr= � proxy_kwargsr! c s, | j d ur |�d| j � t� j|fi |��S )Nr� )r� rz r� �proxy_manager_for)r� r� r� r� r5 r6 r� s
z)_SSLContextAdapterMixin.proxy_manager_for)r� r� r� r r. r� )
r� r� r< r� r� r/ r� r r. r )r� r= r� r r. r! ) r� r� r� �__doc__r� r
r� r� �
__classcell__r5 r5 r� r6 r� � s
�
�r� c @ � e Zd ZdS )r N�r� r� r� r5 r5 r5 r6 r ' � r c @ r� )r Nr� r5 r5 r5 r6 r + r� r c � e Zd Zd
� fd d � Z� ZS )�InsecureHTTPAdapter�connr r� r= r� r� r� r� r. r� c � t � j||d|d� d S �NF)r� r� r� r� �r� � cert_verify�r� r� r� r� r� r� r5 r6 r� 0 � z InsecureHTTPAdapter.cert_verify�
r� r r� r= r� r� r� r� r. r� �r� r� r� r� r� r5 r5 r� r6 r� / � r� c r� )�InsecureCacheControlAdapterr� r r� r= r� r� r� r� r. r� c r� r� r� r� r� r5 r6 r� ; r� z'InsecureCacheControlAdapter.cert_verifyr� r� r5 r5 r� r6 r� : r� r� c st e Zd ZU dZded< dddddd�d0� fdd�Zd1dd�Z d2d3d"d#�Zd4d%d&�Zd5d)d*�Z d6� fd.d/� Z
� Z S )7�
PipSessionNz
int | Noner` r r5 )�retries�cache�
trusted_hosts�
index_urlsr� �argsr r� r� r� �
str | Noner� �
Sequence[str]r� �list[str] | Noner� r� r� r. r� c s� t � j|i |�� g | _d| _t� | jd< t|d�| _tj |g d�dd�}t
|d�}|r?t t |�||d�} t
t |�|d �| _n t||d
�} || _| �d | � | �d |� | �d
t� � |D ] }
| j|
dd� q]dS )zj
:param trusted_hosts: Domains not to emit warnings for when not using
HTTPS.
Nz
User-Agent)r� )i� i� i� i i g �?)�total�status_forcelist�backoff_factor)� max_retries)r� r� r� )r� r� )r� r� zhttps://zhttp://zfile://T)�suppress_logging)r� r� �pip_trusted_origins� pip_proxyr� r� r �authr �Retryr� r r r� �_trusted_host_adapterr �mountr� �add_trusted_host) r� r� r� r� r� r� r� r� �insecure_adapter�secure_adapter�hostr� r5 r6 r� H s: �
�
� �zPipSession.__init__�new_index_urls� list[str]c C s || j _dS )zn
:param new_index_urls: New index urls to update the authentication
handler with.
N)r� r� )r� r� r5 r5 r6 �update_index_urls� s z PipSession.update_index_urlsFr� r= �sourcer� r/ c C s� |sd|��}|dur|d|� d�7 }t �|� t|�\}}|du r)td|����||f| jvr8| j�||f� | �t|dd�d | j� | �t|�d | j� |sl| �t|dd�d | j� | �t|�d | j� dS dS )
z�
:param host: It is okay to provide a host that has previously been
added.
:param source: An optional source string, for logging where the host
string came from.
zadding trusted host: Nz (from �)z+Trusted host URL must include a host part: �http)�scheme�/rg ) �logger�infor �
ValueErrorr� �appendr� r r� )r� r� r� r� �msg� parsed_host� parsed_portr5 r5 r6 r� � s*
���zPipSession.add_trusted_host�#Generator[SecureOrigin, None, None]c c s8 � t E d H | jD ]\}}d||d u rdn|fV q d S )Nr% )r) r� )r� r� �portr5 r5 r6 �iter_secure_origins� s
�
�z PipSession.iter_secure_origins�locationr c C s� t j�t|��}|j|j|j}}}|�dd�d }| �� D ]L}|\}}} ||kr/|dkr/q zt �
|p5d�}
t � |�} W n t yV |rT|�
� |�
� krT|dkrTY q Y nw |
| vr\q || kri| dkri| d uriq dS t�d||� dS ) N�+r; ���r% � Tz�The repository located at %s is not a trusted or secure host and is being ignored. If this repository is available via HTTPS we recommend you use HTTPS instead, otherwise you may silence this warning and allow it anyway with '--trusted-host %s'.F)�urllib�parse�urlparser= r� �hostnamer �rsplitr � ipaddress�
ip_address�
ip_networkr �lowerr �warning) r� r
�parsed�origin_protocol� origin_host� origin_port�
secure_origin�secure_protocol� secure_host� secure_port�addr�networkr5 r5 r6 �is_secure_origin� sD
�
��� � zPipSession.is_secure_origin�methodr� r c s8 |� d| j� |� d| j� t� j||g|�R i |��S )Nr` r� )rz r` r� r� r� )r� r# r� r� r� r� r5 r6 r� s zPipSession.request)r� r r� r� r� r� r� r� r� r� r� r� r� r r. r� )r� r� r. r� )NF)r� r= r� r� r� r/ r. r� )r. r )r
r r. r/ )
r# r= r� r= r� r r� r r. r ) r� r� r� r` �__annotations__r� r� r� r r" r� r� r5 r5 r� r6 r� E s
�
Q �
!
Cr� )r. r/ )r. r= )]r� �
__future__r � email.utilsr� � functoolsr� r rk �loggingr� r1 rl r r� ro � urllib.parser �warnings�collections.abcr r r �typingr r r r rt r
r �pip._vendor.cachecontrolr �_BaseCacheControlAdapter� pip._vendor.requests.adaptersr
r r �_BaseHTTPAdapter�pip._vendor.requests.modelsr r � pip._vendor.requests.structuresr �"pip._vendor.urllib3.connectionpoolr � pip._vendor.urllib3.exceptionsr r> r �pip._internal.metadatar �pip._internal.models.linkr �pip._internal.network.authr �pip._internal.network.cacher �pip._internal.utils.compatr �pip._internal.utils.glibcr �pip._internal.utils.miscr r �pip._internal.utils.urlsr r� r � pip._vendor.urllib3.poolmanagerr � pip._vendor.urllib3.proxymanagerr! � getLoggerr� r �tupler= r� � SecureOrigin�filterwarningsr) r$ r9 r: � lru_cacher� r� r� r� r� �Sessionr� r5 r5 r5 r6 �<module> sl
e,)