o .j-@sUddlmZddlZddlZddlmZddlmZddlm Z ddl m Z m Z dd l mZejr>dd lmZdd lmZd Zegd ZegdZdZzzddlZWn eybddlZYnwWn eymYnwed7ZzddlZWn eyYnwed7ZGdddeZej Z!de"d<hdZ#      dBdCd"d#Z$dDd'd(Z%dEd+d,Z&dEd-d.Z'dFd3d4Z(dGd5d6Z)Gd7d8d8ej*Z+ 9dHdId@dAZ,dS)J) annotationsN) b64encode)Enum)UnrewindableBodyError)to_bytesiscoroutinefunction)BytesQueueBuffer)Final)_TYPE_BODY_POSITIONz@@@SKIP_HEADER@@@)accept-encodinghost user-agent)zcontent-encodingzcontent-languagezcontent-locationz content-typezcontent-lengthdigestz last-modifiedz gzip,deflatez,brz,zstdc@seZdZdZdS)_TYPE_FAILEDTELLrN)__name__ __module__ __qualname__tokenrrI/home/thesage/.local/lib/python3.10/site-packages/urllib3/util/request.pyr5srzFinal[_TYPE_FAILEDTELL] _FAILEDTELL>GETHEADTRACEDELETECONNECTOPTIONS keep_alive bool | Noneaccept_encodingbool | list[str] | str | None user_agent str | None basic_authproxy_basic_auth disable_cachereturndict[str, str]cCsi}|rt|tr n t|trd|}nt}||d<|r!||d<|r'd|d<|r7dt|d|d<|rGdt|d|d <|rMd |d <|S) a Shortcuts for generating request headers. :param keep_alive: If ``True``, adds 'connection: keep-alive' header. :param accept_encoding: Can be a boolean, list, or string. ``True`` translates to 'gzip,deflate'. If either the ``brotli`` or ``brotlicffi`` package is installed 'gzip,deflate,br' is used instead. List will get joined by comma. String will be used as provided. :param user_agent: String representing the user-agent you want, such as "python-urllib3/0.6" :param basic_auth: Colon-separated username:password string for 'authorization: basic ...' auth header. :param proxy_basic_auth: Colon-separated username:password string for 'proxy-authorization: basic ...' auth header. :param disable_cache: If ``True``, adds 'cache-control: no-cache' header. Example: .. code-block:: python import urllib3 print(urllib3.util.make_headers(keep_alive=True, user_agent="Batman/1.0")) # {'connection': 'keep-alive', 'user-agent': 'Batman/1.0'} print(urllib3.util.make_headers(accept_encoding=True)) # {'accept-encoding': 'gzip,deflate'} ,r rz keep-alive connectionzBasic zlatin-1 authorizationzproxy-authorizationzno-cachez cache-control) isinstancestrlistjoinACCEPT_ENCODINGrencodedecode)rr!r#r%r&r'headersrrr make_headersDs*/   r5body typing.AnyboolcCstt|dddS)NtellcSsdS)Nrrrrrszis_async_file..)r getattr)r6rrr is_async_filesr<pos_TYPE_BODY_POSITION | NonecCsR|dur t|||St|dddur'z|}W|Sty&t}Y|Sw|S)z If a position is provided, move file to that point. Otherwise, we'll attempt to record a position for future use. Nr9) rewind_bodyr;r9OSErrorrr6r=rrrset_file_positions    rBcs`|durt||IdH|St|dddur.z |IdH}W|Sty-t}Y|Sw|S)z\ Asynchronous variant for set_file_position when using anyio.AsyncFile for example. Nr9) arewind_bodyr;r9r@rrArrraset_file_positions  rDtyping.IO[typing.AnyStr]body_posr Nonec Cstt|dd}|dur(t|tr(z||WdSty'}ztd|d}~ww|tur0tdtdt|d)z Attempt to rewind body to a certain position. Primarily used for request redirects and retries. :param body: File-like object that supports seek. :param int pos: Position to seek to in file. seekNAAn error occurred when rewinding request body for redirect/retry.RUnable to record file position for rewinding request body during a redirect/retry.1body_pos must be of type integer, instead it was .r;r-intr@rr ValueErrortyper6rF body_seekerrrr?s& r?c s|t|dd}|dur,t|tr,z ||IdHWdSty+}ztd|d}~ww|tur4tdtdt|d)z+ Async counterpart of rewind_body. rHNrIrJrKrLrMrQrrrrCs( rCc@s&eZdZUded<ded<ded<dS)ChunksAndContentLengthz;typing.Iterable[bytes] | typing.AsyncIterable[bytes] | Nonechunksz int | Nonecontent_lengthr8 is_stringN)rrr__annotations__rrrrrTs  rTFtyping.Any | Nonemethodr. blocksizerNforcec sHdurd}|tvrd}nd}t||ddSdfdd }dfd d }tttfrLt}t|}|rHt|krHt ||}nM|f}nIt d r\t d s\|}d}n9t d rg|}d}n.zt } Wn!t yzt }d}Wnt yt ddwYnwf}| j}t||tttjtjfdS)aRTakes the HTTP request method, body, and blocksize and transforms them into an iterable of chunks to pass to socket.sendall() and an optional 'Content-Length' header. A 'Content-Length' of 'None' indicates the length of the body can't be determined so should use 'Transfer-Encoding: chunked' for framing instead. NrF)rUrVrWr(typing.Iterable[bytes]c3s8ttj} }|sdS|r|d}|Vq)NTutf-8)r-io TextIOBasereadr2)r2 datablockr[r6rrchunk_readables   z&body_to_chunks..chunk_readabletyping.AsyncIterable[bytes]csdur tds Jd}tdr4 IdH}|s dS|dur)t|t}|r0|dn|Vqt}2z!3dHW}|durHt|t}||rQ|dn||Vq96|rh|V|s^dSdS)N __aiter__raTr^)hasattrrar-r.r2r putget)r2blockqueuercrrchunk_areadable&s,     z'body_to_chunks..chunk_areadablerarfzO'body' must be a bytes-like object, file-like object, or iterable. Instead was )r(r])r(re)upper_METHODS_NOT_EXPECTING_BODYrTr-r.bytesrlenr_BytesIOrg memoryview TypeErroriternbytesStringIO TextIOWrapper) r6rZr[r\rUrVrdrl convertedmvrrcrbody_to_chunkssn  !      rz)NNNNNN)rr r!r"r#r$r%r$r&r$r'r r(r))r6r7r(r8)r6r7r=r>r(r>)r6rErFr r(rG)r6r7rFr r(rG)F) r6rYrZr.r[rNr\r8r(rT)- __future__rr_typingbase64renumr exceptionsrutilrr responser TYPE_CHECKINGtyping_extensionsr _typingr SKIP_HEADER frozensetSKIPPABLE_HEADERSNOT_FORWARDABLE_HEADERSr1 brotlicffi_unused_module_brotli ImportErrorbrotli zstandard_unused_module_zstdrrrrXrnr5r<rBrDr?rC NamedTuplerTrzrrrrsh               O