7ThubSrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r J r SSKJ r SSK r SSKJr SSKJr SS KJrJr SS KJrJrJrJr S S KJr \R<"S 5r\R<"S5r \RB"S5r""SS\RFRH5r%"SS\RL5r'"SS5r("SS5r)"SS\5r*"SS\5r+\R<"S5r,Sr-"SS\5r.S r/S$S!jr0S"r1\1"5 S#r2g!\ \\4a Sr Nf=f)%z(This file is largely copied from http.pyN)copy)dumpsloads)urlparseF)_DEFAULT_CALLBACK)register_implementation)AbstractBufferedFileAbstractFileSystem)DEFAULT_BLOCK_SIZE isfilelike nullcontexttokenize)AllBytesz6<(a|A)\s+(?:[^>]*?\s+)?(href|HREF)=["'](?P[^"']+)z-(?Phttp[s]?://[-a-zA-Z0-9@:%_+.~#?&/=]+)z fsspec.httpc\rSrSrSrg)JsHttpExceptionN__name__ __module__ __qualname____firstlineno____static_attributes__rX/var/www/auris/envauris/lib/python3.13/site-packages/fsspec/implementations/http_sync.pyrrssrrc\rSrSrSrg)StreamIO!rNrrrrrr!srrc\rSrSrSrSSjr\S5rSr\S5r \S5r Sr S r \S 5r \S 5r\S 5r\S 5r\S5rSrSrg) ResponseProxy'zLooks like a requests responsec8XlX lSUlSUlgN)requeststream_data_headers)selfreqr&s r__init__ResponseProxy.__init__*s    rcURcWURRR5nUR(a[ U5UlUR$XlUR$r$)r'r%responseto_bytesr&r)r)bs rrawResponseProxy.raw0sS ::  %%..0A{{%a[ zz zzrc,[US5(aU?gg)Nr')hasattrr'r)s rcloseResponseProxy.close:s 4 ! !  "rcURce[URR5R 5R S5Vs/sHnUR S5PM sn5UlUR$s snf)Nz : )r(dictr%getAllResponseHeadersstripsplit)r)_s rheadersResponseProxy.headers>sp ==  "\\??AGGIOOPVWWGGDMWDM }} s A?c@[URR5$r$)intr%statusr5s r status_codeResponseProxy.status_codeIs4<<&&''rcUR(d7[URURURUR S5egr$)okrurlrDreasonr?r5s rraise_for_statusResponseProxy.raise_for_statusMs8ww!$**DKKt rc/`# URRU5nU(aUv OgM*7fr$)r1read)r) chunksizer>__outs r iter_contentResponseProxy.iter_contentSs*((-- *C  s,.c.URR$r$)r% statusTextr5s rrIResponseProxy.reason[s||&&&rc URS:$)N)rDr5s rrGResponseProxy.ok_s#%%rcBURRR$r$)r%r. responseURLr5s rrHResponseProxy.urlcs||$$000rc6URR5$r$)contentdecoder5s rtextResponseProxy.textgs||""$$rc(SUlUR$NF)r&r1r5s rr]ResponseProxy.contentls xxrc,[UR5$r$)rr_r5s rjsonResponseProxy.jsonqsTYYr)r'r(r%r&N)F)rrrr__doc__r+propertyr1r6r?rDrJrQrIrGrHr_r]rerrrrr!r!'s( (( ''&&11%% rr!cd\rSrSrSrS SjrSrSrSrSr S r S r S r g) RequestsSessionShimuc0Ulgr$r?r5s rr+RequestsSessionShim.__init__vs  rNcSSKJnJn [R SX5 U(d#U(dU (dU(dU(dU (a[ eU(aU(a [ S5eUR5nU(aUOSnU(a$US[RRU53nUR"XS/UQ76 U (aU Ul U(a,UR5HunnURUU5 M URSS 5 S UlU(a4UR[!U5/["S 05nUR%U5 OrU(aZ['U[(R*5(aUR-5nURU/["S 05nUR%U5 OUR%S5 [/UU S 9$) Nr)BlobXMLHttpRequestzJS request: %s %szUse json= or data=, not bothr?FAcceptzapplication/octet-stream arraybufferzapplication/json)r&)jsrprqloggerdebugNotImplementedError ValueErrornewurllibparse urlencodeopentimeoutitemssetRequestHeader responseTypertypesend isinstanceioIOBaserMr!)r)methodrHparamsdatar?cookiesfilesauthrallow_redirectsproxieshooksr&verifycertrerprqr*extrakvblobs rr%RequestsSessionShim.requestysW& , (&6 6WE% % D;< <  "" E6<<11&9:;C e,e, !CK  1$$Q*( X'AB( 88U4[MD2D+EFD HHTN $ **yy{88TFT+E$FGD HHTN HHTNS00rc *UR"SU40UD6$)NGETr%r)rHkwargss rgetRequestsSessionShim.get||E31&11rc *UR"SU40UD6$)NHEADrrs rheadRequestsSessionShim.heads||FC2622rc *UR"SU40UD6$)NzPOST}rrs rpostRequestsSessionShim.post||GS3F33rc *UR"SU40UD6$)NPUTrrs rputRequestsSessionShim.putrrc *UR"SU40UD6$)NPATCHrrs rpatchRequestsSessionShim.patchrrc *UR"SU40UD6$)NDELETErrs rdeleteRequestsSessionShim.deletes||Hc4V44rrm)NNNNNNNNNNNNNN) rrrrr+r%rrrrrrrrrrrjrjusW    #21h234245rrjc^\rSrSrSrSrSrSU4Sjjr\S5r Sr \ S\ S \ 4S j5r \ U4S j5rSS jrSS jrSrSSjrS\4SjrS\S4SjrSrSrSrS SjrSrSrS!SjrSrSrU=r$)"HTTPFileSystema$ Simple File-System for fetching data via HTTP(S) This is the BLOCKING version of the normal HTTPFileSystem. It uses requests in normal python and the JS runtime in pyodide. ***This implementation is extremely experimental, do not use unless you are testing pyodide/pyscript integration*** )httphttps sync-http sync-https/c |>[T U]"U40UD6 UbUO[UlXlX0lX@lXPlU=(d 0UlXpl Xl SSK n [RS5 [5UlSUl ['U5n U R)SS5UlU R)SS5 U R)S S5 U R)S S5 Xl g![ aKn SSKn [RSU 5 U R$"S 0U=(d 0D6UlSUl Sn A NSn A ff=f) a  Parameters ---------- block_size: int Blocks to read bytes; if 0, will default to raw requests file-like objects instead of HTTPFile instances simple_links: bool If True, will consider both HTML tags and anything that looks like a URL; if False, will consider only the former. same_scheme: True When doing ls/glob, if this is True, only consider paths that have http/https matching the input URLs. size_policy: this argument is deprecated client_kwargs: dict Passed to aiohttp.ClientSession, see https://docs.aiohttp.org/en/stable/client_reference.html For example, ``{'auth': aiohttp.BasicAuth('user', 'pass')}`` storage_options: key-value Any other parameters passed on to requests cache_type, cache_options: defaults used in open NrzStarting JS sessionTz'Starting cpython session because of: %sFuse_listings_cachelistings_expiry_time max_pathsskip_instance_cacher)superr+r block_size simple_links same_schema cache_type cache_options client_kwargsencodedrrurvrwrjsession ExceptionrequestsSessionrpopr)r)rr same_schemerrrrstorage_optionsruerrequest_options __class__s rr+HTTPFileSystem.__init__sB 11(2(>*DV(&$**0b %    LL. /.0DLDG/"1"5"56JE"R2D9K.148%    LLBA F#++D}/BDDLDGG  s/C&& D;0AD66D;cg)Nrrr5s rfsidHTTPFileSystem.fsid srcX[(a[R"XRS9$U$)N)r)yarlURLrr)rHs r encode_urlHTTPFileSystem.encode_urls 488C6 6 rpathreturncJURSS5RSS5nU$)z-For HTTP, we always want to keep the full URLz sync-http://zhttp://z sync-https://zhttps://)replace)clsrs r_strip_protocolHTTPFileSystem._strip_protocols+||NI6>> Z  rcF>[TU]U5n[U5S:aU$g)N)r_parentlen)rrparrs rrHTTPFileSystem._parents&god# s8a<Jrc >URR5nURU5 [R U5 UR R "URU540URD6nURXQ5 URnUR(a?[RU5[RU5Vs/sHowSPM sn-nO'[RU5Vs/sHowSPM nn[5n [U5n UGHln [!U ["5(aU Sn U R%S5(a.['U 5S:aU R(S-U R*-U -n U R%S5(aUR,(a;U R%UR/S5S-5(aU R1U 5 MU R3SS5R%UR3SS5R/S5S-5(aU R1U 5 GM GM#U S;dGM,U R1SR5UR/S5U R7S5/55 GMo U (d5UR9S5(aUR;UR/S5SS 9n U(a/U Vs/sH!nUSUR9S5(aS OS S .PM# sn$[=U 5$s snfs snfs snf) Nrrz://rr)z..z../F)detail directoryfilenamesizer)rrupdatervrwrrr_raise_not_found_for_statusr_rex2findallexsetrrtuple startswithrschemenetlocrrstripaddrjoinlstripendswith_ls_realsorted) r)rHrrkwrr_ulinksrPpartsls rrHTTPFileSystem._ls_real&sq [[    & S LL  T__S1 AT[[ A ((0vv   KK%rzz$7G(H7G!17G(HHE#%::d#34#3aqT#3E4e A!U##aD||C  SVaZLL5(5<<7!;||F#### SZZ_s5J(K(KGGAJYYw/::KK077C   A  +,::c??K   #; G)I40sL;L(Lc UR(a XR;aURUnU$UR"U4SU0UD6nX@RU'U$)Nr)rdircacher)r)rHrrrPs rlsHTTPFileSystem.lsTsT  " "smm';--$C --=F=f=C!$MM#  rcZURS:Xa [U5eUR5 g)zE Raises FileNotFoundError for 404s, otherwise uses raise_for_status. iN)rDFileNotFoundErrorrJ)r)r.rHs rr*HTTPFileSystem._raise_not_found_for_status\s)   3 &#C( (!!#rc URR5nURU5 [R U5 UcUb?X#:XagUR S05R5nUR XU5US'XeS'URR"URU540UD6nURXq5 UR$)Nrr?Range) rrrrvrwr_process_limitsrrrrr])r)rHstartendrrr?rs rcat_fileHTTPFileSystem.cat_fileds [[    & S  |ffY+002G#33CDGG #yM LL  T__S1 8R 8 ((0yyriPc URR5nURU5 [R U5 UR R "URU540UD6n[URR SS5=(d URR SS55nURU5 URXq5 [U5(d [!US5nUR#USS9H.n UR%U 5 UR'[)U 55 M0 g![[[4a SnNf=f)Ncontent-lengthContent-LengthwbF)decode_unicode)rrrrvrwrrrrBr?ryKeyError TypeErrorset_sizerr r~rQwriterelative_updater) r)rpathlpath chunk_sizecallbackrrrrchunks rget_fileHTTPFileSystem.get_filets[[    & U LL  T__U3 :r :  .5999==!148D $ ((2%  %E^^Ju^EE KK   $ $SZ 0FHi0 D s.AD77EErc (^^^UUU4SjnURR5nURU5 UR5nUS;a[ SU<35e[ UR U5n U "U4SU"50UD6n URX5 g)Nc3># [T[R5(a[T5nSnO[ TS5nSnUnU(a3TR UR SS55 UR S5 OTR [USS55 URT5nU(a8Uv TR[U55 URT5nU(aM8SSS5 g!,(df  g=f7f)NFrbTrrr) rrrr r~r seekgetattrrMr"r)contextuse_seekfr'r&r%r$s r gen_chunks+HTTPFileSystem.put_file..gen_chunkss%++%e, ud+A%%affQl3FF1I%%ga&>?z*K,,SZ8FF:.Ees>DB%C1( D1 C?;D)rrz.method has to be either 'post' or 'put', not: r)rrrlowerryr.rr) r)r$r#r%r&rrr2rmethresps ` `` rput_fileHTTPFileSystem.put_files /.[[    &  (@ K t||V,E3 33 ((5rc8SnSnUb3US:a-UcU*nSnSnO'U=(d URU5SnXB-nOUcSnU(dMUb+US:a%Ub!U=(d URU5SnXC-nOUcSn[U[5(aUS-nSUS U3$) z"Helper for "Range"-based _cat_fileNFrrTrrbytes=-)inforrB)r)rHrrrsuffs rrHTTPFileSystem._process_limitss  {f5tyy~f5  ]E37$9499S> D*C#s##qwau%%rc URR5nURU5 [R U5 UR R "URU540UD6nURS:$![a gf=f)NrWF) rrrrvrwrrrrDr)r)rrrrs rexistsHTTPFileSystem.existsst [[    &  LL    !6="=A==3& &  sAA== B  B c (UR"U40UD6$r$)r@)r)rrs risfileHTTPFileSystem.isfiles{{4*6**rc US:wa[eUbUO URnURR5n U R U5 U=(d UR "U40UD6SnU(aKU(aD[ UU4URUUUU=(d URU=(d URS.U D6$[UU4UURS.U D6$)aSMake a file-like object Parameters ---------- path: str Full URL with protocol mode: string must be "rb" block_size: int or None Bytes to download in one request; use instance value if None. If zero, will return a streaming Requests file-like instance. kwargs: key-value Any other parameters, passed to requests calls r,r)rrmoderrr)rFr) rxrrrrr<HTTPFilerrrHTTPStreamFile) r)rrFr autocommitrrrrrs r_openHTTPFileSystem._opens2 4<% %#-#9Zt [[    &8tyy008 $  %%8+At/A/A   "    rcB[XRUR5$)z;Unique identifier; assume HTTP files are static, unchanging)rrprotocolrs rukeyHTTPFileSystem.ukeys[[$--88rc n0nSH[nUR[URU54UURS.URDUD65 UR S5b OM] USS.UESS0E$![ a;nUS:Xa [U5Ue[R[U55 SnAMSnAff=f) aGet info of URL Tries to access location via HEAD, and then GET methods, but does not fetch the data. It is possible that the server does not supply any size information, in which case size will be given as None (and certain operations on the corresponding file will not work). )rr) size_policyrrNrrrrr) r _file_inforrrrrrrvrwstr)r)rHrr<policyexcs rr<HTTPFileSystem.infos%F ' ,$* $ ++  ! 88F#/0&&TBTB66BB  'U?+C0c9 SX&&  'sAA// B490B//B4c SSKnURS5nURU5nURS5S:aURS5O [ U5nURS5S:aURS5O [ U5n[ Xg5nUR SS5n [U5(dNUn Sn U(aUS - nOURU5(aU (dU/$XRU50$U (d/$0$SUSU;a>USURS5n USU S-n S U;aSOXS-SRS5S-n O#S n S U;aSOXS-SRS5S-n UR"U 4U=(d U S S S .UD6n SURSS5RSS5RSS5RSS5RSS5RSS5RSS5RSS5RSS5RSS 5RS!S"5RS5-S-nUR"S#S$U5nUR"S%S&U5nUR"URS$S'55n[!U 5Vs0sH?nUR#URSS5RS55(dM:XU_MA nnU (aU$[%U5$s snf)(z Find files by glob-matching. This implementation is idntical to the one in AbstractFileSystem, but "?" is not considered as a character for globbing, because it is so common in URLs, often identifying the "query" part. rNr*[rFrz/*z**rT)maxdepthwithdirsr^\z\\.z\.+z\+z//(z\()z\)|z\|z\^$z\${z\{}z\}z[*]{2}z =PLACEHOLDER=z[*]z[^/]*z.*)rerrfindrminr has_magicr@r<rindexcountrrsubcompilermatchlist)r)rr[rrgendsindstarindbraceindrrootdepthind2allpathspatternprPs rglobHTTPFileSystem.glob7s }}S!##D)$(IIcNa$7$))C.SY%)YYs^q%8499S>c$i'$He,DE T"" 6M ))D/22II D#J :$$S)D $(#D DLDd!8:.>.D.DS.IA.MED DLDd79o.C.CC.H1.LE99  #,utD LR   T5)e$e$s#e$e$e$e$e$e$e$   $&&?G<&&1**W___dCDH% %}}QYYtS188=> A{N%  J9  s ,9L) Lcd[URU55$![[4a gf=frb)boolr rry)r)rs risdirHTTPFileSystem.isdirs1  & &!:.  s //) rrrrrrurrrrr)TNT readaheadNNF)T)NN)r,NNNNNr$) rrrrrgrMsepr+rhrr classmethodrTrrrr rrrr(r7rr@rCrJrNr<r{rr __classcell__rs@rrrsUS:wa [S5eX lX0lX(SS.Ul[T U]"SUUUUUUS.U D6 g)Nr,zFile mode not supportedrr)fsrrFrrrr)rxrHrdetailsrr+) r)rrHrrrFrrrrrs rr+HTTPFile.__init__s\ 4<%&?@ @ #6B   !!'   rcJ>US:aGURS:Xa7URbURUR::dUR5 URcUS:aUR5 O#[ URUR- U5n[ TU]U5$)zRead bytes from file Parameters ---------- length: int Read up to this many bytes. If negative, read all content to end of file. If the server has not supplied the filesize, attempting to read only part of the data will raise a ValueError. r)locr blocksize _fetch_allrirrM)r)lengthrs rrM HTTPFile.reads}aZDHHMYY*tyyDNN/J OO  99 z!TXX-v6Fw|F##rc[RSU35 [UR[5(dUR R "URRUR540URD6nUR5 URn[ [U5SSUS9Ul[U5Ulgg)zRead whole file in one shot, without caching This is only called when position is still at zero, and read() is called without a byte-count. zFetch all for N)rfetcherrr)rvrwrcacherrrrrrHrrJr]rr)r)rrPs rrHTTPFile._fetch_alls  ~dV,-$**h//   !3!3DHH!=MMA   ))C!s3xTWXDJCDI 0rc"URSS5n[R"SU5nU(dgUSS:XaS=pEO0USRS5Vs/sHn[ U5PM snupEUS S:XaSO [ US 5nXEU4$s snf) zParse the Content-Range header Content-Rangerzbytes (\d+-\d+|\*)/(\d+|\*))NNNrrYNr;r)rrgror=rB)r)r?smrrxtotals r_parse_content_rangeHTTPFile._parse_content_ranges KK , HH3Q 7# Q43; EC*+A$**S/:/Q#a&/:JE! QqT5  ;sB c[RSUSUSU35 URR5nUR S05R5nSUSUS- 3US'[RSUR US5 UR R"URRUR 54SU0UD6nURS :Xag UR5 URRS URRS US-55nURS :H=(d8 URUR5SU:H=(d [U5X!- :*nU(aURnU$US:a [!S5eSn/nUR#SS5H"n UR%U 5 U['U 5- nM$ S R)U5SX!- nU$)a Download a block of data The expectation is that the server returns only the requested bytes, with HTTP code 206. If this is not the case, we first check the headers, and then stream the output - if the data size is bigger than we requested, an exception is raised. zFetch range for r9r;r?r:rrz%s : %sirrrrzThe HTTP server doesn't appear to support range requests. Only reading this file from the beginning is supported. Open with block_size=0 for a streaming file interface.iFN)rvrwrrrrHrrrrrDrJr?rrBr]ryrQappendrr) r)rrrr?rclresponse_is_rangerPr's r _fetch_rangeHTTPFile._fetch_ranges  'vRwau=>!!#**Y+002#E7!C!G95 Y''*:; LL  TWW//9 U7 Uf U ==C   YY]]+QYY]];KSSTW-U V MMS  &((3A6%? &2w#+%  ))C  QYI BCu5 5!c%j 6((3- #+.C r)rrrrrH)NNr,bytesNN) rrrrrgr+rMrrrrrrs@rrGrGs:8   6$. ! !00rrGz([*[])c4[RU5nUSL$r$) magic_checksearch)rros rrjrj,s   q !E  rcB^\rSrSrSU4SjjrSrSSjrSrSrU=r $) rHi1c `>X lX@lUS:wa[eUSS.Ul[TU]"S XUSS.UD6 URR "URRU54SS0UD6nURRXb5 URSS5Ul S Ul X`l g) Nr,rRr)rrrFrr&TiFrr)rHrryrrr+rrrrrQitleftoverr)r)rrHrFrrrrs rr+HTTPStreamFile.__init__2s 4<  #T2  VBt VvV LL  TWW//4 LT LV L ++A3..u- rc[S5e)NzCannot seek streaming HTTP file)ry)r)argsrs rr-HTTPStreamFile.seekAs:;;rcUR/n[UR5nX1:dUS:aRURR5nU(aUR U5 OOU[U5- nX1:aMJUS:aMRSR U5nUS:aXASUlUSUnOSUlU=R[U5- slU$![a MZf=f)Nrr)rrr__next__ StopIterationrrr)r)numbufslengrPs rrMHTTPStreamFile.readDs 4==!jC!G gg&&( C  CH DjC!Ghhtn !8IDMds)CDM CH !  sC CCcFURR5 SUlg)NT)rr6closedr5s rr6HTTPStreamFile.closeZs   r)rrrrrrrH)r,Nr) rrrrr+r-rMr6rrrs@rrHrH1s <,rrHc UR5nURS05R5nSUSUS- 3US'UR"U4SU0UD6nUR5 UR$)Nr?r:r;rr)rrrrJr])rrHrrrr?rs r get_ranger_so [[]FjjB',,.Gwaay1GG C33F3A 99rc [RSU5 UR5nURSS5nUR S05R5nXSS'0nUS:XaUR "U4SU0UD6nO*US:XaUR"U4SU0UD6nO[ SU35eUR5 SUR;a[URS5US 'OS UR;a.[URS RS 5S 5US 'OiS UR;a[URS 5US 'O=SUR;a-[URSRS 5S 5US 'SH6nURR U5(dM%URUXh'M8 U$)zCall HEAD on the server to get details about the file (size/checksum etc.) Default operation is to explicitly allow redirects and use encoding 'identity' (no compression) to get the true size of the target. zRetrieve file size for %srTr?rrz)size_policy must be "head" or "get", got rrrrrrz content-range)ETagz Content-MD5Digest) rvrwrrrrrrJr?rBr=) rHrrQrarrr<rchecksum_fields rrSrSis  LL,c2 [[]F %t ,B ::i $ ) ) +D9 Df LL ;b ;F ;   KK :R :6 :CK=QRR 199$199%567V AII %199_5;;C@CDV QYY &199%567V AII %199_5;;C@CDV ; 99== ( (#$99^#rs*.  !/3@NNZZMNjjEF   = )3fll,,2rzz K K \H5H5VL'L^W#Wtjj"  +)+\(XH Cc ('2 DsD D.-D.