Ë
|
ñúh1 ã óÄ 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 ejh e5« Z6d dZ7d dZ8 d! d"dZ9d#dZ:d$dZ;d%dZ<e G d d « « Z= G d d « Z>y)&z(Download files with progress indicators.é )Ú annotationsN)ÚIterableÚMapping)Ú dataclass)Ú
|
HTTPStatus)ÚBinaryIO)ÚPreparedRequest)ÚResponse)Ú HTTPResponse)ÚHTTPHeaderDict)ÚReadTimeoutError)ÚBarTypeÚ get_download_progress_renderer)ÚIncompleteDownloadErrorÚNetworkConnectionError)ÚPyPI)ÚLink)Ú SafeFileCacheÚ is_from_cache)ÚCacheControlAdapterÚ
|
PipSession)ÚHEADERSÚraise_for_statusÚresponse_chunks)Ú format_sizeÚredact_auth_from_urlÚsplitextc óh t | j d « S # t t t f$ r Y y w xY w)Núcontent-length)ÚintÚheadersÚ
|
ValueErrorÚKeyErrorÚ TypeError©Úresps úQH:\Change_password\venv_build\Lib\site-packages\pip/_internal/network/download.pyÚ_get_http_response_sizer( s5 ðÜ4<<Ð 0Ñ1Ó2Ð2øÜ ¤)Ð ,ò Ùðús 1°1c ól | j j d| j 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* ð
|
<<× Ñ F D§L¡L×$4Ñ$4°_Ó$EÓ FÐFó c ó` |j t j k( r |j }n |j }t |« }|r1|r | dt |« dt |« d}n| dt |« d}t | « rt j d|« n/|rt j d|« nt j d|« t j « t j kD rd}n t | « rd}n|sd}n
|
|d kD rd}nd}t | « }|s|S t |||¬
|
« } | |« S ) Nz (ú/ú)zUsing cached %szResuming download %szDownloading %sFTi )Úbar_typeÚsizeÚinitial_progress)Únetlocr Úfile_storage_domainÚshow_urlÚurl_without_fragmentr r r ÚloggerÚinfoÚgetEffectiveLevelÚloggingÚINFOr r )
|
r& ÚlinkÚ progress_barÚ total_lengthÚ range_startÚurlÚ
|
logged_urlÚ show_progressÚchunksÚrenderers
|
r' Ú _log_downloadrF / s% ð {{d×.Ñ.Ò.Ømmà×'Ñ'ä% cÓ*JáÙ à ,b¤¨[Ó!9Ð :¸!¼KÈ Ó<UÐ;VÐVWÐXñ ð '< r¬+°lÓ*CÐ)DÀAÐFJäTÔÜ Ð% zÕ2Ù Ü Ð*¨JÕ7ä Ð$ jÔ1ä × Ñ Ó!¤G§L¡LÒ0Ø Ü tÔ Ø Ù Ø Ø Ò $Ø à ä TÓ "Fá Ø ä-Ø LÀ;ôHñ FÓ Ðr- c ó@ t j j | « S )zJ
|
Sanitize the "filename" value from a Content-Disposition header.
|
)ÚosÚpathÚbasename)Úfilenames r' Úsanitize_content_filenamerL b s ô 77× Ñ HÓ %Ð%r- c ó¢ t j j « }| |d< |j d« }|rt t |« « }|xs |S )z
|
Parse the "filename" value from a Content-Disposition header, and
|
return the default filename if the result is empty.
|
ú content-typerK )ÚemailÚmessageÚMessageÚ get_paramrL Ústr)Úcontent_dispositionÚdefault_filenameÚmrK s r' Úparse_content_dispositionrW i sM ô
|
× Ñ Ó AØ+AnÑØ{{:Ó&HÙô -¬S°«]Ó;Ø Ò 'Ð'Ð'r- c ó |j }| j j d« }|r t ||« }t |« d }|s6t j | j j dd« « }|r||z }|sL|j | j k7 r3t j j | j « d }|r||z }|S )zoGet an ideal filename from the given HTTP response, falling back to
|
the link filename if not provided.
|
zcontent-dispositioné rN Ú )
|
rK r! r+ rW r Ú mimetypesÚguess_extensionrA rH rI )r& r= rK rT Úexts r' Ú_get_http_response_filenamer^ x s² ð }}Hà ,,×*Ñ*Ð+@ÓAÐÙÜ,Ð-@À(ÓKÜ xÓ(¨Ñ+CÙ Ü×'Ñ'¨¯ © ×(8Ñ(8¸ ÈÓ(LÓMÙ Ø OHÙ 488txxÒ'Ügg× Ñ txxÓ(¨Ñ+Ù Ø OHØ Or- c ód e Zd ZU dZded< ded< ded< dZd ed
|
< dZd ed < dd Zdd ZddZ y)Ú _FileDownloadz+Stores the state of a single link download.r r= r Ú output_fileú
|
int | Noner2 r r Úbytes_receivedÚ
|
reattemptsc óf t | j d uxr | j | j k « S ©N)Úboolr2 rc ©Úselfs r' Ú is_incompletez_FileDownload.is_incomplete s* ÜDII TÐ)ÒM¨d×.AÑ.AÀDÇIÁIÑ.MÓNÐNr- c óv | xj t |« z c_ | j j |« y rf )rc Úlenra Úwrite)ri Údatas r' Ú write_chunkz_FileDownload.write_chunk s+ Ø ×Òs 4yÑ(ÕØ ×Ñ× Ñ tÕ$r- c ó| | j j d« | j j « d| _ y)z1Delete any saved data and reset progress to zero.r N)ra ÚseekÚtruncaterc rh s r' Ú
|
reset_filez_FileDownload.reset_file s0 à ×Ñ× Ñ aÔ Ø ×Ñ×!Ñ!Ô#Ø Õr- N)Úreturnrg )rn Úbytesrt ÚNone)rt rv )
|
Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú__annotations__rc rd rj ro rs © r- r' r` r` s:
á5à
|
JØÓØ
|
ÓØNCÓØJÓóOó%ô r- r` c ó e Zd Z d
|
dZ d dZd dZd dZ ddZ ddZ ddZ e
|
fddZ y )Ú
|
Downloaderc óF |dk\ sJ d« || _ || _ || _ y )Nr z<Number of max resume retries must be bigger or equal to zero)Ú_sessionÚ _progress_barÚ_resume_retries)ri Úsessionr> Úresume_retriess r' Ú__init__zDownloader.__init__¦ s5 ð aÒ ð Jà Ió JØ à Ø )ÔØ -Õ r- c # óB K |D ] } | ||« \ }}|||ff yw)z.Convenience method to download multiple links.Nr| )ri ÚlinksÚlocationr= ÚfilepathÚ content_types r' ÚbatchzDownloader.batch³ s8 è ø ð ò 1DÙ%)¨$°Ó%9Ñ "HlØ <Ð0Ð0Ó 0ñ 1ùs c ó | j |« }t |« }t j j |t ||« « }t |d« 5 }t |||« }| j ||« |j « r| j ||« ddd« |j j dd« }||fS # 1 sw Y )xY w)z+Download a link and save it under location.ÚwbNz Content-TyperZ ) Ú _http_getr( rH rI Újoinr^ Úopenr` Ú_process_responserj Ú _attempt_resumes_or_redownloadsr! r+ ) ri r= r r& Ú download_sizer Ú content_fileÚdownloadr s r' Ú__call__zDownloader.__call__» s¸ à~~dÓ#Ü/°Ó5 ä77<< Ô*EÀdÈDÓ*QÓRÜ (DÓ !ð E \Ü$ T¨<¸ ÓGHØ × "Ñ " 8¨TÔ 2Ø×%Ñ%Ô'Ø×4Ñ4°X¸tÔD÷ Eð ||×'Ñ'¨¸Ó; Ø Ð%Ð%÷ Eð Eús ÁAB=Â=Cc ó t ||j | j |j |j ¬« } |D ] }|j |« y# t $ r-}|j |t j d« Y d}~yd}~ww xY w)z)Download and save chunks from a response.)r@ Nz'Connection timed out while downloading.) rF r= r r2 rc ro r r8 Úwarning)ri r r& rD ÚchunkÚes r' r z Downloader._process_responseÊ s ä Ø Ø MMØ × Ñ Ø MMØ ×/Ñ/ô
|
ð FØ ò ,Ø×$Ñ$ UÕ+ñ ,øä ò Fà}}Ð$Øä NNÐD× EÑ Eûð Fús ºA Á B Á #BÂB c óR |j | j k r |j « rü|j J |xj dz c_ t j dt |j « t |j « |j « | j ||¬« }|j t j k7 }|r"|j « t |« |_ |}| j ||« |j | j k r|j « rü|j « r4t% j& |j( j* « t- |« |j dkD r| j/ ||« yy# t t t" f$ r Y ¤w xY w)zAAttempt to resume/restart the download if connection was dropped.NrY z<Attempting to resume incomplete download (%s/%s, attempt %d))Ú should_matchr )rd r rj r2 r8 r r rc Ú_http_get_resumeÚ status_coder ÚPARTIAL_CONTENTrs r( r ÚConnectionErrorr ÚOSErrorrH Úremovera Únamer Ú_cache_resumed_download)ri r Ú
|
first_respÚ resume_respÚ must_restarts r' r z*Downloader._attempt_resumes_or_redownloadsÝ sk ð
|
×!Ñ! D×$8Ñ$8Ó8¸X×=SÑ=SÔ=UØ==Ð,Ð ,Ð,Ø × Ò 1Ñ $Õ Ü NNØNÜH× 3Ñ 3Ó4ÜHMMÓ*Ø×#Ñ#ô ð Ø "× 3Ñ 3°HÈ:Ð 3Ó V ð +× 6Ñ 6¼*×:TÑ:TÑ T Ù Ø ×'Ñ'Ô)Ü$;¸KÓ$HHMØ!,Jà×&Ñ& x°Ô=ð+ ×!Ñ! D×$8Ñ$8Ò8¸X×=SÑ=SÕ=Uð4 × !Ñ !Ô #Ü IIh×*Ñ*×/Ñ/Ô 0Ü)¨(Ó3Ð 3ð × Ñ Ò "Ø × (Ñ (¨°:Õ >ð #øô $Ô%5´wÐ?ò Úð ús ÂA&F ÆF&Æ%F&c óÆ |j j }| j j |« }t |t
|
« st j d|« yt |j t « sJ d« t « }|j d|i ¬« t « }|j j « D ] \ }}|j « dvs|||< t! |j" « |d< t% d|d d
|
¬ « } |j& j) |« }
|
|j& j* j- || d « } |j j/ |
|
| « |j0 j3 « t5 |j0 j6 d « 5 } |j j9 |
|
| « ddd« t j d|« y# 1 sw Y xY w)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.
|
z<Skipping resume download caching: no cache controller for %sNz separate body cache not in use!ÚGET)ÚmethodrA r! )z content-ranger r rZ éÈ F)Úbodyr! ÚstatusÚpreload_contentr- Úrbz?Cached resumed download as complete response for future use: %s) r= r7 r Ú get_adapterÚ
|
isinstancer r8 ÚdebugÚcacher r Úpreparer r! ÚitemsÚlowerrS r2 ÚURLlib3ResponseÚ
|
controllerÚ cache_urlÚ
|
serializerÚdumpsÚsetra Úflushr r£ Úset_body_from_io) ri r Úoriginal_responserA ÚadapterÚsynthetic_requestÚsynthetic_response_headersÚkeyÚvalueÚsynthetic_responser¹ Ú metadata_blobÚfs r' r¤ z"Downloader._cache_resumed_download s» ð mm×0Ñ0Ø--×+Ñ+¨CÓ0ô 'Ô#6Ô7Ü LLØNÐPSô ð ô Ø MM=ô
|
ð -à ,ó -ð
|
ô ,Ó -ÐØ×!Ñ!¨°CÀÐ!ÔDä%3Ó%5Ð"Ø+×3Ñ3×9Ñ9Ó;ò 8JCØyy{Ð"EÒEØ27Ð*¨3Ò/ð 8ô 8;¸8¿=¹=Ó7IÐ"Ð#3Ñ4ä ,ØØ.ØØ !ô
|
Ðð ×&Ñ&×0Ñ0°Ó5 Ø ×*Ñ*×5Ñ5×;Ñ;Ø Ð 1°3ó
|
ð ×Ñ) ]Ô3Ø× Ñ ×"Ñ"Ô$Ü (×&Ñ&×+Ñ+¨TÓ 2ð 9°aØ MM× *Ñ *¨9°aÔ 8÷ 9ô Ø MÈsõ
|
÷ 9ð 9ús Æ GÇG c ó¬ t j « }d|j d|d< t |« x}r||d< | j |j
|
|« S )z2Issue a HTTP range request to resume the download.zbytes=ú-ÚRangezIf-Range)r Úcopyrc r, r r= )ri r r r! Ú
|
identifiers r' r zDownloader._http_get_resume= s[ ô ,,.Ø # H×$;Ñ$;Ð#<¸AÐ>Ñô BÀ,ÓOÐ O:Ð OØ",GJÑ Ø~~hmm¨WÓ5Ð5r- c ó |j } | j j ||d¬« }t |« |S # t $ r?}|j
|
J t j d|j
|
j |« d }~ww xY w)NT)r! Ústreamz HTTP error %s while getting %s) r7 r r+ r r Úresponser8 Úcriticalr )ri r= r! Ú
|
target_urlr& r s r' r zDownloader._http_getK s Ø×.Ñ.
|
ð Ø==×$Ñ$ Z¸ÈÐ$ÓNDÜ TÔ "ð øô &ò Ø::Ð)Ð )Ð)Ü OOØ0°!·*±*×2HÑ2HÈ$ô ð ûð ús )9 ¹ BÁ:A<Á<BN)r r r> r r r rt rv )r zIterable[Link]r rS rt z&Iterable[tuple[Link, tuple[str, str]]])r= r r rS rt ztuple[str, str])r r` r& r
|
rt rv )r r` r¥ r
|
rt rv )r r` r¿ r
|
rt rv )r r` r r
|
rt r
|
)r= r r! zMapping[str, str]rt r
|
) rw rx ry r
r r r r r¤ r r r r| r- r' r~ r~ ¥ sº ð .àð .ð ð .ð ð .ð
|
|
ó .ð1Ø#ð1Ø/2ð1à /ó1ó &ó Fð&&?Ø%ð&?Ø3;ð&?à ó&?ðP6
|
Ø%ð6
|
Ø:Bð6
|
à ó6
|
ðp 6Ø%ð 6Ø5=ð 6à ó 6ð BIõ r- r~ )r& r
|
rt rb )r& r
|
rt z
|
str | None)r ) r& r
|
r= r r> r r? rb r@ rb rt zIterable[bytes])rK rS rt rS )rT rS rU rS rt rS )r& r
|
r= r rt rS )?rz Ú
|
__future__r Ú email.messagerO r; r[ rH Ú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 Ú getLoggerrw r8 r( r, rF rL rW r^ r` r~ r| r- r' ú<module>ræ sä ðÙ .å "ã Û Û Û ß -Ý !Ý Ý å 0Ý 0Ý ?Ý ;Ý ;ç Sß TÝ +Ý *ß Dß Iß RÑ Rß PÑ Pà × Ñ 8Ó $óóGð ð 0 Ø
|
ð0 à
|
ð0 ð ð0 ð ð 0 ð
|
ð 0 ð ó 0 óf&ó (ó ð* ÷ ð ó ð ÷.qò qr-
|
