]j;* d dl mZ d dlmZmZ n# e$ r d dlmZmZ Y nw xY w d dlmZ n# e$ r G d d ZY nw xY wd dlm Z ddl
m Z dd l m
Z
dd
lmZmZ d d gZ e Z G d
d e Z G d d e ZdS ) )absolute_import)MappingMutableMapping)RLockc e Zd Zd Zd ZdS )r c d S N selfs K/opt/imunify360/venv/lib64/python3.11/site-packages/urllib3/_collections.py __enter__zRLock.__enter__ D c d S r r
)r exc_type exc_value tracebacks r
__exit__zRLock.__exit__ r r N)__name__
__module__ __qualname__r r r
r r
r r s2 r r ) OrderedDict )
InvalidHeader)six)iterkeys
itervaluesRecentlyUsedContainerHTTPHeaderDictc H e Zd ZdZeZd dZd Zd Zd Z d Z
d Z d
Z d Z
dS )
r a
Provides a thread-safe dict-like container which maintains up to
``maxsize`` keys while throwing away the least-recently-used keys beyond
``maxsize``.
:param maxsize:
Maximum number of recent elements to retain.
:param dispose_func:
Every time an item is evicted from the container,
``dispose_func(value)`` is called. Callback which will get called
Nc z || _ || _ | | _ t | _ d S r )_maxsize dispose_func ContainerCls
_containerr lock)r maxsizer% s r
__init__z RecentlyUsedContainer.__init__/ s3
( ++--GG r c | j 5 | j | }|| j |< |cd d d S # 1 swxY w Y d S r )r( r' pop)r keyitems r
__getitem__z!RecentlyUsedContainer.__getitem__6 s
Y ?&&s++D#'DOC s
&;??c n t }| j 5 | j |t }|| j |< t | j | j k r | j d \ }}d d d n # 1 swxY w Y | j r |t ur| | d S d S d S )NF)last)_Nullr( r' getlenr$ popitemr% )r r- value
evicted_value_keys r
__setitem__z!RecentlyUsedContainer.__setitem__= s
Y J J O / /U ; ;M#(DOC 4?##dm33&*o&=&=5&=&I&I#m J J J J J J J J J J J J J J J - e!;!; m , , , , , - -!;!;s A&BBBc | j 5 | j | }d d d n # 1 swxY w Y | j r| | d S d S r )r( r' r, r% )r r- r6 s r
__delitem__z!RecentlyUsedContainer.__delitem__L s
Y - -O'',,E - - - - - - - - - - - - - - - % e $ $ $ $ $ % %s /33c l | j 5 t | j cd d d S # 1 swxY w Y d S r )r( r4 r' r s r
__len__z RecentlyUsedContainer.__len__S s{
Y ( (t'' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s )--c t d )Nz7Iteration over this class is unlikely to be threadsafe.)NotImplementedErrorr s r
__iter__z RecentlyUsedContainer.__iter__W s ! E
r c | j 5 t t | j }| j d d d n # 1 swxY w Y | j r|D ]}| | d S d S r )r( listr r' clearr% )r valuesr6 s r
rC zRecentlyUsedContainer.clear\ s
Y $ $*T_5566F O ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $
)
)
)!!%(((( ) )
)
)s ;AAAc | j 5 t t | j cd d d S # 1 swxY w Y d S r )r( rB r r' r s r
keyszRecentlyUsedContainer.keysf s
Y 3 3 1122 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s !6::)r" N)r r r __doc__r r& r* r/ r9 r; r= r@ rC rF r
r r
r r s L
-
-
- % % %( ( (
) ) )3 3 3 3 3r c e Zd ZdZd fd Zd Zd Zd Zd Zd Z d Z
e j re
j Ze
j Z e Zd
Zd Zefd Zd
Zd Zd ZefdZeZeZeZeZ d Z d Z d Z d Z d Z!d Z"e#d Z$ xZ%S )r ap
:param headers:
An iterable of field-value pairs. Must not contain multiple field names
when compared case-insensitively.
:param kwargs:
Additional field-value pairs to pass in to ``dict.update``.
A ``dict`` like container for storing HTTP Headers.
Field names are stored and compared case-insensitively in compliance with
RFC 7230. Iteration provides the first case-sensitive key seen for each
case-insensitive pair.
Using ``__setitem__`` syntax overwrites fields that compare equal
case-insensitively in order to maintain ``dict``'s api. For fields that
compare equal, instead create a new ``HTTPHeaderDict`` and use ``.add``
in a loop.
If multiple fields that are equal case-insensitively are passed to the
constructor or ``.update``, the behavior is undefined and some will be
lost.
>>> headers = HTTPHeaderDict()
>>> headers.add('Set-Cookie', 'foo=bar')
>>> headers.add('set-cookie', 'baz=quxx')
>>> headers['content-length'] = '7'
>>> headers['SET-cookie']
'foo=bar, baz=quxx'
>>> headers['Content-Length']
'7'
Nc 2 t t | t | _ |@t |t r| | n| | |r| | d S d S r )superr r* r r'
isinstance
_copy_fromextend)r headerskwargs __class__s r
r* zHTTPHeaderDict.__init__ s
nd##,,...%-- '>22
%(((( G$$$ KK r c | ||g| j | < | j | S r r' lowerr r- vals r
r9 zHTTPHeaderDict.__setitem__ s/ (+Sz $syy{{++r c z | j | }d |dd S )N, r r' rS joinrT s r
r/ zHTTPHeaderDict.__getitem__ s0 ociikk*yyQRR!!!r c : | j | = d S r rR r r- s r
r; zHTTPHeaderDict.__delitem__ s OCIIKK ( ( (r c 8 | | j v S r )rS r' r[ s r
__contains__zHTTPHeaderDict.__contains__ s yy{{do--r c j t |t st |d sdS t |t | s t | | }t d | D t d | D k S )NrF Fc 3 H K | ] \ }}| |fV d S r rS .0kvs r
<genexpr>z(HTTPHeaderDict.__eq__.<locals>.<genexpr> s2 AAtq!QWWYYNAAAAAAr c 3 H K | ] \ }}| |fV d S r r` ra s r
re z(HTTPHeaderDict.__eq__.<locals>.<genexpr> sK J
J
#q!QWWYYNJ
J
J
J
J
J
r )rK r hasattrtypedict
itermergedr others r
__eq__zHTTPHeaderDict.__eq__ s %)) '%2H2H 5%d,, & DJJu%%EAAt/@/@AAAAAT J
J
','7'7'9'9J
J
J
F
F
r c . | | S r )rm rk s r
__ne__zHTTPHeaderDict.__ne__ s ;;u%%%%r c * t | j S r )r4 r' r s r
r= zHTTPHeaderDict.__len__ s 4?###r c # V K | j D ] }|d V
d S )Nr )r' rD )r valss r
r@ zHTTPHeaderDict.__iter__ s< O**,, Dq'MMMM r c V | | }| |= |S # t $ r || j u r |cY S w xY w)zD.pop(k[,d]) -> v, remove specified key and return the corresponding value.
If key is not found, d is returned if given, otherwise KeyError is raised.
)KeyError_HTTPHeaderDict__marker)r r- defaultr6 s r
r, zHTTPHeaderDict.pop sT IE S L
$-''NNN s ((c 0 | |= d S # t $ r Y d S w xY wr )rt r[ s r
discardzHTTPHeaderDict.discard s4 S DD s
c | }||g}| j || }||ur| | dS dS )zAdds a (name, value) pair, doesn't overwrite the value if it already
exists.
>>> headers = HTTPHeaderDict(foo='bar')
>>> headers.add('Foo', 'baz')
>>> headers['foo']
'bar, baz'
N)rS r'
setdefaultappend)r r- rU key_lowernew_valsrr s r
addzHTTPHeaderDict.add s\ IIKK :)))X>> 4 KK r c t | dk r/t d t | t | dk r|d nd}t |t r1| D ]\ }}| || nt |t r"|D ] }| ||| nbt |d r4| D ] }| ||| n |D ]\ }}| || |
D ]\ }}| || dS )zGeneric import function for any type of header-like object.
Adapted version of MutableMapping.update in order to insert items
with self.add instead of self.__setitem__
r z9extend() takes at most 1 positional arguments ({0} given)r r
rF N) r4 TypeErrorformatrK r iteritemsr~ r rg rF items)r argsrO rl r- rU r6 s r
rM zHTTPHeaderDict.extend s
t99q==((.s4yy(9(9
t99>>Qr e^ , , % !OO - -
#
#Sc""""
#
w
'
' %
*
*eCj))))
*
UF
#
# % zz||
*
*eCj))))
* $
%
%
Ue$$$$ ,,.. ! !JC HHS% ! !r c | j | }|dd S # t $ r || j u rg cY S |cY S w xY w)zmReturns a list of all the values for the named field. Returns an
empty list if the key doesn't exist.r N)r' rS rt ru )r r- rv rr s r
getlistzHTTPHeaderDict.getlist sf ?399;;/D 8O $-'' NNN s + AAAc t t | j dt | dS )N())rh r ri rj r s r
__repr__zHTTPHeaderDict.__repr__ s4 ::...T__5F5F0G0G0G0GHHr c |D ][}| | }t |t rt | }|g|z | j | < \d S r )r rK rB r' rS )r rl r- rU s r
rL zHTTPHeaderDict._copy_from sf 7 7C--$$C#t$$
3ii,/53;DOCIIKK ( ( 7 7r c ^ t | }| | |S r )rh rL )r clones r
copyzHTTPHeaderDict.copy" s, T
r c # K | D ]:}| j | }|dd D ]}|d |fV ;dS )z8Iterate over all header lines, including duplicate ones.r Nr rR )r r- rr rU s r
r zHTTPHeaderDict.iteritems' sf # #C?399;;/DABBx
#
#1gsl""""
# # #r c # K | D ]H}| j | }|d d |dd fV IdS )z:Iterate over all headers, merging duplicate ones together.r rW r NrX rT s r
rj zHTTPHeaderDict.itermerged. s_ - -C/#))++.Ca&$))CG,,, , , , , - -r c D t | S r )rB r r s r
r zHTTPHeaderDict.items4 s DNN$$%%%r c ` d}g }|j D ]}| | r?|st d|z |d \ }}||dz | z f|d< V| dd \ }}| || f | | S )z4Read headers from a Python 2 httplib message object.) z/Header continuation with no previous header: %sr :r )rN
startswithr stripsplitr{ )clsmessageobs_fold_continued_leadersrN liner- r6 s r
from_httplibzHTTPHeaderDict.from_httplib7 s &1"O 1 1D 9::
(IDP ")JC#& djjll(B"CGBK C++JC NNC / 0 0 0 0s7||r r )&r r r rG r* r9 r/ r; r] rm ro r PY2r r r objectru r= r@ r, rx r~ rM r
getheadersgetallmatchingheadersigetget_allr rL r r rj r classmethodr
__classcell__)rP s @r
r r k s B , , ," " ") ) ). . .
& & & w /!*#.
vxxH$ $ $
( " ! ! !8 $,
J # D GI I I7 7 7
# # #- - - & & & [ r N)
__future__r collections.abcr r ImportError collections threadingr r
exceptionsr packagesr packages.sixr r __all__r r2 r r r
r r
<module>r s & & & & & &4777777777 4 4 433333333334 $ # # # # # % % % % % % . . . . . . . . "$4
5 I3 I3 I3 I3 I3N I3 I3 I3Xf f f f f ^ f f f f f s
!!, A A