o 'hC@s4ddlmZddlZddlmZddlmZmZddlm Z ej r5ddlm Z ddl m Z Gdd d e Zd d gZed Zed ZedZejd ejeefejeeefd fZGdddeZdddZGdd d ejeefejeefZGdddeeeefZ Gdd d ejeefZ!dS)) annotationsN) OrderedDict)Enumauto)RLock)Protocol)Selfc@s eZdZd ddZd ddZd S) HasGettableStringKeysreturntyping.Iterator[str]cCdSNselfrrP/var/www/html/olx_land/venv/lib/python3.10/site-packages/urllib3/_collections.pykeyszHasGettableStringKeys.keyskeystrcCr r rrrrrr __getitem__rz!HasGettableStringKeys.__getitem__Nr r rrr r)__name__ __module__ __qualname__rrrrrrr s r RecentlyUsedContainerHTTPHeaderDict_KT_VT_DTc@seZdZeZdS) _SentinelN)rrrr not_passedrrrrr"'s r" potentialobjectr ValidHTTPHeaderSource | NonecCszt|tr|St|tjrttjttf|St|tjr+ttjtttf|St|dr;t|dr;td|SdS)Nrrr ) isinstancertypingMappingcastrIterabletuplehasattr)r$rrr%ensure_can_construct_http_header_dict+s    r.cseZdZUdZded<ded<ded<ded < d%d&fdd Zd'ddZd(ddZd)ddZd*ddZ d+ddZ d,d d!Z d-d#d$Z Z S).ra 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 ztyping.OrderedDict[_KT, _VT] _containerint_maxsize#typing.Callable[[_VT], None] | None dispose_funcrlock Nmaxsizer Nonecs*t||_||_t|_t|_dSr )super__init__r1r3rr/rr4)rr6r3 __class__rrr9Rs  zRecentlyUsedContainer.__init__rrr cCsD|j|j|}||j|<|WdS1swYdSr )r4r/pop)rritemrrrr]s   $z!RecentlyUsedContainer.__getitem__valuec Csd}|j5z||j|f}||j|<Wnty2||j|<t|j|jkr0|jjdd}YnwWdn1s=wY|durT|jrV|\}}||dSdSdS)NF)last)r4r/r<KeyErrorlenr1popitemr3)rrr> evicted_item_ evicted_valuerrr __setitem__ds"  z!RecentlyUsedContainer.__setitem__cCsJ|j|j|}Wdn1swY|jr#||dSdSr )r4r/r<r3)rrr>rrr __delitem__}s z!RecentlyUsedContainer.__delitem__cCs4|j t|jWdS1swYdSr )r4rAr/rrrr__len__s$zRecentlyUsedContainer.__len__typing.NoReturncCstd)Nz7Iteration over this class is unlikely to be threadsafe.)NotImplementedErrorrrrr__iter__szRecentlyUsedContainer.__iter__cCs`|jt|j}|jWdn1swY|jr,|D] }||q$dSdSr )r4listr/valuesclearr3)rrMr>rrrrNs  zRecentlyUsedContainer.clearset[_KT]cCs8|jt|jWdS1swYdSr )r4setr/rrrrrrs $zRecentlyUsedContainer.keys)r5N)r6r0r3r2r r7)rrr r )rrr>r r r7)rrr r7r r0)r rI)r r7)r rO)rrr__doc____annotations__r9rrFrGrHrKrNr __classcell__rrr:rr?s        c@sBeZdZUdZded<dddZdd d Zdd dZdddZdS)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_headersheadersr r7cCs ||_dSr )rV)rrWrrrr9 zHTTPHeaderDictItemView.__init__r0cCstt|jSr )rArLrV iteritemsrrrrrHszHTTPHeaderDictItemView.__len__ typing.Iterator[tuple[str, str]]cCs |jSr )rVrYrrrrrKrXzHTTPHeaderDictItemView.__iter__r=r%boolcCsDt|tr t|dkr |\}}t|tr t|tr |j||SdS)NF)r'r,rArrV_has_value_for_header)rr= passed_key passed_valrrr __contains__s z#HTTPHeaderDictItemView.__contains__N)rWrr r7rQr rZ)r=r%r r[) rrrrRrSr9rHrKr`rrrrrUs    rUcs`eZdZUdZded<dVdWfd d ZdXddZdYddZdZddZd[ddZ d\d]fdd Z d^ddZ d^d d!Z d_d#d$Z d`d&d'ZdZd(d)Zd*d+dad-d.Zdbd1d2Zejdcd4d5Zejddd8d5Zejfded:d5Zdfdd?Zdhd@dAZdfdBdCZdidEdFZdidGdHZ djdJdKZ!dkdNdOZ"dldPdQZ#dmdRdSZ$dmdTdUZ%Z&S)nrap :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/NrWr&kwargsrc sNti|_|durt|tr||n|||r%||dSdSr )r8r9r/r'r _copy_fromextend)rrWrbr:rrr9s    zHTTPHeaderDict.__init__rvalr r7cCs*t|tr |d}||g|j|<dS)Nlatin-1)r'bytesdecoder/lowerrrrerrrrFs  zHTTPHeaderDict.__setitem__cCs |j|}d|ddS)N, r/rijoinrjrrrrszHTTPHeaderDict.__getitem__cCs|j|=dSr r/rirrrrrGszHTTPHeaderDict.__delitem__r%r[cCst|tr ||jvSdS)NF)r'rrir/rrrrr`s zHTTPHeaderDict.__contains__defaultcst||Sr )r8 setdefaultrrrqr:rrrr szHTTPHeaderDict.setdefaultothercCsDt|}|dur dSt||}dd|Ddd|DkS)NFcSsi|] \}}||qSr)ri).0kvrrr sz)HTTPHeaderDict.__eq__..)r.type itermerged)rrtmaybe_constructableother_as_http_header_dictrrr__eq__s zHTTPHeaderDict.__eq__cCs || Sr )r})rrtrrr__ne__s zHTTPHeaderDict.__ne__r0cCs t|jSr )rAr/rrrrrHrXzHTTPHeaderDict.__len__r ccs |jD]}|dVqdS)Nr)r/rM)rvalsrrrrK!s zHTTPHeaderDict.__iter__cCs"z||=WdStyYdSwr )r@rrrrdiscard&s   zHTTPHeaderDict.discardF)combinercCsxt|tr |d}|}||g}|j||}||ur:t|dks%J|r3|dd||d<dS||dSdS)aAdds 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')] rfr\rkN)r'rgrhrir/rrrAappend)rrrer key_lowernew_valsrrrradd,s  zHTTPHeaderDict.addargsValidHTTPHeaderSourcecOs$t|dkrtdt|dt|dkr|dnd}t|tr1|D] \}}|||q%nPt|tjrG|D] \}}|||q;n:t|tj rht tj t t t f|}|D] \}}|||q\nt |drt |dr|D] }||||qv|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__ rlz/extend() takes at most 1 positional arguments (z given)rrrrN)rA TypeErrorr'rrYrr(r)itemsr+r*r,rr-r)rrrbrtrrer>rrrrdOs0      zHTTPHeaderDict.extend list[str]cCr r rrrrrgetlistpzHTTPHeaderDict.getlistr!list[str] | _DTcCr r rrsrrrrsr_Sentinel | _DTcCsHz |j|}Wnty|tjurgYS|YSw|ddS)zmReturns a list of all the values for the named field. Returns an empty list if the key doesn't exist.rlN)r/rir@r"r#)rrrqrrrrrvs   rcCs gd}|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-LengthDigestz Last-Modified)r)rcontent_specific_headersheaderrrr_prepare_for_method_changes z)HTTPHeaderDict._prepare_for_method_changecCst|jdt|dS)N())ryrdictrzrrrr__repr__szHTTPHeaderDict.__repr__cCs,|D]}||}|g||j|<qdSr )rr/ri)rrtrrerrrrcs zHTTPHeaderDict._copy_fromcCst|}|||Sr )ryrc)rclonerrrcopys  zHTTPHeaderDict.copyrZccs>|D]}|j|}|ddD] }|d|fVqqdS)z8Iterate over all header lines, including duplicate ones.rlNrro)rrrrerrrrYszHTTPHeaderDict.iteritemsccs:|D]}|j|}|dd|ddfVqdS)z:Iterate over all headers, merging duplicate ones together.rrkrlNrmrjrrrrzs zHTTPHeaderDict.itermergedrUcCst|Sr )rUrrrrrszHTTPHeaderDict.items header_namepotential_valuecCs&||vr||j|ddvSdS)NrlFro)rrrrrrr]sz$HTTPHeaderDict._has_value_for_headercCs"t|}|dur tS|||Sr )r.NotImplementedrd)rrtr{rrr__ior__s  zHTTPHeaderDict.__ior__cCs*t|}|dur tS|}|||Sr )r.rrrdrrtr{resultrrr__or__s  zHTTPHeaderDict.__or__cCs.t|}|dur tSt||}|||Sr )r.rryrdrrrr__ror__s   zHTTPHeaderDict.__ror__r )rWr&rbr)rrrerr r7r)rrr r7)rr%r r[)rp)rrrqrr r)rtr%r r[rQr)rrrerrr[r r7)rrrbrr r7)rrr r)rrrqr!r r)rrrqrr r)r r)r r)rtrr r7ra)r rU)rrrrr r[)rtr%r r)rtr%r r)'rrrrRrSr9rFrrGr`rrr}r~rHrKrrrdr(overloadrr"r#r getheadersgetallmatchingheadersigetget_allrrcrrYrzrr]rrrrTrrr:rrsJ !        #!             )r$r%r r&)" __future__rr( collectionsrenumrr threadingr TYPE_CHECKINGrtyping_extensionsrr __all__TypeVarrr r!Unionr)rr+r,rr"r.GenericMutableMappingrrPrUrrrrrs2          &]0