r>J?r? S SK@JArA S SKBJCrC \(aSSKDJErEJFrF SSKJGrGJHrH S SK5JIrIJJrJ SS KKJLrL \ "\M5rNS!rOS rPS"rQ"S#S$\R5rS"S%S&\5rT"S'S(\SS)9rU\."S*S+S,S-9S/S.j5rVg)0z,Tools for managing a subdir's repodata.json.) annotationsN)UserList defaultdict)partial)chain) getLogger)existsgetmtimeisfilejoinsplitext)Path)time) TYPE_CHECKING) IndexedSet)dals)CONDA_PACKAGE_EXTENSION_V1 REPODATA_FN)context) DummyExecutorThreadLimitedThreadPoolExecutordashlist)groupby_to_dict) url_to_path)join_url) deprecated) ChannelErrorCondaUpgradeErrorUnavailableInvalidChannel)rm_rf)CACHE_STATE_SUFFIXCondaRepoInterface RepodataFetch RepodataState cache_fn_urlcreate_cache_dirget_repo_interface)Channelall_channel_urls) MatchSpec) PackageRecord)IterableIterator)AnySelf) RepodataCache RepoInterface) PackageRefs4"(_etag|_mod|_cache_control)":[ ]?"(.*?[^\\])"[,}\s]c2^\rSrSr\4SU4SjjjrSrU=r$)SubdirDataType9cn>UR(deUR(ae[U5[Lde[ 5nU=(d [ nUR SS9U4nU[R;a[RUnUS(amUSRS5(aTUR 5nU(a<[US-U-5n[U5(aUR[U5:aU$OU$[T U]=X[!5S9nX8l U[RU'U$)NTwith_credentialsrfile:///)r2)subdirpackage_filenametyper)rrurl SubdirData_cache_ startswithrr _mtimer super__call__r() clschannel repodata_fnnow cache_key cache_entry channel_url file_pathsubdir_data_instance __class__s 6lib/python3.13/site-packages/conda/core/subdir_data.pyrGSubdirDataType.__call__:s~~~++++G}'''f!0[ KKK6 C  ** *$,,Y7K| ! 7 7 B B%kkm  +K#,= ,K LIi(([-?-?8ICV-V**""$w/ 0B0D 0 '*#(< 9%##)rIr)rJstrreturnrB)__name__ __module__ __qualname____firstlineno__rrG__static_attributes__ __classcell__)rQs@rRr7r79s;F$$rTr7c"\rSrSrSrSSjrSrg)PackageRecordListSa Lazily convert dicts to PackageRecord. This class inherits from the built-in UserList class and provides a way to lazily convert dictionaries to PackageRecord objects. It overrides the __getitem__ method to check if the item at the given index is a PackageRecord object. If not, it converts the dictionary to a PackageRecord object and stores it in the data list. :param data: The list of items c[U[5(aURURU5$URUn[U[5(d[ S0UD6nX RU'U$)aZ Returns the PackageRecord at index i. If i is a slice, returns a new instance of PackageRecordList containing the PackageRecords at the indices in i. If the PackageRecord at index i is not already an instance of PackageRecord, it is converted to one and stored back in the data list. :param i: An integer or slice object indicating the index or indices of the PackageRecord(s) to be returned. :return: If i is a slice, returns a new instance of PackageRecordList containing the PackageRecords at the indices in i. If i is an integer, returns the PackageRecord at index i. rU) isinstanceslicerQdatar,)selfirecords rR __getitem__PackageRecordList.__getitem___s_ a  >>$))A,/ /YYq\Ffm44&00% ! MrTrUN)rfintrWr,)rXrYrZr[__doc__rhr\rUrTrRr_r_Ss  rTr_c\rSrSr%Sr0rS\S'\SS Sjj5r\ SS\ 4S!Sjj5r S"Sjr \ \ 4S#S jjr\S$S j5r\S%S j5r\S&S j5rS'S jr\S(Sj5r\S(Sj5r\S)Sj5r\S)Sj5r\S(Sj5rS'SjrS*SjrS+SjrS,SjrS-SjrS.SjrS/SjrS0Sjr S1S2Sjjr!S1S3Sjjr"SS4Sjjr#Sr$g)5rBva A class representing the SubdirData. This class provides functionality for managing and caching SubdirData instances. :param channel: The channel object :param repodata_fn: The name of the repodata file. Defaults to REPODATA_FN :return: A SubdirData instance. z5dict[tuple[str, str], PackageRecordList | SubdirData]rCcU(aOURR5VVs0sH"up#USRS5(aM X#_M$ snnUlgURR5 gs snnf)aD Clear the cached local channel data. This method is used to clear the cached local channel data. It is primarily used during unit tests to handle changes in the CONDA_USE_ONLY_TAR_BZ2 environment variable during the process lifetime. :param exclude_file: A flag indicating whether to exclude file:// URLs from the cache. rr<N)rCitemsrDclear)rH exclude_filekvs rRclear_cached_local_channel_data*SubdirData.clear_cached_local_channel_datas\ !$!2!2!4!4AaDOOI&SubdirData.query_all..s s~~i/HrTFrUz>Ignoring the following channel urls because mode is offline.%sTcZ>[[[U5TS9RT55$)z Queries the SubdirData for a given URL and returns a tuple of PackageRecord objects. :param url: The URL of the SubdirData to query. :return: A tuple of PackageRecord objects representing the query results. )rJ)tuplerBr)query)rApackage_ref_or_match_specrJs rR subdir_query*SubdirData.query_all..subdir_querys.73<[AGG- rTr3) max_workers)rArVrWtuple[PackageRecord, ...])r'rchannelsrwr*offlinegroupbygetloginforrdebugrepodata_threadsrrrr|r from_iterablemap) r~rrwrJ channel_urls grouped_urls ignored_urlsrExecutorexecutorresults ` ` rR query_allSubdirData.query_alls&   ''H ?ooG'B ??"#H,WL'++E26LT\*&l&6&6tR&@AL   }} 8 8A = /W=U=U Z8##HLL$LMF Z s /E Ec#d# UR(dUR5 Un[U[5(a [ U5n[U[5(aUR S5(aFUR S5nUR U5HnURU5(dMUv M! gUR5HnURU5(dMUv M! g[U[5(deUR UR5HnXB:XdM Uv M g7f)z A function that queries for a specific package reference or MatchSpec object. :param package_ref_or_match_spec: The package reference or MatchSpec object to query. :yields: PackageRecord objects. nameN) _loadedloadrbrVr+get_exact_value_iter_records_by_namematch iter_recordsr,r)rer~param package_nameprecs rRr}SubdirData.querys|| IIK) eS ! !e$E eY ' '$$V,,$44V<  66|DD{{4((" E!--/D{{4((" 0e]33 33225::>=J?sB(D0.0D0"AD0' D0cUR(deUR(aUR5nUS [S0UD6nXlURR SS9=(d SUlURR SS9=(d SUlUR UlURUl X l X0l SUl SUl g)z Initializes a new instance of the SubdirData class. :param channel: The channel object. :param repodata_fn: The repodata filename. :param RepoInterface: The RepoInterface class. r?Fr:TNrU)r>r?dumpr)rIrA url_w_subdirurl_w_credentials _base_url_base_url_w_credentialsrJr2r_key_mgr)rerIrJr2partss rR__init__SubdirData.__init__s~~~  # #LLNE()&&G  LL,,e,DJ!%!1!14!1!H!NB**'+'='=$&*  rTc.URR$)z( Changes as we mutate self.repodata_fn. ) repo_fetch_repores rRrSubdirData._repos $$$rTc.URR$)zZ Returns the `RepodataCache` object associated with the current instance of `SubdirData`. )r repo_cachers rRrSubdirData.repo_caches )))rTc|[[UR5URURUR S9$)zo Object to get repodata. Not cached since self.repodata_fn is mutable. Replaces self._repo & self.repo_cache. )repo_interface_cls)r$rcache_path_baserIrJr2rs rRrSubdirData.repo_fetch!s8 %% & LL   #11   rTc4SUlUR5 U$)z+ Update the instance with new information. F)rrrs rRreloadSubdirData.reload/s   rTc ~[[5[[URUR 55S5$)z Get the base path for caching the repodata.json file. This method returns the base path for caching the repodata.json file. It is used to construct the full path for caching the file. r)r r'r r&rrJrs rRrSubdirData.cache_path_base7s7   \$"8"8$:J:JK LQ O  rTc:URS-UR-$)zb Get the URL with the repodata filename. This method returns the URL with the repodata filename. r=)rrJrs rRurl_w_repodata_fnSubdirData.url_w_repodata_fnDs   3&)9)999rTcf[UR[R(aSOS-S-5$)zR Get the path to the cache file. This method returns the path to the cache file. 1rz.json)rrruse_only_tar_bz2rs rRcache_path_jsonSubdirData.cache_path_jsonMs.  7+C+CC Lw V  rTcn[UR[R(aSOS-[-5$)z Out-of-band etag and other state needed by the RepoInterface. Get the path to the cache state file. This method returns the path to the cache state file. rr)rrrrr"rs rRcache_path_stateSubdirData.cache_path_stateXs4  ..sB 8  !  rTc^UR[R(aS-S-$S-S-$)z` Get the path to the cache pickle file. This method returns the path to the cache pickle file. rrz.q)rrrrs rRcache_path_pickleSubdirData.cache_path_picklegs1##g.F.FsORVVVBORVVVrTcvUR5nURSS5[:a![[ S5UR -5eURSUR 5UlURSUR5Ul Xl USUl USUl USUl S UlU$) zw Load the internal state of the SubdirData instance. This method loads the internal state of the SubdirData instance. repodata_versionr The current version of conda is too old to read repodata from %s (This version only supports repodata_version 1 and 2.) Please update conda to use this channel. base_urlbase_url_w_credentials_package_records _names_index_track_features_indexT)_loadrMAX_REPODATA_VERSIONrrrrrrr_internal_staterrrr)rers rRrSubdirData.loadps **,   11 58L L# (( )  ),,Z9J9JK'6':': $d&<&<( $ / /0B C+N;%45L%M"  rTcnUR(dUR5 [UR5$)a< A function that iterates over package records. This function checks if the package records are loaded. If not loaded, it loads them. It returns an iterator over the package records. The package_records attribute could potentially be replaced with fully-converted UserList data after going through the entire list. )rriterrrs rRrSubdirData.iter_recordss%|| IIKD))**rTc#Z# URUHnURUv M g7f)z A function that iterates over package records by name. This function iterates over package records and yields those whose name matches the given name. If include_self is True, it also yields the record with the given name. N)rr)rerrfs rRr SubdirData._iter_records_by_names-""4(A''* *)s)+cURnUR5up#URX#5$![a3 UR[ :wa[ UlUR 5s$ef=f)z Try to load repodata. If e.g. we are downloading `current_repodata.json`, fall back to `repodata.json` when the former is unavailable. )rfetch_latest_parsed_process_raw_repodatar rJrr)refetcherrepodatastates rRrSubdirData._loadse ooG%99;OH--h> >( ;.#. zz|#  s.19A.,A.cd[RSURUR5 [ URS5n[ R "URU[ R5 SSS5 g!,(df  g=f![a [RSSS9 gf=f)z* Pickle the object to the specified file. z!Saving pickled state for %s at %swbNz Failed to dump pickled repodata.Texc_info) rrrropenpicklerrHIGHEST_PROTOCOL Exception)refhs rR _pickle_meSubdirData._pickle_mes I II3&&&&  d,,d3r D00"f6M6MN433 I II84I H Is0AB1A=4B= B B BB/.B/cURU5nU(aU$URR5up1URX15nURULdeUR 5 U$)z4 Read local repodata from the cache and process it. ) _read_pickledr read_cache_process_raw_repodata_strrr)rer_pickled_stateraw_repodata_strrs rR_read_local_repodataSubdirData._read_local_repodatash ++E2 ! !"&//"<"<">889IQ##666 rTc## SURS5UR4v SURS5URR4v SURS5[R 4v SURS5U4v SURS5U4v SURS5[ 4v SURS5UR4v g7f) a Throw away the pickle if these don't all match. :param pickled_state: The pickled state to compare against. :param mod: The modification information to check. :param etag: The etag to compare against. :yields: Tuples of the form (check_name, pickled_value, current_value). _url _schannel_add_pip_mod_etag_pickle_versionfnN)rrrIcanonical_nameradd_pip_as_python_dependencyREPODATA_PICKLE_VERSIONrJ)re pickled_statemodetags rR_pickle_valid_checksSubdirData._pickle_valid_checkssm''/1G1GGG=,,[94<<;V;VVV    j )  0 0  m''/44}((1477    / 0 #  M%%d+T-=-===sCCc .^^^^[T[5(d*[TRTRTRTS9m[ TR 5(a[ TR5(dg[ TR 5(a [RSTR 5 [TR S5n[R"U5mSSS5 S UUU4SjjmS U4S jjn[U"55(d;[RS TRTR[!T"555 gT$!,(df  Nr=f![a, [RSSS9 [TR 5 gf=f) z Read pickled repodata from the cache and process it. :param state: The repodata state. :return: A dictionary containing the processed pickled repodata, or None if the repodata is not pickled. dictNzfound pickle file %srbz Failed to load pickled repodata.TrcR>TRTTRTR5$)z Generate a list of checks to verify the validity of a pickled state. :return: A list of tuples, where each tuple contains a check name, the value from the pickled state, and the current value. )rrr)rrersrRchecks(SubdirData._read_pickled..checkss",,^UYY S SrTc3<># T"5H upnX:Hv M g7f)z Generate a generator that yields the results of checking the validity of a pickled state. :yields: True if the pickled state is valid, False otherwise. NrU)_leftrightr s rR_check_pickled_valid6SubdirData._read_pickled.._check_pickled_valids #)(m##+sz.Pickle load validation failed for %s at %s. %r)rWz%Iterator[tuple[str, str | None, str]])rWzIterator[bool])rbr%rrrJr rrrrrrrr!allrr|)rerrrrr s`` @@rRrSubdirData._read_pickleds@%//!$$%%   Ed,,--VDFr:TrIrrrrrrrrrrr_cache_controlrrrrrrrarchplatform)rrIrschannelr>packageszpackages.condaNic30># UH oTU4v M g7fNrU).0rrlegacy_packagess rR 3SubdirData._process_raw_repodata..s E/D!/!$%/Dsz.condaz.tar.bz2md5legacy_bz2_md5sizelegacy_bz2_sizerpythonversion)z2.z3.dependspiprecord_versionr3z"Ignoring record_version %d from %srA)&rbr%rrrJrrIr>rrrr_rrlistrr _get_base_urlrrrrrrrrrsetkeysrolenrDappendupdaterrrr)rerrr>add_piprrrrrrrmeta_in_commonconda_packages_tar_bz2rruse_these_legacy_keysgroupcopy_legacy_md5rr counterpart record_indexr#s @rRr SubdirData._process_raw_repodata@s%//!$$%%   Efb)--h7N4<<;N;N,,,,,66<<..3D3FF 0+6t+<<L=H=NN"%:%%h%G!%!3!3Ht!3!T t|| D--  !7!7    %&<  t33   $""   0  L  $%:  UYYw'  EIIf%  eii(89  EIIf%   6! " # $  *O>O$O!% 1 1 3 ,C%))#..* 1 12355%2$5$5c$:M$}.;s+-0044d4KK! ! )) )   / "!$,,"="=!>iHYHYGZ[-- sD E 1EE ) r2rrrrrrrrrIrJrr)T)rqboolrWNone) r~zPackageRef | MatchSpec | strrzIterable[Channel | str] | NonerwzIterable[str] | NonerJrVrWr)r~zstr | MatchSpecrWIterator[PackageRecord])rIr)rJrVr2ztype[RepoInterface])rWr2)rWr1)rWr$)rWr0)rWrV)rWr)rWrN)rrVrWrN)rWdict[str, Any])rWrM)rr%rWrO)rrOrrVrrVrWzIterator[tuple[str, Any, Any]])rr%rWzdict[str, Any] | Noner!)rrVrRepodataState | NonerWrO)rrOrrPrWrO)rrr;rLrWrV)%rXrYrZr[rkrC__annotations__ classmethodrt staticmethodrrr}r#rpropertyrrrrrrrrrrrrrrrrrrrr0r\rUrTrRrBrBvsFHG BG  &48(,& ;#?;0;&; ; # ;;z)8 B'-? + @%% **         ::      WWB ++" I >+>25>=@> '>6:~'+ A A$ A  A GKv&v/Cv vp*!*!rTrB) metaclassz25.3z25.9z>Use `conda.core.models.records.PackageRecord.feature` instead.)addendumc.[R"U5$)z Create a feature record based on the given feature name. :param feature_name: The name of the feature :return: The created PackageRecord for the feature. )r,feature) feature_names rRmake_feature_recordrZs   ..rT)rYrVrWr,)Wrk __future__rrr collectionsrr functoolsr itertoolsrloggingros.pathr r r r r pathlibrrtypingrboltons.setutilsr auxlib.ishrbase.constantsrr base.contextr common.iorrrcommon.iteratorsrr common.pathr common.urlr deprecationsr exceptionsrrr gateways.disk.deleter!gateways.repodatar"r#r$r%r&r'r(models.channelr)r*models.match_specr+models.recordsr,collections.abcr-r.r/r0r1r2indexr4rXrrrREPODATA_HEADER_REr@r7r_rBrZrUrTrRrus3" -<< 'D"PP9%!%SS(7)*2 @!O$T$4  Fl !>l !^   M /  /rT