+ ,jL5(^RIHt^RIt^RIt^RIHt^RIHtHtH t H t H t H t ^RI Ht^RIHt^RIHt^RIHt^R IHt^R IHtHt^R IHtHtHt^R IHt]'d^R I H!t!!RR4t"]!RR44t#!RR4t$RRlt%R#)) annotationsN) dataclass) TYPE_CHECKINGAnyIterableListOptionalUnion)Channel) MatchSpec)Client) CacheAction) PackageName)PlatformPlatformLiteral) PyGateway PyMatchSpecPySourceConfig)RepoDataRecordRepoDataSourcec>]tRt^tRtRRltRRltRRltRtR #) _RepoDataSourceAdapterzAdapter that wraps a user's RepoDataSource and converts FFI types. This adapter receives raw PyPlatform and PyPackageName from Rust, converts them to the proper Python wrapper types (Platform, PackageName), and calls the user's implementation. c V^8dQhRRRR/#)sourcerreturnNone)formats"9lib/python3.14/site-packages/rattler/repo_data/gateway.py __annotate__#_RepoDataSourceAdapter.__annotate__s~$c WnR#)N_source)selfrs&&r!__init___RepoDataSourceAdapter.__init__s r$c$V^8dQhRRRRRR/#)r py_platformrpy_namerzList[RepoDataRecord]r)r s"r!r"r# s'HHsHSHMaHr$c "\P!V4p\P!V4pVPP W44GRjxL #L5i)5Convert FFI types and delegate to the wrapped source.N)r_from_py_platformr_from_py_package_namer'fetch_package_records)r(r,r-platformnames&&& r!r2,_RepoDataSourceAdapter.fetch_package_records sD--k:009\\77GGGGsA A AAc V^8dQhRRRR/#)rr,rrz List[str]r)r s"r!r"r#)s4444r$c d\P!V4pVPPV4#)r/)rr0r' package_names)r(r,r3s&& r!r8$_RepoDataSourceAdapter.package_names)s'--k:||))(33r$r&N) __name__ __module__ __qualname____firstlineno____doc__r)r2r8__static_attributes__rr$r!rrsH44r$rc]tRt^/t$RtRtR]R&RtR]R&RtR]R&Rt R]R &R t R ]R &R Rlt RRlt Rt R#) SourceConfigzw Describes properties about a channel. This can be used to configure the Gateway to handle channels in a certain way. Tbool zstd_enabled bz2_enabledsharded_enabledNzOptional[bool] jlap_enabledzcache-or-fetchr cache_actioncV^8dQhRR/#)rrrr)r s"r!r"SourceConfig.__annotate__Mstr$c `VPe \P!R\^R7R#R#)NzYThe 'jlap_enabled' option is deprecated and has no effect. JLAP support has been removed.) stacklevel)rFwarningswarnDeprecationWarningr(s&r! __post_init__SourceConfig.__post_init__Ms(    ( MMk"  )r$cV^8dQhRR/#)rrrr)r s"r!r"rIUs  . r$c p\VPVPVPVPR7#)z Converts this object into a type that can be used by the Rust code. Examples -------- ```python >>> SourceConfig()._into_py() # doctest: +ELLIPSIS >>> ``` )rCrDrErG)rrCrDrErGrOs&r!_into_pySourceConfig._into_pyUs5**(( 00**   r$r)r:r;r<r=r>rC__annotations__rDrErFrGrPrTr?rr$r!rArA/s[L$9K8 OT 5#'L.'K 0L+0  r$rAcb]tRt^itRtRRRlltRRRlltRRltRR R lltR R lt R t R#)Gatewaya The gateway manages all the quircks and complex bits of efficiently acquiring repodata. It implements all the necessary logic to fetch the repodata from a remote server, cache it locally and convert it into python objects. The gateway can also easily be used concurrently, as it is designed to be thread-safe. When two threads are querying the same channel at the same time, their requests are coalesced into a single request. This is done to reduce the number of requests made to the remote server and reduce the overall memory usage. The gateway caches the repodata internally, so if the same channel is queried multiple times the records will only be fetched once. However, the conversion of the records to a python object is done every time the query method is called. Therefor, instead of requesting records directly, its more efficient to pass the gateway itself to methods that accepts it. Nc4V^8dQhRRRRRRRRR R R R R R/#)r cache_dirzOptional[os.PathLike[str]]default_configzOptional[SourceConfig]per_channel_configz!Optional[dict[str, SourceConfig]]max_concurrent_requestsintclientzOptional[Client] show_progressrBrrr)r s"r!r"Gateway.__annotate__{sP' ' -' /' > ' "% ' ! ' '  ' r$c  T;'g \4p\TVP4T;'g/P4UUu/uFwrxWxP4bK uppTVe VPMRVR7VnR#uuppi)a8 Arguments: cache_dir: The directory where the repodata should be cached. If not specified the default cache directory is used. default_config: The default configuration for channels. per_channel_config: Source configuration on a per-URL basis. This URL is used as a prefix, so any channel that starts with the URL uses the configuration. The configuration with the longest matching prefix is used. max_concurrent_requests: The maximum number of concurrent requests that can be made. client: An authenticated client to use for acquiring repodata. If not specified a default client will be used. show_progress: Whether to show progress bars when fetching repodata. Examples -------- ```python >>> Gateway() Gateway() >>> ``` N)rZr[r\r]r_r`)rArrTitems_client_gateway) r(rZr[r\r]r_r`channelconfigs &&&&&&& r!r)Gateway.__init__{sz<(99<>!)224SeSkSkikRrRrRtuRtw): :Rtu$;%+%76>>T'    vsBc ,V^8dQhRRRRRRRRR R /#) rsources-Iterable[Union[Channel, str, RepoDataSource]] platforms$Iterable[Platform | PlatformLiteral]specsz'Iterable[MatchSpec | PackageName | str] recursiverBrzList[List[RepoDataRecord]]r)r s"r!r"rasC=j=j>=j8=j7 =j  =j $ =jr$c "VPP\V4VUu.uF:p\V\4'd VP M\ V4P NK< upVUu.uF;p\V\ 4'd VPM\\V4RR4NK= upVR7GRjxL pVUU u.uF(qU u.uFp \P!V 4NK up NK* up p#uupiuupiLEuup iuup pi5i)aQueries the gateway for repodata from channels and custom sources. If `recursive` is `True` the gateway will recursively fetch the dependencies of the encountered records. If `recursive` is `False` only the records with the package names specified in `specs` are returned. The `specs` can either be a `MatchSpec`, `PackageName` or a string. If a string or a `PackageName` is provided it will be converted into a MatchSpec that matches any record with the given name. If a `MatchSpec` is provided all records that match the name specified in the spec will be returned, but only the dependencies of the records that match the entire spec are recursively fetched. The gateway caches records from channels internally, so if the same channel is queried multiple times the records will only be fetched once. However, the conversion of the records to a python object is done every time the query method is called. Note: Custom RepoDataSource implementations are **not cached** by the gateway. If caching is needed for custom sources, it must be implemented within the source itself. Arguments: sources: The sources to query. Can be channels (by name, URL, or Channel object) or custom RepoDataSource implementations. platforms: The platforms to query. specs: The specs to query. recursive: Whether recursively fetch dependencies or not. Returns: A list of lists of `RepoDataRecord`s. The outer list contains the results for each source in the same order they are provided in the `sources` argument. Examples -------- ```python >>> import asyncio >>> gateway = Gateway() >>> records = asyncio.run(gateway.query(["conda-forge"], ["linux-aarch64"], ["python"])) >>> assert len(records) == 1 >>> ``` T)rjrlrnroN) requery_convert_sources isinstancer_innerr _match_specrstrr_from_py_record) r(rjrlrnror3spec py_recordsrecordsrecords &&&&& r!rq Gateway.querys^ ==..$W-!* )H$.h#A#AxPXGYG`G`` ) "!D%/tY$?$?  [QTUYQZ\`bfEgg! /   _ii^hSZgNgF//7gN^hii  OisN$D AC5 &D ,AC: - D 9C?: D D D *D1D DD c$V^8dQhRRRRRR/#)rrjrkrlrmrzList[PackageName]r)r s"r!r"ras-$f$f>$f8$f  $fr$c T"VPP\V4VUu.uF:p\V\4'd VP M\ V4P NK< upR7GRjxL pVUu.uFp\ P!V4NK up#uupiL/uupi5i)aQueries all the names of packages in channels or custom sources. Arguments: sources: The sources to query. Can be channels (by name, URL, or Channel object) or custom RepoDataSource implementations. platforms: The platforms to query. Returns: A list of package names that are present in the given subdirectories. Examples -------- ```python >>> import asyncio >>> gateway = Gateway() >>> records = asyncio.run(gateway.names(["conda-forge"], ["linux-64"])) >>> PackageName("python") in records True >>> ``` )rjrlN)renamesrrrsrrtrr1)r(rjrlr3py_package_names package_names&&& r!r Gateway.namess6"&!4!4$W-!* )H$.h#A#AxPXGYG`G`` )"5"  UeeTdL 11,?Tdee fs/$B(AB & B(1B!2B(:B# B(#B(c(V^8dQhRRRRRRRR/#) rrfz Channel | strsubdirsz.Optional[Iterable[Platform | PlatformLiteral]] clear_diskrBrrr)r s"r!r"ra s3" " " @"  "  " r$c  JVPP\V\4'd VPM\V4PVeHVUu0uF:p\V\ 4'd VP M\ V4P kK< upMRV4R#uupi)a Clears the cache for the given channel. Any subsequent query will re-fetch any required data from the source. Arguments: channel: The channel to clear the cache for. subdirs: A selection of subdirectories to clear, if `None` is specified all subdirectories of the channel are cleared. clear_disk: If `True`, also clears the on-disk cache. By default only the in-memory cache is cleared. Examples -------- ```python >>> gateway = Gateway() >>> gateway.clear_repodata_cache("conda-forge", ["linux-64"]) >>> gateway.clear_repodata_cache("robostack") >>> gateway.clear_repodata_cache("conda-forge", clear_disk=True) >>> ``` N)reclear_repodata_cachersr _channelrrt)r(rfrrsubdirs&&&& r!rGateway.clear_repodata_cache s8 ** *7G < >> Gateway() Gateway() >>> ``` z())typer:rOs&r!__repr__Gateway.__repr__-st*%%&b))r$)re)NNNdNF)T)NF) r:r;r<r=r>r)rqrrrr?rr$r!rXrXis+"' R=j~$fL" H * *r$rXc V^8dQhRRRR/#)rrjz Iterable[Any]rz List[Any]r)r s"r!r"r"<sm r$c^RIHp.pVFp\V\4'd'VP \ V4P 4K?\V\ 4'dVP VP 4Kr\W14'dVP \V44K\R\V4P R24h V#)aTConvert an iterable of sources to a list suitable for the Rust gateway. Channels are converted to their internal PyChannel representation. Custom RepoDataSource implementations are wrapped in an adapter that converts between FFI types and Python wrapper types. Raises: TypeError: If a source doesn't implement the required interface. rzKExpected Channel, str, or object implementing RepoDataSource protocol, got z8. See rattler.RepoDataSource for the required interface.) rattler.repo_data.sourcerrsrvappendr rr TypeErrorrr:)rjr convertedrs& r!rrrr<s8I fc " "   WV_55 6  ( (   V__ -  / /   3F; <F|,,-.IJ  r$)& __future__rosrL dataclassesrtypingrrrrr r rattler.channel.channelr rattler.match_spec.match_specr rattler.networking.clientr "rattler.networking.fetch_repo_datarrattler.package.package_namerrattler.platform.platformrrrattler.rattlerrrrrattler.repo_data.recordrrrrrArXrrrr$r!rsn" !FF+3,:4?BB37444 6 6  6 rP*P*fr$