6 @ddlZddlZddlmZddlmZmZmZddlm Z m Z m Z ddl m Z ddlmZddlmZej&ej(Zd Zd Zej0d Zd Zd ZdZdZdZdZddZ dZ!dZ"ddddde jFddddf dZ$dZ%y)N)_)binnullrevsha1nodeconstants)dagoperrormdiff) repository)sidedata)hashutilc|tjk(r&tj}|j |n4||kr|}|}n|}|}t j |}|j ||j ||jS)zCompute the SHA-1 for revision data and its parents. This hash combines both the current file contents and its history in a manner that makes it easy to distinguish nodes with the same content in the revision graph. )rnullid _nullhashcopyupdater sha1digest)textp1p2sabs ?usr/lib/python3.12/site-packages/mercurial/utils/storageutil.pyhashrevisionsha1r"sw  % %% NN    7AAAA MM!   HHTN 88: c|dddk7rytj|dj}|d|}i}|jD]}|j dd\}}|||<||dzfS)zParse metadata header from revision data. Returns a 2-tuple of (metadata, offset), where both can be None if there is no metadata. Nrr)NNs: r) METADATA_REsearchstart splitlinessplit)rrmtextmetalkvs r parsemetar+?s BQx94#))+A 1IE D    wwua 1Q  Q;rc\t}djfd|D}d||fzS)z2Add metadata to fulltext to produce revision text.rc32K|]}d||fzyw)s%s: %s N).0r)r's r zpackmeta..TsADq q$q'l2Dss %s %s)sortedjoin)r'rkeysmetatexts` rpackmetar5Qs0 $r iscensoredrevrenamedread)r@rAfiledata revisiontextrr computednodes rfiledataequivalentrKs9%&1  ]]4 FB#L"b9Lt  $(3 }}Tzz$8++ rcPd}|||kDrd}||z }||kDr|}n|}t|||S)z)Iterate over revision numbers in a store.r)range)storelenr#stopsteps riterrevsrRsB D  4<D   (?D d ##rct|tr |j|St|t|jk(r |j||St|dt|jzk(r t|}|j||S t|}d|z|k7rt |j|S#t$r$t j d|z|t dwxYw#tj $rYwxYw#t$rYwxYw#ttf$rYnwxYwn#ttf$rYnwxYwt j ||t d)aResolve the file node for a value. ``store`` is an object implementing the ``ifileindex`` interface. ``fileid`` can be: * A binary node of appropiate size (e.g. 20/32 Bytes). * An integer revision number * A hex node of appropiate size (e.g. 40/64 Bytes). * A bytes that can be parsed as an integer representing a revision number. ``identifier`` is used to populate ``error.LookupError`` with an identifier for the store. Raises ``error.LookupError`` on failure. s%dsno match foundr) isinstanceintrA IndexErrorr LookupErrorrlenrrEr TypeError ValueError OverflowError)r@fileid identifierrawnoderEs r fileidlookupr_sm"&# ::f% %  6{c%,,''  IIf M 6{a#ell+++ &kG IIg N  &k 3;&   ::c? "7 ## A.?,@          I&      &      FJ2C0D EEs_CC7=DD56D-C47D  D  DDD1.D50D11D55EEct}|dz}i}t}|D]&} || } | || <| |k\s|j| (|r||dz}|j|} | |kr|j|n|j| ||D]0} | tk7s || } | || <| |k\s |j| 2|r|||fS)aResolve information needed to strip revisions. Finds the minimum revision number that must be stripped in order to strip ``minlinkrev``. Returns a 2-tuple of the minimum revision number to do that and a set of all revision numbers that have linkrevs that would be broken by that strip. ``tiprev`` is the current tip-most revision. It is ``len(store) - 1``. ``headrevs`` is an iterable of head revisions. ``linkrevfn`` is a callable that receives a revision and returns a linked revision. ``parentrevsfn`` is a callable that receives a revision number and returns an iterable of its parent revision numbers. r)setaddpopremover) minlinkrevtiprevheadrevs linkrevfn parentrevsfn brokenrevs strippointheadsfuturelargelinkrevshead headlinkrevlinkrevpplinkrevs rresolvestripinforss"J!J E%o !d * $  # #K 0  a ))J' Z  NN: &  & &w /j)AG|$Q<#az)'++H5 *  z !!rFc #T %&'(K|j}|j'|j(|dk(r|Dcgc] }'| }}nO|dk(r6|Dchc] }'| }}tj||j}nt 'fd|D}d}| t jk(s| r(|dd}t&t%| r8t(fd|D}|j||j|d%%&fd }|D]0}|tk(rd}| | d xxd z cc<||}(|\}}| $||k7r|tk7r|tk7r | d xxd z cc<|r/||}| +|tk(r| d xxd z cc<n| dxxd z cc<nt}| t jk(r| d}|}n| t jk(r | d}t}n| t jk(r| d}|}ni||r| d}|}nZ|tk(r| d}|}nJ|tk7r| | dxxd z cc<n1||r| d}|}n"||r| d}|}n|| d}|}n | d}t}tk7r"| |||s| d}| dxxd z cc<t}d}d}d}| r|j|s|j|rD |j|}|tk7r|r ||}nt'|j|}n|tk(rS| t jk7r@| | dxxd z cc<| dxxd z cc<|j|}&j)|nV|r| z|dk(r| dxxd z cc<| dxxd z cc<nZ|dk(r| dxxd z cc<| dxxd z cc<n:|dk(r| dxxd z cc<| dxxd z cc<n|dk(r| dxxd z cc<nJd|||}n| |dk(r| dxxd z cc<| dxxd z cc<ng|dk(r| dxxd z cc<| dxxd z cc<nG|dk(r| dxxd z cc<| dxxd z cc<n'|dk(r| dxxd z cc<| dxxd z cc<nJdt+j,|j||j|}&j)|d}d} | rE |j/|}!t1j2|| |!|\}"} |"rt1j4|"}|r||nd}#d}$|r|$t6z}$|#| d| d zz}#|||||||||#|||||$ |}3ycc}wcc}w#t j"$r(}| d}| dxxd z cc<|j$}Yd}~d}~wwxYw#t j"$ri}"YwxYww) a Generic implementation of ifiledata.emitrevisions(). Emitting revision data is subtly complex. This function attempts to encapsulate all the logic for doing so in a backend-agnostic way. ``store`` Object conforming to ``ifilestorage`` interface. ``nodes`` List of revision nodes whose data to emit. ``resultcls`` A type implementing the ``irevisiondelta`` interface that will be constructed and returned. ``deltaparentfn`` (optional) Callable receiving a revision number and returning the revision number of a revision that the internal delta is stored against. This delta will be preferred over computing a new arbitrary delta. If not defined, a delta will always be computed from raw revision data. ``candeltafn`` (optional) Callable receiving a pair of revision numbers that returns a bool indicating whether a delta between them can be produced. If not defined, it is assumed that any two revisions can delta with each other. ``rawsizefn`` (optional) Callable receiving a revision number and returning the length of the ``store.rawdata(rev)``. If not defined, ``len(store.rawdata(rev))`` will be called. ``revdifffn`` (optional) Callable receiving a pair of revision numbers that returns a delta between them. If not defined, a delta will be computed by invoking mdiff code on ``store.revision()`` results. Defining this function allows a precomputed or stored delta to be used without having to compute on. ``flagsfn`` (optional) Callable receiving a revision number and returns the integer flags value for it. If not defined, flags value will be 0. ``deltamode`` constaint on delta to be sent: * CG_DELTAMODE_STD - normal mode, try to reuse storage deltas, * CG_DELTAMODE_PREV - only delta against "prev", * CG_DELTAMODE_FULL - only issue full snapshot. Whether to send fulltext revisions instead of deltas, if allowed. ``nodesorder`` ``revisiondata`` ``assumehaveparentrevisions`` ``sidedata_helpers`` (optional) If not None, means that sidedata should be included. See `revlogutil.sidedata.get_sidedata_helpers`. ``debug_info` An optionnal dictionnary to gather information about the bundling process (if present, see config: debug.bundling.stats. snodesslinearc3.K|] }|ywNr.)r/nfrevs rr0z emitrevisions..s-u!d1gusNrc3<K|]}|D]}|ywrvr.)r/rrqr>s rr0z emitrevisions..s?dGAJq1J1dsT) inclusivec,|tk(ry|vxs|vS)z5Is a delta against this revision usable over the wireF)r)rE availableemitteds ris_usable_basez%emitrevisions..is_usable_bases! '>g~1 !11rzrevision-totalrz merge-totalzavailable-fullzavailable-deltaprevfullrstoragezdenied-base-not-availablerzdenied-delta-candeltafnzdenied-delta-not-availablezcomputed-deltaz delta-fullzdelta-against-prevzdelta-against-p1zreused-storage-delta unreachable)rr)r@sidedata_helpersr rE) rAp1nodep2nodebasenodeflagsbaserevisionsizer?deltar protocol_flags)rArE parentrevsr linearizer1r CG_DELTAMODE_PREVradifference_update ancestorsrCG_DELTAMODE_FULLCG_DELTAMODE_P1rDrawdatar CensoredNodeError tombstonerXrbr textdiffr sidedatamodrun_sidedata_helpersserialize_sidedataCG_FLAG_SIDEDATA))r@nodes nodesorder resultcls deltaparentfn candeltafn rawsizefn revdifffnflagsfn deltamode revisiondataassumehaveparentrevisionsr debug_infofnoderwrevsprevrev common_headsrrEdebug_delta_sourcerAp1revp2revdeltaparentrevbaserevr?rreserialized_sidedatasidedata_flags old_sidedatar rrr}r~rxr>s) @@@@r emitrevisionsr&sl JJE 99DGX!&'AQ' y !&'AQ'tU%5%56-u--GJ0004M$q'"1%eGI ?d?? &&t,OOLDOA 2  '> !  ! ' (A - (Szs| u  !~%7"2u7G=)Q.) *3/N%!W,/0A5001Q61%N  44 4%%+"G*66 6%%+"G *44 4%%)"G N +%%."$G w &%%."$G(Z-C671<7 &))-&&))-&$))/&!))/&! w &w,%%+"45:5G (E,<,!C>7-75%gs3E!--7&'78A=8&|494/69&'78A=8&';<A</47&'78A=8&'9:a?:/9<&'78A=8&'=>!C>7-75!NN g. c0BE C "  $~~c2 ,7+K+K%5) ,(. &1&D&DX&N# ' Q  . .NN1-1B0BBBE<<7^-()  _5('F..+!--3*"#?@AE@ {{H +D**  sm.V(U V(U IV(1UG*V(-V >BV(V "V?V(V  V( V%"V($V%%V(ctjd}t||kry||}t||z }|d|tj||k7ryd}t|}||k\xr ||||z|k(S)aRDetermine if a delta represents censored revision data. ``baserev`` is the base revision this delta is encoded against. ``baselenfn`` is a callable receiving a revision number that resolves the length of the revision fulltext. Returns a bool indicating if the result of the delta represents a censored revision. s>lllFNs  censored:)structcalcsizerXr replacediffheader)rr baselenfnhlenoldlennewlenrbaddlens rdeltaiscensoredrms ??7 #D 5zT w F Z$ F Ud|u..vv>> C XF V  BdTF] ;s BBr)rN)&reri18nrrArrrrr r interfacesr revlogutilsr rutilsr rrrrrcompiler!r+r5r7r<rBrKrRr_rsCG_DELTAMODE_STDrrr.rrrs   $1 HMM+22 3 4bjj# $2( 6"J $ 5Fp1"r ))#DN Cr