a AiD@s:ddlmZddlZddlmZddlmZmZddlm Z ej rjddlm Z ddl m Z Gdd d e Zd d gZed Zed ZedZejd ejeefejeeefd fZGdddeZdddddZGdd d ejeefejeefZGdddeeeefZ Gdd d ejeefZ!dS)) annotationsN) OrderedDict)Enumauto)RLock)Protocol)Selfc@s*eZdZddddZdddddZd S) HasGettableStringKeystyping.Iterator[str]returncCsdSNselfrrQ/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/urllib3/_collections.pykeyszHasGettableStringKeys.keysstrkeyr cCsdSr rrrrrr __getitem__rz!HasGettableStringKeys.__getitem__N)__name__ __module__ __qualname__rrrrrrr sr RecentlyUsedContainerHTTPHeaderDict_KT_VT_DTc@seZdZeZdS) _SentinelN)rrrr not_passedrrrrr!'sr!objectValidHTTPHeaderSource | None) potentialr cCs~t|tr|St|tjr0ttjttf|St|tjrVttjtttf|St|drvt|drvtd|SdSdS)Nrrr ) isinstancertypingMappingcastrIterabletuplehasattr)r%rrr%ensure_can_construct_http_header_dict+s    r-cseZdZUdZded<ded<ded<ded <d%ddd d fdd ZdddddZddd dddZdd dddZddddZ ddddZ d dd d!Z d"dd#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_maxsizez#typing.Callable[[_VT], None] | None dispose_funcrlock NNone)maxsizer1r cs*t||_||_t|_t|_dSr )super__init__r0r1rr.rr2)rr5r1 __class__rrr7Rs  zRecentlyUsedContainer.__init__rrrcCsD|j*|j|}||j|<|WdS1s60YdSr )r2r.pop)rritemrrrr]s  z!RecentlyUsedContainer.__getitem__)rvaluer c Csd}|jjz||j|f}||j|<Wn:tyd||j|<t|j|jkr`|jjdd}Yn0Wdn1sz0Y|dur|jr|\}}||dS)NF)last)r2r.r:KeyErrorlenr0popitemr1)rrr<Z evicted_item_ evicted_valuerrr __setitem__ds  2z!RecentlyUsedContainer.__setitem__cCsF|j|j|}Wdn1s(0Y|jrB||dSr )r2r.r:r1)rrr<rrr __delitem__}s*z!RecentlyUsedContainer.__delitem__r cCs4|jt|jWdS1s&0YdSr )r2r?r.rrrr__len__szRecentlyUsedContainer.__len__ztyping.NoReturncCs tddS)Nz7Iteration over this class is unlikely to be threadsafe.)NotImplementedErrorrrrr__iter__szRecentlyUsedContainer.__iter__cCs\|j(t|j}|jWdn1s40Y|jrX|D]}||qHdSr )r2listr.valuesclearr1)rrIr<rrrrJs (zRecentlyUsedContainer.clearzset[_KT]cCs8|jt|jWdS1s*0YdSr )r2setr.rrrrrrszRecentlyUsedContainer.keys)r3N)rrr__doc____annotations__r7rrCrDrErGrJr __classcell__rrr8rr?s    c@sVeZdZUdZded<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_headersr4)headersr cCs ||_dSr )rP)rrQrrrr7szHTTPHeaderDictItemView.__init__r/r cCstt|jSr )r?rHrP iteritemsrrrrrEszHTTPHeaderDictItemView.__len__ typing.Iterator[tuple[str, str]]cCs |jSr )rPrRrrrrrGszHTTPHeaderDictItemView.__iter__r#bool)r;r cCsDt|tr@t|dkr@|\}}t|tr@t|tr@|j||SdS)NF)r&r+r?rrP_has_value_for_header)rr;Z passed_keyZ passed_valrrr __contains__s z#HTTPHeaderDictItemView.__contains__N) rrrrLrMr7rErGrWrrrrrOs rOcseZdZUdZded<dTdddfdd Zddd d d d ZdddddZdd dddZdddddZ dUddddfdd Z dddddZ dddddZ 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>Zdd dd?d@Zd:d!dAdBZdCd!dDdEZdCd!dFdGZ dHd!dIdJZ!ddddKdLdMZ"ddddNdOZ#dd:ddPdQZ$dd:ddRdSZ%Z&S)Vrap :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)rQkwargsc sJti|_|dur8t|tr.||n |||rF||dSr )r6r7r.r&r _copy_fromextend)rrQrXr8rrr7s    zHTTPHeaderDict.__init__r4)rvalr cCs*t|tr|d}||g|j|<dSNlatin-1r&bytesdecoder.lowerrrr[rrrrCs  zHTTPHeaderDict.__setitem__rcCs4t|tr|d}|j|}d|ddS)Nr], )r&r_r`r.rajoinrbrrrrs  zHTTPHeaderDict.__getitem__cCs$t|tr|d}|j|=dSr\r^rrrrrDs  zHTTPHeaderDict.__delitem__r#rTcCs0t|tr|d}t|tr,||jvSdS)Nr]F)r&r_r`rrar.rrrrrW s    zHTTPHeaderDict.__contains__)rdefaultr cst||Sr )r6 setdefaultrrrgr8rrrhszHTTPHeaderDict.setdefault)otherr cCsDt|}|durdSt||}dd|Ddd|DkS)NFcSsi|]\}}||qSr)ra).0kvrrr rz)HTTPHeaderDict.__eq__..)r-type itermerged)rrjmaybe_constructableZother_as_http_header_dictrrr__eq__s zHTTPHeaderDict.__eq__cCs || Sr )rr)rrjrrr__ne__!szHTTPHeaderDict.__ne__r/r cCs t|jSr )r?r.rrrrrE$szHTTPHeaderDict.__len__r ccs|jD]}|dVq dS)Nr)r.rI)rvalsrrrrG'szHTTPHeaderDict.__iter__cCs"z ||=WntyYn0dSr )r>rrrrdiscard,s  zHTTPHeaderDict.discardF)combine)rr[rvr cCsrt|tr|d}|}||g}|j||}||urnt|dksJJ|rd|dd||d<n ||dS)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')] r]rUrcN)r&r_r`rar.rhr?append)rrr[rv key_lowernew_valsrtrrradd2s  zHTTPHeaderDict.addValidHTTPHeaderSource)argsrXr cOs*t|dkr tdt|dt|dkr4|dnd}t|trb|D]\}}|||qJnt|tjr|D]\}}|||qvnxt|tj rt tj t 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__ rdz/extend() takes at most 1 positional arguments (z given)rrrrN)r? TypeErrorr&rrRr{r'r(itemsr*r)r+rr,r)rr}rXrjrr[r<rrrrZUs(      zHTTPHeaderDict.extendz list[str]cCsdSr rrrrrgetlistvszHTTPHeaderDict.getlistr zlist[str] | _DTcCsdSr rrirrrrysz_Sentinel | _DTcCs`t|tr|d}z|j|}Wn(tyN|tjurFgYS|YS0|ddSdS)zmReturns a list of all the values for the named field. Returns an empty list if the key doesn't exist.r]rdN)r&r_r`r.rar>r!r")rrrgrtrrrr|s     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-LengthZDigestz Last-Modified)ru)rZcontent_specific_headersheaderrrr_prepare_for_method_changes  z)HTTPHeaderDict._prepare_for_method_changecCst|jdt|dS)N())rordictrprrrr__repr__szHTTPHeaderDict.__repr__cCs,|D]"}||}|g||j|<qdSr )rr.ra)rrjrr[rrrrYs zHTTPHeaderDict._copy_fromcCst|}|||Sr )rorY)rclonerrrcopys  zHTTPHeaderDict.copyrSccs<|D]2}|j|}|ddD]}|d|fVq"qdS)z8Iterate over all header lines, including duplicate ones.rdNrr.ra)rrrtr[rrrrRszHTTPHeaderDict.iteritemsccs8|D].}|j|}|dd|ddfVqdS)z:Iterate over all headers, merging duplicate ones together.rrcrdN)r.rarerbrrrrpszHTTPHeaderDict.itermergedrOcCst|Sr )rOrrrrrszHTTPHeaderDict.items) header_namepotential_valuer cCs&||vr"||j|ddvSdS)NrdFr)rrrrrrrVsz$HTTPHeaderDict._has_value_for_headercCs"t|}|durtS|||Sr )r-NotImplementedrZ)rrjrqrrr__ior__s  zHTTPHeaderDict.__ior__cCs*t|}|durtS|}|||Sr )r-rrrZrrjrqresultrrr__or__s  zHTTPHeaderDict.__or__cCs.t|}|durtSt||}|||Sr )r-rrorZrrrr__ror__s   zHTTPHeaderDict.__ror__)N)rf)'rrrrLrMr7rCrrDrWrhrrrsrErGrur{rZr'overloadrr!r"r getheadersgetallmatchingheadersigetget_allrrYrrRrprrVrrrrNrrr8rrsH !  #!  )" __future__rr' collectionsrenumrr threadingr TYPE_CHECKINGrZtyping_extensionsrr __all__TypeVarrrr Unionr(rr*r+r|r!r-GenericMutableMappingrrKrOrrrrrs0         &]0