暾j2|dZddlmZddlZddlZddlZddlZddlm Z m Z  ddl Z ddlZddlmZmZe r ddlmZddlmZd Zd Zej0eZGd d e Zd diZ ddZddZdddddddef ddZGddej@Z!Gdde!Z"y#e $rdZ YwxYw)znImplements file-like objects for reading from http; ``kerberos=True`` needs the ``requests-kerberos`` package.) annotationsN) TYPE_CHECKING TypedDictT) bytebuffer constants)WriteableBuffer)TransportParamsi)httphttpsc"eZdZUded<ded<y)_HTTPUristrschemeuri_pathN)__name__ __module__ __qualname____annotations__Y/home/spazio/kingdom_calls/work5/transenv/lib/python3.12/site-packages/smart_open/http.pyr r $s KMrr zAccept-Encodingidentityctjj|}|jtvsJ|j |j z}d|jdz}|j|dS)zAParse an ``http://`` or ``https://`` URI into its path component./)rr)urllibparseurlsplitrSCHEMESnetlocpathlstrip) uri_as_string split_urirs r parse_urir$2sb %%m4I   w && &)..0HX__S))H&&H ==rBufferedInputBasecdtjjt|}t||fi|S)zAOpen an HTTP/HTTPS URI using the given mode and transport params.) smart_openutils check_kwargsopen)urimodetransport_paramskwargss ropen_urir/<s-    * *41A BF T $V $$rFc |tjk(rXt||| ||||||| } tjt j j|j| _ | Sd|d} t| )aImplement streamed reader from a web site. Supports Kerberos and Basic HTTP authentication. Args: uri: The URL to open. mode: The mode to open using. kerberos: If True, will attempt to use the local Kerberos credentials. user: The username for authenticating over HTTP. password: The password for authenticating over HTTP. cert: If a string, path to ssl client cert file (``.pem``). If a tuple, ``('cert', 'key')``. headers: Any headers to send in the request. If ``None``, the default headers are sent: ``{'Accept-Encoding': 'identity'}``. To use no headers at all, set this variable to an empty dict, ``{}``. timeout: Request timeout in seconds. session: The ``requests.Session`` object to use with HTTP GET requests. Can be used for OAuth2 clients. buffer_size: The buffer size to use when performing I/O. Returns: A file-like object opened for reading. Raises: NotImplementedError: If ``mode`` is anything other than ``"rb"``. Note: If neither ``kerberos`` nor ``(user, password)`` are set, will connect unauthenticated, unless set separately in headers. ) buffer_sizekerberosuserpasswordcertheaderssessiontimeoutzhttp support for mode z not implemented) r READ_BINARYSeekableBufferedInputBase posixpathbasenamerrurlparser nameNotImplementedError) r+r,r2r3r4r5r6r8r7r1fobjmsgs rr*r*BsT y$$$(  #  &&v||'<'Nzrequests.Response | NoneresponserFc b||_||_| xst|_|rddl} | j |_n| | ||f|_nd|_||_||_|tj|_ n||_ | |_ |jj|j|j |jd|j|j|_|jjs|jj!t#j$||_d|_y)NrT)authr5streamr6r8)urlr5requestsr7requests_kerberosHTTPKerberosAuthrFr1r,_HEADERScopyr6r8getrCokraise_for_statusr ByteBuffer _read_buffer _current_pos) selfrHr,r1r2r3r4r5r6r7r8rJs r__init__zBufferedInputBase.__init__s *(  $)::= -1, got zreading with size: %drr) ValueErrorrWrXrRrClenreadrawfillrS)rTsizerAbufrCretvals rrlzBufferedInputBase.reads <D "9,TF3CS/ ! ,d3))4==X ;(*dai 2:3xhll&7&7&99!**,c(T/88HLL)Q.c(T/XXd^F S[( rc&|j|S)zThis is the same as read().)ro)rlrTros rread1zBufferedInputBase.read1syydy##rct|jd}|jt|}|sy||dt|t|S)zLRead up to ``len(b)`` bytes into ``b``, and return the number of bytes read.BrN) memoryviewcastrlrk)rTbmvdatas rreadintozBufferedInputBase.readintosG ]   $yyR!;SY4yrrHrr,rr1intr2boolr3 str | Noner4rr5str | tuple[str, str] | Noner6dict[str, str] | Noner7requests.Session | Noner8 float | NonereturnNone)rr)rr)rz io.RawIOBase)ri)ro int | Nonerbytes)ryrrr~)rrr__doc__rrCDEFAULT_BUFFER_SIZErUr[propertyrYr^r`rfrlrtr|rrrr%r%sN I)-H&- .#-1)-+/ $2 22 2  2  22+2'2)22 2n%%%&8$rc eZdZdZdedddddddf d fd Zd d dZddZddZddd Z ddd Z xZ S)r:aSeekable streamed reader from a web site. Supports Kerberos, client certificate and Basic HTTP authentication. If ``kerberos`` is True, will attempt to use the local Kerberos credentials. If ``cert`` is set, will try to use a client certificate. Otherwise, will try to use "basic" HTTP authentication via username/password. If none of those are set, will connect unauthenticated. rDFNc 2t |||||||||| | |jJt|jjj dd|_|jjj ddjdk7|_y)NzContent-Lengthriz Accept-Rangesnone) superrUrCr~r6rNcontent_lengthlower _seekable) rTrHr,r1r2r3r4r5r6r7r8 __class__s rrUz"SeekableBufferedInputBase.__init__ s dK44QXZacjk}}(((!$--"7"7";";rs?u" +,)2     8 $y z *>%)-%) '+*:# :# :#:#  :#  :# ' :##:#:#%:#:#:#z))D| 1| ]LsB11B;:B;