8 ddlZddlmZddlmZddlmZddlmZm Z m Z m Z ddl mZe jZdZd Zd Zd Zd Zd ddegZej,GddZddddddZdddddddddddddddddddddddddddddddddddddddiddidZeded<d iiZhd!Zd"Zeeed#Zd$Zd,d%Zd&Z d'Z! d-d(Z"Gd)d*Z#d+Z$y).N)cast)_)attr)error requirementssslutilutil) stringutils bundle-cachesclonebundles.manifestspeer-bundle-cache://cT|jjt}|jDcgc]}|j dd}}g}|D]@}t ||d}t |dk(r|dz}n d||dfz}|j|Bdj|Scc}w)z>get the bundle manifest to be served to a client from a server rr s%s %s ) vfstryreadCB_MANIFEST_FILE splitlinessplitalter_bundle_urllenappendjoin)reporaw_texteentries new_linesurllines :usr/lib/python3.12/site-packages/mercurial/bundlecaches.py get_manifestr!sxx 01H)1)<)<)>?)>AqwwtQ)>G?I tQqT* q6Q;;Dad +D  88I @sB%c|S)za function that exist to help extension and hosting to alter the url This will typically be used to inject authentication information in the url of cached bundles.)rrs r rr/s Jrshttp://shttps://s largefile://ceZdZejZejZejZejZejZ ejZ e dZ e dZ ddZdZy) bundlespeccVtj|j|jSN) collectionsChainMap_explicit_params _default_optsselfs r paramszbundlespec.paramsLs!##D$9$94;M;MNNrc|jSr')r.r,s r contentoptszbundlespec.contentoptsPs{{rcD|s||jvr||j|<yy)zOSet a bundle parameter value. Will only overwrite if overwrite is trueN)r*)r-keyvalue overwrites r set_paramzbundlespec.set_paramUs) 4#8#88).D ! !# &9rcd|j|jfzg}t|jj D]}|j d|zdj |S)Ns%s-%ss%s=%s;) compressionversionsortedr*itemsrr)r-partsparams r as_speczbundlespec.as_spec\s\T--t||<<=D11779:E LLE) *;yyrNT)__name__ __module__ __qualname__ribr8wirecompressionr9 wireversionr*r+propertyr.r0r5r>r#rr r%r%?s$'')KdggiOdggiG$'')KtwwyDGGIM OO/ rr%s0102s03s1)v1v2v3packed1bundle2TF) changegroup cg.version obsolescencephasestagsfnodescacherevbranchcache)rNrOrPrQstreamv2rRrS)rNrOrPrQ streamv3-exprRrSrO)rIrJrKrTrUrLrMrJrMrT>gzipnonebzip2ctj|}|'td}|||fz}tj||S)z'make a boolean out of a parameter values'parameter %s should be a boolean ('%s'))r parseboolrrInvalidBundleSpecification)r2r3bmsgs r param_boolr^sFU#Ay:; U|..s33 Hr)rPsobsolescence-mandatoryrQcd|vr|ifSi}|jdd\}}td}|jdD]}d|vr||z}tj||jdd\}}tj |}tj |}t j|} | | ||}|||<||fS)z~parse bundlespec parameter section input: "comp-version;params" string return: (spec; {param_key: param_value}) r7rs:invalid bundle specification: missing "=" in parameter: %s=)rrrr[urlrequnquotebundle_spec_param_processingget) sr.r9paramstrerrpr]r2r3processs r _parseparamsrjs 1}"u Fa(GX I JC ^^D ! q='C2237 7WWT1% UnnS!u%.2237  C'Es " F?rc|r%d|vr!tjtd|z|jddd}d|vr|jdd\}}|tj j vr!tjtd|zt|\}}|tvrtjtd|z|rJt|\}}|tj j vrL|}d}tj|jvrd }ntj|jvrd }|tvr9d }n6|tvr |d k(rd }nd }|}n!tjtd |z|dk(r)|tvr!tjtd|z|d k(r}d|vrytt!t"|djd}|tj$z }|r9tjtddj't)|zd|vr|dd k(rd}|ddk(rd}tj+|ij-} |dk(s|dk(rd }tj j/|} | j1\}} t|d} t3|| || || S)aParse a bundle string specification into parts. Bundle specifications denote a well-defined bundle/exchange format. The content of a given specification should not change over time in order to ensure that bundles produced by a newer version of Mercurial are readable from an older version. The string currently has the form: -[;[;]] Where is one of the supported compression formats and is (currently) a version string. A ";" can follow the type and all text afterwards is interpreted as URI encoded, ";" delimited key=value pairs. If ``strict`` is True (the default) is required. Otherwise, it is optional. Returns a bundlespec object of (compression, version, parameters). Compression will be ``None`` if not in strict mode and a compression isn't defined. An ``InvalidBundleSpecification`` is raised when the specification is not syntactically well formed. An ``UnsupportedBundleSpecification`` is raised when the compression or bundle type/version is not recognized. Note: this function will likely eventually return a more complex data structure, including bundle2 part information. -sCinvalid bundle specification; must be prefixed with compression: %sr7rrs%s compression is not supporteds%%s is not a recognized bundle versionrIrJrLrWrXs+%s is not a recognized bundle specifications4compression engine %s is not supported on v1 bundless requirements,s+missing support for repository features: %ss, sstreamrTsv3-exprUrO)rr[rrr compenginessupportedbundlenamesUnsupportedBundleSpecificationrj_bundlespeccontentoptsrequirementsmodGENERALDELTA_REQUIREMENTrREVLOGV2_REQUIREMENT_bundlespecv1compenginessetrbytesSTREAM_FIXED_REQUIREMENTSrr:rdcopy forbundlename bundletyper%) rspecstrictpre_argsr8r9r.r missingreqsr0enginerDrEs r parsebundlespecrsB$d".. 9     zz$"1%H x#zz$2 W d..CC C6645 C 'w/ 0 066:;gE  z#D) f 4##88 8KG774;L;LL 559J9JJ":: + +z!% & G66@ADH  %K/GG22 E F   *F!:4vo'>?EEdKL "_%N%NN 66@A**VK012  F )  %!G )  )%G(,,Wb9>>@K+O!;    + +K 8F#)#4#4#6 K(1-@K _g{FK rc g}|jD]}|j}|sd|di}|ddD]}|jdd\}}tjj |}tjj |}|||<|dk(sa t ||} | j |d<| j|d<|j||S#tj$rYtj$rYwxYw) zParses the raw text of a clone bundles manifest. Returns a list of dicts. The dicts have a ``URL`` key corresponding to the URL and other keys are the attributes for the entry. URLrrNr` BUNDLESPECs COMPRESSIONsVERSION) rrr rarbrr8r9rr[rpr) rremrfieldsattrsrawattrr2r3r%s r parseclonebundlesmanifestrZs A  #abzG tQ/JC++%%c*CKK''.EE#J m#!0u!=J,6,B,BE.)(2(:(:E*%"& 14 H77;;s*CD-DDc|jdk(r|jdk(ry|jdk(rF|jdk(r7|jjds|jjdryy)NsUNrHTrGrTrUF)rDrEr0rd)r%s r isstreamclonespecr~sn!!U*z/E/E/N ""e+  " "e +  " " & &{ 3%%))/: rc g}|D]w}|jd}|sKttDcgc]}|j|c}s|jj d|zb|jd}|r< t ||d} |r*t| s|jj d|zn!|r|jj d |zd |vr0tjs |jj d |zd |vr] tj |d } |jj%} | (| dz| kr |jj d|zg|j'|z|Scc}w#tj$r<} |jj tj| dzYd} ~ d} ~ wtj$r>} |jj d |tj| fzYd} ~ d} ~ wwxYw#tj"$r"|jj d|zYWwxYw)auRemove incompatible clone bundle manifest entries. Accepts a list of entries parsed with ``parseclonebundlesmanifest`` and returns a new list consisting of only the entries that this client should be able to apply. There is no guarantee we'll be able to apply all returned entries because the metadata we use to filter on may be missing or wrong. rs8filtering %s because not a supported clonebundle scheme rT)r}s(filtering %s because not a stream clone rNs1filtering %s because unsupported bundle spec: %s s?filtering %s because cannot determine if a stream clone bundle s REQUIRESNIs'filtering %s because SNI not supported s REQUIREDRAMs0filtering %s due to a bad REQUIREDRAM attribute gQ?s8filtering %s as it needs more than 2/3 of system memory )rdanySUPPORTED_CLONEBUNDLE_SCHEMES startswithuidebugrrrr[r forcebytestrrpr hassnir sizetoint ParseErrorestimatememoryr) rrstreamclonerequested pullbundles newentriesentryrschemer|r%r requiredram actualrams r filterclonebundleentriesrs<Jii32O P2OS^^F #2O P$  GGMML  yy'  ,T4E (0A*0MGGMMDsJ" GGMM"$'(   E !'.. GGMMEK L  U " "nnU>-BC ..0I$T)9K)G P% }@ { Q*33  j55a85@A77  "%(**A*A!*D$EF  ,##  H3N  s;F ;9FH(H%1GH%'3H  H%(1IIc@eZdZdZdZdZdZdZdZdZ dZ d Z y ) clonebundleentryzRepresents an item in a clone bundles manifest. This rich class is needed to support sorting since sorted() in Python 3 doesn't support ``cmp`` and our comparison is complex enough that ``key=`` won't work. c ||_||_yr')r3prefers)r-r3rs r __init__zclonebundleentry.__init__s  rc|jD]j\}}|jj|}|jj|}| |||k(ry| |||k(ry||W||k(r]||k(ry||k(ryly)Nrr)rr3rd)r-otherprefkey prefvalueavaluebvalues r _cmpzclonebundleentry._cmps"&,, GYZZ^^G,F[[__W-F!fn99L!fn99L~"" 7#/>rc*|j|dkSNrrr-rs r __lt__zclonebundleentry.__lt__yy!##rc*|j|dkDSrrrs r __gt__zclonebundleentry.__gt__rrc*|j|dk(Srrrs r __eq__zclonebundleentry.__eq__yy1$$rc*|j|dkSrrrs r __le__zclonebundleentry.__le__rrc*|j|dk\Srrrs r __ge__zclonebundleentry.__ge__rrc*|j|dk7Srrrs r __ne__zclonebundleentry.__ne__rrN) r@rArB__doc__rrrrrrrrr#rr rrs0 D$$%%%%rrc|jdds t|Sd}Dcgc] }|| c}tfd|D}|Dcgc]}|jc}Scc}wcc}w)Nsuisclonebundlepreferscd|vr.td}tjtd|z||jddS)Nr`s3each comma separated item should be key=value pairss&invalid ui.clonebundleprefers item: %s)hintr)rrAbortr)rhrs r _splitz&sortclonebundleentries.._split'sH q=KLD++;z)sortclonebundleentries..1sAA#Aw/s) configlistlistr:r3)rrrrhr;irs @r sortclonebundleentriesr"ssmmE#89G G} #**'Qvay'*G AA AE" #UAGGU ##+ $s A(A-r?)FF)%r(typingri18nr thirdpartyrrrrrr r utilsr raBUNDLE_CACHE_DIRrCLONEBUNDLESCHEMEr!rrrer%_bundlespeccgversionsrq_bundlespecvariantsrur^rcrjrrrrrrr#rr rs   "++   !     J    !        ! !  u u]1d&%>%B$r