o
ai @ s d Z ddgZddlmZmZ ddlmZ ddlmZ ddl m
Z
m Z m Z m
Z
mZmZ ddlmZmZ dd lmZ dd
lmZmZ dd lmZmZmZ dd l m Z dd
l m Z m Z m!Z! G dd de"Z#de$de$de defddZ%G dd dZ&dS )zLazy ZIP over HTTPHTTPRangeRequestUnsupporteddist_from_wheel_url ) bisect_left bisect_right)contextmanager)NamedTemporaryFile)AnyDictIteratorListOptionalTuple)
BadZipfileZipFile)canonicalize_name)CONTENT_CHUNK_SIZEResponse)BaseDistribution MemoryWheelget_wheel_distribution)
PipSession)HEADERSraise_for_statusresponse_chunksc @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r /builddir/build/BUILDROOT/alt-python310-pip-21.3.1-5.el8.x86_64/opt/alt/python310/lib/python3.10/site-packages/pip/_internal/network/lazy_wheel.pyr s nameurlsessionreturnc C sH t ||}t|j|}t|t| W d S 1 s w Y dS )a Return a distribution object from the given wheel URL.
This uses HTTP range requests to only fetch the potion of the wheel
containing metadata, just enough for the object to be constructed.
If such requests are not supported, HTTPRangeRequestUnsupported
is raised.
N)LazyZipOverHTTPr r r r )r r r! zfwheelr r r r s $c
@ s e Zd ZdZefdedededdfddZe defd d
Z
e defd d Z de fd
dZ
d8ddZe de fddZd9dedefddZde fddZd:dededefd d Zdefd d Zd;dee defd d!Zde fd"d#Zd )zWhether the file is closed.)r2 closedr< r r r rC S r? zLazyZipOverHTTP.closedsizec C s` t || j}| | j}}|dk r|nt|| |}t d|| }| ||d | j|S )zRead up to size bytes from the object and return them.
As a convenience, if size is unspecified or -1,
all bytes until EOF are returned. Fewer than
size bytes may be returned if EOF is reached.
r )maxr/ tellr1 min _downloadr2 read)r8 rE
download_sizestartlengthstopr r r rK X s zLazyZipOverHTTP.readc C r: )z3Return whether the file is readable, which is True.Tr r< r r r readablef rA zLazyZipOverHTTP.readabler offsetwhencec C s | j ||S )a- Change stream position and return the new absolute position.
Seek to offset relative position indicated by whence:
* 0: Start of stream (the default). pos should be >= 0;
* 1: Current position - pos may be negative;
* 2: End of stream - pos usually negative.
)r2 seek)r8 rQ rR r r r rS j s zLazyZipOverHTTP.seekc C s
| j S )z Return the current position.)r2 rH r< r r r rH t s
zLazyZipOverHTTP.tellc C s | j |S )zResize the stream to the given size in bytes.
If size is unspecified resize to the current position.
The current stream position isn't changed.
Return the new file size.
)r2 r3 )r8 rE r r r r3 x s zLazyZipOverHTTP.truncatec C r: )z
Return False.Fr r< r r r writable rA zLazyZipOverHTTP.writablec C s | j | S N)r2 __enter__r< r r r rV s
zLazyZipOverHTTP.__enter__excc G s | j j| S rU )r2 __exit__)r8 rW r r r rX s zLazyZipOverHTTP.__exit__c c s. | }z dV W | | dS | | w )zyReturn a context manager keeping the position.
At the end of the block, seek back to original position.
N)rH rS )r8 posr r r _stay s
zLazyZipOverHTTP._stayc
C s | j d }ttd|| jD ]6}| || | " zt| W n ty* Y n w W d dS W d n1 s?w Y qdS )z1Check and download until the file is a valid ZIP.rF r N)r1 reversedranger/ rJ rZ r r )r8 endrM r r r r7 s
zLazyZipOverHTTP._check_ziprM r] base_headersc C s8 | }d| d| |d< d|d< | jj| j|ddS )z:Return HTTP response to a range request from start to end.zbytes=-Rangezno-cachez
Cache-ControlT)r' stream)copyr- r6 r. )r8 rM r] r^ r' r r r _stream_response s z LazyZipOverHTTP._stream_responseleftrightc
c s | j || | j|| }}t|g|dd }}t|g|dd }t||D ]\}} ||kr<||d fV | d }q-||krJ||fV |g|g| j ||< | j||< dS )a/ Return an iterator of intervals to be fetched.
Args:
start (int): Start of needed interval
end (int): End of needed interval
left (int): Index of first overlapping downloaded data
right (int): Index after last overlapping downloaded data
NrF rD )r4 r5 rI rG zip)
r8 rM r] rd re lslicersliceijkr r r _merge s
&zLazyZipOverHTTP._mergec C s | @ t| j|}t| j|}| ||||D ]"\}}| ||}| | | t || j
D ]}| j | q2qW d dS 1 sGw Y dS )z-Download bytes from start to end inclusively.N)
rZ r r5 r r4 rl rc r rS r r/ r2 write)r8 rM r] rd re responsechunkr r r rJ s
"zLazyZipOverHTTP._download)r" N)rD )r rU )r" r# )&r r r __doc__r strr r0 r9 propertyr= r boolr@ rB rC r) rK rP rS rH r r3 rT rV r rX r r
rZ r7 r r r rc r
rl rJ r r r r r# ( sj
r# N)'rp __all__bisectr r
contextlibr tempfiler typingr r r
r r r
zipfiler r pip._vendor.packaging.utilsr pip._vendor.requests.modelsr r pip._internal.metadatar r r pip._internal.network.sessionr pip._internal.network.utilsr r r Exceptionr rq r r# r r r r s