Mim&SrSSKrSSKrSSKrSSKrSSKrSSK J r J r SSK r SrSr\R "\5rSS0rS rS rS SSSSSS\4S jr"S S\R.5r"SS\5rg!\a Sr Nef=f)z3Implements file-like objects for reading from http.NT) bytebuffer constantsi)httphttpszAccept-Encodingidentityc[RRU5nUR[;deUR UR -nSURS5-n[URUS9$)N/)schemeuri_path) urllibparseurlsplitr SCHEMESnetlocpathlstripdict) uri_as_string split_urir s i/var/www/eduai.edurigo.com/storigo/production/storigo_env/lib/python3.13/site-packages/smart_open/http.py parse_urir&sd %%m4I   w && &)..0HX__S))H y''( ;;cb[RR[U5n[X40UD6$N) smart_openutils check_kwargsopen)urimodetransport_paramskwargss ropen_urir#/s+    * *41A BF  $V $$rFc U[R:Xa[[XXX4UXhUS9 n [RR [ RRU5R5U l U $[SU-5e)u/Implement 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 rrr4soH y$$$( ;tg  GG$$V\\%:%:3%?%D%DE  !"Lt"STTrc v\rSrSrSrS\SSSSSSS4 SjrSr\S5r Sr S r S r SS jr SS jrS rSrg)BufferedInputBasedNrFc tXlXplU =(d [UlU(aSSKn U R 5UlOUb Ub XV4UlOSUlX0lX lUc[R5Ul OXl Xl URRURUR URSURURS9UlURR(dURR!5 ["R$"U5UlSUlg)NrT)authr)streamr*r,)urlr)requestsr+requests_kerberosHTTPKerberosAuthr:r%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__BufferedInputBase.__init__gs *(  $)::rcn[RS5 UR(dSUlSUlgg)zFlush and close this stream.z close: calledN)loggerdebugclosedrCrGrIs rcloseBufferedInputBase.closes) _%{{ DM $D rcURSL$r)rCrPs rrOBufferedInputBase.closeds}}$$rcg)z+Return True if the stream can be read from.TrPs rreadableBufferedInputBase.readablesrcg)NFrVrPs rseekableBufferedInputBase.seekablesrc"[Rez Unsupported.ioUnsupportedOperationrPs rdetachBufferedInputBase.detach%%%rcUS:a[SU35e[RSU5 UR(dUS:XagUS:Xa[ UR 5(a@UR R 5URRR 5-nOURRR 5nO[ UR 5U:aOUR RURR5S:XaO[ UR 5U:aMOUR R U5nU=R[ U5- sl U$)z. Mimics the read call to a filehandle object. zsize must be >= -1, got zreading with size: %drr) ValueErrorrMrNrOlenrGreadrCrawfillrH)rIsizeretvals rrhBufferedInputBase.reads "97v>? ? ,d3 ;;$!) 2:4$$%%**//1DMM4E4E4J4J4LL**//1d''(4/$$))$--*;*;<Ad''(4/&&++D1F S[( rc URUS9$)zThis is the same as read().)rk)rhrIrks rread1BufferedInputBase.read1syydy##rcvUR[U55nU(dgX!S[U5&[U5$)zDRead up to len(b) bytes into b, and return the number of bytes read.rN)rhrg)rIbdatas rreadintoBufferedInputBase.readintos3yyQ *3t9 4yr) rHrGr:r%r)r*r rCr+r,r<)re)__name__ __module__ __qualname____firstlineno__rCDEFAULT_BUFFER_SIZErJrQpropertyrOrWrZrarhrpru__static_attributes__rVrrr6r6dsZH!$2EdTtT'X%%% &4$rr6c l^\rSrSrSrS\SSSSSSS4 U4SjjrS SjrSrS r SS jr SS jr S r U=r $)r.zz Implement seekable streamed reader from a web site. Supports Kerberos, client certificate and Basic HTTP authentication. r8FNc  >[T U]XX4XVXxX5 [URRR SS55UlURRR SS5R5S:gUlg)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-Lengthrez Accept-RangesnoneN) superrJintrCr*rBcontent_lengthlower _seekable) rIr<r r%r&r'r(r)r*r+r, __class__s rrJ"SeekableBufferedInputBase.__init__so K44Zak!$--"7"7";";rs: -     8 $ z *<% #4tT?R-U`m))m`_ 1_GLsA33A>=A>