U
|
ý°dÉ< ã @ s4 d dl mZ d dlZd dlmZ d dlmZmZ d dlm Z ej
|
r^d dl m Z G dd de Z d d
|
gZe d ¡Ze d ¡Ze d ¡Zejd
|
ejeef ejejeef df ZG dd deZdddddZG dd d ejeef ej eef Z G dd dej ejeef Z G dd
|
d
|
ej eef Z dS )é )Ú annotationsN)Ú OrderedDict)ÚEnumÚauto)ÚRLock)ÚProtocolc @ s* e Zd ZddddZdddddZd S )
|
ÚHasGettableStringKeysútyping.Iterator[str]©Úreturnc C s d S ©N© ©Úselfr r úKd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\urllib3/_collections.pyÚkeys s zHasGettableStringKeys.keysÚstr©Úkeyr 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 ÚRecentlyUsedContainerÚHTTPHeaderDictÚ_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 | tjr0t tjttf | ¡S t | tjrXt tjtjttf | ¡S t| drxt| drxt d| ¡S d S d S )Nr r r ) Ú
|
isinstancer ÚtypingÚMappingÚcastr ÚIterableÚTupleÚhasattr)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]Ú
|
_containerÚintÚ_maxsizez#typing.Callable[[_VT], None] | NoneÚ dispose_funcr Úlocké
|
NÚNone)Úmaxsizer/ r c s* t ¡ || _|| _t | _t | _d S r )ÚsuperÚ__init__r. r/ r r, r r0 )r r3 r/ ©Ú __class__r r r5 R s
|
|
z RecentlyUsedContainer.__init__r r r c
|
C s8 | j ( | j |¡}|| j|< |W 5 Q R £ S Q R X d S r )r0 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)r0 r, r8 ÚKeyErrorÚlenr. Úpopitemr/ )r r r: Z evicted_itemÚ_Ú evicted_valuer r r Ú __setitem__d s
|
z!RecentlyUsedContainer.__setitem__c C s2 | j | j |¡}W 5 Q R X | jr.| |¡ d S r )r0 r, r8 r/ )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 )r0 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 )r0 Úlistr, ÚvaluesÚclearr/ )r rG r: r r r rH s zRecentlyUsedContainer.clearzset[_KT]c
|
C s, | j t| j ¡ W 5 Q R £ S Q R X d S r )r0 Úsetr, r r r r r r s zRecentlyUsedContainer.keys)r1 N)r r r Ú__doc__Ú__annotations__r5 r rA rB rC rE rH r Ú __classcell__r r r6 r r ? 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 Ú_headersr2 )Úheadersr c C s
|
|| _ d S r )rN )r rO r r r r5 » s z HTTPHeaderDictItemView.__init__r- r
|
c C s t t| j ¡ S r )r= rF rN Ú iteritemsr r r r rC ¾ s z HTTPHeaderDictItemView.__len__ú typing.Iterator[tuple[str, str]]c C s
|
| j ¡ S r )rN rP r r r r rE Á s z HTTPHeaderDictItemView.__iter__r! Úbool)r9 r c C sD t |tr@t|dkr@|\}}t |tr@t |tr@| j ||¡S dS )Né F)r$ Útupler= r rN Ú_has_value_for_header)r r9 Z
|
passed_keyZ
|
passed_valr r r Ú __contains__Ä s
|
z#HTTPHeaderDictItemView.__contains__N) r r r rJ rK r5 rC rE rV r r r r rM s
|
rM c sÄ e Zd ZU dZded< dKddd fdd Zddd
|
d d d ZdddddZdd
|
dddZdddddZ dLdddd 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/d0d1Zejdd2dd3d4Zejdd5d6dd7d4Zejfdd8d6dd9d4ZeZeZeZeZdd!d:d;Zd d
|
dd<d=Z d d!d>d?Z d@d!dAdBZ d@d!dCdDZ dEd!dFdGZ ddddHdIdJZ! Z"S )Mr 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 )rO Úkwargsc sJ t ¡ i | _|d k r8t|tr.| |¡ n
|
| |¡ |rF| |¡ d S r )r4 r5 r, r$ r Ú
|
_copy_fromÚextend)r rO rW r6 r r r5 ð s
|
|
|
zHTTPHeaderDict.__init__r2 )r Úvalr c C s* t |tr| d¡}||g| j| ¡ < d S )Núlatin-1)r$ ÚbytesÚdecoder, Úlower©r r rZ r r r rA û 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 rB s zHTTPHeaderDict.__delitem__r! rR c C s t |tr| ¡ | jkS dS )NF)r$ r r^ r, r r r r rV s
|
zHTTPHeaderDict.__contains__Ú )r Údefaultr c s t ||¡S r )r4 Ú
|
setdefault©r r rf r6 r r rg s zHTTPHeaderDict.setdefault)Úotherr c C sD t |}|d krdS t| |}dd | ¡ D dd | ¡ D kS )NFc S s i | ]\}}| ¡ |qS r )r^ )Ú.0ÚkÚvr r r Ú
|
<dictcomp> s z)HTTPHeaderDict.__eq__.<locals>.<dictcomp>)r+ ÚtypeÚ
|
itermerged)r ri Zmaybe_constructableZother_as_http_header_dictr r r Ú__eq__ s ÿzHTTPHeaderDict.__eq__c C s | |¡ S r )rp )r ri r r r Ú__ne__ s zHTTPHeaderDict.__ne__r- r
|
c C s
|
t | jS r )r= r, r r r r rC s zHTTPHeaderDict.__len__r c c s | j ¡ D ]}|d V q
|
d S )Nr )r, rG )r Úvalsr r r rE ! 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 rZ rt 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[ rS éÿÿÿÿr` N) r$ r\ r] r^ r, rg r= ÚAssertionErrorÚappend)r r rZ rt Ú key_lowerÚnew_valsrr r r r Úadd, s
|
|
zHTTPHeaderDict.addÚValidHTTPHeaderSource)ÚargsrW r c O s, t |dkr tdt | dt |dkr4|d nd}t|trb| ¡ D ]\}}| ||¡ qJn¦t|tjr| ¡ D ]\}}| ||¡ qvnzt|tj rÒt
|
tj tj t t f |¡}|D ]\}}| ||¡ qºn6t |drt |dr| ¡ D ]}| ||| ¡ qò| ¡ D ]\}}| ||¡ qdS ) zÀGeneric 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__
|
ra z/extend() takes at most 1 positional arguments (z given)r r r r N)r= Ú TypeErrorr$ r rP rz r% r& Úitemsr( r' r) r r* r )r r| rW ri r rZ r: r r r rY O s( ÿ
|
zHTTPHeaderDict.extendz list[str]c C s d S r r r r r r Úgetlistp s zHTTPHeaderDict.getlistr zlist[str] | _DTc C s d S r r rh r r r r t 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.ra N)r, r^ r< r r )r r rf rr r r r r x s
|
|
c C s t | j dt| ¡ dS )Nú(ú))rn r Údictro r r r r Ú__repr__ s zHTTPHeaderDict.__repr__c C s, |D ]"}| |¡}|f|| j| ¡ < qd S r )r r, r^ )r ri r rZ r r r rX s
|
zHTTPHeaderDict._copy_fromc C s t | }| | ¡ |S r )rn rX )r Úcloner r r Úcopy s
|
|
zHTTPHeaderDict.copyrQ c c s< | D ]2}| j | ¡ }|dd
D ]}|d |fV q"qdS )z8Iterate over all header lines, including duplicate ones.ra Nr rd )r r rr rZ r r r rP s zHTTPHeaderDict.iteritemsc c s8 | D ].}| j | ¡ }|d d |dd
¡fV qdS )z:Iterate over all headers, merging duplicate ones together.r r` ra Nrb r_ r r r ro ¦ s zHTTPHeaderDict.itermergedrM c C s t | S r )rM r r r r r~ ¬ s zHTTPHeaderDict.items)Ú header_nameÚpotential_valuer c C s& || kr"|| j | ¡ dd
kS dS )Nra Frd )r r r r r r rU ¯ s z$HTTPHeaderDict._has_value_for_header)N)re )#r r r rJ rK r5 rA r rB rV rg rp rq rC rE rs rz rY r% Úoverloadr r r Ú
|
getheadersÚgetallmatchingheadersÚigetÚget_allr rX r
rP ro r~ rU rL r r r6 r r Ì s@
|
! #!ÿ)!Ú
|
__future__r r% Ú collectionsr Úenumr r Ú threadingr Ú TYPE_CHECKINGZtyping_extensionsr r Ú__all__ÚTypeVarr r r ÚUnionr& r r( r) r{ r r+ ÚGenericÚMutableMappingr ÚSetrM r r r r r Ú<module> s.
|
|
|
ýÿ&] 0
|
