q]u,ddlmZddlmZmZddlmZddlmZm Z m Z m Z m Z ddl mZmZddlmZmZddiZd Zd Zd Zd Zd ZGddZGddZdZej:GddZGddZGdde jZ y))_)binhex)attr)encodingerrormetadatapycompatrevlog)dateutil stringutil) constantsflagutilbranchdefaultc|jddjddjdd}|jddS) aA >>> from .pycompat import bytechr as chr >>> d = {b'nl': chr(10), b'bs': chr(92), b'cr': chr(13), b'nul': chr(0)} >>> s = b"ab%(nl)scd%(bs)s%(bs)sn%(nul)s12ab%(cr)scd%(bs)s%(nl)s" % d >>> s 'ab\ncd\\\\n\x0012ab\rcd\\\n' >>> res = _string_escape(s) >>> s == _string_unescape(res) True \\\ s\n s\r\0)replacetexts 7usr/lib/python3.12/site-packages/mercurial/changelog.py_string_escaper#sB UG$     <<v &&cd|vr6|jdd}|jdd}|jdd}tj|S)Nrrs\\ rrr)rr unescapestrrs r_string_unescaper!7sJ ~||GY/||FE*||E3'  ! !$ ''rctj}|jdD](}|st|jdd\}}|||<*|S)a >>> from .pycompat import bytechr as chr >>> sorted(decodeextra(encodeextra({b'foo': b'bar', b'baz': chr(0) + b'2'}) ... ).items()) [('baz', '\x002'), ('branch', 'default'), ('foo', 'bar')] >>> sorted(decodeextra(encodeextra({b'foo': b'bar', ... b'baz': chr(92) + chr(0) + b'2'}) ... ).items()) [('baz', '\\\x002'), ('branch', 'default'), ('foo', 'bar')] r:r) _defaultextracopysplitr!)rextralkvs r decodeextrar+@sS    E ZZ  #A&,,T15DAqE!H Lrc t|Dcgc]}td|||fz}}dj|Scc}w)Ns%s:%sr)sortedrjoin)dr)itemss r encodeextrar1SsA;A!9 E9a^H1Q4y0 19E E ::e  Fs;cdj|jDcgc]}|jc}jdScc}w)z>strip trailing whitespace and leading and trailing empty linesr)r. splitlinesrstripstrip)descr(s r stripdescr7Ys= ::4??+<=+ D DU KK=sA c`eZdZdZdZdZdZdZedZ dZ ddZ dd Z d Z d Zd Zy )appenderz`the changelog index must be updated last on disk, so we use this class to delay writes to itc||_|||}||_|j|_|j |j |_|j |_yN)datafptelloffsetfstatst_sizesize_end)selfvfsnamemodebufr=s r__init__zappender.__init__bsH t_ggi IIbM)) II rc|jSr;)rCrDs rendz appender.endjs yyrc|jSr;)r?rKs rr>z appender.tellms {{rcyr;rKs rflushzappender.flushps rc.|jjSr;)r=closedrKs rrRzappender.closedssww~~rc8|jjyr;)r=closerKs rrTzappender.closews  rc |dk(r||_n8|dk(r|xj|z c_n|dk(r|j|z|_|j|jkr&|jj |jyy)z,virtual file offset spans real file and datarN)r?rLrBr=seek)rDr?whences rrXz appender.seekzsg Q; DK q[ KK6 !K q[((*v-DK ;; " GGLL % #rc d}|j|jkrN|jj|}|}|xjt |z c_|dkDr|t |z}|dk7r|j|jz }|j j ddj|j |j dd=|j d|||z}|xjt |z c_||z }|S)z5only trick here is reads that span real file and datarrVrN)r?rBr=readlenr<insertr.)rDcountretsdoffs rr[z appender.reads ;; " U#AC KK3q6 !KqyQ A:;;*D II  Q 3 4 !"  ! TD5L1A KK3q6 !K 1HC rc|jjt||xjt |z c_|xj t |z c_yr;)r<appendbytesr?r\rC)rDr`s rwritezappender.writes< q" s1v  SV rc:|jj|Sr;)r= __enter__rKs rrgzappender.__enter__s  rc4|jj|Sr;)r=__exit__)rDargss rrizappender.__exit__stww&&rN)rV))__name__ __module__ __qualname____doc__rIrLr>rPpropertyrRrTrXr[rergrirOrrr9r9^sM  &$ 'rr9c eZdZdZddZdZy) _divertopenerc ||_||_yr;)_opener_target)rDopenertargets rrIz_divertopener.__init__s  rc v||jk7r|j||fi|S|j|dz|fi|S)N.a)rurt)rDrFrG checkambigkwargss r__call__z_divertopener.__call__sB 4<< 4<<d5f5 5t||D5L$9&99rc.t|j|Sr;)getattrrt)rDrs r __getattr__z_divertopener.__getattr__st||T**rNrF)rlrmrnrIr|rrOrrrrrrs: +rrrcdfd }|S)z?build an opener that stores chunks in 'buf' instead of 'target'cF|k7r ||fi|S|rJt||Sr;)r9)rFrGrzr{rHrvrws r_delayz_delayopener.._delays5 6>$// /zdC00rrrO)rvrwrHrs``` r _delayopenerrs1 MrceZdZejZejZejdZejdZejeje Z ejdZ ejdZ ejdZejdZejdZejeddfZy)_changelogrevisionr)default)rVrVNrF)rlrmrnribr'manifestuserdateFactorylistfiles filesadded filesremovedp1copiesp2copies descriptionr$ branchinforOrrrrs DGGIEtwwyH 4773 D 4776 "D DGGLDLL. /E&J4774(Ltwwt$Htwwt$H$''#&K- ":E!BCJrrceZdZdZdZfdZedZedZedZ edZ edZ ed Z ed Z ed Zed Zed ZedZedZedZedZxZS)changelogrevisionzHolds results of a parsed changelog revision. Changelog revisions consist of multiple pieces of data, including the manifest node, user, and date. This object exposes a view into the parsed object. )_offsets_text _sidedata_cpsd_changescx|stt|jStt||}|j d}|j d|dz}|j d|dz}||dz|dzdk(r|} n|j d|dz} |||| f|_||_||_ ||_ d|_ |S)N)r'rrrrW ) rr$nullidsuperr__new__indexrrrrr) clsclrsidedatacpsdrDnl1nl2nl3doublenl __class__s rrzchangelogrevision.__new__s%MBIIN N&4S9jjjja(jja( a#' "e +Hzz'373Hc31  !   rcLt|jd|jdS)NrV)rrrrKs rrzchangelogrevision.manifests!4::a$--"2344rcp|j}tj|j|ddz|dSNrVr)rrtolocalrrDoffs rrzchangelogrevision.user s3mm 3q6A:A ?@@rct|j}|j|ddz|d}|jddddS)NrrW rV)rrr&)rDr dateextras r_rawdatezchangelogrevision._rawdates?mmJJs1vzCF3 tQ'!,,rc|j}|j|ddz|d}|jdd}t|dk7ry|dS)NrrWr)rrr&r\)rDrrfieldss r _rawextrazchangelogrevision._rawextrasPmmJJs1vzCF3 q) v;! ayrc|j}t|d} t|d}||fS#t$rd}Y||fSwxYwr)rfloatint ValueError)rDrawtimetimezones rrzchangelogrevision.datesVmmSV} 3q6{HX~ HX~ s . ??c@|j}|tSt|Sr;)rr$r+)rDrs rr'zchangelogrevision.extra*s!nn ; 3rc\|j |jS|jr tj|j}n`tj |j xsd|jxsd|jxsd|jxsi|jxsi}||_|S)NrO)touchedaddedremoved p1_copies p2_copies) rrr decode_files_sidedatar ChangingFilesrrrrr)rDchangess rrzchangelogrevision.changes2s == $== ::44T^^DG,, (boo+))/R---2---2 G  rc|jrt|jjS|j}|d|dk(rgS|j |ddz|dj dS)NrWrrr)rr-rrrrr&rs rrzchangelogrevision.filesCsd ::$,,../ /mm q6SV Izz#a&1*s1v.44U;;rc|jr|jjS|jj d}|yt j |j|S)Ns filesadded)rrrr'getr decodefileindicesrrD rawindicess rrzchangelogrevision.filesaddedMsK ::<<%% % 6J  ))$**jAArc|jr|jjS|jj d}|yt j |j|S)Ns filesremoved)rrrr'rr rrrs rrzchangelogrevision.filesremovedWsK ::<<'' '8J  ))$**jAArc|jr|jjS|jj d}|yt j |j|S)Nsp1copies)rrcopied_from_p1r'rr decodecopiesrrD rawcopiess rrzchangelogrevision.p1copiesaK ::<<.. . {3I  $$TZZ;;rc|jr|jjS|jj d}|yt j |j|S)Nsp2copies)rrcopied_from_p2r'rr rrrs rrzchangelogrevision.p2copieskrrcftj|j|jddzdS)NrrW)rrrrrKs rrzchangelogrevision.descriptionus- 4==+;a+?+A BCCrcj|j}tj|jdd|vfS)Nrsclose)r'rrr)rDr's rrzchangelogrevision.branchinfoys/  ) 45x57HHHr)rlrmrnro __slots__rrprrrrrr'rrrrrrrr __classcell__rs@rrrs7I$L55AA--      <<BBBB<<<<DDIIrrceZdZddZedZej dZfdZdZdZ dZ ddZ d Z d Z d Z dd Zd ZdZxZS) changelogc tjj||tjdfddd|jj dd|| |j rH|jtjk(r+|xjtjzc_ d|_ d|_ ||_ d|_d|_d|_t#|_i|_|jj d|_y)aVLoad a changelog revlog using an opener. If ``trypending`` is true, we attempt to load the index from a ``00changelog.i.a`` file instead of the default ``00changelog.i``. The ``00changelog.i.a`` file contains index (and possibly inline revision) data for a transaction that hasn't been finalized yet. It exists in a separate file to facilitate readers (such as hooks processes) accessing data before a transaction is finalized. ``concurrencychecker`` will be passed to the revlog init function, see the documentation there. Ns 00changelogTspersistent-nodemapF)rwradixrzmmaplargeindexpersistentnodemapconcurrencychecker trypendingscopies-storage)r rIrevlog_constantsKIND_CHANGELOGoptionsr _initempty_format_versionREVLOGV1 _format_flagsFLAG_GENERALDELTA _generaldelta_storedeltachains _realopener_delayed _delaybuf_divert frozenset _filteredrevs_filteredrevs_hashcache_copiesstorage)rDrvrrs rrIzchangelog.__init__s    $33T: $nn001FN1!   ?? 4 4 G   6#;#;"; ; !&D  "'!  &[')$$nn001BCrc|jSr;)rrKs r filteredrevszchangelog.filteredrevss!!!rcDt|tsJ||_i|_yr;) isinstancerrr)rDvals rrzchangelog.filteredrevss$#y))) ')$rcF|jstt||yyr;)rrr _write_docket)rDtrrs rrzchangelog._write_dockets}} )T 0 4rc|j|jst|dk(r}d|_|jj |j dzr(|jj|j dzt|j|j |_ n7g|_ t|j|j |j|_ |j|j_ |j|j_ d|_|jdt|z|j |j#dt|z|j$y)z2delay visibility of index updates to other readersNrVTryscl-%i)_docketrr\rrexists _indexfileunlinkrrrvrr _segmentfile_segmentfile_sidedata addpendingid _writepending addfinalize _finalize)rDrs r delayupdatezchangelog.delayupdates <<  4yA~# ##**4??U+BC$$++DOOe,CD+D,<, x"T(*DNN;rcd|_|j|_|j|j_|j|j_|j |j |n|jrq|jrJ|jdz}|jj|}|j|jj||jdnk|jr_|j|jdd}|jdj|j|jd|_d|_|j|dy) zfinalize index updatesFNryT)rzar side_write)rrrvrrrrrrropenrTrenamerer._enforceinlinesize)rDrtmpnamenfiler=s rr zchangelog._finalizes && #';; ,0KK"") << #   r " \\~~ %%oo-GKK$$W-E KKM KK  wD  I ^^T__dtDB HHSXXdnn- . HHJ!DN  u5rc|jr|jj|dS|jr|j|j}|jdz}|j ||j|d}|j|j |jdj|j|jd|_d|_ t|j|j|_ |j|j_ |j|j_ |jryy)zLcreate a file containing the unfinalized state for pretxnchangegroupT)pendingrywrNF)rrerrr registertmpr[r.rTrrrrvrr)rDrfp1pendingfilenamefp2s rr zchangelog._writependings <<<<%%b$%7 7 >>""4??3C"oo5O NN? +""?D9C IIchhj ! IIchht~~. / IIK!DNDL'(8(8$//JDK'+{{D   $04 D & & - <<rcb|js#tjj|||yy)Nr)rr r)rDrrs rrzchangelog._enforceinlinesizes'}} MM , ,T2* , Mrc|j|}|j|}|jdk(}t||||}|j|j |j |j|j|jfS)aObtain data from a parsed changelog revision. Returns a 6-tuple of: - manifest node in binary - author/user as a localstr - date as a 2-tuple of (time, timezone) - list of files - commit message as a localstr - dict of extra metadata Unless you need to access all fields, consider calling ``changelogrevision`` instead, as it is faster for partial object access. changeset-sidedata) _revisiondatarrrrrrrrr')rD nodeorrevr/rcopy_sdcs rr[zchangelog.readsn   y )==+%%)>> dAx 9 AFFAFFAGGQ]]AGGLLrc||j|}|j|}t||||jdk(S)z6Obtain a ``changelogrevision`` for a node or revision.r )r!rrr)rDr"rrs rrzchangelog.changelogrevisionsB!!),==+ $$"5"59N"N  rc|j|}|sgS|jd}|d|jd}|ddS)zX short version of read that only returns the files modified by the cset rNrr)revisionrr&)rDr"rlastr(s r readfileszchangelog.readfiles%sI}}Y'Izz'" $K  e $u rc tj|tj|}}|j}|stjt dd|vr4tjt dt j|zt|}|rdtj|z} ndtjz} | r>| jd} | dvr| d=n%| dvr!tjt d| zt|j} d } d}|jd k(r4|j r| t"j$z} t'j(|}| rt+| } d | | fz} t-||| g| zd |gz}dj/|}|j1||t3||||| }|j5|S)Nsempty usernamersusername %r contains a newlines%d %dr)rr).snullstipsthe name '%s' is reservedrVr s%s %sr)rflags)r fromlocalr5r StorageErrorrr bytestrr7r parsedatemakedaterr-rrhas_copies_inforREVIDX_HASCOPIESINFOr encode_files_sidedatar1rr. addrevisionr\node)rDrrr6 transactionp1p2rrr' parseddatebranch sortedfilesr,rr(rrevs raddz changelog.add0s''-x/A/A$/Gdzz|$$Q'8%9: : D=$$34x7G7G7MM  !H$6$6t$<U]]+    "7 7$$66655errCrrs@rrrsz*DX""** 5<&60:NM,  (:x6rrN)!i18nrr6rr thirdpartyrrrr r r utilsr r revlogutilsrrrr$rr!r+r1r7r9rrrr`rrrrOrrrJs J' '((& L C'C'L + +  D D D mImI`y yr