+ :1j,Rt^RIHt^RIt^RIt^RIHt^RIHt^RI t ^RI t ]'d ^RI H t ^RIH t ]P!]4tRsR t]!RR 44tRR lt!R R 4tR#)zf Cache suitable for shards, not allowed to change because they are named after their own sha256 hash. ) annotationsN) dataclass) TYPE_CHECKING)Path) ShardDictzrepodata_shards.dbcB]tRt^t$RRltR]R&R]R&R]R&RtR #) AnnotatedRawShardc$V^8dQhRRRRRR/#)urlstrpackagecompressed_shardbytes)formats";lib/python3.14/site-packages/conda/_private/shards/cache.py __annotate__AnnotatedRawShard.__annotate__!s! 1 1C 1# 1 1c rRV9d \R4hRV9d \R4hWnW nW0nR#)z://zurl must contain '://'zpackage must not contain '://'N) ValueErrorr r r)selfr r rs&&&&r__init__AnnotatedRawShard.__init__!s:  56 6 G => > 0rr r r rr)rr r N)__name__ __module__ __qualname____firstlineno__r__annotations____static_attributes__rrrrrs 1 H Lrrc\P!VRRR7p\PVnT;_uu_4pVP R4P 4^,pV'd7VP4PR4'dVP R4VP R4RRR4V# \P dRpLri;i +'giT#;i) ze Get database connection. dburi: uri-style sqlite database filename; accepts certain ?= parameters. Tg>@)uritimeoutzPRAGMA journal_mode = WALNwalzPRAGMA synchronous = NORMALzPRAGMA foreign_keys = ON) sqlite3connectRow row_factoryexecutefetchone DatabaseErrorlower startswith)dburiconncmodes& rr&r&1s ??5dD 9D{{D  9989BBDQGD DJJL++E22 II3 4 ,-  K $$ D   Ks:C&B:!C)$C"C:CCCC C( c|]tRt^DtRtRRRlltRtRtRtRt RRlt R R lt R R lt R Rlt RtRtRtR#) ShardCachezA Handle caching for individual shards (not the index of shards). cV^8dQhRR/#)r baserr)rs"rrShardCache.__annotate__Is$$T$rc 6WnVPVR7R#)z0 base: directory and filename prefix for cache. createN)r5r&)rr5r9s&&&rrShardCache.__init__Is  F #rc V#Nrrs&r __enter__ShardCache.__enter__Ps rc &VP4R#r<)close)rexc_typeexc_valexec_tbs&&&&r__exit__ShardCache.__exit__Ss  rc pVP'd$VPP4RVnR#R#)zF Clean up connection. ShardCache can no longer be used after close(). N)r/rAr=s&rrAShardCache.closeVs' 999 IIOO DI rc 0\VPRR7#)z5 Copy cache with new connection. Useful for threads. Fr8)r3r5r=s&rcopyShardCache.copy^s$))E22rc VP\, P4p\V4VnV'gR#VP;_uu_4pVP R4RRR4R# +'giR#;i \ Pdp\TR4pT'dT'd TP\ P8Xdq\PRY54TP4M0 \d#p\PRY54RsRp?MRp?ii;iTPTRR7uRp?#hRp?ii;i) zr Args: create: if True, create table if not exists. retry: remove cache, log warning, and retry on error. NzCREATE TABLE IF NOT EXISTS shards (url TEXT PRIMARY KEY, package TEXT, shard BLOB, timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP)sqlite_errorcodez%s '%s'; remove and retry.z %s '%s'; use alternate filename.zrepodata_shards_1.dbF)r9retry)r5SHARD_CACHE_NAMEas_urir&r/r)r%r+hasattrrM SQLITE_NOTADBlogwarning remove_cacheOSError)rr9rNr.r0e has_errorcodes&&& rr&ShardCache.connectds--557EN   a E $$  $A'9:M"(:(:g>S>S(S 8%C>%%'>KK BEM'=$> ||6|?? % srBA1'B1 B <BBE E65E,C=<E= D*D% E%D**E?E EE cV^8dQhRR/#)r raw_shardrr)rs"rrr6s   1 rc VP;_uu_4pVPRVPVPVP34RRR4R# +'giR#;i)zd Args: url: of shard package: package name raw_shard: msgpack.zst compressed shard data zCINSERT OR IGNORE INTO SHARDS (url, package, shard) VALUES (?, ?, ?)N)r/r)r r r)rr[r0s&& rinsertShardCache.insertsDYYY! IIU 1 193M3MN YYYs 4A A$ cV^8dQhRR/#)r returnzShardDict | Noner)rs"rrr6s  / rc  .VP;_uu_4pVPRV34P4pV'd8\P!\ P !VR,\R74MRuuRRR4# +'giR#;i)z&SELECT shard FROM shards WHERE url = ?shardmax_output_sizeN)r/r)r*msgpackloads zstandard decompressZSTD_MAX_SHARD_SIZE)rr r0rows&& rretrieveShardCache.retrievesj YYY!))DsfMVVXC  ((G 6I  YYYs A#B B c V^8dQhRRRR/#)r urlsz list[str]r`zdict[str, ShardDict | None]r)rs"rrr6si4Orc  V'g/#\P!4pRRPR\V4,4 R2pVP;_uu_4pVP W14Uu/uFGpVR,V'd3\ P!VPVR,\R74MRbKI ppVuuRRR4#uupi +'giR#;i) zt Query database for cached shard urls. Return a dict of urls in cache mapping to the Shard or None if not present. z,SELECT url, shard FROM shards WHERE url IN (,z) ORDER BY urlr rbrcN)?) rgZstdDecompressorjoinlenr/r)rerfrhri)rrndctxqueryr0rjresults&& rretrieve_multipleShardCache.retrieve_multiples I))+>sxxQTUYQZHZ?[>\\jk YYY!99U1 3 2C E $MMOOCLBUOV  2 3Y3YYs$C -C8C:C C  C c VP;_uu_4pVPR4RRR4R# +'giR#;i)z8 Truncate the database by removing all rows from tables zDELETE FROM shardsN)r/r))rr0s& r clear_cacheShardCache.clear_caches(YYY! II* +YYYs 1 A c VP4VP\, P4R# \dCTP\, P TP\ R2, 4R#i;i)z$ Remove the sharded cache database. z .conda_trashN)rAr5rOunlinkrVrenamer=s&rrUShardCache.remove_cachesd   YY) ) 1 1 3  YY) ) 1 1 /0 ==  s%9A BB)r5r/N)T)TT)rrrr__doc__rr>rErArJr&r]rkrxr{rUr rrrr3r3Ds?$3 'R  2, rr3i)zcache.db)r __future__rloggingr% dataclassesrtypingrrergpathlibrr getLoggerrrSrOrirr&r3rrrrsr #! ! !'   "&PPr