L%U d Z ddlmZ ddlZddlZddlZddlZddlm Z m
Z
ddl m Z ddl
mZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ dd lmZ dd
l m Z m Z ddl m Z m!Z! ddl"m#Z# ddl$m%Z% ddl&m'Z'm(Z( ddl)m*Z*m+Z+ ddl,m-Z-m.Z.m/Z/ ddl0m1Z1m2Z2m3Z3 ej4 e5 Z6d/dZ7d0dZ8 d1d2d#Z9d3d&Z:d4d)Z;d5d*ZdS )6z(Download files with progress indicators. ) annotationsN)IterableMapping) dataclass)
HTTPStatus)BinaryIO)PreparedRequest)Response) HTTPResponse)HTTPHeaderDict)ReadTimeoutError)BarType get_download_progress_renderer)IncompleteDownloadErrorNetworkConnectionError)PyPI)Link)
SafeFileCache
is_from_cache)CacheControlAdapter
PipSession)HEADERSraise_for_statusresponse_chunks) format_sizeredact_auth_from_urlsplitextrespr
return
int | Nonec t t | j d S # t t t f$ r Y d S w xY w)Ncontent-length)intheaders
ValueErrorKeyError TypeErrorr s p/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/pip/_internal/network/download.py_get_http_response_sizer* sF 4< 01222 ) , tts 77
str | Nonec h | j d| j d S )z
Return either the ETag or Last-Modified header (or None if neither exists).
The return value can be used in an If-Range header.
etagz
last-modified)r$ getr( s r) (_get_http_response_etag_or_last_modifiedr/ ' s,
< FDL$4$4_$E$E F FF linkr progress_barr total_length range_startIterable[bytes]c |j t j k r|j }n|j }t | }|r=|r&| dt
| dt
| d}n| dt
| d}t | r t d| n9|r t d| nt d| t
t j k rd}n"t | rd}n|sd}n |d k rd}nd}t | }|s|S t |||
} | | S ) Nz (/)zUsing cached %szResuming download %szDownloading %sFTi )bar_typesizeinitial_progress)netlocr file_storage_domainshow_urlurl_without_fragmentr r r loggerinfogetEffectiveLevelloggingINFOr r )
r r1 r2 r3 r4 url
logged_url
show_progresschunksrenderers
r)
_log_downloadrJ / s {d...m'%c**J G G XX[!9!9XXK #A99A>
first_respc > |j | j k r'| r|j J |xj dz
c_ t dt
|j t
|j |j | || }|j t j k }|r*| t | |_ |}| || n # t t t" f$ r Y w xY w|j | j k r| | r-t% j |j j t- | |j dk r| || dS dS )zAAttempt to resume/restart the download if connection was dropped.Nr] z > > > > # "s A.C6 6DDoriginal_responsec |j j }| j | }t |t
s t d| dS t |j t s
J d t }| d|i t }|j
D ] \ }}| dvr|||< !t! |j |d< t% d|d d
} |j | }
|j j || d } |j |
| |j t5 |j j d
5 } |j |
| ddd n # 1 swxY w Y t d| dS )an
Manually cache a file that was successfully downloaded via resume retries.
cachecontrol doesn't cache 206 (Partial Content) responses, since they
are not complete files. This method manually adds the final file to the
cache as though it was downloaded in a single request, so that future
requests can use the cache.
zH$;>>> B,OO O: -",GJ ~~hmW555r0 r$ Mapping[str, str]c |j } | j ||d }t | nB# t $ r5}|j J t d|j j | d }~ww xY w|S )NT)r$ streamz HTTP error %s while getting %s) r? r r. r r responser@ criticalr )rl r1 r$
target_urlr r s r) r zDownloader._http_getK s .
=$$Z$NND T " " " "% :))) OO0!*2H$
s ,6
A5 0A00A5N)r r r2 r r r# r rp )r r r rL r r )r1 r r rL r r )r rd r r
r rp )r rd r r
r rp )r rd r r
r rp )r rd r r
r r
)r1 r r$ r r r
) ry rz r{ r r r r r r r r r r~ r0 r) r r s . . . .1 1 1 1
&
&
&
& F F F F&&? &? &? &?P6
6
6
6
p 6 6 6 6 BI r0 r )r r
r r )r r
r r+ )r ) r r
r1 r r2 r r3 r r4 r r r5 )rK rL r rL )rR rL rS rL r rL )r r
r1 r r rL )?r|
__future__r
email.messagerV rC r_ rN collections.abcr r dataclassesr httpr typingr pip._vendor.requestsr pip._vendor.requests.modelsr
pip._vendor.urllib3r r pip._vendor.urllib3._collectionsr pip._vendor.urllib3.exceptionsr
pip._internal.cli.progress_barsr r pip._internal.exceptionsr r pip._internal.models.indexr pip._internal.models.linkr pip._internal.network.cacher r pip._internal.network.sessionr r pip._internal.network.utilsr r r pip._internal.utils.miscr r r getLoggerry r@ r* r/ rJ rQ r[ rb rd r r~ r0 r) r s . . " " " " " " - - - - - - - - ! ! ! ! ! ! 0 0 0 0 0 0 0 0 0 0 0 0 ? ? ? ? ? ? ; ; ; ; ; ; ; ; ; ; ; ; S S S S S S S S T T T T T T T T + + + + + + * * * * * * D D D D D D D D I I I I I I I I R R R R R R R R R R P P P P P P P P P P 8 $ $ G G G G 0 0 0 0 0 f& & & & ( ( ( ( * .q q q q q q q q q qr0