R`iw d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z d dl m Z
dZddlmZ ddlmZ dd lmZmZ dd
lmZmZmZmZmZm Z m Z m Z m Z m Z dd l!m"Z" dd l#m$Z$m%Z% ejL e' Z( G d
de) Z* G d de) Z+ G d de) Z,e G d de) Z- G d de) Z.d Z/ G d dej` Z1y) )absolute_importN)contextmanager)error)timeout )util)HTTPHeaderDict) BaseSSLError
HTTPException)
BodyNotHttplibCompatible DecodeError HTTPErrorIncompleteReadInvalidChunkLength
InvalidHeader
ProtocolErrorReadTimeoutErrorResponseNotChunkedSSLError)six) is_fp_closedis_response_to_headc e Zd Zd Zd Zd Zy)DeflateDecoderc R d| _ d| _ t j | _ y )NT )
_first_try_datazlib
decompressobj_objselfs /builddir/build/BUILDROOT/alt-python312-pip-23.3.1-3.el8.x86_64/opt/alt/python312/lib/python3.12/site-packages/pip/_vendor/urllib3/response.py__init__zDeflateDecoder.__init__$ s
&&( r c . t | j | S Ngetattrr! r# names r$ __getattr__zDeflateDecoder.__getattr__) tyy$''r c |s|S | j s| j j | S | xj |z
c_ | j j | }|rd| _ d | _ |S # t j
$ rb d| _ t j t j | _ | j | j d | _ cY S # d | _ w xY ww xY w)NF)r r!
decompressr r r r MAX_WBITS)r# data decompresseds r$ r/ zDeflateDecoder.decompress, s K99''- -
d
" 99//5L"' !
zz " #DO **DNN?;DI
"tzz2 !
T
"s% ,A/ /AC$3C
C$ C C$N__name__
__module__ __qualname__r% r, r/ r r$ r r # s )
("r r c e Zd ZdZdZdZy)GzipDecoderStater r N)r4 r5 r6 FIRST_MEMBER
OTHER_MEMBERS SWALLOW_DATAr7 r r$ r9 r9 C s LMLr r9 c e Zd Zd Zd Zd Zy) GzipDecoderc t j dt j z | _ t j
| _ y N )r r r0 r! r9 r; _stater" s r$ r% zGzipDecoder.__init__K s* &&rDNN':; &33 r c . t | j | S r' r( r* s r$ r, zGzipDecoder.__getattr__O r- r c $ t }| j t j k( s|s t | S || j
j
| z
}| j
j }|s t | S t j | _ t j dt j z | _ # t j $ rC | j }t j | _ |t j k( r
t | cY S w xY wrA )
bytearrayrC r9 r= bytesr! r/ r r r< unused_datar r0 )r# r1 retprevious_states r$ r/ zGzipDecoder.decompressR s k ;;*77 7t:
tyy++D11 99((D Sz!*88DK **2+>?DI ::
!% . ; ; !%5%C%CC :%
s B9 9AD
DNr3 r7 r r$ r? r? J s 4(@r r? c e Zd Zd Zd Zy)
BrotliDecoderc t j | _ t | j d r | j j | _ y | j j
| _ y )Nr/ )brotli Decompressorr! hasattrr/ processr" s r$ r% zBrotliDecoder.__init__n sB ++-DItyy,/"&))"6"6"&))"3"3r c d t | j d r| j j S y)Nflushr )rP r! rS r" s r$ rS zBrotliDecoder.flushu s$ tyy'*yy((r N)r4 r5 r6 r% rS r7 r r$ rL rL j s 4 r rL c " e Zd ZdZd Zd Zd Zy) MultiDecodera
From RFC7231:
If one or more encodings have been applied to a representation, the
sender that applied the encodings MUST generate a Content-Encoding
header field that lists the content codings in the order in which
they were applied.
c |j d D cg c] }t |j c}| _ y c c}w )N,)split _get_decoderstrip _decoders)r# modesms r$ r% zMultiDecoder.__init__ s1 ;@;;s;KL;Ka,qwwy1;KLLs =c < | j d j S Nr )r[ rS r" s r$ rS zMultiDecoder.flush s ~~a &&((r c \ t | j D ] }|j | } |S r' )reversedr[ r/ )r# r1 ds r$ r/ zMultiDecoder.decompress s( $..)A<<%D * r N)r4 r5 r6 __doc__r% rS r/ r7 r r$ rU rU { s M)r rU c | d| v r t | S | dk( r
t S t | dk( r
t S t S )NrW gzipbr)rU r? rN rL r )modes r$ rY rY s@
d{D!! v~}
ddl r c e Zd ZdZddgZeedgz
Zg dZ d'dZd Zd Z d
Z
e d Z e d Z
d
Zd Zd Zd Zeej( fZeeej( fz
Zd Zd Zed Zd Zd(dZd)dZ e d Z d Z d*dZ d Z!d Z"e d Z#d Z$d Z%d Z&d Z'd! Z(d" Z)d# Z*d+d$Z+d% Z,d& Z-y), HTTPResponsea
HTTP Response container.
Backwards-compatible with :class:`http.client.HTTPResponse` but the response ``body`` is
loaded and decoded on-demand when the ``data`` property is accessed. This
class is also compatible with the Python standard library's :mod:`io`
module, and can hence be treated as a readable object in the context of that
framework.
Extra parameters for behaviour not present in :class:`http.client.HTTPResponse`:
:param preload_content:
If True, the response's body will be preloaded during construction.
:param decode_content:
If True, will attempt to decode the body based on the
'content-encoding' header.
:param original_response:
When this HTTPResponse wrapper is generated from an :class:`http.client.HTTPResponse`
object, it's convenient to include the original for debug purposes. It's
otherwise unused.
:param retries:
The retries contains the last :class:`~urllib3.util.retry.Retry` that
was used during the request.
:param enforce_content_length:
Enforce content length checking. Body returned by server must match
value of Content-Length header, if present. Otherwise, raise error.
re deflateNrf )i- i. i/ i3 i4 c t |t r|| _ nt | | _ || _ || _ || _ || _ || _ |
| _ || _ || _
d | _ d | _ d | _
| | _ d| _ | | _ || _ |r't |t$ j& t( f r|| _ |
| _ | | _ t/ |d r|| _
d| _ d | _ | j j5 dd j7 }d |j9 d D }d|v rd | _ | j; | | _ |r%| j s| j? |
| _ y y y ) Nr readFztransfer-encoding c 3 < K | ] }|j y wr' )rZ ).0encs r$ z(HTTPResponse.__init__.. s >,=SSYY[,=s rW chunkedTdecode_content)
isinstancer headersstatusversionreasonstrictrt retriesenforce_content_length
auto_close_decoder_body_fp_original_response_fp_bytes_readmsg _request_urlr string_typesrG _pool _connectionrP rr
chunk_leftgetlowerrX _init_lengthlength_remainingrl )r# bodyrv rw rx ry rz preload_contentrt original_responsepool
connectionr r{ r| request_method request_urlr} tr_enc encodingss r$ r% zHTTPResponse.__init__ sX * g~ ."DL)'2DL , &<#$
"3 ' Jtc&6&6%>? DJ
% 4 DH !!"5r:@@B>FLL,=> ! DL !% 1 1. A 4:: .ADJ $.?r c j | j | j v r| j j d S y)a
Should we redirect and where to?
:returns: Truthy redirect location string if we got a redirect status
code and valid location. ``None`` if redirect status and no
location. ``False`` if not a redirect status code.
locationF)rw REDIRECT_STATUSESrv r r" s r$ get_redirect_locationz"HTTPResponse.get_redirect_location s. ;;$00 0<<##J/ /r c | j r | j sy | j j | j d | _ y r' )r r _put_connr" s r$ release_connzHTTPResponse.release_conn s4 zz!1!1
T - -. r c d | j y# t t t t f$ r Y yw xY w)z
Read and discard any remaining HTTP response data in the response connection.
Unread data in the HTTPResponse connection blocks the connection from being released back to the pool.
N)rl r SocketErrorr
r r" s r$
drain_connzHTTPResponse.drain_conn s+ IIK; mD s //c p | j r | j S | j r| j d S y )NT)
cache_content)r r rl r" s r$ r1 zHTTPResponse.data% s2 :::: 8899490 0 r c | j S r' )r r" s r$ r zHTTPResponse.connection. s r c , t | j S r' )r r r" s r$ isclosedzHTTPResponse.isclosed2 s DHH%%r c | j S )z
Obtain the number of bytes pulled over the wire so far. May differ from
the amount of content returned by :meth:``urllib3.response.HTTPResponse.read``
if bytes are encoded on the wire (e.g, compressed).
)r r" s r$ tellzHTTPResponse.tell5 s """r c | j j d }|| j rt j d y t |j
d D cg c]
}t | c} }t | dkD rt d|z |j }|dk rd} t | j }|dv sd |cxk rd
k sn |d k( rd}|S c c}w # t $ r d}Y Bw xY w# t $ r d}Y =w xY w) zM
Set initial length value for Response content if available.
zcontent-lengthNzReceived response with both Content-Length and Transfer-Encoding set. This is expressly forbidden by RFC 7230 sec 3.3.2. Ignoring Content-Length and attempting to process response as Transfer-Encoding: chunked.rW r z8Content-Length contained multiple unmatching values (%s)r ) i0 d HEAD)
rv r rr logwarningsetrX intlenr pop
ValueErrorrw )r# r lengthvallengthsrw s r$ r zHTTPResponse._init_length= s !!"23 ||
" 6<<3D E3DCs3x3D EFwCIIK == 4#8#88 ,-= >
(( . 3 3C 8 8wwyD$9$99 GGI 8
y>$01A$BDM "
) ! s -3Cc ( |s|S | j r| j j | }|r|| j z
}|S # | j $ r>}| j j dd j }t
d|z | d}~ww xY w)zN
Decode the data passed in and potentially flush the decoder.
r rm zEReceived response with content-encoding: %s, but failed to decode it.N)r~ r/ DECODER_ERROR_CLASSESrv r r r
_flush_decoder)r# r1 rt
flush_decoderr r s r$ _decodezHTTPResponse._decode s K }}}}//5 D'') )D )) #|| / /0BB G M M O ')9:
s 'A B9B Bc | j r8| j j d }|| j j z S y)zk
Flushes the decoder. Should only be called if the decoder is actually
being used.
r )r~ r/ rS )r# bufs r$ r zHTTPResponse._flush_decoder s:
==--**3/C ,,.. .r c # B K d} d d}|sL| j r| j j | j r| j j | j r,| j j r| j yyy# t $ r t | j dd t $ r4}dt | vr t | t | j dd d}~wt t f$ r}t d|z | d}~ww xY w# |sL| j r| j j | j r| j j | j r,| j j r| j w w w xY ww)z
Catch low-level python exceptions, instead re-raising urllib3
variants, so that low-level exceptions are not leaked in the
high-level api.
On exit, release the connection back to the pool.
FNzRead timed out.zread operation timed outzConnection broken: %rT)
SocketTimeoutr r r
strr r r r r closer r r )r#
clean_exitr s r$ _error_catcherzHTTPResponse._error_catcher s
+ $
D* J **++113
##$$**, &&4+B+B+K+K+M!!# ,N&M !
L 'tzz49JKK
L-SV;"1+%&tzz49JKK!;/
D#$;a$?CC
D **++113
##$$**, &&4+B+B+K+K+M!!# ,N&sF F B D BF (D2ww(55g>( 9 Ha(
88II88
r c R t j dt d | j S )Nz|HTTPResponse.getheaders() is deprecated and will be removed in urllib3 v2.1.0. Instead access HTTPResponse.headers directly.r: category
stacklevel)warningswarnDeprecationWarningrv r" s r$
getheaderszHTTPResponse.getheaders s&
O'
||r c r t j dt d | j j || S )NzHTTPResponse.getheader() is deprecated and will be removed in urllib3 v2.1.0. Instead use HTTPResponse.headers.get(name, default).r: r )r r r rv r )r# r+ defaults r$ getheaderzHTTPResponse.getheader s3
V'
|| g..r c | j S r' )rv r" s r$ infozHTTPResponse.info s ||r c | j s| j j | j r| j j | j s t
j j | y y r' )r r r r r} r IOBaser" s r$ r zHTTPResponse.close sN {{ HHNN " " $ IIOOD ! r c @ | j s)t j j j | S | j
yt
| j
d r| j
j S t
| j
d r| j
j S y)NTr r )r} r r r __get__r rP r r" s r$ r zHTTPResponse.closed sq 99##++D1 1
XX
TXXz
*88$$& &
TXXx
(88?? "r c | j t d t | j d r| j j S t d )Nz-HTTPResponse has no file to get a fileno fromfilenozOThe file-like object this HTTPResponse is wrapped around has no file descriptor)r IOErrorrP r r" s r$ r zHTTPResponse.fileno sI 88 IJ J
TXXx
(88??$ $0
r c | j It | j d r2t | j dd s| j j S y y y )NrS r F)r rP r) rS r" s r$ rS zHTTPResponse.flush sJ HH '*DHHh688>># # 7 +
!r c y)NTr7 r" s r$ readablezHTTPResponse.readable s r c | j t | }t | dk( ry||d t | t | S r_ )rl r )r# btemps r$ readintozHTTPResponse.readinto s; yyQ t9> !AkD Nt9 r c . t | j d S )a
Checks if the underlying file-like object looks like a
:class:`http.client.HTTPResponse` object. We do this by testing for
the fp attribute. If it is present we assume it returns raw chunks as
processed by read_chunked().
fp)rP r r" s r$ r z#HTTPResponse.supports_chunked_reads s txx&&r c | j y | j j j }|j dd d } t |d | _ y # t $ r | j t | | w xY w)N ;r r rB ) r r r readlinerX r r r r )r# r s r$ _update_chunk_lengthz!HTTPResponse._update_chunk_length ss ?? & xx{{##%zz$"1% 1 !$mDO 1 JJL$T40 0 1s A &B c V d }|K| j j | j }|}| j j d d | _ |S || j k r3| j j | }| j |z
| _ |}|S || j k( rA| j j | }| j j d d | _ |}|S | j j | j }| j j d d | _ |S )Nr: )r
_safe_readr )r# r returned_chunkchunkvalues r$
_handle_chunkzHTTPResponse._handle_chunk s
;HH''8E "N HH " "DO 4??
"HH'',E "oo 3DO "N DOO
#HH'',E HH " "DO "N
"XX 0 0 AN HH " "DO r c # K | j | j s t d | j s t d | j 5 | j r9t | j r$| j j ddd y| j j
ddd y | j | j dk( rn,| j | }| j ||d }|r| L|r| j }|r| | j j j! }|sn|dk( rn.| j r| j j ddd y# 1 sw Y yxY ww)a
Similar to :meth:`HTTPResponse.read`, but with an additional
parameter: ``decode_content``.
:param amt:
How much of the content to read. If specified, caching is skipped
because it doesn't make sense to cache partial content as the full
response.
:param decode_content:
If True, will attempt to decode the body based on the
'content-encoding' header.
zHResponse is not chunked. Header 'transfer-encoding: chunked' is missing.zkBody should be http.client.HTTPResponse like. It should have have an fp attribute which returns raw chunks.Nr F)rt r s
)r rr r r r r r r r r r r r r r r r
)r# r rt r decodedr s r$ r zHTTPResponse.read_chunked s{
||$B
**,*P
"&&+>t?V?V+W''--/ #
" xx{{" #
" ))+??a' **3/ ,,. ' !M --/!M xx{{++-7?
&&''--/S #
"
"s7 AF
=E> F
E>2 F
;B:E>5 F
>FF
c | j Bt | j j r#| j j d j S | j S )z
Returns the URL that was the source of this response.
If the request that generated this response redirected, this method
will return the final redirect location.
)r{ r historyredirect_locationr r" s r$ geturlzHTTPResponse.geturlU sF << #DLL,@,@(A<<''+== =$$ $r c # . K g }| j d D ]d }d|v rM|j d }dj | |d z dz |dd D ] }|dz |d r|d g}Qg }T|j | f |rdj | y y w)NTrs
r r r r )r rX joinappend)r# r r xs r$ __iter__zHTTPResponse.__iter__` s [[[5E~ E*hhv&q1E99 qAe)O %9 #Bi[F F
e$ 6 ((6" " s BB)rm Nr r Nr TTNNNNNFNNT)NNF)i Nr' )NN).r4 r5 r6 rc r rN r r% r r r propertyr1 r r r r r r r r r r r r r r rl r classmethodr r r r r r r rS r r r r r r r r r7 r r$ ri ri s @ *
TF"1
$%ABF 1 1 hC& %djj 1
&,, 0 , 5$ 5$n.N`FP 4 @ / "
$ ' 1 ,D0L %#r ri )2
__future__r r loggingr r r
contextlibr socketr r r r rN rm r _collectionsr r r
r
exceptionsr r
r r r r r r r r packagesr
util.responser r getLoggerr4 r objectr r9 r? rL rU rY r ri r7 r r$ r+ s &
% ' +
( 3 <g! "V "@v @& @<
"6 *
R #299 R #r