U
fC @ s@ d dl mZ d dlZd dlmZ d dlmZmZ d dlm Z ej
rjd dlm Z d dl m
Z
G dd d e Zd
d gZed Zed
ZedZejd ejeef ejejeef d f ZG dd deZdddddZG dd
d
ej eef ej eef Z G dd dej ejeef Z G dd d ej eef Z!dS ) ) annotationsN) OrderedDict)Enumauto)RLock)Protocol)Selfc @ s* e Zd ZddddZdddddZd S )
HasGettableStringKeystyping.Iterator[str]returnc C s d S N selfr r E/opt/alt/python38/lib/python3.8/site-packages/urllib3/_collections.pykeys s zHasGettableStringKeys.keysstrkeyr c C s d S r
r r r r r r __getitem__ s z!HasGettableStringKeys.__getitem__N)__name__
__module__ __qualname__r r r r r r r s r RecentlyUsedContainerHTTPHeaderDict_KT_VT_DTc @ s e Zd Ze ZdS ) _SentinelN)r r r r
not_passedr r r r r ) s r object ValidHTTPHeaderSource | None) potentialr c C s t | tr| S t | tjr0ttjttf | S t | tjrXttjtjttf | S t| drxt| drxtd| S d S d S )Nr r r )
isinstancer typingMappingcastr IterableTuplehasattr)r$ r r r %ensure_can_construct_http_header_dict- s
r, c s e Zd ZU dZded< ded< ded< ded < d%ddd d
fdd
ZdddddZddd dddZdd dddZdddd Z d dd d Z
d dd d!Z d"dd#d$Z Z
S )&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
z typing.OrderedDict[_KT, _VT]
_containerint_maxsizez#typing.Callable[[_VT], None] | None dispose_funcr lock
NNone)maxsizer0 r c s* t || _|| _t | _t | _d S r
)super__init__r/ r0 r r- r r1 )r r4 r0 __class__r r r6 T s
z RecentlyUsedContainer.__init__r r r c
C s8 | j ( | j|}|| j|< |W 5 Q R S Q R X d S r
)r1 r- pop)r r itemr r r r _ s
z!RecentlyUsedContainer.__getitem__)r valuer c C s d }| j b z || j|f}|| j|< W n< tk
rf || j|< t| j| jkrb| jjdd}Y nX W 5 Q R X |d k r| jr|\}}| | d S )NF)last)r1 r- r9 KeyErrorlenr/ popitemr0 )r r r; Z evicted_item_
evicted_valuer r r __setitem__f s
z!RecentlyUsedContainer.__setitem__c C s2 | j | j|}W 5 Q R X | jr.| | d S r
)r1 r- r9 r0 )r r r; r r r __delitem__ s z!RecentlyUsedContainer.__delitem__r c
C s( | j t| jW 5 Q R S Q R X d S r
)r1 r> r- r r r r __len__ s z RecentlyUsedContainer.__len__ztyping.NoReturnc C s t dd S )Nz7Iteration over this class is unlikely to be threadsafe.)NotImplementedErrorr r r r __iter__ s z RecentlyUsedContainer.__iter__c C sH | j t| j }| j W 5 Q R X | jrD|D ]}| | q4d S r
)r1 listr- valuesclearr0 )r rH r; r r r rI s zRecentlyUsedContainer.clearzset[_KT]c
C s, | j t| j W 5 Q R S Q R X d S r
)r1 setr- r r r r r r s zRecentlyUsedContainer.keys)r2 N)r r r __doc____annotations__r6 r rB rC rD rF rI r
__classcell__r r r7 r r A s
c @ sV e Zd ZU dZded< dddddZdd d
d Zd d d
dZdddddZdS )HTTPHeaderDictItemViewa
HTTPHeaderDict is unusual for a Mapping[str, str] in that it has two modes of
address.
If we directly try to get an item with a particular name, we will get a string
back that is the concatenated version of all the values:
>>> d['X-Header-Name']
'Value1, Value2, Value3'
However, if we iterate over an HTTPHeaderDict's items, we will optionally combine
these values based on whether combine=True was called when building up the dictionary
>>> d = HTTPHeaderDict({"A": "1", "B": "foo"})
>>> d.add("A", "2", combine=True)
>>> d.add("B", "bar")
>>> list(d.items())
[
('A', '1, 2'),
('B', 'foo'),
('B', 'bar'),
]
This class conforms to the interface required by the MutableMapping ABC while
also giving us the nonstandard iteration behavior we want; items with duplicate
keys, ordered by time of first insertion.
r _headersr3 )headersr c C s
|| _ d S r
)rO )r rP r r r r6 s z HTTPHeaderDictItemView.__init__r. r c C s t t| j S r
)r> rG rO iteritemsr r r r rD s z HTTPHeaderDictItemView.__len__ typing.Iterator[tuple[str, str]]c C s
| j S r
)rO rQ r r r r rF s z HTTPHeaderDictItemView.__iter__r" bool)r: r c C sD t |tr@t|dkr@|\}}t |tr@t |tr@| j||S dS )N F)r% tupler> r rO _has_value_for_header)r r: Z
passed_keyZ
passed_valr r r __contains__ s
z#HTTPHeaderDictItemView.__contains__N) r r r rK rL r6 rD rF rW r r r r rN s
rN c s e Zd ZU dZded< dTddd fdd
Zddd
d d d
ZdddddZdd
dddZdddddZ dUdddd fdd
Z
dddd d Z dddd d Z d d!d"d#Z
d$d!d%d&Zdd
dd'd(Zd)d*dddd
d+d,d-Zd.dd
d/d0d1Zejdd2dd3d4Zejdd5d6dd7d4Zejfdd8d6dd9d4Zd:d!d;d<ZeZeZeZeZdd!d=d>Z d d
dd?d@Z d:d!dAdBZ dCd!dDdEZ dCd!dFdGZ dHd!dIdJZ!ddddKdLdMZ"dd ddNdOZ#dd:ddPdQZ$dd:ddRdSZ% Z&S )Vr 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'
z%typing.MutableMapping[str, list[str]]r- Nr# r )rP kwargsc sJ t i | _|d k r8t|tr.| | n
| | |rF| | d S r
)r5 r6 r- r% r
_copy_fromextend)r rP rX r7 r r r6 s
zHTTPHeaderDict.__init__r3 )r valr c C s* t |tr|d}||g| j| < d S )Nlatin-1)r% bytesdecoder- lowerr r r[ r r r rB s
zHTTPHeaderDict.__setitem__r c C s | j | }d|dd S )N, r- r_ joinr` r r r r s zHTTPHeaderDict.__getitem__c C s | j | = d S r
r- r_ r r r r rC s zHTTPHeaderDict.__delitem__r" rS c C s t |tr| | jkS dS )NF)r% r r_ r- r r r r rW
s
zHTTPHeaderDict.__contains__ )r defaultr c s t ||S r
)r5
setdefaultr r rg r7 r r rh s zHTTPHeaderDict.setdefault)otherr c C sD t |}|d krdS t| |}dd | D dd | D kS )NFc S s i | ]\}}| |qS r )r_ ).0kvr r r
s z)HTTPHeaderDict.__eq__..)r, type
itermerged)r rj maybe_constructableZother_as_http_header_dictr r r __eq__ s zHTTPHeaderDict.__eq__c C s | | S r
)rr )r rj r r r __ne__ s zHTTPHeaderDict.__ne__r. r c C s
t | jS r
)r> r- r r r r rD s zHTTPHeaderDict.__len__r
c c s | j D ]}|d V q
d S )Nr )r- rH )r valsr r r rF # s zHTTPHeaderDict.__iter__c C s$ z
| |= W n t k
r Y nX d S r
)r= r r r r discard( s
zHTTPHeaderDict.discardF)combine)r r[ rv r c C sr t |tr|d}| }||g}| j||}||k rnt|dksJt|rd|d d | |d< n
|| dS )a Adds a (name, value) pair, doesn't overwrite the value if it already
exists.
If this is called with combine=True, instead of adding a new header value
as a distinct item during iteration, this will instead append the value to
any existing header value with a comma. If no existing header value exists
for the key, then the value will simply be added, ignoring the combine parameter.
>>> headers = HTTPHeaderDict(foo='bar')
>>> headers.add('Foo', 'baz')
>>> headers['foo']
'bar, baz'
>>> list(headers.items())
[('foo', 'bar'), ('foo', 'baz')]
>>> headers.add('foo', 'quz', combine=True)
>>> list(headers.items())
[('foo', 'bar, baz, quz')]
r\ rT ra N) r% r] r^ r_ r- rh r> AssertionErrorappend)r r r[ rv key_lowernew_valsrt r r r add. s
zHTTPHeaderDict.addValidHTTPHeaderSource)argsrX r c O s, t |dkr tdt | dt |dkr4|d nd}t|trb| D ]\}}| || qJnt|tjr| D ]\}}| || qvnzt|tj rt
tj tj t t f |}|D ]\}}| || qn6t
|drt
|dr| D ]}| ||| q| D ]\}}| || qdS ) 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__
rb z/extend() takes at most 1 positional arguments (z given)r r r r N)r> TypeErrorr% r rQ r| r& r' itemsr) r( r* r r+ r )r r~ rX rj r r[ r; r r r rZ Q s(
zHTTPHeaderDict.extendz list[str]c C s d S r
r r r r r getlistr s zHTTPHeaderDict.getlistr zlist[str] | _DTc C s d S r
r ri r r r r v s z_Sentinel | _DTc C sN z| j | }W n* tk
r< |tjkr4g Y S | Y S X |dd S dS )zmReturns a list of all the values for the named field. Returns an
empty list if the key doesn't exist.rb N)r- r_ r= r r! )r r rg rt r r r r z s
r c C s* dddddddg}|D ]}| | q| S )z
Remove content-specific header fields before changing the request
method to GET or HEAD according to RFC 9110, Section 15.4.
zContent-EncodingzContent-LanguagezContent-Locationz Content-TypezContent-LengthZDigestz
Last-Modified)ru )r Zcontent_specific_headersheaderr r r _prepare_for_method_change s z)HTTPHeaderDict._prepare_for_method_changec C s t | j dt| dS )N())ro r dictrp r r r r __repr__ s zHTTPHeaderDict.__repr__c C s, |D ]"}| |}|f|| j| < qd S r
)r r- r_ )r rj r r[ r r r rY s
zHTTPHeaderDict._copy_fromc C s t | }|| |S r
)ro rY )r cloner r r copy s
zHTTPHeaderDict.copyrR c c s< | D ]2}| j | }|dd D ]}|d |fV q"qdS )z8Iterate over all header lines, including duplicate ones.rb Nr re )r r rt r[ r r r rQ s zHTTPHeaderDict.iteritemsc c s8 | D ].}| j | }|d d|dd fV qdS )z:Iterate over all headers, merging duplicate ones together.r ra rb Nrc r` r r r rp s zHTTPHeaderDict.itermergedrN c C s t | S r
)rN r r r r r s zHTTPHeaderDict.items) header_namepotential_valuer c C s& || kr"|| j | dd kS dS )Nrb Fre )r r r r r r rV s z$HTTPHeaderDict._has_value_for_headerc C s" t |}|d krtS | | | S r
)r, NotImplementedrZ )r rj rq r r r __ior__ s
zHTTPHeaderDict.__ior__c C s* t |}|d krtS | }|| |S r
)r, r r rZ r rj rq resultr r r __or__ s
zHTTPHeaderDict.__or__c C s. t |}|d krtS t| |}|| |S r
)r, r ro rZ r r r r __ror__ s
zHTTPHeaderDict.__ror__)N)rf )'r r r rK rL r6 rB r rC rW rh rr rs rD rF ru r| rZ r& overloadr r r! r
getheadersgetallmatchingheadersigetget_allr rY r rQ rp r rV r r r rM r r r7 r r sH
! #!
)"
__future__r r& collectionsr enumr r threadingr
TYPE_CHECKINGr Ztyping_extensionsr r __all__TypeVarr r r Unionr' r r) r* r} r r, GenericMutableMappingr SetrN r r r r r s0
&] 0