\jm&dZddlZddlZddlZddlZ ddlZddl m Z m Z ddl Z dZdZej eZddiZ d Zd Zd ddddddefd ZGd dej.ZGddeZy#e$rdZ YcwxYw)z3Implements file-like objects for reading from http.NT) bytebuffer constantsi)httphttpszAccept-Encodingidentityctjj|}|jtvsJ|j |j z}d|jdz}t|j|S)N/)schemeuri_path) urllibparseurlsplitr SCHEMESnetlocpathlstripdict) uri_as_string split_urir s 9/root/env/lib/python3.12/site-packages/smart_open/http.py parse_urir&sd %%m4I   w && &)..0HX__S))H y''( ;;cdtjjt|}t||fi|SN) smart_openutils check_kwargsopen)urimodetransport_paramskwargss ropen_urir#/s-    * *41A BF T $V $$rFc |tjk(rbt||| ||||||| } tjj t jj|j| _ | Std|z)uImplement streamed reader from a web site. Supports Kerberos and Basic HTTP authentication. Parameters ---------- url: str The URL to open. mode: str The mode to open using. kerberos: boolean, optional If True, will attempt to use the local Kerberos credentials user: str, optional The username for authenticating over HTTP password: str, optional The password for authenticating over HTTP cert: str/tuple, optional if String, path to ssl client cert file (.pem). If Tuple, (‘cert’, ‘key’) headers: dict, optional 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, ``{}``. session: object, optional The requests Session object to use with http get requests. Can be used for OAuth2 clients. buffer_size: int, optional The buffer size to use when performing I/O. Note ---- If neither kerberos or (user, password) are set, will connect unauthenticated, unless set separately in headers. ) buffer_sizekerberosuserpasswordcertheaderssessiontimeoutz(http support for mode %r not implemented) r READ_BINARYSeekableBufferedInputBaseosrbasenamer r urlparsenameNotImplementedError) rr r&r'r(r)r*r,r+r%fobjs rrr4swH y$$$( ;tWg  GG$$V\\%:%:3%?%D%DE  !"Lt"STTrc heZdZdZdedddddddf dZdZedZdZ dZ d Z d d Z d d Z d Zy)BufferedInputBaseNrFc b||_||_| xst|_|rddl} | j |_n| | ||f|_nd|_||_||_|tj|_ n||_ | |_ |jj|j|j |jd|j|j|_|jjs|jj!t#j$||_d|_y)NrT)authr)streamr*r,)urlr)requestsr+requests_kerberosHTTPKerberosAuthr9r%r _HEADERScopyr*r,getresponseokraise_for_statusr ByteBuffer _read_buffer _current_pos) selfr;r r%r&r'r(r)r*r+r,r=s r__init__zBufferedInputBase.__init__gs *(  $)::rcdtjd|jsd|_d|_yy)zFlush and close this stream.z close: calledN)loggerdebugclosedrBrFrHs rclosezBufferedInputBase.closes) _%{{ DM $D rc|jduSr)rBrNs rrMzBufferedInputBase.closeds}}$$rcy)z+Return True if the stream can be read from.TrNs rreadablezBufferedInputBase.readablesrcy)NFrRrNs rseekablezBufferedInputBase.seekablesrc"tjz Unsupported.ioUnsupportedOperationrNs rdetachzBufferedInputBase.detach%%%rc|dkrtd|tjd||js|dk(ry|dk(rzt |j r@|j j |jjj z}n|jjj }nt |j |krL|j j|jjdk(rnt |j |krL|j j |}|xjt |z c_ |S)z> Mimics the read call to a filehandle object. zsize must be >= -1, got zreading with size: %drr) ValueErrorrKrLrMlenrFreadrBrawfillrG)rHsizeretvals rrazBufferedInputBase.reads "97v>? ? ,d3 ;;$!) 2:4$$%**//1DMM4E4E4J4J4LL**//1d''(4/$$))$--*;*;<Ad''(4/&&++D1F S[( rc&|j|S)zThis is the same as read().)rd)rarHrds rread1zBufferedInputBase.read1syydy##rcn|jt|}|sy||dt|t|S)zLRead up to len(b) bytes into b, and return the number of bytes read.rN)rar`)rHbdatas rreadintozBufferedInputBase.readintos5yyQ *3t9 4yr)r^)__name__ __module__ __qualname__rBDEFAULT_BUFFER_SIZErIrOpropertyrMrSrUr[rarhrlrRrrr6r6dsZH!$2EdTtT'X%%% &4$rr6c ZeZdZdZdedddddddf fd Zd dZdZdZd d Z d d Z xZ S) r.z Implement seekable streamed reader from a web site. Supports Kerberos, client certificate and Basic HTTP authentication. r7FNc t |||||||||| | t|jjj dd|_|jjj ddjdk7|_y)a. 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. zContent-Lengthr^z Accept-RangesnoneN) superrIintrBr*rAcontent_lengthlower _seekable) rHr;r r%r&r'r(r)r*r+r, __class__s rrIz"SeekableBufferedInputBase.__init__s{ dK44QXZacjk!$--"7"7";";rs: -     8 $ z *<% #4tT?R-U`m))m`_ 1_GLsA22A<;A<