U
|
H=®dc ã @ sü d Z ddgZddlmZmZ ddlmZ ddlmZ ddl m
|
Z
|
m Z ddl m Z dd lmZ dd
|
lmZmZmZ dd lmZ dd lmZ erÐdd lmZmZmZm Z m Z m Z ddl m Z ddl m!Z! ddl"m#Z# G dd de$Z%dd Z&G dd de'Z(dS )zLazy ZIP over HTTPÚHTTPRangeRequestUnsupportedÚdist_from_wheel_urlé )Ú bisect_leftÚ bisect_right)Úcontextmanager)ÚNamedTemporaryFile)Ú
|
BadZipfileÚZipFile)ÚCONTENT_CHUNK_SIZE)Úrange)ÚHEADERSÚraise_for_statusÚresponse_chunks)ÚMYPY_CHECK_RUNNING)Ú$pkg_resources_distribution_for_wheel)ÚAnyÚDictÚIteratorÚListÚOptionalÚTuple)Ú Distribution)ÚResponse)Ú
|
PipSessionc @ s e Zd ZdS )r N)Ú__name__Ú
|
__module__Ú __qualname__© r r úWD:\z\workplace\VsCode\pyvenv\venv\Lib\site-packages\pip/_internal/network/lazy_wheel.pyr s c
|
C s8 t ||$}t|}t|| |jW 5 Q R £ S Q R X dS )a% Return a pkg_resources.Distribution 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 Úname)r ÚurlÚsessionÚwheelÚzip_filer r r r " s c @ sÆ e Zd ZdZefddZedd Zedd Zdd Z d
|
d Z
|
ed d Z d+ddZ dd Z d,ddZdd Zd-ddZdd Zd d Zd d Zed!d" Zd#d$ Zefd%d&Zd'd( Zd)d* ZdS ).r a File-like object mapped to a ZIP file over HTTP.
|
|
This uses HTTP range requests to lazily fetch the file's content,
|
which is supposed to be fed to ZipFile. If such requests are not
|
supported by the server, raise HTTPRangeRequestUnsupported
|
during initialization.
|
c C s |j |td}t| |jdks$t||| | _| _| _t|j d | _
|
t | _ | | j
|
¡ g | _g | _d|j dd¡krtd| ¡ d S )N)ÚheaderséÈ zContent-LengthÚbytesz Accept-RangesÚnonez range request is not supported)Úheadr r Ú status_codeÚAssertionErrorÚ_sessionÚ_urlÚ _chunk_sizeÚintr% Ú_lengthr Ú_fileÚtruncateÚ_leftÚ_rightÚgetr Ú
|
_check_zip)Úselfr! r" Ú
|
chunk_sizer) r r r Ú__init__= s zLazyZipOverHTTP.__init__c C s dS )z!Opening mode, which is always rb.Úrbr ©r7 r r r ÚmodeL s zLazyZipOverHTTP.modec C s | j jS )z Path to the underlying file.)r1 r r; r r r r R s zLazyZipOverHTTP.namec C s dS )z9Return whether random access is supported, which is True.Tr r; r r r ÚseekableX s zLazyZipOverHTTP.seekablec C s | j ¡ dS )zClose the file.N)r1 Úcloser; r r r r> ] s zLazyZipOverHTTP.closec C s | j jS )zWhether the file is closed.)r1 Úclosedr; r r r r? b s zLazyZipOverHTTP.closedéÿÿÿÿc C s` t || j}| ¡ | j }}|dk r(|n t|| |}t d|| }| ||d ¡ | j |¡S )zäRead 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. Útellr0 ÚminÚ _downloadr1 Úread)r7 ÚsizeZ download_sizeÚstartÚlengthÚstopr r r rF h s zLazyZipOverHTTP.readc C s dS )z3Return whether the file is readable, which is True.Tr r; r r r Úreadablew s zLazyZipOverHTTP.readabler c 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.
|
)r1 Úseek)r7 ÚoffsetÚwhencer r r rL | s zLazyZipOverHTTP.seekc C s
|
| j ¡ S )z Return the current possition.)r1 rC r; r r r rC s zLazyZipOverHTTP.tellNc C s | j |¡S )zÌResize 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.
|
)r1 r2 )r7 rG r r r r2 s zLazyZipOverHTTP.truncatec C s dS )z Return False.Fr r; r r r Úwritable s zLazyZipOverHTTP.writablec C s | j ¡ | S ©N)r1 Ú __enter__r; r r r rQ s
|
zLazyZipOverHTTP.__enter__c G s | j j| S rP )r1 Ú__exit__)r7 Úexcr r r rR ¡ s zLazyZipOverHTTP.__exit__c c s$ | ¡ }z
|
dV W 5 | |¡ X dS )zyReturn a context manager keeping the position.
|
|
At the end of the block, seek back to original position.
|
N)rC rL )r7 Úposr r r Ú_stay¥ s
|
zLazyZipOverHTTP._stayc
|
C sv | j d }ttd|| jD ]T}| ||¡ | ¡ 6 z t| W n tk
|
rV Y nX W 5 Q R £ qrW 5 Q R X q dS )z1Check and download until the file is a valid ZIP.rA r N)r0 Úreversedr r. rE rU r r )r7 ÚendrH r r r r6 ² s
|
|
zLazyZipOverHTTP._check_zipc C s. dd ||¡i}| |¡ | jj| j|ddS )z:Return HTTP response to a range request from start to end.ZRangez bytes={}-{}T)r% Ústream)ÚformatÚupdater, r5 r- )r7 rH rW Z base_headersr% r r r Ú_stream_response s
|
z LazyZipOverHTTP._stream_responsec
|
c s¸ | j ||
| j||
}}t|g|dd
}}t|g|dd
}t||D ]&\}} ||krv||d fV | d }qX||kr||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
|
NrA r@ )r3 r4 rD rB Úzip)
|
r7 rH rW ÚleftÚrightZlsliceZrsliceÚiÚjÚkr r r Ú_mergeÉ s
|
|
|
zLazyZipOverHTTP._mergec C s | ¡ t t| j|}t| j|}| ||||¡D ]D\}}| ||¡}| ¡ | |¡ t || j
|
D ]}| j |¡ qdq2W 5 Q R X dS )z-Download bytes from start to end inclusively.N) rU r r4 r r3 rb r[ r rL r r. r1 Úwrite)r7 rH rW r] r^ ÚresponseÚchunkr r r rE Þ s
|
|
zLazyZipOverHTTP._download)r@ )r )N)r r r Ú__doc__r
|
r9 Úpropertyr< r r= r> r? rF rK rL rC r2 rO rQ rR r rU r6 r r[ rb rE r r r r r 4 s0
|
|
|
|
|
|
|
r N))rf Ú__all__Úbisectr r Ú
|
contextlibr Útempfiler Úzipfiler r Zpip._vendor.requests.modelsr
|
Úpip._vendor.six.movesr Úpip._internal.network.utilsr r r Úpip._internal.utils.typingr Úpip._internal.utils.wheelr Útypingr r r r r r Zpip._vendor.pkg_resourcesr r Ú pip._internal.network.sessionr Ú Exceptionr r Úobjectr r r r r Ú<module> s$
|
