XSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK Jr SSKrSSKrSSKJr SSKJr S S KJr S S KJrJrJr S SKJr \(aSSKrSSKJr SSK J!r!J"r" S SKJ#r# \RH"\%5r&Sr'Sr(Sr)Sr*Sr+Sr,1Skr-Sr."SS\/5r0"SS\/5r1"SS \25r3S/S0S!jjr4S1S"jr5S2S3S#jjr6S$r7S%r8S&r9S'r:\ S(5r;S4S)jr<"S*S+\Rz5r>S5S6S,jjr?S7S-jr@S8S9S.jjrAg):zJLAP consumer.) annotationsN)contextmanager)blake2b) TYPE_CHECKING) HTTPError)mask_anaconda_token)context)ETAG_KEYLAST_MODIFIED_KEY RepodataState)JLAP)Iterator)ResponseSession) RepodataCache jlapheadersblake2_256_nominal blake2_256latest>dateetag content-type cache-control content-range last-modifiedcontent-lengthcontent-encodingc[[S9$)zOrdinary hash.) digest_size)r DIGEST_SIZEBlib/python3.13/site-packages/conda/gateways/repodata/jlap/fetch.pyhashr*;s { ++r(c\rSrSrSrg)Jlap304NotModified@r'N__name__ __module__ __qualname____firstlineno____static_attributes__r'r(r)r,r,@r(r,c\rSrSrSrg) JlapSkipZstDr'Nr.r'r(r)r6r6Dr4r(r6c\rSrSrSrg)JlapPatchNotFoundHr'Nr.r'r(r)r9r9Hr4r(r9c^TRS:Xa [5eSU4Sjjn[R"U"5X!5nUSupn[R "U5nTR R5VVs0sH0upxUR5[;dMUR5U_M2 snnUSSUUS.n XI4$s snnf)N0c3@># TRSS9ShvN gN7f)N ) delimiter) iter_linesresponsesr)lines$process_jlap_response..linesRs&&&777s )rivposfooter)returnzIterator[bytes]) status_coder,r from_linesjsonloadsritemslower STORE_HEADERS) rBrIrHrCbufferrJ_kv new_states ` r)process_jlap_responserXLss" ""8__UWb .FBZNC ZZ F !((..0 0wwyM) AGGIqL0 Rjn I   s :CCc,[XX$US9n[XaUS9$)N)rIr ignore_etagsession)rIrH) request_jlaprX)urlrIrrHrZr[rBs r) fetch_jlapr^js" 4'H !r ::r(c 0nU(a SUS3US'U(a U(dX%S'[RS[U5U5 Uce[R[R 4nUR USXVS9nUR5 UR(a?[RS[R"URR55 O[RS 5 [RS [R"URR5VV s0sH!upUR5[;dMX_M# sn n55 [RS UR5 SU;a'URS ;a[!S UR3US9e[R#SU5 U$s sn nf)z>Return the part of the remote .jlap file we are interested in.zbytes=-range if-none-match%s %sT)streamrtimeoutzrequest headers: %szresponse without request.zresponse headers: %sz status: %d)r<iz+Unexpected response code for range request rAz%s)logdebugrr remote_connect_timeout_secsremote_read_timeout_secsgetraise_for_statusrequestpprintpformatrrPrQrRrLrinfo) r]rIrrZr[rrerBrUrVs r)r\r\qsyG #C5? K#' IIg*3/9   1173S3SSG{{3tW{NH  '8H8H8P8P)QR -.II&..446 U6da!'')}:TTQT6 U  IIlH001'   '; ;=h>R>R=ST!  HHT8 O! Vs ,GGcUSSS-$)zAbbreviate hash for formatting.Nu…r')r*s r) format_hashrts 90 00r(c/n[U5H+nX:Xa O%USU:XdMURU5 USnM- X:wa8[RS[ U535 [ S[ U535eU$)NtofromzNo patch from local revision )reversedappendrhrirtr9)patcheshavewantapplypatchs r) find_patchesrs~ E'" <  ;$  LL =D # | 1+d2C1DEF"? D@Q?R STT Lr(c U(aUR5n[R[US5S[US5S[ US5S35 [ R "US5RUSS9nU(aMgg) Nrw → rvz, r~z stepsT)in_place)poprhrirtlen jsonpatch JsonPatchr})datar}r~s r) apply_patchesrs   5=)**@USW[AY@ZZ\5>"#6 + ""5>2888M %r(c0[R"SX5$)Nz(\.\w+)$)resub)r]exts r)withextrs 66+s ((r(c## [R"5nSv [R"5n[RSXU- 5 g7f)Nz%sTook %0.02fs)time monotonicrhri)messagebeginends r)timemers3 NN E .. CIIu5sA A cl0nUR5(aURS5nU(aX2S'U$)z%Caching headers for a path and state._etagrb)existsrl) json_pathstaterrs r) build_headersrs4Gyy! '+O $ Nr(c*\rSrSrSrSSjrSrSrg) HashWritercXlX lgNbackinghasher)selfrrs r)__init__HashWriter.__init__s   r(cnURRU5 URRU5$r)rupdaterwrite)rbs r)rHashWriter.writes) 1||!!!$$r(c8URR5 gr)rclose)rs r)rHashWriter.closes r(rN)rbytes)r/r0r1r2rrrr3r'r(r)rrs%r(rcXUcUnU=(d [5n[X$5n[R[R4nUR USXS9n [ RSXR5 U R5 Sn U RS:XaU(a?[R"5n U R[URS5U5SS9n O[URS5U5n U n U R!S S 9HnU R#U5 M SSS5 U R$(aC['U RS 5n [ R/S XR$R5 U $!,(df  Nd=f![([*[,4a NTf=f) zDownload url if it doesn't exist, passing bytes through hasher.update(). json_path: Path of old cached data (ignore etag if not exists). dest_path: Path to write new data. NT)rdrerrcrwb)closefdi@) chunk_sizezContent-LengthzDownload %d bytes %r)rrr rjrkrlrhrirrmrL zstandardZstdDecompressor stream_writerropen iter_contentrrnintKeyError ValueErrorAttributeErrorrq)rr]rr[ris_zst dest_pathrrerBlength decompressorwriterrepodatablocks r)download_and_hashrsn  $]_EI-G1173S3SSG{{3tW{NHIIgs,,-  Fs" $557L!//9>>$/80F  t 4f=F x!..'.Bu%C ))*:;U 05S//SQ/5n OU[ n SnURSS5nURSS5nUR[S5n[US5n[(RAS[-U5UU5 [CUUU[DRGU5US S9upUR1SS5 S nU(a[C[US5US 9upXa['[S$5 [US%U RV55nU RXunnn[:RZ"U5S&n[]UU U5n[(RKS'[_U5S([aU 5S)[aU535 U(Ga0[S*5 [:RZ"URc55nXRdR[ 5:wa'[(R+S+5 SSS5 SSS5 gSSS5 [gWU5 [S,5 URiS-5n[5n [kUU 5Rm[:R<"US.S/9RoS055 U R75U[8'UU[ 'UsSSS5 sSSS5 sSSS5 $U[ U:XdeSSS5 g![[ ["R$4an ['U ["R$5(a*[(R+S[-[US55U 5 ['U [ 5(a[/U 5(de['U [5(dUR1SS 5 [U [US 5UUUUS 9n Sn A GNVSn A ff=f!,(df  GN =f![Ha [(RKS5 GN[La [(ROS5 GN>[ ajn [/U 5(a%UR1SS 5 [QUUSUUUS9sSn A $[(RKSU RRR45 Sn A GNSn A ff=f![H[L4a`n [(ROS!U S"9 [ /SQS[:R<"[>S#05S//SQ/5n UR1SS 5 Sn A GNSn A ff=f!,(df  GN=f!,(df  O=fSSS5 GMP!,(df  GN_=f![p[:Rr4aYn ['U [p5(a[(RKS15 U(aS25e[QUUSUUUS9sSn A sSSS5 $Sn A ff=f!,(df  g=f)3NrzDownload complete  zstz .json.zstT)rr[rrz9Could not decompress %s as zstd. Fall back to .json. (%s)Fz.json)rr[rr!_modrrr_cache_controlr)rGrrr)rrrrHrIz.jlapzFetch %s from iv=%s, pos=%s)rIrrHr[rZz@Checksum not OK on JLAP range request. Retry with complete JLAP.z&IndexError reading JLAP. Invalid file?) full_downloadr[cache temp_pathzAResponse code %d on JLAP range request. Retry with complete JLAP.)r[zError parsing jlap)exc_info 00000000000000000000000000000000zApply Patches c3T# UHupn[R"U5v M g7fr)rNrO).0rTr~s r) )request_url_jlap_state..s HK[Qqtzz%((Ks&(rzApply z patches rzLoad z)repodata cache changed during jlap fetch.zWrite changed r),:) separatorszutf-8zICurrent repodata.json %s not found in patchset. Re-download repodata.jsonzRecursion error):rlJLAP_KEYHEADERScache_path_jsonr NOMINAL_HASHrshould_check_formatr*rrr r rrr6rr ZstdError isinstancerhwarningrrset_has_formatrrL hexdigest ON_DISK_HASHrNdumpsLATESTrir^rfromhexrrq IndexError exceptionrequest_url_jlap_staterBlistbody penultimaterOrrrtloadrrrrrencoder9JSONDecodeError)r]rrr[rr jlap_staterrrSrrBrr{ need_jlapiv_hexrIrjlap_urlrzrTrJr|r} repodata_jsonrs r)rrsu8R(JnnWb)G%%I VF %)*:*:*<*<((00 (Q/ 05( (D) +T2 ,,U330[1!"+ '## H&-'.%,,00AE&M%--11&9E'N&.&6&6&:&:?&KE" #Y1^   3 &8>8H8H8J JE, % "5\" |aVTN)CR%H+VW\" * ^^D"-F..*C;;x.DsG,H II-#H-  ",==(! " F   .I.  4%/W0Ew%W"%h  ! HFKKHH)) 61zz&!(+:  $5E HHU It$%%;K X1/X,6X1<*X,,X14Z$AZZ$' Z6 1['9 [ [ ['] [$ ['"]$['']A]]]]] ]+)rr()rBr)rNr(TN)rNTN)r[zSession | None)r pathlib.Pathrr)FN)rrr[rrzRepodataState | Nonerzpathlib.Path | None)rrrKbool)F) rrr[rrrrrrKz dict | None)B__doc__ __future__riorNloggingrorr contextlibrhashlibrtypingrrrrequestsrconda.common.urlr base.contextr rr r rcorerpathlibcollections.abcr connectionrrr getLoggerr/rhr&rrrrrrRr* Exceptionr,r6 LookupErrorr9rXr^r\rtrrrrr RawIOBaserrrrr'r(r)r s"  % 0$99(/  !  #    ,    )   <;HL)6D)X1  N)66  & %)** * *#*Z;Q Q  Q  QQQr(