h:,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/home/james-whalen/.local/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 dU =(d [UlU(aSSKn U R5n O UbUbXV4n OSn X0lX lUc[ R5UlOXlXl URRUU USURURS9Ul URR(dURR5 URRUR5Ul[ R""U5UlSUlSUlg)NrT)authr)streamr*r,)requestsr+requests_kerberosHTTPKerberosAuthr%r _HEADERScopyr*r,getresponseokraise_for_status iter_content _read_iterr ByteBuffer _read_buffer _current_posraw) selfurlr r%r&r'r(r)r*r+r,r=r:s r__init__BufferedInputBase.__init__gs*(  $$557D  ("6#DD& ?#==?DL"L  (( LLLL )  }} MM * * ,--44T5E5EF&11+> rcn[RS5 UR(dSUlSUlgg)zFlush and close this stream.z close: calledN)loggerdebugclosedrBrFrKs rcloseBufferedInputBase.closes( _%{{ DM"DOrcURSL$r)rBrSs rrRBufferedInputBase.closeds}}$$rcg)z+Return True if the stream can be read from.TrSs rreadableBufferedInputBase.readablesrcg)NFrYrSs rseekableBufferedInputBase.seekablesrc"[Rez Unsupported.ioUnsupportedOperationrSs rdetachBufferedInputBase.detach%%%rcX[RSU5 URcgUS:XagUS:a?[UR5S:Xa&URR R 5nGOUS:a@URR 5URR R 5-nO[UR5U:a[RSURU5 URRUR5nUS:Xa:URR 5nU=R[U5- slU$[UR5U:aMURR U5nU=R[U5- slU$)z. Mimics the read call to a filehandle object. zreading with size: %drrz:http reading more content at current_pos: %d with size: %d) rPrQrBlenrHrJreadrIfillrF)rKsizeretval bytes_reads rriBufferedInputBase.readsS  ,d3 ==  19 AX#d//0A5]]&&++-F AX&&++- 0A0A0F0F0HHFd''(4/ P%%t"..33DOOD ?!..335F%%V4%!Md''(4/&&++D1F S[( rc URUS9$)zThis is the same as read().)rk)rirKrks rread1BufferedInputBase.read1syydy##rcvUR[U55nU(dgX!S[U5&[U5$)zDRead up to len(b) bytes into b, and return the number of bytes read.rN)rirh)rKbdatas rreadintoBufferedInputBase.readintos3yyQ *3t9 4yr) rIrHrFr%r*r rJrBr+r,))__name__ __module__ __qualname____firstlineno__rBDEFAULT_BUFFER_SIZErMrTpropertyrRrZr]rdrirqrv__static_attributes__rYrrr6r6ds[H!$2EdTtT+`#%% &!F$rr6c ^\rSrSrSrS\SSSSSSS4 SjrS SjrSrS r SS jr SS jr S r g)r.zz Implement seekable streamed reader from a web site. Supports Kerberos, client certificate and Basic HTTP authentication. r8FNc XlU =(d [UlU(aSSKn U R 5UlOUb Ub XV4UlOSUlUc[ R5UlOXlXpl Xl X0l X l UR5UlURR(dURR!5 ["R%SURURR&5 [)URRR+SS55UlURRR+SS5R/5S:gUlURR3UR5Ul[6R8"U5UlSUlSUlg) 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. rNzself.response: %r, raw: %rzContent-Lengthrxz Accept-Rangesnone)rLr<r+r=r>r:r?r@r*r)r,r%r _partial_requestrBrCrDrPrQrJintrAcontent_lengthlower _seekablerErFrrGrHrI) rKrLr r%r&r'r(r)r*r+r,r=s rrM"SeekableBufferedInputBase.__init__sS*(  $):: rcZ[RSX5 U[R;a[ S[R-5eUR 5(d [ S5eU[R:XaUnOGU[R:XaURU-nO#U[R:XaURU-nURS:Xa[RRWSS9nO([RRWURS9nURU:Xa UR$[RSURU5 X0l X0R:Xa4SUlSUlUR"R%5 UR$UR'U5nUR((aVX@lURR+UR,5UlUR"R%5 UR$SUlUR$)zSeek to the specified position. :param int offset: The offset in bytes. :param int whence: Where the offset is from. Returns the position after seeking.z seeking to offset: %r whence: %rz"invalid whence, expected one of %rzstream is not seekablerxN)maxvalz0http seeking from current_pos: %d to new_pos: %d)rPrQrWHENCE_CHOICES ValueErrorr]OSError WHENCE_STARTWHENCE_CURRENTrI WHENCE_ENDrrrclamprBrFrHemptyrrCrEr%)rKoffsetwhencenew_posrBs rseekSeekableBufferedInputBase.seek s  7H 11 1AID\D\\] ]}}23 3 Y++ +G y// /''&0G y++ +))F2G   " $ &&,,WT,BG &&,,WT=P=P,QG    '$$ $ GIZIZ\cd# )) ) DM"DO    # # %   ,,W5H{{ ( "&--"<"rs: -     8 $ z *<% #4tT?R-U`z))zzE 1EaLsA33A>=A>