>FddlmZddlmZmZmZmZddlmZm Z m Z m Z m Z mZmZddlmZmZddlmZddlmZmZmZej4ZGdd ZGd d ZGd d eZ GddeZej>ej@GddeZ!y))_)binhexnullrevsha1nodeconstants)ancestor changelogdagopencodingerrormanifestpycompat) repositoryutil) stringutil)gitutilindexr c.eZdZdZdZdZdZdZdZy)baselogz9Common implementations between changelog and manifestlog.c ||_||_yN)gitrepo_db)selfgrdbs 4usr/lib/python3.12/site-packages/hgext/git/gitlog.py__init__zbaselog.__init__#s clt|jjdjdS)NzSELECT COUNT(*) FROM changelogr)intrexecutefetchoners r__len__zbaselog.__len__'s0 HH  = > G G I! L  r c|tjk(ry|jjdt j |fj }| tj|dtd|dS)Nz(SELECT rev FROM changelog WHERE node = ? 00changelog.is no node %dr) rnullidrr#r togitnoder$r LookupErrorrrnts rrevz baselog.rev,sp !(( ( HH   69J9J19M8O (*  9##A'7=9IJ Jt r c|tk(rtjS|jj d|fj }| t j|dtdt|dS)Nz(SELECT node FROM changelog WHERE rev = ?r)sno noder) rrr*rr#r$r r,rr)rrr/s rnodez baselog.node6si <$++ + HH   6 (*  9##A'7:G G1Q4yr c|jjdtj|fj }|duS)Nz)SELECT node FROM changelog WHERE node = ?)rr#rsysstrr$r-s rhasnodezbaselog.hasnode@s@ HH   7 __Q  !  (* }r N) __name__ __module__ __qualname____doc__rr&r0r3r6r rrr sC r rc$eZdZdZdZdZdZy) baselogindexc||_yr)_log)rlogs rrzbaselogindex.__init__Is  r c>|jj|dk7SNr()r?r0)rr.s rhas_nodezbaselogindex.has_nodeLsyy}}Q2%%r c,t|jSr)lenr?r%s rr&zbaselogindex.__len__Os499~r c |jj|\}}|||d||||jj|fSrB)r? parentrevsr3)ridxp1revp2revs r __getitem__zbaselogindex.__getitem__RsKyy++C0 u        IINN3   r N)r7r8r9rrCr&rKr;r rr=r=Hs& r r=ceZdZdZdZdZedZedZedZ dZ dd Z d Z d Z d Zdd Zd dZdZd!dZdZd dZd"dZd"dZdZd#dZdZdZdZeZdZdZdZ d$dZ y)%r sextracZ |j|y#tj$rYywxYw)NTF)r3r r,rr0s r __contains__zchangelog.__contains__ks-  IIcN    s **c<ttt|Sr)iterrangerEr%s r__iter__zchangelog.__iter__rsE#d)$%%r ctSr)setr%s r filteredrevszchangelog.filteredrevsus u r ct|Sr)r=r%s rrzchangelog.index{s D!!r c|jjdDcic]}t|d|d}}t|tj <|Scc}w)NzSELECT node, rev FROM changelogrr)rr#rrrr*)rvr2s rnodemapzchangelog.nodemapsaXX%%&GH H !IqtOH  '.  " "#  sAc|jjdj}|rt|dStj S)Nz4SELECT node FROM changelog ORDER BY rev DESC LIMIT 1r)rr#r$rrr*rr/s rtipz changelog.tipsB HH   B (*  qt9  '''r Nct||j}|jjd||f}d|DS)NzFSELECT rev FROM changelog WHERE rev >= ? AND rev <= ? ORDER BY REV ASCc38K|]}t|dywrN)r").0r2s r z!changelog.revs..s%1aAaD 1s)tiprevrr#)rstartstopr/s rrevszchangelog.revssA <;;=D HH   DM   &1%%r cd|jjdj}||dSy)Nz3SELECT rev FROM changelog ORDER BY REV DESC LIMIT 1rr()rr#r$r\s rrczchangelog.tiprevs6 HH   G (*  =Q4Kr ctjj|rtj|j j dtj|dzfDcgc]}t|d}}tjj|r|jtjt|dkDr tj|dtd|r|dSycc}w)Nz,SELECT node FROM changelog WHERE node LIKE ?%rrr)sambiguous identifier)rwdirhex startswithr WdirUnsupportedrr#rr5rnullhexappendr*rEAmbiguousPrefixLookupErrorr)ridx candidatess r _partialmatchzchangelog._partialmatchs  $ $ / / 3'' 'XX%%>d+-  !I    $ $ / / 3   /66 7 z?Q 22$a(?&@  a=  s%C0cy)Nrr;rNs rflagszchangelog.flagssr c  t|}t|t|dzD]]}|d|}t|jj dt j|dzfjd}|dk(s[|cS|S)Nrz0SELECT COUNT(*) FROM changelog WHERE node LIKE ?rir) rrRrEr"rr#rr5r$)rr3 minlengthnodehexattempt candidatematchess rshortestzchangelog.shortestsd)YG q(89G)I  F__Y%568(*Q G !|  :r c|jjdDcgc]}t|d}}|rt|Dcgc] }||vs| c}St|Scc}wcc}w)NzISELECT rev FROM changelog INNER JOIN heads ON changelog.node = heads.noder)rr#r"sorted)rrfrq realheadsr2s rheadrevszchangelog.headrevssXX%%B  !I   d=da9n1d=> >i   >sA  A% A%c jt|tr|j|}n|}ddi}|tjk(r%t j |tjStj|}|jjd|tjfDcgc]}|d }}|jjd|tjfDcgc]}|d }}|j|}t j |d|jjjd|jj jdfz|jj"|jj$ d zf|||j&jd| Scc}wcc}w) Nsbranchdefault)extrar zBSELECT filename FROM changedfiles WHERE node = ? and filenode != ?rzASELECT filename FROM changedfiles WHERE node = ? and filenode = ?s%s <%s>utf8<)r userdatefiles filesremoved descriptionr) isinstancer"r3rr* hgchangelog_changelogrevisionrr+rr#nullgitrauthornameencodeemailtimeoffsetmessage) r nodeorrevr.rhnr2rrcs rchangelogrevisionzchangelog.changelogrevisions i % )$AAJ' !(( (11&7&>&>   q !XX%%3W__%  aD  XX%%2W__%  aD   LL --xx}}##F+QXX^^-B-B6-JKL((--!((//!1B!67% ((0  #  s $ F+ F0ct|}|j|j}|D]}||kDs td|zt j |j |||S)NsInvalid rev %r)stoprev inclusive)listr0r] IndexErrorr lazyancestorsrG)rrfrrr]r2s r ancestorszchangelog.ancestorsscDzhhtxxz"A3w !2Q!677%% OOT7i  r cXtj||j|jSr)r descendantrevsrfrG)rrfs r descendantszchangelog.descendants s##D$))T__EEr cT|tg}tj|j|S)aOReturn an object that can be used to incrementally compute the revision numbers of the ancestors of arbitrary sets that are not ancestors of common. This is an ancestor.incrementalmissingancestors object. 'common' is a list of revision numbers. If common is not supplied, uses nullrev. )rrincrementalmissingancestorsrG)rcommons rincrementalmissingrevsz changelog.incrementalmissingrevss' >YF33DOOVLLr c~|tg}||j}|j|}|j|S)axReturn the revision numbers of the ancestors of heads that are not ancestors of common. More specifically, return a list of revision numbers corresponding to nodes N such that every N satisfies the following constraints: 1. N is an ancestor of some node in 'heads' 2. N is not an ancestor of any node in 'common' The list is sorted by revision number, meaning it is topologically sorted. 'heads' and 'common' are both lists of revision numbers. If heads is not supplied, uses all of the revlog's heads. If common is not supplied, uses nullid.r)rrrmissingancestors)rrheadsincs rfindmissingrevszchangelog.findmissingrevssD >YF =MMOE)))8##E**r cb|tjg}||j}|Dcgc]}|j|}}|Dcgc]}|j|}}|j |}|j |Dcgc]}|j |c}Scc}wcc}wcc}w)a.Return the ancestors of heads that are not ancestors of common. More specifically, return a list of nodes N such that every N satisfies the following constraints: 1. N is an ancestor of some node in 'heads' 2. N is not an ancestor of any node in 'common' The list is sorted by revision number, meaning it is topologically sorted. 'heads' and 'common' are both lists of node IDs. If heads is not supplied, uses all of the revlog's heads. If common is not supplied, uses nullid.r)rr*rr0rrr3)rrrr.rr2s r findmissingzchangelog.findmissing5s >'../F =JJLE'-.v!$((1+v.&+,e!e,)))8&)&:&:5&AB&A ! &ABB /,CsB"B'B,cng}|j|}|j|dzD]}|j|Dcgc]}|tk7s |}}|r.|D](}||k(s |j |j |*[|tk(se|j |j ||Scc}w)z!find the children of a given noder)rd)r0rfrGrrnr3)rr3rpr2prprevss rchildrenzchangelog.childrenOs  HHTNQ'A"&//!"4F"4Bg R"4EFBQw1. g1&(Gs B2B2cHtj|j||||Sr)r _reachablerootspurerG)rminrootrroots includepaths rreachablerootszchangelog.reachableroots]s$(( OOWeUK  r cj|j||j|}}|j||Sr)r0 isancestorrevrabs r isancestorzchangelog.isancestorcs.xx{DHHQK1!!!Q''r cn|tk(ry||k(ry||kDryt|j||g|gdS)NTF)r)rboolrrs rrzchangelog.isancestorrevhsC < !V UD''A3'GHHr c.|j|}tj|}|tjk7r|j|}n t t fSt x}}|j r|j|j djj}t|j dkDrtjdt|j dk(r2|j|j djj}||fS)NrsTODO octopus merge handlingr) r3rr+rrrparentsr0rprawrEr Abort)rr0r.rrp1p2s rrGzchangelog.parentrevsqs IIcN   q !   R AG# #R 99!))A,//--.B199~!kk"@AA199~"XXaiiloo1122v r c|j||j|}}tj|j||Dcgc]}|j |c}Scc}wr)r0rcommonancestorsheadsrGr3)rrrr.s rrzchangelog.commonancestorsheadss_xx{DHHQK1224??AqI I IIaLI   sA!cy)zAGit doesn't do named branches, so just put everything on default.)rFr;rNs r branchinfozchangelog.branchinfos r cyrr;)rtrs r delayupdatezchangelog.delayupdates r c g}tj|tj|}}|tjk7r|j ||r$|tjk7r|j ||J|\}}t j tjtj|tjtj|t|t|dz }|jjd|||tj||}|jjj!d|dt#j$|j|j&|j(S)Nrzrefs/hg/internal/latest-commitT)force)rr+rr*rnpygit2 Signaturer unifromlocalrpersonrr"r create_commit referencescreater _index_reporr)rr rdesc transactionrrrrrp1copiesp2copies filesaddedrrhp1hp2 timestamptzsigoids raddz changelog.addsB $$R('*;*;B*?S ")) ) NN3  ")000 NN3  2  ! !*"3"3D"9 :  ! !*"2"24"8 9  N r]N   ll(( #sD'"3"3H"=w  && ,c ' $,,1wwr r`)rr)rFNN)F)NNNNNN)!r7r8r9_copiesstoragerOrSpropertyrVrrZr]rfrcrsrur|rrrrrrrrrrrrG_uncheckedparentrevsrrrrr;r rr r fsN& ""( &(  !* X F M+0C4  ( I"& ! +r r ceZdZeZdZdZy) manifestlogc&|jd|SNr )getrr3s rrKzmanifestlog.__getitem__sxxT""r c`|tjk(rtj||S|jt j |}|j}|r6|jd}|D] }||}|j|j}"tj|j|S)N/) rr*r memtreemanifestctxrrr+treesplitrp gitmanifestgittreemanifestctx)rrelpathr3commitr/partsrtes rrzmanifestlog.gets $++ +..tW= =g//56 KK MM$'EqTLL'--dllA>>r N)r7r8r9r nodeconstantsrKrr;r rrrs%M# ?r rc\eZdZfdZdZdZdZd dZdZdZ dZ d Z d Z d Z xZS) filelogctt| ||t|tsJ||_t j|_yr)superrrrbytespathrr*)rrrr __class__s rrzfilelog.__init__s8 gt%b"-$&&& '.. r c|tjk(ry|jtj|j Sr)rr*rrr+datars rreadz filelog.reads4 $++ +||G--d34999r c0t|dvr t|}t|trJdt|dk(r t|}t j |}||j vr|Stj|j|td)N)(stodo revnums for nodesr sno match found) rEr"rrrr+rr r,rr)rr3hnodes rlookupzfilelog.lookups t9H $t9D dC 33 35 t9?t9D!!$' DLL K 43D1EFFr c*|j||k7S)z9Returns True if text is different than content at `node`.)r)rr3texts rcmpz filelog.cmpsyy$&&r cT|rJ|jj|jSr)r create_blobr)rr metarlinkrrs rrz filelog.adds$x||''-111r c#K|jjdtj|jt j fD] }|d yw)Nz SELECT rev FROM changelog INNER JOIN changedfiles ON changelog.node = changedfiles.node WHERE changedfiles.filename = ? AND changedfiles.filenode != ? r)rr#rfsdecoderrr)rclrevs rrSzfilelog.__iter__sLXX%%   tyy )7?? ;  E(N sAAc|Srr;)rfrs rlinkrevzfilelog.linkrevs r c.|jjdtj|jt j |fj}|*tj|j|tdt|dS)Nz SELECT rev FROM changelog INNER JOIN changedfiles ON changelog.node = changedfiles.node WHERE changedfiles.filename = ? AND changedfiles.filenode = ?s no such noder) rr#rrrrr+r$r r,rr")rr3rows rr0z filelog.revshh A  tyy )7+<+r1s '    %%P  <[[| ?'?(:223aga4ar